MyBatis入门

1、MyBatis的介绍

　　1. MyBatis 是一个支持普通SQL查询，存储过程和高级映射的优秀持久层（Dao）框架。MyBatis消除了几乎所有的JDBC代码和参数的手工设置以及对结果集的检索封装。

　　2. MyBatis 消除了几乎所有的JDBC代码和手工设置参数以及结果集的检索。

　　3. MyBatis 使用简单的 XML或注解用于配置和原始映射，将接口和 Java 的POJOs（Plain Old Java Objects，普通的 Java对象）映射成数据库中的记录。

　　4. 一个MyBatis的应用程序都以一个SqlSessionFactory 对象（单例）的实例为核心;

　　　　SqlSession对象完全包含以数据库为背景的所有执行SQL操作的方法。

　　5. MyBatis是针对数据库交互的一个辅助框架，也是对jdbc做了的简单封装，以xml配置代替Java代码来管理数据库的交互细节！！

　　注意：

　　　　JPA 可以自动建表。

　　　　MyBatis不能自动创建表，如果要建表，必须自己先准备好建表的sql语句。

 

MyBatis三大核心对象
    1. SqlSessionFactoryBuilder
        　　目的是创建SqlSessionFactory  ，  用完就扔  ， 写在方法内部 ， 作为局部变量 ， 建造者模式。
    2. SqlSessionFactory
        　　重量级对象 ， 作用域整个应用  ， 单例模式使用  ， 有二级缓存。
    3. SqlSession
        轻量级的  ，  请求作用域，一个请求对应一个SqlSession对象 ， 线程不安全的 ， 有一级缓存。
    4. （扩展）Executor 数据库的操作都是调用的Executor接口的方法
                update：增、删、改所用方法。
                query：查询所用方法。

 

MyBatis执行流程：　

　　①：我们需要核心文件(提供联系数据库的环境)

　　②：需要映射文件(提供ORM与运行的SQL语句)

　　③：拿到SqlSession对象，用于执行SQL

 

2、MyBatis的入门使用

　　注意：

　　　　使用Mybatis的方式用两种，一种是xml配置的方式，一种是接口+注解的方式。

　　　　这里主要是介绍xml配置方式。

 

　　1.导入相应的jar包

　　　　核心包：mybatis-3.2.1.jar

　　　　数据库驱动包：mysql-connector-java-5.1.26-bin.jar

　　　　依赖包:
   　　　　　　　　 asm-3.3.1.jar
    　　　　　　　　cglib-2.2.2.jar
    　　　　　　　　commons-logging-1.1.1.jar
    　　　　　　　　javassist-3.17.1-GA.jar
   　　　　　　　　 log4j-1.2.17.jar
    　　　　　　　　slf4j-api-1.7.2.jar
    　　　　　　　　slf4j-log4j12-1.7.2.jar

　　2.准备相应的数据

　　　　数据库-->新建数据库-->新建表-->插入测试数据

　　 3.准备domain实体类、dao和测试类

　　　　注意：类的名称和类型都和我们的product表相对应匹配

　　案例：

domain实体类

public class Product {
    private    Long id;
    //商品名称
    private String productName;
    //品牌
    private String brand;
    //供应商
    private String supplier;
    //零售价
    private Double salePrice;
    //进价
    private Double costPrice;
    //折扣比例
    private Double cutoff;
    //商品分类编号
    private Long dir_id;

　　-----之后是get、set方法（略）
}

 

dao层接口

public interface IProductDao {
    /**
     * 添加一个商品
     */
    void save(Product p);
    /**
     * 更新一个商品
     */
    void update(Product product);
    /**
     * 删除一个商品
     */
    void delete(Long id);
    /**
     * 查询一个商品
     */
    Product findOne(Long id);
    /**
     * 查询所有商品
     */
    List<Product> findAll();

}

dao层接口实现类　

　　注：添加、修改、删除的时候一定要记住提交事务(配置事务、表结构支持事务)。

　　　　JDBC的事务是自动提交的，而JPA、Hibernate、MyBatis事务都是需要手动提交的。

package cn.wang.dao.daoImpl;

import cn.wang.Utils.MyBatisUtils;
import cn.wang.dao.IProductDao;
import cn.wang.domain.Product;
import org.apache.ibatis.session.SqlSession;

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

public class ProductDaoImpl implements IProductDao {

