ibatis调用mysql进行数据库操作实例

yinian

iBatis是个像Hibernate, JDO,EJB一类的数据持久框架,它能将对象映射为SQL语句.它是个轻量级的框架并且持久性API适合持久化POJO.iBatis也与Hibernate, JDO不同,因为它使用存储过程和现有的SQL来处理数据库.
 
以下例子显示了如何创建ibatis例子及执行查询插入删除更新调用存储过程的过程。
1在mysql数据库中创建一个数据库ibatisdata及数据库表person及一个存储过程showData，创建代码如下

SET FOREIGN_KEY_CHECKS=0; -- ---------------------------- -- Table structure for person -- ---------------------------- DROP TABLE IF EXISTS `person`; CREATE TABLE `person` (   `id` int(11) NOT NULL DEFAULT '0',   `name` varchar(16) DEFAULT NULL,   `passwd` varchar(16) DEFAULT NULL,   PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;   -- ---------------------------- -- Procedure structure for showData -- ---------------------------- DROP PROCEDURE IF EXISTS `showData`; DELIMITER ;; CREATE DEFINER=`root`@`localhost` PROCEDURE `showData`() BEGIN select * from Person; END;; DELIMITER ;   -- ---------------------------- -- Records -- ---------------------------- INSERT INTO `person` VALUES ('1', 'zhang', null);

 
2 在myeclipse中创建一个java project，然后通过右击项目-properties-java build path-libraries –add external jars ，导入ibatis及mysql-connector jar包；
然后创建 Person.java类，即对应数据库中person表的POJO类。
为了映射配置我们需要创建SqlMapConfig.xml（类似于hibernate中的hibernate.cfg.xml文件）来指定如下信息：针对映射语句的命名空间前缀、我们数据库使用jdbc进行访问及访问驱动、链接url、链接用户名密码、对应的SQL语句描述文件等信息。
创建SqlMap映射文件Person.xml负责程序执行的SQL语句（相当于Hibernate的映射文件 *.hbm.xml，只是它的映射不靠POJO的属性到数据库字段的一一映射，靠的是Sql语句，所以谓之 SqlMap, 注意每条语句中参数的写法）等。
创建一个获取SqlMapClient的工厂类，相当于MyEclipse为Hibernate应用程序生成的HibernateSessionFactory类。
创建测试类ClientTest.java来测试数据库一系列操作。
 
创建完目录结构如下图所示

 

 
Person.java

package com.yan; public class Person {     public Integer id;     public String name;     public String passwd;     public Person() {        super();     }     public Person(Integer id) {        super();        this.id = id;     }     public Integer getId() {        return id;     }     public String getName() {        return name;     }     public String getPasswd() {        return passwd;     }     public void setId(Integer id) {        this.id = id;     }     public void setPasswd(String passwd) {        this.passwd = passwd;     }     public void setName(String name2) {        this.name = name2;     } }

 
SqlMapConfig.java

package com.yan; import java.io.Reader; import com.ibatis.common.resources.Resources; import com.ibatis.sqlmap.client.SqlMapClient; import com.ibatis.sqlmap.client.SqlMapClientBuilder; public class SqlMapConfig {     private static final SqlMapClient sqlMap;     static     {         try         {             String resource = "SqlMapConfig.xml";             Reader reader = Resources.getResourceAsReader(resource);             sqlMap = SqlMapClientBuilder.buildSqlMapClient(reader);         }         catch (Exception e)         {             e.printStackTrace();             throw new RuntimeException("Error initializing MyAppSqlConfig class. Cause: " + e);         }     }     public static SqlMapClient getSqlMapInstance()     {         return sqlMap;     } }

 
SqlMapConfig.xml

<!DOCTYPE sqlMapConfig PUBLIC "-//iBATIS.com//DTD SQL Map Config 2.0//EN" "http://www.ibatis.com/dtd/sql-map-config-2.dtd"> <sqlMapConfig>       <!-- SqlMap的环境属性配置 -->     <settings cacheModelsEnabled="true" enhancementEnabled="true"        lazyLoadingEnabled="true" maxRequests="32" maxSessions="10"        maxTransactions="5" useStatementNamespaces="false" />         <!-- 配置SqlMap的连接池属性，默认使用SimpleDataSource实现-->     <transactionManager type="JDBC">        <dataSource type="SIMPLE">            <property name="JDBC.Driver" value="com.mysql.jdbc.Driver" />            <property name="JDBC.ConnectionURL" value="jdbc:mysql://127.0.0.1:3306/ibatisdata" />            <property name="JDBC.Username" value="root" />            <property name="JDBC.Password" value="123456" />        </dataSource>     </transactionManager>         <!-- SqlMap的映射文件 -->     <sqlMap resource="com/yan/Person.xml" /> </sqlMapConfig>

 
Person.xml

<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE sqlMap PUBLIC "-//iBATIS.com//DTD SQL Map 2.0//EN" "http://www.ibatis.com/dtd/sql-map-2.dtd"> <sqlMap namespace="Person">     <!-- 传入包装类型（Integer）参数，查询到结果集组装成一个Person对象返回 -->     <select id="getPerson" parameterClass="int" resultClass="com.yan.Person">        SELECT ID as id, NAME as name, PASSWD as passwd         FROM PERSON  WHERE ID = #value#     </select>         <!-- 插入一条Person对应的记录到数据库中 -->     <insert id="insertPerson" parameterClass="com.yan.Person">        INSERT INTO PERSON (ID, NAME, PASSWD) VALUES (#id#,#name#, #passwd#)     </insert>         <!-- 关联ID更新一条Person记录到数据库中 -->     <update id="updatePerson" parameterClass="com.yan.Person">        UPDATE PERSON SET NAME = #name#, PASSWD = #passwd# WHERE ID = #id#     </update>         <!-- 根据ID从数据库中删除一条Person记录 -->     <delete id="deletePerson" parameterClass="com.yan.Person">        DELETE FROM PERSON WHERE ID = #id#     </delete>         <!-- 调用存储过程 -->     <procedure id="storedinfo" resultClass="com.yan.Person" >       {call showData()}     </procedure> </sqlMap>

 
ClientTest.java

package com.yan;   import java.util.List;   import com.ibatis.sqlmap.client.SqlMapClient; public class ClientTest {     public static void main(String[] args) throws Exception     {         SqlMapClient sqlMap = SqlMapConfig.getSqlMapInstance(); // as coded above                 Integer personPk = new Integer(1);//根据id查找Person         Person person = (Person) sqlMap.queryForObject("getPerson", personPk);         System.out.println(person.getName());                person.setName("yan");         sqlMap.update("updatePerson",person);//更新Person                 person.setId(7);         sqlMap.insert("insertPerson",person);//插入新的Person                 sqlMap.delete("deletePerson", person);//根据id删除Person                 List<Person> persons=sqlMap.queryForList("storedinfo",null);//调用存储过程，查询出所有的Person         for(Person p:persons){         System.out.println("id:"+p.getId()+"   name :"+p.getName()+"   pwd:"+p.getPasswd());         }     } }