如何使用 Mybatis 實現(xiàn)數(shù)據(jù)庫 CURD 操作?(mybatis cursor)
作者 | 阿文,責編 | 郭芮
頭圖 | CSDN 下載自東方IC
出品 | CSDN(ID:CSDNnews)
MyBatis 是一款優(yōu)秀的持久層框架,它支持自定義 SQL、存儲過程以及高級映射。MyBatis 免除了幾乎所有的 JDBC 代碼以及設置參數(shù)和獲取結果集的工作。MyBatis 可以通過簡單的 XML 或注解來配置和映射原始類型、接口和 Java POJO(Plain Old Java Objects,普通老式 Java 對象)為數(shù)據(jù)庫中的記錄。
在傳統(tǒng)的JDBC 實現(xiàn)中,我們需要把查詢過程寫在java 類中,這樣非常不便于后期維護,而使用mybatis 則可以將查詢語句配置在配置文件中,只需要維護好映射關系即可, 下面我們就來一起看雪如何去使用Mybatis吧。
準備工作
首先,你需要準備以下軟件:
- idea
- maven
- mysql
創(chuàng)建數(shù)據(jù)庫并插入數(shù)據(jù)
首先,我們創(chuàng)建一個mybatis_db 的數(shù)據(jù)庫,然后創(chuàng)建一個表 t_user,在這個表中我們插入幾條數(shù)據(jù),如下所示:
mysql> create database mybatis_db;Query OK, 1 row affected (0.01 sec)mysql> use mybatis_db;Database changedmysql> create table t_user(-> id int(32) primary key auto_increment,-> username varchar(50),-> jobs varchar(50),-> phone varchar(16));Query OK, 0 rows affected, 1 warning (0.01 sec)mysql> insert into t_user values(1,”zhangsan”,”teacher”,”13142767333″);Query OK, 1 row affected (0.01 sec)mysql> insert into t_user values(2,”lisi”,”engineer”,”13142767334″);Query OK, 1 row affected (0.01 sec)mysql> insert into t_user values(3,”wangwu”,”pilot”,”12342767334″);Query OK, 1 row affected (0.00 sec)mysql>
配置pom.xml 下載jar包
我們創(chuàng)建一個maven工程,并配置pom.xml 下載mybatis 和mysql-connect-java 的jar包,目前mybatis 的最新版本是3.5.4。
<dependency><groupId>org.mybatis</groupId><artifactId>mybatis</artifactId><version>3.5.4</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.19</version></dependency>
整個工程的目錄如下:
配置mybatis-config
接下來,我們在 idea 的resource 中創(chuàng)建一個mybatis-config.xml 的配置文件(如果沒有你需要在srcmain目錄點擊右鍵創(chuàng)建一個目錄,創(chuàng)建的時候選擇resource即可),內容如下,具體不需要過多解釋,該配置文件主要是定義JDBC相關的參數(shù)包括使用的驅動、mysql 訪問地址、用戶名和密碼以及通過mappers 定義一個mybatis 的映射文件。
<?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=”mysql”><environment id=”mysql”><transactionManager type=”JDBC” /><dataSource type=”POOLED”><property name=”driver” value=”com.mysql.jdbc.Driver” /><property name=”url” value=”jdbc:mysql://192.168.10.128:3306/mybatis_db” /><property name=”username” value=”root” /><property name=”password” value=”123456″ /></dataSource></environment></environments><mappers><mapper resource=”UserMapper.xml” /></mappers></configuration>
創(chuàng)建user類
接下里我們創(chuàng)建對于的User類,并生成get和set以及toString 方法,在idea 中,我們在IDE中右鍵選擇Generate 然后選擇Getter 和Setter 以及toString 全選即可快速生成對應的get和set方法。
最終結果如下:
package com.mybatis;public class User {private Integer id;private String username;private String jobs;private String phone;public Integer getId {return id;}public String getUsername {return username;}public String getJobs {return jobs;}public String getPhone {return phone;}public void setId(Integer id) {this.id = id;}public void setUsername(String username) {this.username = username;}public void setJobs(String jobs) {this.jobs = jobs;}public void setPhone(String phone) {this.phone = phone;}@Overridepublic String toString {return “User{” “id=” id “, username='” username ”’ “, jobs='” jobs ”’ “, phone='” phone ”’ ‘}’;}}
創(chuàng)建測試類
配置UserMapper.xml
接下里,我們創(chuàng)建映射文件UserMapper.xml 然后需要制定一個namespace就是 UserMapper,接著寫一個select 語句,定義id和參數(shù)類型以及resultType,resultMap是指描述如何從數(shù)據(jù)庫結果集中加載對象,是最復雜也是最強大的元素。
<?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=”UserMapper”><!–根據(jù)用戶編號獲取用戶信息 –><select id=”findUserById” parameterType=”Integer” resultType=”com.mybatis.User”>select * from t_user where id=#{id}</select></mapper>
然后我們創(chuàng)建一個測試類,根據(jù)id來查詢用戶:
package com.mybatis;import java.io.InputStream;import org.apache.ibatis.io.Resources;import org.apache.ibatis.session.SqlSession;import org.apache.ibatis.session.SqlSessionFactory;import org.apache.ibatis.session.SqlSessionFactorybuilder;import org.junit.jupiter.api.Test;/*** @Auth: xxxx* @E-mail: xxx* @title: MybatisTest* @projectName: mybatis* @description: TODO 描述信息* @Date 2020/4/7 9:15 下午**/public class MybatisTest {@Testpublic void findUserByIdTest throws Exception {String resource = “mybatis-config.xml”;InputStream inputStream = Resources.getResourceAsStream(resource);SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder.build(inputStream);SqlSession sqlSession = sqlSessionFactory.openSession;User user = sqlSession.selectOne(“findUserById”, 1);System.out.println(user.toString);sqlSession.close;}}
如果我們希望進行模糊查詢,則在UserMapper.xml 中定義:
<select id=”findUserByName” parameterType=”String” resultType=”com.mybatisdemo.User”>select * from t_user where username like concat(‘%’,’${value}’,’%’)</select>
使用like concat(‘%’,’${value}’,’%’) 是為了防止sql 注入帶來的安全隱患。
然后在測試類中新建一個方法進行測試:
@Testpublic void findUserByNameTest throws Exception {String resource = “mybatis-config.xml”;InputStream inputStream = Resources.getResourceAsStream(resource);SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder.build(inputStream);SqlSession sqlSession = sqlSessionFactory.openSession;List<User> users = sqlSession.selectList(“findUserByName”,”g”);for (User user:users){System.out.println(user.toString);}sqlSession.close;}
如圖所示:
接下來我們測試下添加新用戶,首先我們在UserMapper.xml 中定義一個insert元素:
<insert id=”addUser” parameterType=”com.mybatisdemo.User” >insert into t_user(username,jobs,phone) value (#{username},#{jobs},#{phone})</insert>
然后來寫測試接口:
@Testpublic void addUser throws Exception {String resource = “mybatis-config.xml”;InputStream inputStream = Resources.getResourceAsStream(resource);SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder.build(inputStream);SqlSession sqlSession = sqlSessionFactory.openSession;User user = new User;user.setUsername(“beiluo”);user.setJobs(“DevOps”);user.setPhone(“1314566666”);int rows = sqlSession.insert(“addUser”,user);if (rows >0){System.out.println(“Success add ” rows “data!”);}else{System.out.println(“add data fail!”);}sqlSession.commit;sqlSession.close;}
如下所示:
接下來測試更新:
<update id=”updateUserInfo” parameterType=”com.mybatisdemo.User”>update t_user set username=#{username},jobs=#{jobs},phone=#{phone} where id =#{id}</update>
然后寫個測試類:
@Testpublic void updateUserinfo throws Exception {String resource = “mybatis-config.xml”;InputStream inputStream = Resources.getResourceAsStream(resource);SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder.build(inputStream);SqlSession sqlSession = sqlSessionFactory.openSession;User user = new User;user.setId(1);user.setUsername(“jike”);user.setJobs(“qa”);user.setPhone(“13142764432”);int rows = sqlSession.update(“updateUserInfo”,user);if (rows >0){System.out.println(“Success update ” rows ” data!”);}else{System.out.println(“update data fail!”);}sqlSession.commit;sqlSession.close;}
執(zhí)行后如下所示:
最后,我們測試下刪除功能:
<delete id=”deleteUser” parameterType=”com.mybatisdemo.User” >delete from t_user where id=#{id}</delete>
測試類如下:
@Testpublic void deleteUser throws Exception {String resource = “mybatis-config.xml”;InputStream inputStream = Resources.getResourceAsStream(resource);SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder.build(inputStream);SqlSession sqlSession = sqlSessionFactory.openSession;int rows = sqlSession.delete(“deleteUser”,1);if (rows >0){System.out.println(“Success delete ” rows ” data!”);}else{System.out.println(“delete data fail!”);}sqlSession.commit;sqlSession.close;}
執(zhí)行結果如下:
?拿下 Gartner 容器產品第一,阿里云打贏云原生關鍵一戰(zhàn)!
?騰訊面試官這樣問我二叉樹,我剛好都會 | 原力計劃
?斬獲GitHub 2000 Star,阿里云開源的 Alink 機器學習平臺如何跑贏雙11數(shù)據(jù)“博弈”?| AI 技術生態(tài)論
?微軟為一人收購一公司?破解索尼程序、寫黑客小說,看他彪悍的程序人生!
?機器學習項目模板:ML項目的6個基本步驟
?IBM、微軟、蘋果、谷歌、三星……這些區(qū)塊鏈中的科技巨頭原來已經(jīng)做了這么多事!
?資深程序員總結:分析Linux進程的6個方法,我全都告訴你今日福利:評論區(qū)留言入選,可獲得價值299元的「2020 AI開發(fā)者萬人大會」在線