关于java:使用Mybatis对数据库进行单表操作

51次阅读

共计 6207 个字符，预计需要花费 16 分钟才能阅读完成。

该篇文章次要是介绍如何应用 MyBatis 对 Mysql 数据库进行单表操作（对于 mybatis 的下载以及配置文件的作用和具体信息，我在上一篇文章中也曾经提到了），应用的环境如下：
JDK 版本：1.8
编译器：IDEA2019
JDBC 版本：8.0.18
mybatis 版本：3.5.3

首先须要有两个配置文件，一个是 configuration.xml 文件，配置的是连贯数据库的环境以及对于 mapper.xml 文件的映射，还有另一个文件就是 mapper.xml，这个文件次要是用来写 sql 语句的

configuration.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="e1">
        <environment id="e1">
            <transactionManager type="JDBC"></transactionManager>
            <dataSource type="POOLED">
                <property name="driver" value="com.mysql.cj.jdbc.Driver"/>
                <property name="url" value="jdbc:mysql://localhost:3306/bank?serverTimezone=CST"/>
                <property name="username" value="root"/>
                <property name="password" value="123456"/>
            </dataSource>
        </environment>
        <environment id="e2">
            <transactionManager type=""></transactionManager>
            <dataSource type=""></dataSource>
        </environment>
    </environments>
    <mappers>
        <mapper resource="mapper/UserMapper.xml"></mapper>
    </mappers>
</configuration>

mapper.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="dao.UserDao">
    <insert id="insert">
        INSERT ATM VALUES(#{account}, #{password}, #{balance})
    </insert>
    <update id="update">
        update atm set account=#{account},password=#{password},balance=#{balance} where account=#{account};
    </update>
    <delete id="delete">
        DELETE FROM ATM WHERE account=#{account};
    </delete>

    <select id="selectAll" resultType="domain.User">
        SELECT *FROM atm;
    </select>

    <select id="getTotalCount" resultType="integer">
        SELECT COUNT(*) FROM atm;
    </select>
    <select id="gettotal" resultType="hashmap">
        select count(*),max(balance) from atm;
    </select>


    <select id="selectAllByAcc" resultType="domain.User">
        SELECT *FROM atm order by ${flag} ${order};
    </select>
</mapper>

具体操作看如下代码，我对代码都进行了肯定的正文，并联合 mapper.xml 文件一起看

public class UserDao {

    // 减少一条记录，user 对象是我创立的实体类
        //mapper.xml 文件的 sql 语句如下：//update atm set account=#{account},password=#{password},balance=#{balance} where account=#{account};
        //#{key}中的 key 要和实体类 user 的属性名统一
        // 如果传递的是根本数据类型或者 String，且 #{key}只有一个，那么名字能够不统一
        // 如果传入的是 map 汇合，#{key}中的 key 要和 map 汇合里的 key 统一
    public void insert(User user){
        //MYBATIS 操作流程
        // 获取工厂 Builder 对象
        SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
        // 获取 configuration.xml 配置文件的输出流
        InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");
        //builder 依据 is 获取 SqlSessionFactory 工厂对象
        SqlSessionFactory factory = builder.build(is);
        // 获取 SqlSession 对象
        SqlSession sqlSession = factory.openSession();
        // 执行 sql 语句操作
            //insert 是在 mapper.xml 下，insert 标签的 id 名
            //user 是我要插入的数据（动静操作），替换掉 sql 语句的 #{}
        sqlSession.insert("insert", user);

        sqlSession.commit();}

    // 改：批改记录，user 是要批改的数据
        //mapper.xml 文件的 sql 语句如下：//update atm set account=#{account},password=#{password},balance=#{balance} where account=#{account};
    public void update(User user){
        //MYBATIS 操作流程
        // 获取工厂 Builder 对象
        SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
        // 获取 configuration.xml 配置文件的输出流
        InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");
        //builder 依据 is 获取 SqlSessionFactory 工厂对象
        SqlSessionFactory factory = builder.build(is);
        // 获取 SqlSession 对象
        SqlSession sqlSession = factory.openSession(true);
        // 执行 sql 语句操作
        sqlSession.update("update",user);
    }
    
    // 删除：依据 account 删除
    //mapper.xml 的 sql 语句如下：// DELETE FROM ATM WHERE account=#{account};
    public void delete(String account){
        //MYBATIS 操作流程
        // 获取工厂 Builder 对象
        SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
        // 获取 configuration.xml 配置文件的输出流
        InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");
        //builder 依据 is 获取 SqlSessionFactory 工厂对象
        SqlSessionFactory factory = builder.build(is);
        // 获取 SqlSession 对象
        SqlSession sqlSession = factory.openSession(true);
        // 执行 sql 语句操作
        sqlSession.update("delete",account);
    }
    
    
    //=============================== 查问 ====================================
    // 查问：查找记录总条数以及 balance 的最大值
    //sql 语句如下：select count(*),max(balance) from atm;
    //select 标签上的 resultType 示意的是返回值，指的是一条记录的类型，最初包裹成 list 汇合
        // 我这里用的 hashMap
    public List<Map<String, Object>> gettotal(){InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);
        SqlSession sqlSession = factory.openSession(true);
        return sqlSession.selectList("gettotal");
    }
    
    // 查问：获取总记录数
    //sql 语句：SELECT COUNT(*) FROM atm;
    //resultType 类型：integer
    public Integer getTotalCount(){InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);
        SqlSession sqlSession = factory.openSession(true);
        return sqlSession.selectOne("getTotalCount");
    }
    
    // 查问：获取表格的所有记录
    //sql 语句：SELECT *FROM atm;
    //resultType 类型：domain.User（如果是本人写的实体类，须要类名的具体门路，除非做了配置）public List<User> selectAll(){InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);
        SqlSession sqlSession = factory.openSession(true);
        return sqlSession.selectList("selectAll");
    }

    // 查问：查问所有该表所有记录，并依据 flag 列进行 order 排序
            //flag 不确定，order 可能是升序也可能是降序(由调用这个办法的用户决定)
    //sql 语句：SELECT *FROM atm order by ${flag} ${order};
        // 这里用的是 ${}而不是 #{}
        //#{}和 ${}的区别：//#{}: 当咱们的动静参数是用作条件的时候咱们用这个，比如说 account=#{key}
        //${}：当咱们的动静参数示意的是一个一般字符串，比如说表名、列名或者关键字咱们用这个
    //resultType：domain.User(domain 包下的 User 类）public List<User> selectAllByAcc(String flag, String order){InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);
        SqlSession sqlSession = factory.openSession(true);
        Map<String, Object> map = new HashMap<>();
        map.put("flag", flag);
        map.put("order", order);
        return sqlSession.selectList("selectAllByAcc", map);
    }
}

