13、mybatis

MyBatis是支持普通SQL查询，存储过程和高级映射的优秀持久层框架。MyBatis消除了几乎所有的JDBC代码和参数的手工设置以及结果集的检索。MyBatis使用简单的XML或注解用于配置和原始映射，将接口和POJO映射成数据库中的记录.

 

orm工具的基本思想：无论是hibernate,mybatis,想象他们有一个共同点：
1. 从配置文件(通常是XML配置文件中)得到 sessionfactory.
2. 由sessionfactory  产生 session
3. 在session 中完成对数据的增删改查和事务提交等.
4. 在用完之后关闭session 。

5. 在java 对象和 数据库之间有做mapping 的配置文件，也通常是xml 文件。

http://blog.csdn.net/techbirds_bao/article/details/9233599/

开发环境搭建

eclipse j2ee 版本我用的是eclipse-jee-luna，mysql 5.1 ,jdk 1.7,mybatis3.2.0.jar,log4j-1.2.12.jar包。

首先建立一个名字为 MyBaits 的 dynamic web project 
1. 现阶段，你可以直接建立java 工程，但一般都是开发web项目，这个系列教程最后也是web的，所以一开始就建立web工程。
2. 将 mybatis-3.2.0-SNAPSHOT.jar，mysql-connector-java-5.1.22-bin.jar 拷贝到 web工程的lib目录.
3. 创建mysql 测试数据库和用户表,注意，这里采用的是 utf-8 编码

创建用户表,并插入一条测试数据