    //抽取sql命名空间名字的值
    private final String NAMESPACE = "cn.wang.domain.ProductMapper.";
    //添加方法
    @Override
    public void save(Product p) {
        SqlSession sqlSession =null;

        try {
            //获取SqlSession对象（MyBatisUtils是为了方便专门抽取出来的工具类）
            sqlSession = MyBatisUtils.getSession();
            //第一个参数：sql命名空间名字的值+对应sql语句映射的id，第二个参数：传入的值
            sqlSession.insert(NAMESPACE+"insert",p);
            //提交事务
            sqlSession.commit();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //关闭sqlSession，释放资源（很重要，不然项目上线后会造成内存溢出)
            MyBatisUtils.colseSession(sqlSession);
        }
    }

    //修改方法
    @Override
    public void update(Product product) {
        SqlSession sqlSession = null;
        try {
            //获取SqlSession对象（MyBatisUtils是为了方便专门抽取出来的工具类）
            sqlSession = MyBatisUtils.getSession();
            //第一个参数：sql命名空间名字的值+对应sql语句映射的id，第二个参数：传入的值
            sqlSession.update(NAMESPACE+"update", product);
            //提交事务
            sqlSession.commit();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //关闭sqlSession，释放资源（很重要，不然项目上线后会造成内存溢出)
            MyBatisUtils.colseSession(sqlSession);
        }
    }

    //删除方法
    @Override
    public void delete(Long id) {
        SqlSession sqlSession=null;

        try {
            //获取SqlSession对象（MyBatisUtils是为了方便专门抽取出来的工具类）
            sqlSession = MyBatisUtils.getSession();
            //第一个参数是获取查询语句：sql命名空间名字的值+对应sql语句映射的id
            sqlSession.delete(NAMESPACE+"delete", id);
            //提交事务
            sqlSession.commit();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //关闭sqlSession，释放资源（很重要，不然项目上线后会造成内存溢出)
            MyBatisUtils.colseSession(sqlSession);
        }
    }

    //查询一条数据
    @Override
    public Product findOne(Long id) {
        SqlSession sqlSession = null;
        Product product= null;
        try {
            //获取SqlSession对象（MyBatisUtils是为了方便专门抽取出来的工具类）
            sqlSession = MyBatisUtils.getSession();
            //第一个参数是获取查询语句：sql命名空间名字的值+对应sql语句映射的id
            product = sqlSession.selectOne(NAMESPACE+"findOne", id);

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //关闭sqlSession，释放资源（很重要，不然项目上线后会造成内存溢出)
            MyBatisUtils.colseSession(sqlSession);
        }
        return product;
    }

    //查询所有数据
    @Override
    public List<Product> findAll() {
        SqlSession sqlSession=null;
        List<Product> list=new ArrayList<>();

        try {
            //获取SqlSession对象（MyBatisUtils是为了方便专门抽取出来的工具类）
            sqlSession = MyBatisUtils.getSession();
            //第一个参数是获取查询语句：sql命名空间名字的值+对应sql语句映射的id
            list=sqlSession.selectList(NAMESPACE+"findAll");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //关闭sqlSession，释放资源（很重要，不然项目上线后会造成内存溢出)
            MyBatisUtils.colseSession(sqlSession);
        }
        return list;
    }
}

抽取出来的MyBatisUtils工具类

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 java.io.Reader;

public class MyBatisUtils {
    //保证sqlSessionFactory是单例
    private static SqlSessionFactory sqlSessionFactory;

    // SqlSessionFactory类似于JPA的EntityManagerFactory，Hibernate的SessionFactory
    // SqlSession 类似于JPA的EntityManager，Hibernate的Session

    //该类被加载的时候就执行该静态代码块
    static {
        try {
            Reader reader = Resources.getResourceAsReader("MyBatis-Config.xml");
            sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);
        } catch (Exception e) {//异常的类型要写大一些，才能够看到具体的报错
            e.printStackTrace();
        }
    }
    //提供一个外界调用的类
    public static SqlSession getSession(){
        //创建并返回SqlSession对象
        return sqlSessionFactory.openSession();
    }
    //关闭sqlSession，释放资源（很重要，不然项目上线后会造成内存溢出)
    public static void colseSession(SqlSession sqlSession){
        if(sqlSession !=null){
            sqlSession.close();
        }
    }
}

jdbc.properties

jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql:///数据库名称
jdbc.username=用户名
jdbc.password=密码

　　3.MyBatis核心配置文件（mybatis-config.xml）

