MyBatis（一）入门

作者: guideEmotion | 来源:发表于2019-07-02 20:22 被阅读0次

一介绍

MyBatis是一个优秀的持久层框架，，它对jdbc的操作数据库的过程进行封装。

本质
Mybatis通过xml或注解的方式将要执行的各种statement（statement、preparedStatemnt、CallableStatement）配置起来，并通过java对象和statement中的sql进行映射生成最终执行的sql语句，最后由mybatis框架执行sql并将结果映射成java对象并返回。

二框架

image.png

mybatis配置

SqlMapConfig.xml，此文件作为mybatis的全局配置文件，配置了mybatis的运行环境等信息。
mapper.xml文件即sql映射文件，文件中配置了操作数据库的sql语句。此文件需要在SqlMapConfig.xml中加载。

SqlSessionFactory

通过mybatis环境等配置信息构造SqlSessionFactory即会话工厂
由会话工厂创建sqlSession即会话，操作数据库需要通过sqlSession进行。

Executor

mybatis底层自定义了Executor执行器接口操作数据库，Executor接口有两个实现，一个是基本执行器、一个是缓存执行器。

Mapped Statement

Mapped Statement也是mybatis一个底层封装对象，它包装了mybatis配置信息及sql映射信息等。mapper.xml文件中一个sql对应一个Mapped Statement对象，sql的id即是Mapped statement的id。
Mapped Statement对sql执行输入参数进行定义，包括HashMap、基本类型、pojo，Executor通过Mapped Statement在执行sql前将输入的java对象映射至sql中，输入参数映射就是jdbc编程中对preparedStatement设置参数。
Mapped Statement对sql执行输出结果进行定义，包括HashMap、基本类型、pojo，Executor通过Mapped Statement在执行sql后将输出结果映射至java对象中，输出结果映射过程相当于jdbc编程中对结果的解析处理过程

三实践

依赖

plugins {
    id 'java'
}

group 'com.zyc'
version '1.0-SNAPSHOT'

sourceCompatibility = 1.8

repositories {
    mavenCentral()
}

dependencies {
    testCompile group: 'junit', name: 'junit', version: '4.12'
    compile group: 'org.mybatis', name: 'mybatis', version: '3.4.6'
    compile group: 'mysql', name: 'mysql-connector-java', version: '5.1.46'
}

项目结构

SqlMapConfig

<?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>
    <!-- 和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://localhost:3306/mybatis1?characterEncoding=utf-8" />
                <property name="username" value="root" />
                <property name="password" value="123456" />
            </dataSource>
        </environment>
    </environments>
    <!-- 加载映射文件 -->
    <mappers>
        <mapper resource="com/zyc/mapping/User.xml"/>
    </mappers>
</configuration>

实体类

package com.zyc.entity;

import java.util.Date;

/**
 * @author zhuyc
 * @create 2019-06-30 20:55
 */
public class User {
    private Integer id;
    // 姓名
    private String username;
    // 性别
    private String sex;
    // 地址
    private String address;
    // 生日
    private Date birthday;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getSex() {
        return sex;
    }

    public void setSex(String sex) {
        this.sex = sex;
    }

    public String getAddress() {
        return address;
    }

    public void setAddress(String address) {
        this.address = address;
    }

    public Date getBirthday() {
        return birthday;
    }

    public void setBirthday(Date birthday) {
        this.birthday = birthday;
    }

    @Override
    public String toString() {
        return "User [id=" + id + ", username=" + username + ", sex=" + sex
                + ", address=" + address + ", birthday=" + birthday + "]";
    }
}

映射文件

<?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，namespace的值习惯上设置成包名+sql映射文件名，这样就能够保证namespace的值是唯一的
例如namespace="com.mybatis.mapping.User"就是com.mybatis.mapping(包名)+User(User.xml文件去除后缀)
 -->
<!-- namespace命名空间,作用就是对sql进行分类化的管理,理解为sql隔离
   注意:使用mapper代理开发时，namespace有特殊作用
