mybatis系列二：单表CRUD -

yuanleilei628

浏览: 12801 次
性别:
来自: 河南安阳

最近访客更多访客>>

hudan729046

hejjon

GGGGeek

hujian_

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

mybatis系列二：单表CRUD

博客分类：

mybatis

单表的CRUD。 C：Create，创建；R：Retrieve，读取；U：Update，更新；D，Delete，删除。

1. 首先配置映射文件User.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.alex.app.entity.User">
  <select id="selectUser" parameterType="int" resultType="com.alex.app.entity.User">
    select * from t_user where id = #{id}
  </select>
  
  <insert id="insertUser" parameterType="com.alex.app.entity.User">
  	insert into t_user(username,password)
  	values(#{username},#{password})
  </insert>
  
  <update id="updateUser" parameterType="com.alex.app.entity.User">
  	update t_user set username=#{username},password=#{password} 
  	where id = #{id}
  </update>
  
  <delete id="deleteUser" parameterType="int">
  	delete from t_user where id = #{id}
  </delete>
</mapper>

2. 先提供一个工具类，方便测试

package com.alex.app.util;

import java.io.IOException;
import java.io.InputStream;

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

public class MyBatisUtil {
	private MyBatisUtil() {
	}
	private static SqlSessionFactory factory;
	private static String configFile = "mybatis-config.xml";
	static{
		InputStream in;
		try {
			//  加载总配置文件
			in = Resources.getResourceAsStream(configFile);
			// 创建SqlSessionFactory
			factory = new SqlSessionFactoryBuilder().build(in);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	/**
	 * 获取SqlSession,并关闭自动提交，打开事务。
	 * 通俗点说就是将自动提交事务，改为手动提交
	 * @return
	 */
	public static SqlSession openSession(){
		return factory.openSession();
	}
	
	/**
	 * 关闭session
	 * @param session
	 */
	public static void coloseSession(SqlSession session){
		if(session != null){
			session.close();
		}
	}
}

SqlSession创建的时候，会关闭自动提交，打开事务。我们扫一眼SqlSessionFactory的openSessoin方法的源码就知道了。

以下源码分析不是重点，可以略过

eclipse中，使用 maven构建的项目要把源码一并下载下来，右击pom.xml选择Run As-->Maven Build..，在对话框Goals中输入命令dependency:sources，点Run，相关maven的插件和源码就都下载下来。

源码已经关联上，图标上有了个文本的标识

SqlSessionFactory是个接口，这里调用到的是DefaultSqlSessionFactory实现类的openSessoin方法。

 public SqlSession openSession() {
    return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);
  }

我们看到第4个参数的值就是false。往里看代码直到JdbcTransaction类中，构造方法有

  public JdbcTransaction(DataSource ds, TransactionIsolationLevel desiredLevel, boolean desiredAutoCommit) {
    dataSource = ds;
    level = desiredLevel;
    autoCommmit = desiredAutoCommit;
  }

flase这个值会传递给JdbcTransaction构造方法的desiredAutoCommit，设置了autoCommmit 这个值为false。

那么肯定有地方调用了这个构造方法，在哪里呢，是在SqlSessoin调用insert/update/delete方法的时候

  public int insert(String statement, Object parameter) {
    return update(statement, parameter);
  }

调用了update(statement, parameter)

  public int update(String statement, Object parameter) {
    try {
      dirty = true;
      MappedStatement ms = configuration.getMappedStatement(statement);
      return executor.update(ms, wrapCollection(parameter));
    } catch (Exception e) {
      throw ExceptionFactory.wrapException("Error updating database.  Cause: " + e, e);
    } finally {
      ErrorContext.instance().reset();
    }
  }

继续往里跟executor.update(ms, wrapCollection(parameter));直到BatchExecutor类的doUpdate方法

  public int doUpdate(MappedStatement ms, Object parameterObject) throws SQLException {
   //.....省略这些代码，节省篇幅
    if (sql.equals(currentSql) && ms.equals(currentStatement)) {
      //.....省略这些代码，节省篇幅
    } else {
      Connection connection = getConnection(ms.getStatementLog());
      stmt = handler.prepare(connection);
      //.....省略这些代码，节省篇幅
    }
      //.....省略这些代码，节省篇幅
  }

其中有一句代码是Connection connection = getConnection(ms.getStatementLog());

  protected Connection getConnection(Log statementLog) throws SQLException {
    Connection connection = transaction.getConnection();
    if (statementLog.isDebugEnabled()) {
      return ConnectionLogger.newInstance(connection, statementLog, queryStack);
    } else {
      return connection;
    }
  }

Connection connection = transaction.getConnection()；transaction对象这里是JdbcTransaction对象

  public Connection getConnection() throws SQLException {
    if (connection == null) {
      openConnection();
    }
    return connection;
  }

openConnection()；

  protected void openConnection() throws SQLException {
   // 省略...
    setDesiredAutoCommit(autoCommmit);
  }

  protected void setDesiredAutoCommit(boolean desiredAutoCommit) {
    try {
      if (connection.getAutoCommit() != desiredAutoCommit) {
       //.....
        connection.setAutoCommit(desiredAutoCommit);
      }
    } catch (SQLException e) {
    // ....
    }
  }

connection.setAutoCommit(desiredAutoCommit);desiredAutoCommit参数的值就是在SqlSession调用openSessoin()方法的时候，第4个参数值 false

public SqlSession openSession() {
    return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);
  }

上面的源分析码可以无视，不是重点

3. 编写UserTest测试类。

package com.alex.app.test;

import org.apache.ibatis.session.SqlSession;
import org.junit.Assert;
import org.junit.Test;

import com.alex.app.entity.User;
import com.alex.app.util.MyBatisUtil;

public class UserTest {
	
	/**
	 * C,Create 创建
	 */
	@Test
	public void testInsertUser() {
		SqlSession session = null;
		try {
			// 获取SqlSession
			session = MyBatisUtil.openSession();
			// 准备要添加的数据
			User user = new User();
			user.setUsername("belongtou");
			user.setPassword("9988");
			/*insert()方法说明
			 * 第一个参数，就是User.xml的namespace属性  + "." +  insert标签的id属性
			 * 我们看到User.xml的namespace属性正好与我们的实体User的完整类名一致
			 * 所以我们可以使用反射的方式取到这个完整的类名，然再后 + "." +  insert标签的id属性，
			 * 一长串的字符写起来很容易出错的。我们说约定优与配置：：：
			 * */
			session.insert(User.class.getName()+".insertUser",user);
			/* 需要手动提交事务
			 * mybaits的事务在创建SqlSessoin时，自动将作了一个操作：Connection.setAutoCommint(false)，将事务设置为非自动提交。
			 */
			session.commit();
		} catch (Exception e) {
			e.printStackTrace();
			// 异常回滚
			session.rollback();
		}finally{
			// 关闭SqlSession
			MyBatisUtil.coloseSession(session);
		}
	}

	/**
	 * R,Retrieve 读取
	 */
	@Test
	public void testSelectUser() {
		SqlSession session = null;
		try {
			session = MyBatisUtil.openSession();
			User user = (User)session.selectOne(User.class.getName()+".selectUser",2);
			
			// 断言 user不为空
			Assert.assertNotNull(user);
			// 断言user对象的Id就是我们刚上面所查询到的ID值 2
			// assertEquals第一个参数是预期值，第二个参数是实际
			Assert.assertEquals(user.getId(), 2);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	/**
	 * U, Update 更新
	 */
	@Test
	public void testUpdateUser() {
		SqlSession session = null;
		try {
			session = MyBatisUtil.openSession();
			User user = (User)session.selectOne(User.class.getName()+".selectUser", 1);
			
			Assert.assertNotNull(user);//断言user对象不为null
			
			user.setUsername("Nunu");
			user.setPassword("7788");
			session.update(User.class.getName()+".updateUser", user);
			
			session.commit();
			
			User user2 = (User)session.selectOne(User.class.getName()+".selectUser", 1);
			
			Assert.assertNotNull(user2);
			//断言，user2所查询到的值，与我们上面更新时(更新user对象)所设置的值是否一致。一致则测试通过
			Assert.assertEquals(user2.getUsername(), "Nunu");
			Assert.assertEquals(user2.getPassword(), "7788");
		} catch (Exception e) {
			e.printStackTrace();
			session.rollback();
		}finally{
			MyBatisUtil.coloseSession(session);
		}
	}
	/**
	 * D ,Delete 删除
	 */
	@Test
	public void testDeleteUser() {
		SqlSession session = null;
		try {
			session = MyBatisUtil.openSession();
			session.delete(User.class.getName()+".deleteUser", 3);
			session.commit();
		} catch (Exception e) {
			e.printStackTrace();
			session.rollback();
		}finally{
			MyBatisUtil.coloseSession(session);
		}
	}
}

注意，SqlSession在创建的时候，MyBatis把事务自动设置为了false，就是JDBC规范的Connection.setAutoCommit(false)；事务不会自动提交。再做URD的时候，需要调用SqlSession的commint() 方法提交。

4. 映射文件问题

现在我们映射文件有很多重复主要是parameterType="com.alex.app.entity.User" resultType="com.alex.app.entity.User" 这里，都是重复的。

我们可以在mybatis-config.xml配置文件中properties标签和environments之前，使用typeAlias 标签配置一个别名

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
  PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
	<!-- 引入外部properties文件 -->
	<properties resource="jdbc.properties" />
	<typeAliases>
		<typeAlias type="com.alex.app.entity.User" alias="User"/>
	</typeAliases>
	<environments default="development">
		<!--  省略部分配置 -->
	</environments>
	<!-- 映射文件 -->
	<mappers>
		<mapper resource="com/alex/app/entity/User.xml"/>
	</mappers>
</configuration>

那么在映射文件中，就可以使用这个别名来定义这些属性 parameterType="User" resultType="User"

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.alex.app.entity.User">
  
  <select id="selectUser" parameterType="int" resultType="User">
    select * from t_user where id = #{id}
  </select>
  
  <insert id="insertUser" parameterType="User">
  	insert into t_user(username,password)
  	values(#{username},#{password})
  </insert>
  
  <update id="updateUser" parameterType="User">
  	update t_user set username=#{username},password=#{password} 
  	where id = #{id}
  </update>
  
  <delete id="deleteUser" parameterType="int">
  	delete from t_user where id = #{id}
  </delete>
</mapper>

单元的测试断言部分不用纠结，可以直接去数据库中查看。或者最笨的方式直接把信息打印到控制台上查看。

另外还有几个问题，就是在执行CRUD操作的时候，会破坏数据库中的数据；每个单元测都是独立的，不依赖与其它单元测试，假如我先执行一个删除动作，删除Id 为2的数据，之后执行了查询动作，查询ID为2的数据，这时候可能会出错。

单元测试是为了测试我们的功能片断是否正常，每个分支是否覆盖到，一些代码的边界是否存在的问题等等，这里不纠结它了，后面我们再研究。