簡介

該篇文章主要是介紹如何使用MyBatis對Mysql數(shù)據(jù)庫進行單表操作（對于mybatis的下載以及配置文件的作用和具體信息，我在上一篇文章中也已經(jīng)提到了），使用的環(huán)境如下：

配置文件

首先需要有兩個配置文件，一個是configuration.xml文件，配置的是連接數(shù)據(jù)庫的環(huán)境以及對于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 resultType='domain.User'> SELECT *FROM atm; </select> <select resultType='integer'> SELECT COUNT(*) FROM atm; </select> <select resultType='hashmap'> select count(*),max(balance) from atm; </select> <select resultType='domain.User'> SELECT *FROM atm order by ${flag} ${order}; </select></mapper>

具體操作

具體操作看如下代碼，我對代碼都進行了一定的注釋，并結(jié)合mapper.xml文件一起看

public class UserDao { //增加一條記錄，user對象是我創(chuàng)建的實體類 //mapper.xml文件的sql語句如下： //update atm set account=#{account},password=#{password},balance=#{balance} where account=#{account}; //#{key}中的key要和實體類user的屬性名一致 //如果傳遞的是基本數(shù)據(jù)類型或者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根據(jù)is獲取SqlSessionFactory工廠對象 SqlSessionFactory factory = builder.build(is); //獲取SqlSession對象 SqlSession sqlSession = factory.openSession(); //執(zhí)行sql語句操作 //insert是在mapper.xml下，insert標(biāo)簽的id名 //user是我要插入的數(shù)據(jù)（動態(tài)操作），替換掉sql語句的#{} sqlSession.insert('insert', user); sqlSession.commit(); } //改：修改記錄，user是要修改的數(shù)據(jù) //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根據(jù)is獲取SqlSessionFactory工廠對象 SqlSessionFactory factory = builder.build(is); //獲取SqlSession對象 SqlSession sqlSession = factory.openSession(true); //執(zhí)行sql語句操作 sqlSession.update('update',user); } //刪除：根據(jù)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根據(jù)is獲取SqlSessionFactory工廠對象 SqlSessionFactory factory = builder.build(is); //獲取SqlSession對象 SqlSession sqlSession = factory.openSession(true); //執(zhí)行sql語句操作 sqlSession.update('delete',account); } //===============================查詢==================================== //查詢：查找記錄總條數(shù)以及balance的最大值 //sql語句如下：select count(*),max(balance) from atm; //select標(biāo)簽上的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'); } //查詢：獲取總記錄數(shù) //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'); } //查詢：查詢所有該表所有記錄，并根據(jù)flag列進行order排序 //flag不確定，order可能是升序也可能是降序(由調(diào)用這個方法的用戶決定) //sql語句： SELECT *FROM atm order by ${flag} ${order}; //這里用的是${}而不是#{} //#{}和${}的區(qū)別： //#{}:當(dāng)我們的動態(tài)參數(shù)是用作條件的時候我們用這個，比如說account=#{key} //${}：當(dāng)我們的動態(tài)參數(shù)表示的是一個普通字符串，比如說表名、列名或者關(guān)鍵字我們用這個 //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); }}

關(guān)于單表操作的底層原理

這里我簡單提一下關(guān)于增刪改查操作的底層原理，以查詢操作為例，查詢操作和增刪改操作的主要區(qū)別在于sql語句的不同以及查詢操作有返回值，所以底層還需要處理返回值

例如：sqlSession.selectOne(sql,obj)

1）首先，底層需要根據(jù)configuration.xml，找到mysql的驅(qū)動類driver，加載驅(qū)動2）根據(jù)configuration.xml文件，找到連接MySQL數(shù)據(jù)庫的url,user,password，獲取連接Connection3）參考configuration.xml配置文件，找到mapper.xml文件，從而找到sql語句，創(chuàng)建狀態(tài)參數(shù)PreparedStatement4）解析sql語句，把#{key}或者${key}轉(zhuǎn)換成?的形式，并記錄key的名字，根據(jù)傳遞過來的obj匹配key，如果傳遞過來的是domain實體對象，通過反射獲取domain實體中的所有屬性，根據(jù)屬性名字去匹配key，然后調(diào)用狀態(tài)參數(shù)的setObject方法對?進行復(fù)制（其他類型的對象也基本如此）5）執(zhí)行SQL操作，獲取結(jié)果集6）分析ResultType屬性，獲取返回值類型，通過反射創(chuàng)建對象，遍歷結(jié)果集，將結(jié)果集包裝成返回值類型的對象基本的流程大概就是這樣，本篇文章主要是對單表操作進行介紹，下一篇文章會介紹如果是多表，該如何進行操作

到此這篇關(guān)于使用Mybatis對數(shù)據(jù)庫進行單表操作的實現(xiàn)示例的文章就介紹到這了,更多相關(guān)Mybatis 數(shù)據(jù)庫單表操作內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！