-->
<mapper namespace="com.zyc.mapping.User">
    <!-- 在映射文件中配置很多sql语句 -->
    <!-- 需求：通过Id查询用户表的记录 -->
    <!-- 通过SELECT执行数据库查询
        id:标识映射文件中的sql，称为statement的id;
            将sql语句封装在mapperStatement的对象中，所以Id称为Statement的id;
        parameterType:指定输入参数的类型,这里指定int型
        #{}:表示一个占位符;
        #{id}:其中Id表示接收输入的参数，参数名称就是Id,如果输入参数是简单类型，#{}中的参数名可以任意，可以是value或者其它名称;
        resultType:指定sql输出结果所映射的java对象类型,select指定resultType表示将单条记录映射成java对象。
    -->
    <select id="findUserById" parameterType="int" resultType="com.zyc.entity.User">
        select username,DATE_FORMAT(birthday,'%Y-%m-%d')birthday,sex,address from t_user where id=#{id}
    </select>

    <!-- 根据用户名称模糊查询用户信息,可能返回多条数据
        resultType:指定的就是单条记录所映射的java类型;
        ${}:表示拼接sql字符串，将接收到的参数内容不加任何修饰拼接在sql中.
            使用${}拼接sql，可能会引起sql注入
        ${value}:接收输入参数的内容，如果传入的是简单类型,${}中只能使用value
     -->
    <select id="findUserByName" parameterType="java.lang.String" resultType="com.zyc.entity.User" >
        select * from t_user where username LIKE '%${value}%'
    </select>

    <!-- 查询所有用户 -->
    <select id="getUserList" resultType="com.zyc.entity.User">
        select username,birthday,sex,address from t_user
    </select>

    <!-- 添加用户
      parameterType:指定输入的参数类型是pojo(包括用户信息);
      #{}中指定pojo的属性名称，接收到pojo对象的属性值    ,mybatis通过OGNL(类似struts2的OGNL)获取对象的属性值
    -->
    <insert id="insertUser" parameterType="com.zyc.entity.User">
        <!--
               将insert插入的数据的主键返回到User对象中;
            select last_insert_id():得到刚insert进去记录的主键值，只适用于自增主键;
            keyProperty:将查询到的主键值，设置到parameterType指定的对象的那个属性
            order:select last_insert_id()执行顺序，相对于insert语句来说它的执行顺序。
            resultType:指定select last_insert_id()的结果类型;
        -->
        <selectKey keyProperty="id" order="AFTER" resultType="java.lang.Integer">
            select last_insert_id()
        </selectKey>
        <!--
             使用mysql的uuid()，实现非自增主键的返回。
             执行过程:通过uuid()得到主键，将主键设置到user对象的Id的属性中，其次，在insert执行时，从user对象中取出Id属性值;
           <selectKey keyProperty="id" order="BEFORE" resultType="java.lang.String">
               select uuid()
           </selectKey>
           insert into t_user (id,username,birthday,sex,address) values(#{id},#{username},#{birthday},#{sex},#{address})
        -->
        insert into t_user(username,birthday,sex,address) values(#{username},#{birthday},#{sex},#{address})
    </insert>

    <!-- 更新用户
        需要传入用户的Id和用户的更新信息
        parameterType:指定User对象，包括Id和用户的更新信息,注意：Id是必须存在的
        #{id}:从输入的User对象中获取Id的属性值
    -->
    <update id="updateUser" parameterType="com.zyc.entity.User">
        update t_user set username=#{username},birthday=#{birthday},sex=#{sex},address=#{address}
        where id=#{id}
    </update>

    <!-- 删除用户
        根据ID删除用户,需要输入Id值
    -->
    <delete id="deleteUser" parameterType="java.lang.Integer">
        delete from t_user where id=#{id}
    </delete>
</mapper>

数据库配置

CREATE TABLE t_user (
  id INT NOT NULL AUTO_INCREMENT PRIMARY KEY,
  username VARCHAR(30) NOT NULL COMMENT '用户名称',
  birthday DATE DEFAULT NULL COMMENT '生日',
  sex CHAR(2) DEFAULT NULL COMMENT '性别',
  address VARCHAR(256) DEFAULT NULL COMMENT '地址'
);
INSERT INTO t_user (username,birthday,sex,address)
                                VALUES
                   ('小A','2015-06-27','2','北京'),
                   ('小B','2015-06-27','2','北京'),
                   ('小C','2015-06-27','1','北京'),
                   ('小D','2015-06-27','2','北京');

测试代码

public class Test1 {

    private SqlSession sqlSession = null;

    private String resource = "SqlMapConfig.xml";

    private InputStream inputStream = null;

    @Before
    public void befor() {
        // mybatis的配置文件
        try {
            inputStream = Resources.getResourceAsStream(resource);
            // 1.创建会话工场,传入mybatis的配置文件信息
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);

            // 2.通过工厂得到SqlSession
            sqlSession = sqlSessionFactory.openSession();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @After
    public void after() {
        if (sqlSession != null) {
            sqlSession.close();
        }
        if (inputStream != null) {
            try {
                inputStream.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }


    // 根据Id查询用户信息，得到一条记录结果
    @Test
    public void findUserByIdTest() {
        // 3.通过sqlSession操作数据库
        // 第一个参数：映射文件中的statement的Id,等于namespace + "." + statement的id;
        // 第二个参数:指定和映射文件中所匹配的parameterType类型的参数;
        // sqlSession.selectOne结果是与映射文件所匹配的resultType类型的对象;
        // selectOne：查询一条结果
        User user = sqlSession.selectOne("com.zyc.mapping.User.findUserById", 1);
        System.out.println(user.toString());
    }

    // 根据姓名模糊查询用户信息，得到一条或多条记录结果
    @Test
    public void findUserByNameTest() {
        // 3.通过sqlSession操作数据库
        // 第一个参数：映射文件中的statement的Id,等于namespace + "." + statement的id;
        // 第二个参数:指定和映射文件中所匹配的parameterType类型的参数;
        // sqlSession.selectList结果是与映射文件所匹配的resultType类型的对象;
        // list中的user和resultType类型一致
        List<User> list = sqlSession.selectList("com.zyc.mapping.User.findUserByName","小");
        System.out.println(list);
    }

    // 添加用户
    @Test
    public void insertUserTest(){
        User user = new User();
        user.setUsername("小红");
        user.setSex("1");
        user.setBirthday(new Date());
        user.setAddress("北京");
        // 3.通过sqlSession操作数据库
        // 第一个参数：映射文件中的statement的Id,等于namespace + "." + statement的id;
        // 第二个参数:指定和映射文件中所匹配的parameterType类型的参数;
        sqlSession.insert("com.zyc.mapping.User.insertUser",user);
        sqlSession.commit();//没有事务不会添加到数据库
        System.out.println(user.getId());
    }

    // 根据Id更新用户信息
    @Test
    public void updateUserTest(){
        //更新用户的信息
        User user = new User();
        user.setId(2);
        user.setUsername("小黑");
        user.setSex("2");
        user.setBirthday(new Date());
        user.setAddress("上海");
        // 3.通过sqlSession操作数据库
        // 第一个参数：映射文件中的statement的Id,等于namespace + "." + statement的id;
        // 第二个参数:指定和映射文件中所匹配的parameterType类型的参数;
        sqlSession.update("com.zyc.mapping.User.updateUser",user);
        // 执行提交事务
        sqlSession.commit();
    }

    // 根据Id删除用户
    @Test
    public void deleteUserTest(){
        sqlSession.delete("com.zyc.mapping.User.deleteUser",1);
        // 执行提交事务
        sqlSession.commit();
    }


}

参考

Mybatis学习总结（一）——入门基础

MyBatis（一）入门

一介绍

二框架

mybatis配置

SqlSessionFactory

Executor

Mapped Statement

三实践

依赖

项目结构

SqlMapConfig

实体类

映射文件

数据库配置

测试代码

参考

相关文章

网友评论

延伸阅读

深度阅读

栏目导航

热点阅读

工作生活

MyBatis（一）入门

一 介绍

二 框架

mybatis配置

SqlSessionFactory

Executor

Mapped Statement

三 实践

依赖

项目结构

SqlMapConfig

实体类

映射文件

数据库配置

测试代码

参考

相关文章

网友评论

延伸阅读

深度阅读

栏目导航

热点阅读

工作生活

一介绍

二框架

三实践