MyBatis 源码学习笔记（一）- MyBatis概述

RiemannHypothesis

发布于 2022-08-19 08:04:10

24000

代码可运行

文章被收录于专栏：ElixirElixir

运行总次数：0

代码可运行

一、JDBC

使用JDBC访问数据库的步骤

定义数据库驱动以及连接信息
注册数据库驱动
获取数据库连接
创建一个查询
定义执行的SQL
执行SQL,获取ResultSet结果集
从结果集中取出数据
关闭连接

public class JdbcTest {
    // 1.定义数据库驱动以及连接信息
    private static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
    private static final String JDBC_URL = "jdbc:mysql://rm-uf67r962043910k193o.mysql.rds.aliyuncs.com:3306/test?useUnicode=true&characterEncoding=utf8&autoReconnect=true&useSSL=false&serverTimezone=Asia/Shanghai&allowMultiQueries=true";
    private static final String JDBC_USER = "root";
    private static final String JBDC_PASSWORD = "Abc*123456";

    public static void main(String[] args) {

        Connection connection = null;
        Statement statement = null;
        try {
            //2.注册数据库驱动
            Class.forName(JDBC_DRIVER);
            //3.获取数据库连接
            connection = DriverManager.getConnection(JDBC_URL,JDBC_USER,JBDC_PASSWORD);
            //4.创建一个查询
            statement = connection.createStatement();
            //5.定义执行的SQL
            String sql = "SELECT * FROM t_user";
            //6.执行SQL,获取ResultSet结果集
            ResultSet resultSet = statement.executeQuery(sql);
            //7.从结果集中取出数据
            List<User> userList = new ArrayList<>();
            while (resultSet.next()){
                User user = new User();
            user.setId(resultSet.getInt("id"));
            user.setUserName(resultSet.getString("user_name"));
                user.setRealName(resultSet.getString("real_name"));
                user.setSex(resultSet.getByte("sex"));
                user.setMobile(resultSet.getString("mobile"));
                user.setEmail(resultSet.getString("email"));
                user.setNote(resultSet.getString("note"));

                System.out.println(user.toString());

                userList.add(user);
            }

            // 8.关闭连接
            connection.close();
            statement.close();
            resultSet.close();
        } catch (Exception e){
            e.printStackTrace();
        } finally {
            try {
                if (statement != null)
                    statement.close();
            } catch (SQLException se2) {
            }// nothing we can do
            try {
                if (connection != null)
                    connection.close();
            } catch (SQLException se) {
                se.printStackTrace();
            }
        }

    }
}
复制代码

上述代码中使用Statement对象执行的查询，如果SQL语句中有参数占位符建议使用PreparedStatement对象来执行查询，PreparedStatement对象可以对SQL语句进行预编译，可以放置SQL注入；而且性能相对Statement会更好些。Jdbc针对数据库写操作需要对事务进行提交。

JDBC访问数据库存在的弊端：

操作数据库步骤繁琐
代码和SQL语句耦合
连接资源需要手动关闭，会有隐患

二、ORM

对象关系映射(ORM)，是一种程序技术，用于实现面向对象编程语言里不同类型系统的数据之间的转换

ORM的优势：

更加贴合面向对象编程语意
技术和业务解耦
自动关闭数据库连接，释放资源

HIBERNATE 🆚 MyBatis

MyBatis是一个半自动ORM框架，除了Entity实体类和数据库表的映射关系外，还需要在XML文件中编写SQL语句

MyBatis映射文件三要素:

Entity
映射规则
SQL

三、MyBatis Quickstart

创建Maven项目mybatis-quick-start，加入相关依赖

<dependencies>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.16</version>
    </dependency>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid</artifactId>
        <version>1.1.14</version>
    </dependency>
    <dependency>
        <groupId>ch.qos.logback</groupId>
        <artifactId>logback-classic</artifactId>
        <version>1.2.3</version>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <version>1.16.18</version>
        <scope>provided</scope>
    </dependency>
    <dependency>
        <groupId>org.mybatis</groupId>
        <artifactId>mybatis</artifactId>
        <version>3.5.7</version>
    </dependency>
    <dependency>
        <groupId>com.github.pagehelper</groupId>
        <artifactId>pagehelper</artifactId>
        <version>5.3.0</version>
    </dependency>
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.12</version>
        <scope>test</scope>
    </dependency>
