Mybatis的簡單增刪改查
- 2021 年 5 月 6 日
- 筆記
剛開始學習Mybatis可以先看下官方文檔，MyBatis是支持定製化SQL、存儲過程以及高級映射的優秀的持久層框架。MyBatis避免了幾乎所有的JDBC代碼和手工設置參數以及抽取結果集。MyBatis使用簡單的XML或註解來配置和映射基本體，將接口和Java的POJOs(Plain Old Java Objects,普通的Java對象)映射成數據庫中的記錄。
下面進入正題：
工具：Navicat premium 、IntelliJ IDEA
簡單的目錄結構
1.創建mysql數據庫
創建一個firend_mq數據庫，建立一張表為 users ，並插入一些數據
2.新建一個maven項目，並導入依賴
<dependencies>
<!-- //mvnrepository.com/artifact/org.mybatis/mybatis -->
<!--添加mybatis依賴-->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.4.6</version>
</dependency>
<!--jdbc驅動-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.47</version>
</dependency>
<!--junit測試類-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
</dependencies>
3.在resources文件夾下新建mybatis-config.xml，編寫mybaits的核心配置文件
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"//mybatis.org/dtd/mybatis-3-config.dtd">
<!-- configuration核心配置文件-->
<configuration>
<environments default="development">
<environment id="development">
<transactionManager type="JDBC"/>
<dataSource type="POOLED">
<property name="driver" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost:3306/firend_mq?useSSL=false&useUnicode=&characterEncodeing=UTF-8"/>
<property name="username" value="root"/>
<property name="password" value="root"/>
</dataSource>
</environment>
</environments>
<!-- 註冊mapper-->
<mappers>
<mapper resource="dao/UserMapper.xml"/>
</mappers>
</configuration>
注意點：resource綁定mapper，需要使用路徑，使用”/”
連接mysql數據庫的時候可能會出現時區的問題，可以看這篇博客
idea連接mysql時區問題解決方案（永久）
4.編寫mybatis工具類
//SqlSessionFactory
public class Mybatisutil {
private static SqlSessionFactory sqlSessionFactory;
static {
try {//使用mybaatis第一步獲取SqlSessionFactory對象
String resource="mybatis-config.xml";
InputStream inputStream= Resources.getResourceAsStream(resource);
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
} catch (IOException e) {
e.printStackTrace();
}
}
//有了 SqlSessionFactory，顧名思義，我們可以從中獲得 SqlSession 的實例。SqlSession
// 提供了在數據庫執行 SQL 命令所需的所有方法。你可以通過 SqlSession 實例來直接執行已映射的 SQL 語句
public static SqlSession getSqlSession(){
SqlSession sqlSession = sqlSessionFactory.openSession();
return sqlSession;
}
}
5.編寫mybatis實體類
package pojo;
public class User {
private int id;
private String username;
private String password;
public User(int id, String username, String password) {
this.id = id;
this.username = username;
this.password = password;
}
public User() {
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
@Override
public String toString() {
return "User{" +
"id=" + id +
", username='" + username + '\'' +
", password='" + password + '\'' +
'}';
}
}
前期的準備工作已完畢，開始編寫代碼
6.編寫Dao層的接口
public interface UserDao {
//查詢所有用戶
List<User> getUserList();
//查詢指定id用戶
User getUserById(int id);
//添加一個用戶
int addUser(User user);
//修改用戶
int updateUser(User user);
//刪除一個用戶
int deleteUser(int id);
}
7.編寫接口實現類
接口實現類由原來的UserDaoImpl轉變為Mapper配置文件夾
<!--namespace=綁定一個對應的Dao/Mapper接口-->
<mapper namespace="dao.UserDao">
<!-- select查詢語句 -->
<select id="getUserList" resultType="pojo.User">
select * from firend_mq.users
</select>
<!-- 根據id查詢-->
<select id="getUserById" parameterType="int" resultType="pojo.User">
select * from firend_mq.users where id = #{id}
</select>
<!-- 添加一個用戶 對象中的屬性，可以直接取出去-->
<insert id="addUser" parameterType="pojo.User">
insert into firend_mq.users (id,username,password) value (#{id},#{username},#{password})
</insert>
<update id="updateUser" parameterType="pojo.User">
update firend_mq.users set username=#{username},password=#{password} where id=#{id};
</update>
<!-- 刪除一個用戶-->
<delete id="deleteUser" parameterType="int">
delete from firend_mq.users where id=#{id}
</delete>
</mapper>
注意點：
- Mapper配置文件一定要在mybatis-config.xml裏面註冊
- 標籤就是增刪改查的類型，在標籤裏面書寫原來的sql語句，使用#{}進行傳值
- namespace=綁定一個對應的Dao/Mapper接口，不要綁定錯誤的接口
- id就是接口裏面的方法名，要一致
- parameterType是方法的參數類型，resultType是方法的返回值類型要對應接口。
8.編寫測試類
public class UserDaoText {
//查詢所有用戶
@Test
public void getUserList(){
//第一步：獲得sqlSession對象
SqlSession sqlSession = Mybatisutil.getSqlSession();
//方式一：getMapper
UserDao mapper = sqlSession.getMapper(UserDao.class);
List<User> userList = mapper.getUserList();
for (User user : userList) {
System.out.println(user);
}
sqlSession.close();
}
// 查詢指定id用戶
@Test
public void getUserById(){
SqlSession sqlSession = Mybatisutil.getSqlSession();
UserDao mapper = sqlSession.getMapper(UserDao.class);
User user = mapper.getUserById(2);
System.out.println(user);
sqlSession.close();
}
//所有的增刪改都要提交事務
//添加一個用戶
@Test
public void addUser(){
SqlSession sqlSession = Mybatisutil.getSqlSession();
UserDao mapper = sqlSession.getMapper(UserDao.class);
mapper.addUser(new User(4,"張三","10086"));
//提交事務
sqlSession.commit();
sqlSession.close();
}
@Test
public void updateUser(){
SqlSession sqlSession = Mybatisutil.getSqlSession();
UserDao mapper = sqlSession.getMapper(UserDao.class);
mapper.updateUser(new User(4,"哈哈","123"));
sqlSession.commit();
sqlSession.close();
}
@Test
public void deleteUser(){
SqlSession sqlSession = Mybatisutil.getSqlSession();
UserDao mapper = sqlSession.getMapper(UserDao.class);
mapper.deleteUser(4);
sqlSession.commit();
sqlSession.close();
}
}
這樣一個簡單Mybatis的增刪改查就寫完了，細節都在代碼中由注釋。
