Mybatis学习笔记（二） 之实现数据库的增删改查

开发环境搭建

mybatis 的开发环境搭建，选择: eclipse j2ee 版本，mysql 5.1 ,jdk 1.7,mybatis3.2.0.jar包。这些软件工具均可以到各自的官方网站上下载。
首先建立一个名字为 MyBaits 的 dynamic web project 
1. 可以创建maven项目，依赖的包mybatis-3.2.0-SNAPSHOT.jar，mysql-connector-java-5.1.22-bin.jar 

	<!-- mybatis包 -->
	<dependency>
	    <groupId>org.mybatis</groupId>
	    <artifactId>mybatis</artifactId>
	    <version>3.2.0</version>
	</dependency>

        <!-- mysql -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.22</version>
        </dependency>

2、构建后的项目结构

实现数据的增删改查

需求：

• 根据id（主键）查询用户信息

• 根据用户名模糊查询用户信息

• 添加用户

• 更新用户

• 删除用户

在新建一个源代码目录config，在config目录下使用以下的log4j属性文件(可以从mybatis示例程序中拷贝)：

编码前的准备

添加log4j

# 开发环境中日志的级别使用DEBUG，生产环境中日志级别为ERROR
log4j.rootLogger=DEBUG, stdout

log4j.logger.org.mybatis.example.BlogMapper=TRACE
# Console output...
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n

1. 设置mybatis 配置文件:Configuration.xml, 在src/main/java目录下建立此文件　

注意:这里的typeAlias就相当于起别名，为com.yihaomen.mybatis.model.User包起一个user别名。

内容如下: 

<?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>
    <typeAliases> 
        <typeAlias alias="User" type="com.yihaomen.mybatis.model.User"/> 
    </typeAliases> 

	<!-- spring整合之后，environments配置将废除  -->
    <environments default="development">
        <environment id="development">
        <!-- 使用jdbc事务管理，事务控制有mybatis -->
        <transactionManager type="JDBC"/>
        	<!-- 数据库连接池 ，有mybatis管理-->
            <dataSource type="POOLED">
            <property name="driver" value="com.mysql.jdbc.Driver"/>
            <property name="url" value="jdbc:mysql://192.168.6.1:3306/test"/>
            <property name="username" value="dev"/>
            <property name="password" value="123qwe"/>
            </dataSource>
        </environment>
    </environments>
   
    <!-- 加载映射文件 -->
    <mappers>
        <mapper resource="com/yihaomen/mybatis/model/User.xml"/>
    </mappers>
</configuration>

2、建立与数据库对应的 java class,以及映射文件.

package com.yihaomen.mybatis.model;

public class User {
    
    private int id;
    private String userName;
    private int userAge;
    private String userAddress;
    
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getUserName() {
        return userName;
    }
    public void setUserName(String userName) {
        this.userName = userName;
    }
    public int getUserAge() {
        return userAge;
    }
    public void setUserAge(int userAge) {
        this.userAge = userAge;
    }
    public String getUserAddress() {
        return userAddress;
    }
    public void setUserAddress(String userAddress) {
        this.userAddress = userAddress;
    }

}

3、同时建立这个User 的映射文件 User.xml:这里边的sql就包括对数据库的增删改查操作。

<?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">