Create TABLE `user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `userName` varchar(50) DEFAULT NULL,
  `userAge` int(11) DEFAULT NULL,
  `userAddress` varchar(200) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;

Insert INTO `user` VALUES ('1', 'summer', '100', 'shanghai,pudong');

 在MyBatis 里面创建两个源码目录（资源目录），分别为 src_user,src_test, 项目右键 new source folder

 设置mybatis 配置文件:Configuration.xml, 在src_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> 

<environments default="development"> 
<environment id="development"> 
<transactionManager type="JDBC"/> 
<dataSource type="POOLED"> 
<property name="driver" value="com.mysql.jdbc.Driver"/> 
<property name="url" value="jdbc:mysql://127.0.0.1:3306/abcc" /> 
<property name="username" value="root"/> 
<property name="password" value="111122"/> 
</dataSource> 
</environment> 
</environments> 

<mappers> 
<mapper resource="com/yihaomen/mybatis/model/User.xml"/> 
</mappers> 
</configuration> 

在src_user下建立package，com.yihaomen.mybatis.model ,并在这个 package 下建立 User 类:添加get,set方法;

package com.yihaomen.mybatis.model;
public class User {
    private int id;
    private String userName;
    private String userAge;
    private String userAddress;
}

同时建立这个User 的映射文件 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.yihaomen.mybatis.models.UserMapper"> 
<select id="selectUserByID" parameterType="int" resultType="User"> 
select * from `user` where id = #{id} 
</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 语句，以及这些语句的参数，以及要返回的类型等.

开始测试
在src_test源码目录下建立com.yihaomen.test这个package,建立测试类Tes1t和测试辅助类TestUtil：

辅助类TestUtil：

package com.yihaomen.test;

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.inter.IUserOperation;
import com.yihaomen.mybatis.model.User;
public class TestUtil {
	 private static SqlSessionFactory sqlSessionFactory;
	    private static Reader reader;
	    static{
	        try{
	            reader = Resources.getResourceAsReader("Configuration.xml");
	            sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);
	        }catch(Exception e){
	            e.printStackTrace();
	        }
	    }
	    public SqlSessionFactory getSession(){
	        return sqlSessionFactory;
	    }
}

 测试类Tes1t：

package com.yihaomen.test;

import org.apache.ibatis.session.SqlSession;
import com.yihaomen.mybatis.model.User;
public class Test1 {
    public static void main(String[] args) {
        SqlSession session = TestUtil.getSession().openSession();
        try {
        User user = (User) session.selectOne("com.yihaomen.mybatis.models.UserMapper.selectUserByID", 1);
        System.out.println(user.getUserAddress());
        System.out.println(user.getUserName());
        } finally {
        session.close();
        }
    }
}

 

 前面已经搭建好了eclipse,mybatis,mysql的环境，并且实现了一个简单的查询。请注意，这种方式是用SqlSession实例来直接执行已映射的SQL语句：
session.selectOne("com.yihaomen.mybatis.models.UserMapper.selectUserByID", 1)

这里要搭建接口查询;

在src_user源码目录下建立 com.yihaomen.mybatis.inter 这个包，并建立接口类 IUserOperation , 内容如下：

package com.yihaomen.mybatis.inter;
import com.yihaomen.mybatis.model.User;
public interface IUserOperation {   
    public User selectUserByID(int id);
}

 修改User.xml  ：namespace改为接口所在的包路径，selectUserByID方法与id值一致为selectUserByID

<mapper namespace="com.yihaomen.mybatis.inter.IUserOperation"> 
       <select id="selectUserByID" parameterType="int" resultType="User"> 
            select * from `user` where id = #{id} 
       </select> 
</mapper>

 测试类Test2：

package com.yihaomen.test;
import org.apache.ibatis.session.SqlSession;
import com.yihaomen.mybatis.inter.IUserOperation;
import com.yihaomen.mybatis.model.User;
public class Test2 {
	public static void main(String[] args) {
        SqlSession session = TestUtil.getSession().openSession();
        try {
            IUserOperation userOperation=session.getMapper(IUserOperation.class);
            User user = userOperation.selectUserByID(1);
            System.out.println(user.getUserAddress());
            System.out.println(user.getUserName());
        } finally {
            session.close();
        }
    }
}

 

实现数据的增删改查

查询数据，前面已经讲过用pojo类作为返回类型resultType="User"，指向表序列中的某个对象；

而整个表，可以理解为list<User>，下面将在User.xml 里面配置返回的类型 resultMap作为多个对象的返回容器；

1、查询数据

手动向user表中添加数据：

3sv233usa

2summer12chongqing

向 IUserOperation 接口中增加方法：public void addUser(User user);

修改User.xml,向其中添加：

<resultMap id="resultListUser"  type="User" >
	<id column="id" property="id" />
        <result column="userName" property="userName" />
        <result column="userAge" property="userAge" />
        <result column="userAddress" property="userAddress" />
 </resultMap>
       
	<!-- resultMap="resultListUser"对应的是resultMap的id值为"resultListUser" -->
	<select id="selectUsers" parameterType="string" resultMap="resultListUser">
		select * from user where userName like #{userName}
	</select>

 向测试辅助类添加：

public void getUserList(String userName){
        SqlSession session = sqlSessionFactory.openSession();
        try {
            IUserOperation userOperation=session.getMapper(IUserOperation.class);          
            List<User> users = userOperation.selectUsers(userName);
            for(User user:users){
                System.out.println(user.getId()+":"+user.getUserName()+":"+user.getUserAddress());
            }
        } finally {
            session.close();
        }
    }

测试：

public class Test3 {
	public static void main(String[] args) {
        TestUtil testUser=new TestUtil();
        testUser.getUserList("%");   //  %通配符
    }
}

 2、添加数据

 

向 IUserOperation 接口中增加方法： public void addUser(User user);

修改User.xml,向其中添加：

<!--执行增加操作的SQL语句。id和parameterType 分别与IUserOperation接口中的addUser方法的名字和 
       参数类型一致。以#{name}的形式引用参数 的name属性，MyBatis将使用反射读取Student参数的此属性。
    #{name}中name大小写敏感。seGeneratedKeys设置 为"true"表明要MyBatis获取由数据库自动生成的主 
       键；keyProperty="id"指定把获取到的主键值注入到User的id属性-->
    <insert id="addUser" parameterType="User" useGeneratedKeys="true" keyProperty="id">
        insert into user(userName,userAge,userAddress)values(#{userName},#{userAge},#{userAddress}) 
    </insert>

  向测试辅助类添加：

public void addUser(){
        User user=new User();
        user.setUserAddress("人民广场");
        user.setUserName("飞鸟");
        user.setUserAge("80");
        SqlSession session = sqlSessionFactory.openSession();
        try {
            IUserOperation userOperation=session.getMapper(IUserOperation.class);
            userOperation.addUser(user);
            session.commit();    //session提交;hibernate的事务提交
            System.out.println("当前增加的用户 id为:"+user.getId());
        } finally {
            session.close();
        }
    }

 测试：

   TestUtil testUser=new TestUtil();
   testUser.addUser();

 

 

3、更新数据：

向 IUserOperation 接口中增加方法：public void updateUser(User user);

修改User.xml,向其中添加：

 

<update id="updateUser" parameterType="User" >
        update user set userName=#{userName},userAge=#{userAge},userAddress=#{userAddress} where id=#{id}
    </update>

   向测试辅助类添加：

public void updateUser(){
        //先得到用户,然后修改，提交。
        SqlSession session = sqlSessionFactory.openSession();
        try {
            IUserOperation userOperation=session.getMapper(IUserOperation.class);
            User user = userOperation.selectUserByID(4);           
            user.setUserAddress("原来是魔都的浦东创新园区");
            userOperation.updateUser(user);
            session.commit();
        } finally {
            session.close();
        }
    }

 测试：

  TestUtil testUser=new TestUtil();
  testUser.updateUser();

 

 

4、删除数据

向 IUserOperation 接口中增加方法：public void deleteUser(int id);

修改User.xml,向其中添加：  

 

 <delete id="deleteUser" parameterType="int">
        delete from user where id=#{id}
    </delete>

 向测试辅助类添加：

public void deleteUser(int id){
        SqlSession session = sqlSessionFactory.openSession();
        try {
            IUserOperation userOperation=session.getMapper(IUserOperation.class);          
            userOperation.deleteUser(id);
            session.commit();           
        } finally {
            session.close();
        }
    }

 测试：

 TestUtil testUser=new TestUtil();
 testUser.deleteUser(2);;

 这样，所有增删改查都完成了，注意在增加，更改，删除的时候要调用session.commit()，这样才会真正对数据库进行操作，否则是没有提交的。

 

 

实现关联数据的查询

在实际项目中，经常是关联表的查询，比如最常见到的多对一，一对多等。这些查询是如何处理的呢，这一讲就讲这个问题。我们首先创建一个Article 这个表，并初始化数据.

mysql中执行sql语句：选择数据库，点击查询，新建查询   输入sql语句 后运行；

Drop TABLE IF EXISTS `article`;
Create TABLE `article` (
  `id` int(11) NOT NULL auto_increment,
  `userid` int(11) NOT NULL,
  `title` varchar(100) NOT NULL,
  `content` text NOT NULL,
  PRIMARY KEY  (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8;
-- ----------------------------
-- 添加几条测试数据
-- ----------------------------
Insert INTO `article` VALUES ('1', '1', 'test_title', 'test_content');
Insert INTO `article` VALUES ('2', '1', 'test_title_2', 'test_content_2');
Insert INTO `article` VALUES ('3', '1', 'test_title_3', 'test_content_3');
Insert INTO `article` VALUES ('4', '1', 'test_title_4', 'test_content_4');

 增加一个 Article 的POJO:

package com.yihaomen.mybatis.model;

public class Article {
    private int id;
    private User user;
    private String title;
    private String content;
添加get/set方法

 向 IUserOperation 接口中增加方法：  public List<Article> getUserArticles(int id);

修改User.xml,向其中添加，注意type要写全路径，column很重要与select查询出来的字段名要吻合！

<resultMap id="resultUserArticleList" type="com.yihaomen.mybatis.model.Article">
        <id property="id" column="aid" />
        <result property="title" column="title" />
        <result property="content" column="content" />        
        <association property="user" javaType="User" resultMap="resultListUser" />            
    </resultMap>

	<select id="getUserArticles" parameterType="int" resultMap="resultUserArticleList">
       select user.id,user.userName,user.userAddress,article.id aid,article.title,article.content from user,article where user.id=article.userid and user.id=#{id}
    </select>
userid是数据表里的字段

 向测试辅助类添加：

        //级联查询
	public void getUserArticles(int userid){
        SqlSession session = sqlSessionFactory.openSession();
        try {
            IUserOperation userOperation=session.getMapper(IUserOperation.class);          
            List<Article> articles = userOperation.getUserArticles(userid);
            for(Article article:articles){
                System.out.println(article.getTitle()+":"+article.getContent()+":作者是:"+article.getUser().getUserName()+":地址:"+article.getUser().getUserAddress());
            }
        } finally {
            session.close();
        }
    }

 测试：

  TestUtil testUser=new TestUtil();
  testUser.getUserArticles(1);
  System.out.println("测试成功！！");

 下一章将讲解mybatis与spring集成;欢迎来群366437263