使用iBATIS3.0完成增删改查

使用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文件是映射文件要使用的，其内容如下：

Properties代码

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

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

Xml代码

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代码如下：

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. <!--  -->
7. <mapper namespace="cn.ibatis3.test.PersonMapper">
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. </mapper>

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

Person.java的代码如下：

Java代码

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

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

Java代码

1. package cn.ibatis3.test; 
3. import java.io.IOException; 
4. import java.io.Reader; 
6. import org.apache.ibatis.io.Resources; 
7. import org.apache.ibatis.session.SqlSessionFactory; 
8. import org.apache.ibatis.session.SqlSessionFactoryBuilder; 
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(); 
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.     } 
31. } 

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

Java代码

1. package cn.ibatis3.test; 
3. import java.util.List; 
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); 
13. } 

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

Java代码

1. package cn.ibatis3.test; 
3. import java.util.ArrayList; 
4. import java.util.List; 
6. import org.apache.ibatis.session.SqlSession; 
7. import org.apache.ibatis.session.SqlSessionFactory; 
9. public class PersonDao implements PersonMapper { 
10. private SqlSessionFactory sessionFactory = SessionFactory.getInstance() 
11.             .getSqlSessionFactory(); 
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.     } 
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.         } 
38. return persons; 
39.     } 
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.         } 
51.     } 
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.         } 
63.     } 
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.         } 
75.     } 
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.         } 
92. return persons; 
93.     } 
95. } 

最后是表的创建：

Sql代码

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; 

好了，做为一次新技术的体验吧，欢迎大家指出其中的错误或者是不恰当的地方。

• 查看图片附件

17
顶

6
踩

分享到：

iBATIS3.0学习（二）使用iBATIS3.0注解完 ...

• 2010-02-03 13:00
• 浏览 11154
• 评论(14)
• 收藏
• 分类:企业架构
• 相关推荐

评论

14 楼 lyb520320 2012-02-01   引用

ibatis3没有试验过打印sql，ibatis2通过jdk动态代理使用log4j打印sql，估计ibatis3也差不多，看下这个连接，主要看log4j.properties配置，这个文件要放到src目录下
http://winyee.iteye.com/blog/457216

13 楼 grandboy 2012-02-01   引用

这个我在网上搜索了好长时间，也试了网上说的一些办法，就是无法把产生的sql打印出来，不知道各位有没有成功经验？如果有人成功，请告诉详细方法或者给兄弟一个链接。
要亲自实验成功的方法。多谢。

12 楼 lyb520320 2012-01-31   引用

qwj528 写道

楼主<mapper namespace="cn.ibatis3.test.PersonMapper"> namespace这个属性有什么作用吗？ 但是必须要有namespace。 从你这个例子来看好像是个接口。

namespace仅仅是为了区分不同的xml的一个名称，至于是什么看你自己的代码习惯

11 楼 qwj528 2012-01-31   引用

楼主<mapper namespace="cn.ibatis3.test.PersonMapper"> namespace这个属性有什么作用吗？ 但是必须要有namespace。 从你这个例子来看好像是个接口。

10 楼 fengyie007 2010-06-21   引用

Java代码

1. public List<Person> selectAll() {   
2.         List<Person> persons = new ArrayList<Person>();   
3.         SqlSession session = null;   
4. try {   
5.             session = sessionFactory.openSession();   
6.             persons = session   
7.                     .selectList("cn.ibatis3.test.PersonMapper.selectAll");   
8.         } finally {   
9.             session.close();   
10.         }   
12. return persons;   
13.     }