溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
小編給大家分享一下使用Mybatis對數據庫進行單表操作的方法，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！
使用的環境如下：
配置文件
首先需要有兩個配置文件，一個是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屬性，獲取返回值類型，通過反射創建對象，遍歷結果集，將結果集包裝成返回值類型的對象
基本的流程大概就是這樣，本篇文章主要是對單表操作進行介紹，下一篇文章會介紹如果是多表，該如何進行操作
以上是使用Mybatis對數據庫進行單表操作的方法的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業資訊頻道！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