<?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>
    <!-- environments：环境集合
        default:默认使用哪一个环境(必须对应一个环境的id)
     -->

    <!--引入外部的属性文件
        不写classpath的原因：resources默认到classpath中寻找资源
    -->
    <properties resource="jdbc.properties" />

    <!--
        配置自定义别名
        注意：别名不区分大小写。
           共两种配置方式：
            一：一个一个配置（typeAlias）
                    type 类型的完全限定名
                    alias 别名
            二：统一为某个包下的所有类起别名（package）
                    name : 包名   别名就是类名（不区分大小写）
    -->
    <typeAliases>
        <!--方法一-->
        <!--<typeAlias type="cn.wang.domain" alias="Product"/>-->

        <!--方法二-->
        <package name="cn.wang.domain"/>
    </typeAliases>

    <environments default="development">
        <!--
            environment：一个环境  id:为这个环境取唯一一个id名称
        -->
        <environment id="development">
            <!--
                transactionManager：事务管理（共有两个值） type:JDBC(支持事务)/MANAGED(什么都不做)
            -->
            <transactionManager type="JDBC" />
            <!-- 数据源, 连接池  type(POOLED):MyBatis自带的连接池
                     type="UNPOOLED" 不使用连接池
                    type="POOLED" 使用连接池
                    type="JNDI" 容器中使用
             -->
            <dataSource type="POOLED">
                <!-- 连接数据库的参数 -->
                <property name="driver" value="${jdbc.driver}" />
                <property name="url" value="${jdbc.url}" />
                <property name="username" value="${jdbc.username}" />
                <property name="password" value="${jdbc.password}" />
            </dataSource>
        </environment>
    </environments>
    <!-- 注册映射文件，这个mappers代表的是相应的ORM映射文件 -->
    <mappers>
        <mapper resource="cn/wang/domain/ProductMapper.xml" />
    </mappers>

</configuration>

　　4.配置映射文件（命名方式：domain实体类名称+Mapper.xml）

　　　注意：

　　　　① 我们的映射文件在这里是和它对应的domain实体类在同一个层级
   　　　　 ② 这个映射文件的名称一般叫做 XxxMapper.xml (Xxx代表的是实体类名称)
    　　　　③ namespace的名称为了确定唯一性，请大家根据我的要求取名
        　　　　如我们有一个类：
        　　　　cn.itsource.domain.Product / cn.itsource.domain.Student
       　　　　 那这里取名应该是：
        　　　　cn.itsource.domain.ProductMapper /cn.itsource.domain.StudentMapper
    　　　　④ 类型都通通使用全限定名

<?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的主要功能就是写sql
    mapper:根
    namespace:命令空间 (用来确定唯一性) 以前这个是可以不加的,现在必需加
     namespace的值，规则的：映射文件XxxMapper.xml所在的包+domain类名+Mapper
 -->
<mapper namespace="cn.wang.domain.ProductMapper">
    <!--
        select : 这里面写查询语句
        id:sql语句的标识，在同一个namespace下不能重复

        parameterType : 传入的参数类型(原本应该用的是全限定名，这里用的是别名)  long:大Long  _long:小long (具体的对应请参见文档)
        resultType : 返回的结果类型(每一条数据返回的对象类型) 自己的对象一定是全限定类名（这里写的是别名）
     -->
    <select id="findOne" parameterType="long" resultType="Product">
        select * from product where id=#{id}
    </select>
    <!--别名不区分大小写-->
    <select id="findAll" resultType="product">
        select * from product
    </select>

    <insert id="insert" parameterType="product" keyProperty="id" useGeneratedKeys="true">
        insert into product(productName,dir_id,salePrice,supplier,brand,cutoff,costPrice) VALUES (
          #{productName},
          #{dir_id},
          #{salePrice},
          #{supplier},
          #{brand},
          #{cutoff},
          #{costPrice}
        )
    </insert>

    <update id="update" parameterType="long">
        UPDATE product set productName=#{productName} where id=#{id}
    </update>

    <delete id="delete" parameterType="long">
        delete FROM product where id=#{id}
    </delete>
</mapper>

　　5.最后进行测试

public class MybatisTest {
    private IProductDao productDao=new ProductDaoImpl();

    @Test
    public void testFindOne(){
        Product product = productDao.findOne(1L);
        System.out.println(product);
    }

    @Test
    public void testFindAll(){
        List<Product> list = productDao.findAll();
        for (Product product : list) {
            System.out.println(product);
        }
    }

    @Test
    public void testInsert(){
        Product product = new Product();
        product.setProductName("大金刚");
        product.setDir_id(3L);
        product.setSalePrice(100.00);
        product.setSupplier("哈哈哈");
        product.setBrand("哇咔咔");
        product.setCutoff(0.66);
        product.setCostPrice(23.00);

        productDao.save(product);
        //获取新添加数据的主键，前提insert标签已经配置了那三个属性
        System.out.println(product.getId());
    }

    @Test
    public void testUpdate(){
       Product product = productDao.findOne(1L);
       product.setProductName("大罗金仙");
       productDao.update(product);
    }
    @Test
    public void testDelete(){

       productDao.delete(1L);
    }

}