iBATIS3 增删改查使用

使用iBATIS3.0完成增删改查

    iBATIS3.0和以前的版本有一些改变，不过学过以前版本的再学习3.0应该不是太难，3.0要求JDK1.5支持，因为其中增加了注解和泛型，这些都是JDK1.5才有的。好了废话不多说，先来利用iBATIS3做下简单的增删改查吧。

    首先到Apache(http://www.apache.org/网站下载iBATIS3的jar 包，我下载的是ibatis-3-core-3.0.0.227.zip，解压后吧那个jar文件（ibatis-3-core-3.0.0.227.jar）添加到工程就可以了，还有一个文件（ibatis-3-core-src-3.0.0.227.zip）是源代码，可以用来查看源代码的，使用eclipse可以用它来关联源代码。

    在MyEclipse新建一个Java Project，结构如下图



    在jdbc.properties文件是映射文件要使用的，其内容如下：

1. driver=com.mysql.jdbc.Driver
   
2. url=jdbc\:mysql\://localhost\:3306/test
   
3. username=root
   
4. password=123456

复制代码

SqlMapper.xml是iBATIS的配置文件，其代码如下：

1. <?xml version="1.0" encoding="UTF-8"?>
   
2. <!DOCTYPE configuration
   
3. PUBLIC "-//ibatis.apache.org//DTD Config 3.0//EN"
   
4. "http://ibatis.apache.org/dtd/ibatis-3-config.dtd">
   
5. <configuration>
   
6.         <properties resource="jdbc.properties"/>
   
7.         <typeAliases>
   
8.                 <typeAlias type="cn.ibatis3.test.Person" alias="Person"/>
   
9.         </typeAliases>
   
10.         <environments default="development">
    
11.                 <environment id="development">
    
12.                         <transactionManager type="JDBC"/>
    
13.                         <dataSource type="POOLED">
    
14.                                 <property name="driver" value="${driver}"/>
    
15.                                 <property name="url" value="${url}"/>
    
16.                                 <property name="username" value="${username}"/>
    
17.                                 <property name="password" value="${password}"/>
    
18.                         </dataSource>
    
19.                 </environment>
    
20.         </environments>
    
21.         <mappers>
    
22.                 <mapper resource="cn/ibatis3/test/person.xml"/>
    
23.         </mappers>
    
24. </configuration>

复制代码

上面文件中的sql映射文件person.xml代码如下：

1. <?xml version="1.0" encoding="UTF-8"?>
   
2. <!DOCTYPE mapper
   
3. PUBLIC "-//ibatis.apache.org//DTD Mapper 3.0//EN"
   
4. "http://ibatis.apache.org/dtd/ibatis-3-mapper.dtd">
   
5. <!--  -->
   
6. 
   
7. <mapper namespace="cn.ibatis3.test.PersonMapper">
   
8. 
   
9.         <select id="selectPerson" parameterType="java.lang.Integer"
   
10.                 resultType="Person">
    
11.                 select * from person where id = #{id}
    
12.         </select>
    
13.         <select id="selectAll" resultType="Person">
    
14.                 select * from person
    
15.         </select>
    
16.         <select id="selectPersonsByName" resultType="Person" parameterType="String">
    
17.                 select * from person where name like #{name}
    
18.         </select>
    
19.         <insert id="insertPerson" parameterType="Person">
    
20.                 insert into person(name,birthday,sex)
    
21.                 values(#{name},#{birthday},#{sex})
    
22.         </insert>
    
23.         <delete id="deletePerson" parameterType="Person">
    
24.                 delete from person where id=#{id}
    
25.         </delete>
    
26.         <update id="updatePerson" parameterType="Person">
    
27.                 update person set name=#{name},birthday=#{birthday},sex=#{sex}
    
28.                 where id=#{id}
    
29.         </update>
    
30.               
    
31. </mapper>

复制代码

注意：在iBATIS3中，属性parameterMap是不推荐使用的，在以后的版本可能会去掉这个属性。

     Person.java的代码如下：

1. package cn.ibatis3.test;
   
2. 
   
3. import java.util.Date;
   
4. 
   
5. public class Person {
   
6.         private int id = 0;
   
7.         private String name = "";
   
8.         private String sex = "male";
   
9.         private Date birthday = null;
   
10. 
    
11.         public Person() {
    
12. 
    
13.         }
    
14. 
    
15.         //省略getter 和 setter 方法
    
16.        
    
17.         @Override
    
18.         public String toString() {
    
19.                 return "id=" + id + "\t" + "name=" + name + "\t" + "sex=" + sex + "\t"
    
20.                                 + "birthday=" + new java.sql.Date(birthday.getTime()).toString();
    
21.         }
    
22. 
    
23. }

复制代码

iBATIS官方推荐我们使用单例模式创建一个sessionFactory，我这里也提供一个sessionFactory.java，呵呵,仅供参考：

1. package cn.ibatis3.test;
   
2. 
   
3. import java.io.IOException;
   
4. import java.io.Reader;
   
5. 
   
6. import org.apache.ibatis.io.Resources;
   
7. import org.apache.ibatis.session.SqlSessionFactory;
   
8. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
   
9. 
   
10. public final class SessionFactory {
    
11.         private String resource="cn/ibatis3/test/SqlMapper.xml";
    
12.         private SqlSessionFactory sqlSessionFactory=null;
    
13.         private static SessionFactory sessionFactory=new SessionFactory();
    
14.        
    
15.         private SessionFactory() {
    
16.                 try {
    
17.                         Reader reader=Resources.getResourceAsReader(resource);
    
18.                         sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);
    
19.                 } catch (IOException e) {
    
20.                         System.out.println("#IOException happened in initialising the SessionFactory:"+e.getMessage());
    
21.                         throw new ExceptionInInitializerError(e);
    
22.                 }
    
23.         }
    
24.         public static SessionFactory getInstance() {
    
25.                 return sessionFactory;
    
26.         }
    
27.         public SqlSessionFactory getSqlSessionFactory() {
    
28.                 return sqlSessionFactory;
    
29.         }
    
30. 
    
31. }

复制代码

基于接口的编程（还有就是iBATIS3的注解也是在接口方法上的，关于注解以后有机会再讲，它也是iBATIS3的一个新特性），DAO层的接口PersonMapper.java代码如下：

1. package cn.ibatis3.test;
   
2. 
   
3. import java.util.List;
   
4. 
   
5. public interface PersonMapper {
   
6.         Person selectById(Integer id);
   
7.         List<Person> selectAll();
   
8.         List<Person> selectPersonsByName(String name);
   
9.         void insert(Person person);
   
10.         void delete(Person person);
    
11.         void update(Person person);
    
12.        
    
13. }

复制代码

接口的实现类PersonDao.java代码如下：

1. package cn.ibatis3.test;
   
2. 
   
3. import java.util.ArrayList;
   
4. import java.util.List;
   
5. 
   
6. import org.apache.ibatis.session.SqlSession;
   
7. import org.apache.ibatis.session.SqlSessionFactory;
   
8. 
   
9. public class PersonDao implements PersonMapper {
   
10.         private SqlSessionFactory sessionFactory = SessionFactory.getInstance()
    
11.                         .getSqlSessionFactory();
    
12. 
    
13.         public Person selectById(Integer id) {
    
14.                 Person person = new Person();
    
15.                 SqlSession session = null;
    
16.                 try {
    
17.                         session = sessionFactory.openSession();
    
18.                         person = (Person) session.selectOne(
    
19.                                         "cn.ibatis3.test.PersonMapper.selectPerson", id);
    
20.                 } finally {
    
21.                         session.close();
    
22.                 }
    
23.                 return person;
    
24.         }
    
25. 
    
26.         @SuppressWarnings("unchecked")
    
27.         public List<Person> selectAll() {
    
28.                 List<Person> persons = new ArrayList<Person>();
    
29.                 SqlSession session = null;
    
30.                 try {
    
31.                         session = sessionFactory.openSession();
    
32.                         persons = session
    
33.                                         .selectList("cn.ibatis3.test.PersonMapper.selectAll");
    
34.                 } finally {
    
35.                         session.close();
    
36.                 }
    
37. 
    
38.                 return persons;
    
39.         }
    
40. 
    
41.         public void delete(Person person) {
    
42.                 SqlSession session = null;
    
43.                 try {
    
44.                         session = sessionFactory.openSession();
    
45.                         session.delete("cn.ibatis3.test.PersonMapper.deletePerson", person);
    
46.                         session.commit();
    
47.                 } finally {
    
48.                         session.close();
    
49.                 }
    
50. 
    
51.         }
    
52. 
    
53.         public void insert(Person person) {
    
54.                 SqlSession session = null;
    
55.                 try {
    
56.                         session = sessionFactory.openSession();
    
57.                         session.insert("cn.ibatis3.test.PersonMapper.insertPerson", person);
    
58.                         session.commit();
    
59.                 } finally {
    
60.                         session.close();
    
61.                 }
    
62. 
    
63.         }
    
64. 
    
65.         public void update(Person person) {
    
66.                 SqlSession session = null;
    
67.                 try {
    
68.                         session = sessionFactory.openSession();
    
69.                         session.insert("cn.ibatis3.test.PersonMapper.updatePerson", person);
    
70.                         session.commit();
    
71.                 } finally {
    
72.                         session.close();
    
73.                 }
    
74. 
    
75.         }
    
76. 
    
77.         @SuppressWarnings("unchecked")
    
78.         public List<Person> selectPersonsByName(String name) {
    
79.                 List<Person> persons = new ArrayList<Person>();
    
80.                 SqlSession session = null;
    
81.                 try {
    
82.                         session = sessionFactory.openSession();
    
83.                         System.out.println(name);
    
84.                         persons = session.selectList(
    
85.                                         "cn.ibatis3.test.PersonMapper.selectPersonsByName", "%"
    
86.                                                         + name + "%");
    
87.                         session.commit();
    
88.                 } finally {
    
89.                         session.close();
    
90.                 }
    
91. 
    
92.                 return persons;
    
93.         }
    
94. 
    
95. }

复制代码

最后是表的创建：

1. DROP TABLE IF EXISTS `test`.`person`;
   
2. CREATE TABLE  `test`.`person` (
   
3.   `id` int(10) unsigned NOT NULL auto_increment,
   
4.   `name` varchar(20) default NULL,
   
5.   `sex` varchar(8) default NULL,
   
6.   `birthday` datetime default NULL,
   
7.   PRIMARY KEY  (`id`)
   
8. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

复制代码

被杰杰严重的落下了，以前还能看懂，现在连看都看不懂了

momo 发表于 2012-1-31 14:43
被杰杰严重的落下了，以前还能看懂，现在连看都看不懂了

确定以前能看懂？

混混@普宁.中国 发表于 2012-1-31 16:21
确定以前能看懂？

额，这个不好确定