<!-- namespace命名空间，作用就是对sql进行分类化管理，注意：使用mapper代理方法开发，namespace有特殊重要作用 -->
<mapper namespace="com.yihaomen.mybatis.dao.IUserOperation">
	<!-- 在映射文件中配置很多sql -->
	<!-- id标识映射文件的sql，称为statement的id ，将sql语句封装到mappedStatement对象中，所以将id称为statement的id
	parameterType:指定输入类型  resultType：指定sql输出结果的所映射的java对象，select指定resultType表示将单挑记录
	映射成java对象-->
    <select id="selectUserByID" parameterType="int" resultType="User">
        select * from `user` where id = #{id}
    </select>
    
    <insert id="addUser" parameterType="User" 
        useGeneratedKeys="true" keyProperty="id"> 
        insert into user(userName,userAge,userAddress) values(#{userName},#{userAge},#{userAddress})  
    </insert>  
    
    <update id="updateUser" parameterType="User">
        update user set userName=#{userName},userAge=#{userAge},userAddress=#{userAddress} where id=#{id}
    </update>
    
    <delete id="deleteUser" parameterType="int">
        delete from user where id=#{id}
    </delete>
    
    <select id="list"  resultType="User">
        select * from `user`
    </select>
    
    <!-- ${}表示拼接sql串，指定就是单挑记录所映射的java对象类型,使用${}拼接，容易导致sql注入
    ${value}:拼接输入参数的内容，如果传入类型是简单类型，${}中只能使用value -->
    <select id="findUserByName"  parameterType="String"  resultType="User">
        select * from `user` where username like '%${value}%'        
    </select>
</mapper>

　　

下面对这几个配置文件解释下：
1.Configuration.xml 是 mybatis 用来建立 sessionFactory 用的，里面主要包含了数据库连接相关东西，还有 java 类所对应的别名，比如 <typeAlias alias="User" type="com.yihaomen.mybatis.model.User"/> 这个别名非常重要，你在 具体的类的映射中，比如User.xml 中 resultType 就是对应这里的。要保持一致，当然这里的 resultType 还有另外单独的定义方式，后面再说。
2.  Configuration.xml 里面 的<mapper resource="com/yihaomen/mybatis/model/User.xml"/>是包含要映射的类的xml配置文件。
3. 在User.xml 文件里面 主要是定义各种SQL 语句，以及这些语句的参数，以及要返回的类型等.　

4、为了以接口方式编程，而且是更好的方法，使用合理描述参数和SQL语句返回值的接口（比如IUserOperation.class），这样现在就可以至此那个更简单，更安全的代码，没有容易发生的字符串文字和转换的错误.下面是详细过程:

在目录下建立 com.yihaomen.mybatis.dao 这个包，并建立接口类 IUserOperation , 内容如下

package com.yihaomen.mybatis.dao;

import java.util.List;

import com.yihaomen.mybatis.model.Article;
import com.yihaomen.mybatis.model.User;

//注意：接口名字必须与  xml中的namespace名字一样   2、接口实现方法每个名字  与xml中的id对应
public interface IUserOperation {   
	//查询数据
    public User selectUserByID(int id);    
    //增加数据
    public void addUser(User user);   
    //更新数据
    public void updateUser(User user);    
    //删除数据
    public void deleteUser(int id);
    //联合查询
    public List<Article> getUserArticles(int id);    
    //list获取
    public List<User> list();    
    //模糊查询
    public List<User> findUserByName(String name);
    
}

　　

5、开始测试，测试类：

package com.yihaomen.mybatis.ui;

import java.io.Reader;
import java.util.List;

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

import com.yihaomen.mybatis.dao.IUserOperation;
import com.yihaomen.mybatis.model.User;

public class Test {
    private static SqlSessionFactory sqlSessionFactory;
    private static Reader reader; 

    //创建会话工厂，传入mybatis的配置文件信息
    static{
        try{
        	//得到配置文件流
            reader = Resources.getResourceAsReader("Configuration.xml");
            //创建会话工厂，传入mybatis的配置文件信息
            sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);
        }catch(Exception e){
            e.printStackTrace();
        }
    }
    //公共方法，返回初始化的sqlSessionFactory对象
    public static SqlSessionFactory getSession(){
        return sqlSessionFactory;
    }
    
    //查询数据
    public void select() {
    	//通过工厂得到sqlsession
        SqlSession session = sqlSessionFactory.openSession();
        try {
        	//通过SqlSession操作数据库
        	//第一个参数：映射文件中statement的id
        	//第二个参数：指定和映射文件所匹配的parameterType类型参数
	        User user = (User) session.selectOne("com.yihaomen.mybatis.model.User.selectUserByID", 1);
	        System.out.println(user.getUserAddress());
	        System.out.println(user.getUserName());
        } finally {
        	session.close();
        }
    }
    
    //增加数据
    public void addUser(String address,String name){
    	//创建user对象
        User user=new User();
        user.setUserAddress(address);
        user.setUserName(name);
        user.setUserAge(80);
        
        //通过工厂得到SqlSession
        SqlSession session = sqlSessionFactory.openSession();
        try {
            IUserOperation userOperation=session.getMapper(IUserOperation.class);
            //添加数据
            userOperation.addUser(user);
            //提交
            session.commit();
            //System.out.println("当前增加的用户 id为:"+user.getId());
        } finally {
            session.close();
        }
    }
    
    //更新数据
    public void updateUser(int id,String address){
        //先得到用户,然后修改，提交。
        SqlSession session = sqlSessionFactory.openSession();
        try {
            IUserOperation userOperation = session.getMapper(IUserOperation.class);
            User user = userOperation.selectUserByID(id);            
            user.setUserAddress(address);
            userOperation.updateUser(user);
            session.commit();
            System.out.println("更新成功！！");
        } finally {
            session.close();
        }
    }
    
    //删除数据
    public void deleteUser(int id) {
    	SqlSession session = sqlSessionFactory.openSession();
    	
    	try{
    		IUserOperation userOperation = session.getMapper(IUserOperation.class);
            userOperation.deleteUser(id);
            session.commit();  
            System.out.println("删除数据：id= "+id);
    	}finally {
            session.close();
        }
		
	}
    
    //list获取
    public void getList() {
    	SqlSession session = sqlSessionFactory.openSession();
    	
    	try{
    		IUserOperation userOperation = session.getMapper(IUserOperation.class);
    		List<User> us = userOperation.list();    		
    		session.commit();  
            //System.out.println("生成list： "+us.size());
    	}finally {
            session.close();
        }
		
	}
    
    //模糊查询
    public void geFindUserByName(String name) {
    	SqlSession session = sqlSessionFactory.openSession();
    	
    	try{
    		IUserOperation userOperation = session.getMapper(IUserOperation.class);
    		List<User> us = userOperation.findUserByName(name);   
    		System.out.println(us.size());
    		session.commit();  
    		
    	}finally {
            session.close();
        }		
	}

	public static void main(String[] args) {
		Test test = new Test();
		test.getList();		
		test.geFindUserByName("小");
		//test.addUser("杭州","小江");
	    }  
}

