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

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

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

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

<?xmlversion="1.0"encoding="UTF-8"?>
<!DOCTYPEconfiguration
PUBLIC"-//ibatis.apache.org//DTDConfig3.0//EN"
"http://ibatis.apache.org/dtd/ibatis-3-config.dtd">
<configuration>
<propertiesresource="jdbc.properties"/>
<typeAliases>
<typeAliastype="cn.ibatis3.test.Person"alias="Person"/>
</typeAliases>
<environmentsdefault="development">
<environmentid="development">
<transactionManagertype="JDBC"/>
<dataSourcetype="POOLED">
<propertyname="driver"value="${driver}"/>
<propertyname="url"value="${url}"/>
<propertyname="username"value="${username}"/>
<propertyname="password"value="${password}"/>
</dataSource>
</environment>
</environments>
<mappers>
<mapperresource="cn/ibatis3/test/person.xml"/>
</mappers>
</configuration>

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration
PUBLIC "-//ibatis.apache.org//DTD Config 3.0//EN"
"http://ibatis.apache.org/dtd/ibatis-3-config.dtd">
<configuration>
	<properties resource="jdbc.properties"/>
	<typeAliases>
		<typeAlias type="cn.ibatis3.test.Person" alias="Person"/>
	</typeAliases>
	<environments default="development">
		<environment id="development">
			<transactionManager type="JDBC"/>
			<dataSource type="POOLED">
				<property name="driver" value="${driver}"/>
				<property name="url" value="${url}"/>
				<property name="username" value="${username}"/>
				<property name="password" value="${password}"/>
			</dataSource>
		</environment>
	</environments>
	<mappers>
		<mapper resource="cn/ibatis3/test/person.xml"/>
	</mappers>
</configuration>

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

<?xmlversion="1.0"encoding="UTF-8"?>
<!DOCTYPEmapper
PUBLIC"-//ibatis.apache.org//DTDMapper3.0//EN"
"http://ibatis.apache.org/dtd/ibatis-3-mapper.dtd">
<!---->

<mappernamespace="cn.ibatis3.test.PersonMapper">

