简介
该篇文章次要是介绍如何应用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属性，获取返回值类型，通过反射创建对象，遍历后果集，将后果集包装成返回值类型的对象
根本的流程大略就是这样，本篇文章次要是对单表操作进行介绍，下一篇文章会介绍如果是多表，该如何进行操作