结果日志：

[2017-01-10 20:22:33] DEBUG [main] - Logging initialized using 'class org.apache.ibatis.logging.slf4j.Slf4jImpl' adapter.
[2017-01-10 20:22:33] DEBUG [main] - PooledDataSource forcefully closed/removed all connections.
[2017-01-10 20:22:33] DEBUG [main] - PooledDataSource forcefully closed/removed all connections.
[2017-01-10 20:22:33] DEBUG [main] - PooledDataSource forcefully closed/removed all connections.
[2017-01-10 20:22:33] DEBUG [main] - PooledDataSource forcefully closed/removed all connections.
[2017-01-10 20:22:33] DEBUG [main] - Opening JDBC Connection
[2017-01-10 20:22:34] DEBUG [main] - Created connection 238157928.
[2017-01-10 20:22:34] DEBUG [main] - Setting autocommit to false on JDBC Connection [com.mysql.jdbc.JDBC4Connection@e320068]
[2017-01-10 20:22:34] DEBUG [main] - ==>  Preparing: select * from `user` where username like '%小%' 
[2017-01-10 20:22:34] DEBUG [main] - ==> Parameters: 
[2017-01-10 20:22:34] DEBUG [main] - <==      Total: 7
7
[2017-01-10 20:22:34] DEBUG [main] - Resetting autocommit to true on JDBC Connection [com.mysql.jdbc.JDBC4Connection@e320068]
[2017-01-10 20:22:34] DEBUG [main] - Closing JDBC Connection [com.mysql.jdbc.JDBC4Connection@e320068]
[2017-01-10 20:22:34] DEBUG [main] - Returned connection 238157928 to pool.

总结

• parameterType在映射文件中通过parameterType指定输入参数的类型。

• resultType在映射文件中通过resultType指定输出结果的类型。

• #{}和${}

#{}表示一个占位符号，#{}接收输入参数，类型可以是简单类型，pojo、hashmap。如果接收简单类型，#{}中可以写成value或其它名称。
#{}接收pojo对象值，通过OGNL读取对象中的属性值，通过属性.属性.属性...的方式获取对象属性值。

${}表示一个拼接符号，会引用sql注入，所以不建议使用${}。
${}接收输入参数，类型可以是简单类型，pojo、hashmap。如果接收简单类型，${}中只能写成value。
${}接收pojo对象值，通过OGNL读取对象中的属性值，通过属性.属性.属性...的方式获取对象属性值。

• selectOne和selectList

  • selectOne表示查询出一条记录进行映射。如果使用selectOne可以实现使用selectList也可以实现（list中只有一个对象）。

  • selectList表示查询出一个列表（多条记录）进行映射。如果使用selectList查询多条记录，不能使用selectOne。

如果使用selectOne报错：

org.apache.ibatis.exceptions.TooManyResultsException: Expected oneresult (or null) to be returned by selectOne(), but found: 4

参考

1、mybatis学习笔记（一）--基本crud操作：https://segmentfault.com/a/1190000003771372

2、mybatis学习笔记入门：http://www.cnblogs.com/hellokitty1/p/5216025.html

3、mybatis实战教程：http://blog.csdn.net/techbirds_bao/article/details/9233599/

4、深入理解mybatis原理：http://blog.csdn.net/column/details/mybatis-principle.html?page=1

5、Mybatis系列学习：http://blog.csdn.net/chris_mao/article/details/48827961