</dependencies>
复制代码

在resource目录下创建mybatis-config配置文件

<?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 resource="db.properties" />

   <settings>
      <setting name="mapUnderscoreToCamelCase" value="true" />
   </settings>

   <!--配置environment环境 -->
   <environments default="development">
      <!-- 环境配置1，每个SqlSessionFactory对应一个环境 -->
      <environment id="development">
         <transactionManager type="JDBC" />
         <dataSource type="UNPOOLED">
            <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>
</configuration>  
复制代码

在resource目录下创建数据库连接信息的配置文件db.properties

jdbc_driver=com.mysql.cj.jdbc.Driver
jdbc_url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&autoReconnect=true&useSSL=false&serverTimezone=Asia/Shanghai
jdbc_username=root
jdbc_password=root
复制代码

在数据库创建t_user表，并插入一条数据，sql如下：

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for t_user
-- ----------------------------
DROP TABLE IF EXISTS `t_user`;
CREATE TABLE `t_user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `user_name` varchar(255) DEFAULT NULL,
  `real_name` varchar(255) DEFAULT NULL,
  `sex` varchar(255) DEFAULT NULL,
  `mobile` varchar(255) DEFAULT NULL,
  `email` varchar(255) DEFAULT NULL,
  `note` varchar(255) DEFAULT NULL,
  `position_id` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;

-- ----------------------------
-- Records of t_user
-- ----------------------------
BEGIN;
INSERT INTO `t_user` VALUES (1, 'Stark', 'Tony Stark', '1', NULL, NULL, NULL, NULL);
COMMIT;

SET FOREIGN_KEY_CHECKS = 1;
复制代码

MyBatis开发步骤：

编写Entity实体类 -> 编写Mapper接口 -> 编写对应Mapper.xml文件 -> 测试Mapper接口

在entity包下编写Entity实体类TUser

@Data
public class User {
    private Integer id;
    private String userName;
    private String realName;
    private Byte sex;
    private String mobile;
    private String email;
    private String note;
    private Integer positionId;
}    
复制代码

在mapper包下编写Mapper接口 TUserMapper，定义一个方法，根据主键查询

public interface TUserMapper {
    User selectByPrimaryKey(Integer id);
}
复制代码

在resource目录下创建mappers目录，新增TUserMapper.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.lilith.mapper.UserMapper">
   <select id="selectByPrimaryKey" resultType="com.lilith.entity.User" parameterType="int">
      select
         id, 
         user_name,
         real_name,
         sex, 
         mobile, 
         email, 
         note,
         position_id
      from t_user
      where id = #{id}
   </select>

</mapper>
复制代码

在mybatis-config.xml配置文件中增加Mapper XML文件映射配置，在configuration标签下增加mapper标签

<mappers>
   <mapper resource="mappers/UserMapper.xml"/>
</mappers>
复制代码

在test包中增加测试类UserMapperTest，测试selectByPrimaryKey()方法

public class UserMapperTest {

    private SqlSessionFactory sqlSessionFactory;

    @Before
    public void init() throws IOException {
        String resource = "mybatis-config.xml";
        InputStream inputStream = Resources.getResourceAsStream(resource);
        // 1.读取mybatis配置文件创SqlSessionFactory
        sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        inputStream.close();
    }

    @Test
    public void selectByPrimaryKey() throws IOException {
        // 2.获取sqlSession
        SqlSession sqlSession = sqlSessionFactory.openSession();
        // 3.获取对应mapper
        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
        // 4.执行查询语句并返回结果
        TUser user = mapper.selectByPrimaryKey(1);
        System.out.println(user);

    }
}
复制代码