<selectid="selectPerson"parameterType="java.lang.Integer"
resultType="Person">
select*frompersonwhereid=#{id}
</select>
<selectid="selectAll"resultType="Person">
select*fromperson
</select>
<selectid="selectPersonsByName"resultType="Person"parameterType="String">
select*frompersonwherenamelike#{name}
</select>
<insertid="insertPerson"parameterType="Person">
insertintoperson(name,birthday,sex)
values(#{name},#{birthday},#{sex})
</insert>
<deleteid="deletePerson"parameterType="Person">
deletefrompersonwhereid=#{id}
</delete>
<updateid="updatePerson"parameterType="Person">
updatepersonsetname=#{name},birthday=#{birthday},sex=#{sex}
whereid=#{id}
</update>
</mapper>

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//ibatis.apache.org//DTD Mapper 3.0//EN"
"http://ibatis.apache.org/dtd/ibatis-3-mapper.dtd">
<!--  -->

<mapper namespace="cn.ibatis3.test.PersonMapper">

	<select id="selectPerson" parameterType="java.lang.Integer"
		resultType="Person">
		select * from person where id = #{id}
	</select>
	<select id="selectAll" resultType="Person">
		select * from person
	</select>
	<select id="selectPersonsByName" resultType="Person" parameterType="String">
		select * from person where name like #{name}
	</select>
	<insert id="insertPerson" parameterType="Person">
		insert into person(name,birthday,sex)
		values(#{name},#{birthday},#{sex})
	</insert>
	<delete id="deletePerson" parameterType="Person">
		delete from person where id=#{id}
	</delete>
	<update id="updatePerson" parameterType="Person">
		update person set name=#{name},birthday=#{birthday},sex=#{sex}
		where id=#{id}
	</update>
</mapper>

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

Person.java的代码如下：

packagecn.ibatis3.test;

importjava.util.Date;

publicclassPerson{
privateintid=0;
privateStringname="";
privateStringsex="male";
privateDatebirthday=null;

publicPerson(){

}

//省略getter和setter方法

@Override
publicStringtoString(){
return"id="+id+"\t"+"name="+name+"\t"+"sex="+sex+"\t"
+"birthday="+newjava.sql.Date(birthday.getTime()).toString();
}

}

package cn.ibatis3.test;

import java.util.Date;

public class Person {
	private int id = 0;
	private String name = "";
	private String sex = "male";
	private Date birthday = null;

	public Person() {

	}

	//省略getter 和 setter 方法
	
	@Override
	public String toString() {
		return "id=" + id + "\t" + "name=" + name + "\t" + "sex=" + sex + "\t"
				+ "birthday=" + new java.sql.Date(birthday.getTime()).toString();
	}

}

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

packagecn.ibatis3.test;

importjava.io.IOException;
importjava.io.Reader;

importorg.apache.ibatis.io.Resources;
importorg.apache.ibatis.session.SqlSessionFactory;
importorg.apache.ibatis.session.SqlSessionFactoryBuilder;

publicfinalclassSessionFactory{
privateStringresource="cn/ibatis3/test/SqlMapper.xml";
privateSqlSessionFactorysqlSessionFactory=null;
privatestaticSessionFactorysessionFactory=newSessionFactory();

privateSessionFactory(){
try{
Readerreader=Resources.getResourceAsReader(resource);
sqlSessionFactory=newSqlSessionFactoryBuilder().build(reader);
}catch(IOExceptione){
System.out.println("#IOExceptionhappenedininitialisingtheSessionFactory:"+e.getMessage());
thrownewExceptionInInitializerError(e);
}
}
publicstaticSessionFactorygetInstance(){
returnsessionFactory;
}
publicSqlSessionFactorygetSqlSessionFactory(){
returnsqlSessionFactory;
}

}

package cn.ibatis3.test;

import java.io.IOException;
import java.io.Reader;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

public final class SessionFactory {
	private String resource="cn/ibatis3/test/SqlMapper.xml";
	private SqlSessionFactory sqlSessionFactory=null;
	private static SessionFactory sessionFactory=new SessionFactory();
	
	private SessionFactory() {
		try {
			Reader reader=Resources.getResourceAsReader(resource);
			sqlSessionFactory=new SqlSessionFactoryBuilder().build(reader);
		} catch (IOException e) {
			System.out.println("#IOException happened in initialising the SessionFactory:"+e.getMessage());
			throw new ExceptionInInitializerError(e);
		}
	}
	public static SessionFactory getInstance() {
		return sessionFactory;
	}
	public SqlSessionFactory getSqlSessionFactory() {
		return sqlSessionFactory;
	}

}

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

packagecn.ibatis3.test;

importjava.util.List;

publicinterfacePersonMapper{
PersonselectById(Integerid);
List<Person>selectAll();
List<Person>selectPersonsByName(Stringname);
voidinsert(Personperson);
voiddelete(Personperson);
voidupdate(Personperson);

}

package cn.ibatis3.test;

import java.util.List;

public interface PersonMapper {
	Person selectById(Integer id);
	List<Person> selectAll();
	List<Person> selectPersonsByName(String name);
	void insert(Person person);
	void delete(Person person);
	void update(Person person);
	
}

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

packagecn.ibatis3.test;

importjava.util.ArrayList;
importjava.util.List;

importorg.apache.ibatis.session.SqlSession;
importorg.apache.ibatis.session.SqlSessionFactory;

publicclassPersonDaoimplementsPersonMapper{
privateSqlSessionFactorysessionFactory=SessionFactory.getInstance()
.getSqlSessionFactory();

publicPersonselectById(Integerid){
Personperson=newPerson();
SqlSessionsession=null;
try{
session=sessionFactory.openSession();
person=(Person)session.selectOne(
"cn.ibatis3.test.PersonMapper.selectPerson",id);
}finally{
session.close();
}
returnperson;
}

@SuppressWarnings("unchecked")
publicList<Person>selectAll(){
List<Person>persons=newArrayList<Person>();
SqlSessionsession=null;
try{
session=sessionFactory.openSession();
persons=session
.selectList("cn.ibatis3.test.PersonMapper.selectAll");
}finally{
session.close();
}

returnpersons;
}

publicvoiddelete(Personperson){
SqlSessionsession=null;
try{
session=sessionFactory.openSession();
session.delete("cn.ibatis3.test.PersonMapper.deletePerson",person);
session.commit();
}finally{
session.close();
}

}

publicvoidinsert(Personperson){
SqlSessionsession=null;
try{
session=sessionFactory.openSession();
session.insert("cn.ibatis3.test.PersonMapper.insertPerson",person);
session.commit();
}finally{
session.close();
}

}

publicvoidupdate(Personperson){
SqlSessionsession=null;
try{
session=sessionFactory.openSession();
session.insert("cn.ibatis3.test.PersonMapper.updatePerson",person);
session.commit();
}finally{
session.close();
}

}

@SuppressWarnings("unchecked")
publicList<Person>selectPersonsByName(Stringname){
List<Person>persons=newArrayList<Person>();
SqlSessionsession=null;
try{
session=sessionFactory.openSession();
System.out.println(name);
persons=session.selectList(
"cn.ibatis3.test.PersonMapper.selectPersonsByName","%"
+name+"%");
session.commit();
}finally{
session.close();
}

returnpersons;
}

}

package cn.ibatis3.test;

import java.util.ArrayList;
import java.util.List;

import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;

public class PersonDao implements PersonMapper {
	private SqlSessionFactory sessionFactory = SessionFactory.getInstance()
			.getSqlSessionFactory();

	public Person selectById(Integer id) {
		Person person = new Person();
		SqlSession session = null;
		try {
			session = sessionFactory.openSession();
			person = (Person) session.selectOne(
					"cn.ibatis3.test.PersonMapper.selectPerson", id);
		} finally {
			session.close();
		}
		return person;
	}

	@SuppressWarnings("unchecked")
	public List<Person> selectAll() {
		List<Person> persons = new ArrayList<Person>();
		SqlSession session = null;
		try {
			session = sessionFactory.openSession();
			persons = session
					.selectList("cn.ibatis3.test.PersonMapper.selectAll");
		} finally {
			session.close();
		}

		return persons;
	}

	public void delete(Person person) {
		SqlSession session = null;
		try {
			session = sessionFactory.openSession();
			session.delete("cn.ibatis3.test.PersonMapper.deletePerson", person);
			session.commit();
		} finally {
			session.close();
		}

	}

	public void insert(Person person) {
		SqlSession session = null;
		try {
			session = sessionFactory.openSession();
			session.insert("cn.ibatis3.test.PersonMapper.insertPerson", person);
			session.commit();
		} finally {
			session.close();
		}

	}

	public void update(Person person) {
		SqlSession session = null;
		try {
			session = sessionFactory.openSession();
			session.insert("cn.ibatis3.test.PersonMapper.updatePerson", person);
			session.commit();
		} finally {
			session.close();
		}

	}

	@SuppressWarnings("unchecked")
	public List<Person> selectPersonsByName(String name) {
		List<Person> persons = new ArrayList<Person>();
		SqlSession session = null;
		try {
			session = sessionFactory.openSession();
			System.out.println(name);
			persons = session.selectList(
					"cn.ibatis3.test.PersonMapper.selectPersonsByName", "%"
							+ name + "%");
			session.commit();
		} finally {
			session.close();
		}

		return persons;
	}

}

最后是表的创建：

DROPTABLEIFEXISTS`test`.`person`;
CREATETABLE`test`.`person`(
`id`int(10)unsignedNOTNULLauto_increment,
`name`varchar(20)defaultNULL,
`sex`varchar(8)defaultNULL,
`birthday`datetimedefaultNULL,
PRIMARYKEY(`id`)
)ENGINE=InnoDBDEFAULTCHARSET=utf8;

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