iBatis框架操纵Oracle、MySQL和MS SQL SERVER数据库使用示例

package com.jb.arklis.dao.util; import static java.lang.System.*; import java.io.*; import java.sql.*; import com.ibatis.common.resources.Resources; import com.ibatis.sqlmap.client.*; /** 功能：书写一个iBatis工具类 作者：Arklis zeng 时间：2009-06-03 地点：成都公兴镇（Home） 备注： 用来调试iBatis框架 */ public class IBatisUtil{ private Statement statement; public IBatisUtil()throws Exception{ // Load the JDBC driver. //Class.forName("com.mysql.jdbc.Driver"); //Class.forName("net.sourceforge.jtds.jdbc.Driver"); Class.forName("oracle.jdbc.driver.OracleDriver"); // Establish the connection to the database. //String url = "jdbc:mysql://localhost/test"; //String url = "jdbc:jtds:sqlserver://localhost:1433/books"; String url = "jdbc:oracle:thin:@192.168.0.22:1521:demo1"; //Connection connection = DriverManager.getConnection(url, "root", "1"); //Connection connection = DriverManager.getConnection(url, "sa", "sa"); Connection connection = DriverManager.getConnection(url, "az", "az"); statement = connection.createStatement(); } public SqlMapClient getSqlMapClient() throws Exception{ Reader reader = Resources.getResourceAsReader("SqlMapConfig.xml"); SqlMapClient sqlMapper = SqlMapClientBuilder.buildSqlMapClient(reader); reader.close(); return sqlMapper; } public void executeSQLCommand(String sql) throws Exception { statement.executeUpdate(sql); } public void checkData(String sql) throws Exception { ResultSet rs = statement.executeQuery(sql); ResultSetMetaData metadata = rs.getMetaData(); for (int i = 0; i < metadata.getColumnCount(); i++) { out.print("\t"+ metadata.getColumnLabel(i + 1)); } out.println("\n----------------------------------"); while (rs.next()) { for (int i = 0; i < metadata.getColumnCount(); i++) { Object value = rs.getObject(i + 1); if (value == null) { out.print("\t "); } else { out.print("\t"+value.toString().trim()); } } out.println(""); } } public static void main(String[] args) throws Exception{ IBatisUtil util = new IBatisUtil(); //util.executeSQLCommand("create table ACCOUNTONE(ACC_ID int, ACC_FIRST_NAME varchar(45),ACC_LAST_NAME varchar(45),ACC_EMAIL varchar(45))"); util.executeSQLCommand("drop table ACCOUNTONE"); util.executeSQLCommand("create table ACCOUNTONE(ACC_ID int, ACC_FIRST_NAME varchar2(45),ACC_LAST_NAME varchar2(45),ACC_EMAIL varchar2(45))"); SqlMapClient sqlMapper = util.getSqlMapClient(); Account account = new Account(); account.setId(1); account.setEmailAddress("arklis@126.com"); account.setFirstName("Arklis"); account.setLastName("zeng"); sqlMapper.insert("insertAccount", account); util.checkData("select * from ACCOUNTONE"); account = (Account) sqlMapper.queryForObject("selectAccountById", 1); out.println("acc.getFirstName()的值是：" + account.getFirstName()); } } class Account implements Serializable{ private int id; private String firstName; private String lastName; private String emailAddress; public int getId() { return id; } public void setId(int id) { this.id = id; } public String getFirstName() { return firstName; } public void setFirstName(String firstName) { this.firstName = firstName; } public String getLastName() { return lastName; } public void setLastName(String lastName) { this.lastName = lastName; } public String getEmailAddress() { return emailAddress; } public void setEmailAddress(String emailAddress) { this.emailAddress = emailAddress; } }