这里我简略提一下对于增删改查操作的底层原理，以查问操作为例，查问操作和增删改操作的次要区别在于 sql 语句的不同以及查问操作有返回值，所以底层还须要解决返回值
例如：sqlSession.selectOne(sql,obj)

1）首先，底层须要依据 configuration.xml，找到 mysql 的驱动类 driver，加载驱动
2）依据 configuration.xml 文件，找到连贯 MySQL 数据库的 url,user,password，获取连贯 Connection
3）参考 configuration.xml 配置文件，找到 mapper.xml 文件，从而找到 sql 语句，创立状态参数 PreparedStatement
4）解析 sql 语句，把 #{key}或者 ${key}转换成? 的模式，并记录 key 的名字，依据传递过去的 obj 匹配 key，如果传递过去的是 domain 实体对象，通过反射获取 domain 实体中的所有属性，依据属性名字去匹配 key，而后调用状态参数的 setObject 办法对? 进行复制（其余类型的对象也根本如此）
5）执行 SQL 操作，获取后果集
6）剖析 ResultType 属性，获取返回值类型，通过反射创建对象，遍历后果集，将后果集包装成返回值类型的对象

根本的流程大略就是这样，本篇文章次要是对单表操作进行介绍，下一篇文章会介绍如果是多表，该如何进行操作

正文完

发表至： java

2020-08-07

0

关于java:java-从基础到精通

JAVA实现word和excel转PDF

关于java:CRUD搬砖两三年了怎么阅读Spring源码

Spring-GetBean流程

关于java:无效的源发行版-11-和-无效的目标发行版11-解决方法

关于javascript:mxgraph学习参考文档