前言
在上一篇文章中,我们讨论了持久化的概念,并简要介绍了 MyBatis。今天我们将深入到 MyBatis 的实际应用中,通过创建一个入门实例来展示如何使用 MyBatis 执行基本的 CRUD(创建、读取、更新、删除)操作。这个过程将帮助我们理解 MyBatis 在数据持久化方面的实际应用和优势。如果你对如何开始使用 MyBatis 或如何通过它进行数据库操作感兴趣,请继续关注我们的教程。
数据库准备
- 首先,我们来创建一个数据库,用于后序步骤的使用;
CREATE DATABASE test;
USE test;
- 接着创建一个表,用于存放数据;
CREATE TABLE user (
id int(20) NOT NULL AUTO_INCREMENT,
name varchar(30) DEFAULT NULL,
password varchar(30) DEFAULT NULL,
PRIMARY KEY (id)
);
- 向数据库中插入数据
INSERT INTO user (id, name, password) VALUES (1, '村雨遥', '123456'),(2, '张三', '1234567'),(3, '李四', '12345678');
创建 Maven 工程
- 对于如何创建 Maven 工程,可以参照我之前写的一篇文章:利用 IDEA 搭建一个 Maven 项目
- 接着在项目的
pom.xml
中添加 MyBatis、MySQL、Junit 以及 Lombok 的依赖,关于更多 Lombok 的使用,可以参考我的另一篇文章:Lombok 安装及使用指南
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.5.9</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.25</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.13</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.22</version>
<scope>provided</scope>
</dependency>
准备工作
- 编写 MyBatis 核心配置文件,在
main/resources
文件下新建mybatis-config.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="development">
<environment id="development">
<transactionManager type="JDBC"/>
<dataSource type="POOLED">
<property name="driver" value="com.mysql.cj.jdbc.Driver"/>
<property name="url"
value="jdbc:mysql://localhost:3306/learndb?characterEncoding=utf8"/>
<property name="username" value="root"/>
<property name="password" value="cunyu1943"/>
</dataSource>
</environment>
</environments>
<!-- 引入映射文件 -->
<mappers>
<mapper resource="mappers/UserMapper.xml"/>
</mappers>
</configuration>
- 编写 MyBatis 工具类;
package com.cunyu.util;
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 java.io.IOException;
import java.io.InputStream;
/**
* Created with IntelliJ IDEA.
*
* @Package : com.cunyu.util
* @ClassName : MybatisUtil.java
* @Description : MyBatis 工具类
*/
public class MybatisUtil {
private static SqlSessionFactory sqlSessionFactory;
static {
try {
String resourceName = "mybatis-config.xml";
InputStream inputStream = Resources.getResourceAsStream(resourceName);
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* @param
* @return
*/
public static SqlSession getSqlSession(){
return sqlSessionFactory.openSession();
}
}
- 接下来创建实体类,用于映射数据库中的
user
表。
package com.cunyu.entity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* Created with IntelliJ IDEA.
*
* @Version : 1.0
* @Package : com.cunyu.entity
* @ClassName : User.java
* @Description :
*/
@AllArgsConstructor
@NoArgsConstructor
@Data
public class User {
private Integer id;
private String name;
private String password;
}
插入操作 insert
- 首先在
UserMapper
接口中添加对应方法
/**
* @param user
* @return
*/
int insert(User user);
- 在映射文件
UserMapper.xml
中添加Insert
语句;
<?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">
<!--绑定对应Dao/Mapper接口-->
<mapper namespace="com.cunyu.mapper.UserMapper">
<insert id="insert" parameterType="com.cunyu.entity.User">
INSERT INTO user(id, name, password)
VALUES (#{id}, #{name}, #{password})
</insert>
</mapper>
- 测试方法中测试;
package com.cunyu.test;
import com.cunyu.entity.User;
import com.cunyu.mapper.UserMapper;
import com.cunyu.util.MybatisUtil;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;
/**
* Created with IntelliJ IDEA.
*
* @Package : com.cunyu.test
* @ClassName : InsertTest.java
* @Description :
*/
public class InsertTest {
@Test
public void testInsert() {
// 获取 SqlSession 对象
SqlSession sqlSession = MybatisUtil.getSqlSession();
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
User user = new User(5, "小雨", "6543210");
int i = mapper.insert(user);
System.out.println(i);
// 提交事务到数据库
sqlSession.commit();
System.out.println("添加用户成功");
// 关闭 SqlSession
sqlSession.close();
}
}
查询操作 select
- 在
UserMapper
中添加对应方法:
/**
* @param
* @return 对应 id 的用户
*/
User query(Integer id);
- 接着在
UserMapper.xml
中添加Select
语句。其中各属性含义如下:
- id:对应接口中的 方法名;
- resultType:SQL 语句执行的返回值;
<select id="query" resultType="com.cunyu.entity.User">
SELECT *
FROM user
WHERE id = #{id}
</select>
- 在测试类中测试即可;
package com.cunyu.test;
import com.cunyu.entity.User;
import com.cunyu.mapper.UserMapper;
import com.cunyu.util.MybatisUtil;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;
/**
* Created with IntelliJ IDEA.
*
* @Package : com.cunyu.test
* @ClassName : QueryTest.java
* @Description :
*/
public class QueryTest {
@Test
public void testQuery() {
// 获取 SqlSession 对象
SqlSession sqlSession = MybatisUtil.getSqlSession();
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
User user = mapper.query(1);
System.out.println(user);
System.out.println("查询用户成功");
// 关闭 SqlSession
sqlSession.close();
}
}
修改操作 update
- 在
UserMapper
添加对应接口;
/**
* @param
* @return
*/
int update(User user);
- 在
UserMapper.xml
中添加update
语句;
<update id="update">
UPDATE user
SET name =#{name},
password=#{password}
WHERE id = #{id}
</update>
- 测试类中测试;
package com.cunyu.test;
import com.cunyu.entity.User;
import com.cunyu.mapper.UserMapper;
import com.cunyu.util.MybatisUtil;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;
/**
* Created with IntelliJ IDEA.
*
* @Package : com.cunyu.test
* @ClassName : UpdateTest.java
* @Description :
*/
public class UpdateTest {
@Test
public void testUpdate() {
// 获取 SqlSession 对象
SqlSession sqlSession = MybatisUtil.getSqlSession();
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
User user = mapper.query(1);
user.setPassword("7891011");
int i = mapper.update(user.getId());
System.out.println(user.toString());
sqlSession.commit();
System.out.println("更新数据成功");
// 关闭 SqlSession
sqlSession.close();
}
}
删除操作 delete
- 在
UserMapper
中添加接口;
/**
* @param id 用户 id
* @return
*/
int delete(Integer id);
- 在
UserMapper.xml
中添加delete
语句;
<delete id="delete">
DELETE
FROM user
WHERE id = #{id}
</delete>
- 在测试类中测试;
package com.cunyu.test;
import com.cunyu.mapper.UserMapper;
import com.cunyu.util.MybatisUtil;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;
/**
* Created with IntelliJ IDEA.
*
* @Package : com.cunyu.test
* @ClassName : DeleteTest.java
* @Description :
*/
public class DeleteTest {
@Test
public void testDelete() {
// 获取 SqlSession 对象
SqlSession sqlSession = MybatisUtil.getSqlSession();
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
int i = mapper.delete(2);
sqlSession.commit();
System.out.println("删除数据成功");
// 关闭 SqlSession
sqlSession.close();
}
}
最后
今天的分享到此结束,感谢您的阅读。如果您觉得文章对您有所帮助,请不吝点赞和关注,以示支持。期待在下一篇文章中与您再次相见。