使用Mybatis对数据库进行单表操作

本篇文章主要是结合我之前面试的各种经历和实战开发中遇到的问题解决经验整理的，希望这篇《使用Mybatis对数据库进行单表操作》对你有很大帮助！欢迎收藏，分享给更多的需要的朋友学习~

简介

该篇文章主要是介绍如何使用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" ?><configuration><environments default="e1"><environment id="e1"><transactionmanager type="JDBC"></transactionmanager><datasource type="POOLED"><property name="driver" value="com.mysql.cj.jdbc.Driver"></property><property name="url" value="jdbc:mysql://localhost:3306/bank?serverTimezone=CST"></property><property name="username" value="root"></property><property name="password" value="123456"></property></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" ?><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>&lt;select id=&quot;selectAll&quot; resulttype=&quot;domain.User&quot;&gt;
        SELECT *FROM atm;
    &lt;/select&gt;&lt;select id=&quot;getTotalCount&quot; resulttype=&quot;integer&quot;&gt;
        SELECT COUNT(*) FROM atm;
    &lt;/select&gt;&lt;select id=&quot;gettotal&quot; resulttype=&quot;hashmap&quot;&gt;
        select count(*),max(balance) from atm;
    &lt;/select&gt;&lt;select id=&quot;selectAllByAcc&quot; resulttype=&quot;domain.User&quot;&gt;
        SELECT *FROM atm order by ${flag} ${order};
    &lt;/select&gt;</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 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);
    }
}</string></user></user></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属性，获取返回值类型，通过反射创建对象，遍历结果集，将结果集包装成返回值类型的对象

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

今天带大家了解了MySQL、Java、mybatis、ide的相关知识，希望对你有所帮助；关于数据库的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~