iBATIS3.0学习（二）使用iBATIS3.0注解完成对数据库的简单操作

 使用iBATIS3.0注解完成对数据库的简单操作

    iBATIS3.0也增加了一些简单的注解，iBATIS3的注解只能完成一些简单操作，要进行更复杂的操作，最好是在XML文件中配置。

    在数据库(本人使用的mysql)中建立一个person表：

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;

 

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

 

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

 

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

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

<?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"/>
	<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/annotation/person.xml"/>
	</mappers>
</configuration>

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

<?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.annotation.PersonMapper">

</mapper>

     注意：在iBATIS3中，命名空间（namespace）是必须的，如果不使用注解的话，名字可以自己定义。一旦使用了注解，这里必须是那个使用注解类或接口的全名。

     Person.java的代码请参考我的《iBATIS3学习（一）》。

    sessionFactory.java和我前面的《iBATIS3学习（一）》一样，只是注意将：

private String resource="cn/ibatis3/test/SqlMapper.xml";

改为private String resource="cn/ibatis3/test/annotation/SqlMapper.xml";

 

    iBATIS3的注解可以定义在接口方法上的，也可以定义在类方法上，我这里定义在接口上，接口PersonMapper.java代码如下：

package cn.ibatis3.test.annotation;

import java.util.List;

import org.apache.ibatis.annotations.CacheNamespace;
import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Options;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.SelectProvider;
import org.apache.ibatis.annotations.Update;

@CacheNamespace(readWrite = true)
public interface PersonMapper {
	@Select("select * from person where id = #{id}")
	@Options(useCache = true, flushCache = false)
	Person selectById(Integer id);

	@SelectProvider(type=SqlProvider.class ,method="selectAllSql")
	List<Person> selectAll();

	@Select("select * from person where name like #{name}")
	List<Person> selectPersonsByName(String name);

	@Insert( { "insert into person(name,birthday,sex)",
			"values(#{name},#{birthday},#{sex})" })
	void insert(Person person);

	@Delete("delete from person where id=#{id}")
	void delete(Person person);

	@Update( {"update person set name=#{name},birthday=#{birthday},sex=#{sex}",
			"where id=#{id}" })
	void update(Person person);

}

 上面的注解SelectProvider使用了一个类SqlProvider.java,其代码如下：

package cn.ibatis3.test.annotation;

public class SqlProvider {
	// 动态的SQL语句，实际上应该使用iBATIS的动态SQL产生方法，这里仅仅是为了使用注解
	public String selectAllSql() {
		return "SELECT * FROM person p";
	}
}

 

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

package cn.ibatis3.test.annotation;

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();
			PersonMapper personMapper = session.getMapper(PersonMapper.class);
			person = personMapper.selectById(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();
			PersonMapper personMapper = session.getMapper(PersonMapper.class);
			persons = personMapper.selectAll();
		} finally {
			session.close();
		}

		return persons;
	}

	public void delete(Person person) {
		SqlSession session = null;
		try {
			session = sessionFactory.openSession();
			PersonMapper personMapper = session.getMapper(PersonMapper.class);
			personMapper.delete(person);
			session.commit();
		} finally {
			session.close();
		}

	}

	public void insert(Person person) {
		SqlSession session = null;
		try {
			session = sessionFactory.openSession();
			PersonMapper personMapper = session.getMapper(PersonMapper.class);
			personMapper.insert(person);
			session.commit();
		} finally {
			session.close();
		}

	}

	public void update(Person person) {
		SqlSession session = null;
		try {
			session = sessionFactory.openSession();
			PersonMapper personMapper = session.getMapper(PersonMapper.class);
			personMapper.update(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();
			PersonMapper personMapper = session.getMapper(PersonMapper.class);
			persons=personMapper.selectPersonsByName("%" + name + "%");
		} finally {
			session.close();
		}

		return persons;
	}

}

   

好了，有时间还会继续写相关文章的，谢谢！欢迎大家指出其中的错误或者是不恰当的地方。

评论

6 楼 ynp 2011-03-31  

请问博主 既然已经使用了注解方式，为什么还得写person.xml这个文件呢，能不能在接口上进行个什么注解从而达到不写这个文件的目的呢？（就像hibernate注解一样，用注解就不用写*.hbm.xml）总感觉有点多余似的。

5 楼 lyb520320 2010-06-03  

hanz188 写道

请问博主，能否写个简单的测试类来验证我们的代码编写的是否正确。比如main()方法，该怎么调用上述的接口呢。

谢谢你的关注，直接调用:

PersonMapper personMapper=new PersonDao();
personMapper.selectAll();

4 楼 hanz188 2010-05-07  

请问博主，能否写个简单的测试类来验证我们的代码编写的是否正确。比如main()方法，该怎么调用上述的接口呢。

3 楼 lyb520320 2010-02-05  

lyb520320 写道

	public void insert(Person person) {
		SqlSession session = null;
		try {
			final String id="cn.ibatis3.test.PersonMapper.insertPerson";
			session = sessionFactory.openSession(ExecutorType.REUSE);
			session.insert(id, person);
			final Configuration configuration=session.getConfiguration();
			final MetaObject metaObject=configuration.newMetaObject(person);
			int idKey=Integer.parseInt( metaObject.getValue("id").toString());
			System.out.println(idKey);
			session.commit();
		} finally {
			session.close();
		}

	}

这个是学习（一）里的例子里面的，其实iBATIS3并没有提供直接获得当前插入记录的id的方法，这个是我从源码里查看它是怎么样设置这个自动生成的id,然后再通过它的get方法获得的。
谢谢你的关注！

对了，还要在person.xml里设置

<insert id="insertPerson" useGeneratedKeys="true" keyProperty="id" parameterType="Person">
		insert into person(name,birthday,sex)
		values(#{name},#{birthday},#{sex})
	</insert>

放假了，没时间来更新了

2 楼 lyb520320 2010-02-05  

	public void insert(Person person) {
		SqlSession session = null;
		try {
			final String id="cn.ibatis3.test.PersonMapper.insertPerson";
			session = sessionFactory.openSession(ExecutorType.REUSE);
			session.insert(id, person);
			final Configuration configuration=session.getConfiguration();
			final MetaObject metaObject=configuration.newMetaObject(person);
			int idKey=Integer.parseInt( metaObject.getValue("id").toString());
			System.out.println(idKey);
			session.commit();
		} finally {
			session.close();
		}

	}

这个是学习（一）里的例子里面的，其实iBATIS3并没有提供直接获得当前插入记录的id的方法，这个是我从源码里查看它是怎么样设置这个自动生成的id,然后再通过它的get方法获得的。
谢谢你的关注！

1 楼 liwenso 2010-02-05  

初次接触IBatis，请问一下楼主，我插入一条记录，如何得到该记录的ID，就拿这个Person这个例子