【Spring 篇】MyBatis中的CRUD魔法：数据之美的四重奏

在这里插入图片描述

MyBatis，这个数据持久化的魔法师，以其优雅的SQL映射和简洁的配置文件，为我们呈现出一场CRUD（Create, Read, Update, Delete）的奇妙之旅。在这篇博客中，我们将深入探讨MyBatis中的增、删、改、查操作，揭示其中的神秘面纱。

数据之美的前奏

在开始我们的CRUD之旅之前，让我们先欣赏一下数据之美的前奏，也就是如何配置和使用MyBatis。首先，我们需要一个简单的实体类User。

public class User {private Long id;private String username;private String password;// 省略 getter 和 setter 方法
}

接下来，我们需要为User类编写一个Mapper映射文件UserMapper.xml，定义与User实体类相关的SQL语句。

<!-- UserMapper.xml -->
<mapper namespace="com.example.mapper.UserMapper"><resultMap id="UserResultMap" type="com.example.model.User"><id property="id" column="id" /><result property="username" column="username" /><result property="password" column="password" /></resultMap><select id="getUserById" resultMap="UserResultMap">SELECT * FROM user WHERE id = #{id}</select><insert id="insertUser" parameterType="com.example.model.User">INSERT INTO user (username, password) VALUES (#{username}, #{password})</insert><update id="updateUser" parameterType="com.example.model.User">UPDATE user SET username = #{username}, password = #{password} WHERE id = #{id}</update><delete id="deleteUser" parameterType="java.lang.Long">DELETE FROM user WHERE id = #{id}</delete>
</mapper>

这个Mapper映射文件包含了四个SQL语句，分别对应CRUD的四个操作：查询、插入、更新、删除。接下来，让我们通过代码演示如何使用这些SQL语句进行CRUD操作。

查询之美：Read

查询是CRUD中最常见的操作，也是数据之美的起点。让我们通过MyBatis的select语句，查询用户信息。

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;public class MyBatisReadMagic {public static void main(String[] args) {// 读取MyBatis配置文件String resource = "mybatis-config.xml";try (InputStream inputStream = Resources.getResourceAsStream(resource)) {// 创建SqlSessionFactorySqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);// 创建SqlSessiontry (SqlSession sqlSession = sqlSessionFactory.openSession()) {// 执行查询操作User user = sqlSession.selectOne("com.example.mapper.UserMapper.getUserById", 1);// 打印查询结果System.out.println("User ID: " + user.getId());System.out.println("Username: " + user.getUsername());System.out.println("Password: " + user.getPassword());}} catch (IOException e) {e.printStackTrace();}}
}

这段代码首先读取MyBatis配置文件，创建SqlSessionFactory，然后通过SqlSessionFactory创建SqlSession。接着，我们执行了一个查询操作，使用selectOne方法查询ID为1的用户信息。最后，打印查询结果。

插入之美：Create

插入操作是CRUD中的“C”（Create），用于向数据库中新增数据。MyBatis通过insert语句来实现插入操作。

public class MyBatisCreateMagic {public static void main(String[] args) {// 创建一个新用户对象User newUser = new User();newUser.setUsername("Alice");newUser.setPassword("new_password");// 读取MyBatis配置文件String resource = "mybatis-config.xml";try (InputStream inputStream = Resources.getResourceAsStream(resource)) {// 创建SqlSessionFactorySqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);// 创建SqlSessiontry (SqlSession sqlSession = sqlSessionFactory.openSession()) {// 执行插入操作int affectedRows = sqlSession.insert("com.example.mapper.UserMapper.insertUser", newUser);// 提交事务sqlSession.commit();// 打印插入结果System.out.println("Inserted new user. Affected rows: " + affectedRows);}} catch (IOException e) {e.printStackTrace();}}
}

这段代码中，我们首先创建了一个新的User对象，设置了用户名和密码。然后，通过MyBatis的insert语句将这个新用户插入到数据库中。最后，通过commit方法提交事务。

更新之美：Update

更新操作是CRUD中的“U”（Update），用于修改数据库中的数据。MyBatis通过update语句来实现更新操作。

public class MyBatisUpdateMagic {public static void main(String[] args) {// 创建一个待更新的用户对象User updateUser = new User();updateUser.setId(1);  // 假设要更新ID为1的用户信息updateUser.setUsername("UpdatedAlice");updateUser.setPassword("updated_password");// 读取MyBatis配置文件String resource = "mybatis-config.xml";try (InputStream inputStream = Resources.getResourceAsStream(resource)) {// 创建SqlSessionFactorySqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);// 创建SqlSessiontry (SqlSession sqlSession = sqlSessionFactory.openSession()) {// 执行更新操作int affectedRows = sqlSession.update("com.example.mapper.UserMapper.updateUser", updateUser);// 提交事务sqlSession.commit();// 打印更新结果System.out.println("Updated user. Affected rows: " + affectedRows);}} catch (IOException e) {e.printStackTrace();}}
}

这段代码中，我们创建了一个待更新的User对象，设置了新的用户名和密码。然后，通过MyBatis的update语句将这个用户对象的信息更新到数据库中。最后，通过commit方法提交事务。

删除之美：Delete

删除操作是CRUD中的“D”（Delete），用于从数据库中删除数据。MyBatis通过delete语句来实现删除操作。

public class MyBatisDeleteMagic {public static void main(String[] args) {// 待删除用户的IDLong userIdToDelete = 1L;  // 假设要删除ID为1的用户信息// 读取MyBatis配置文件String resource = "mybatis-config.xml";try (InputStream inputStream = Resources.getResourceAsStream(resource)) {// 创建SqlSessionFactorySqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);// 创建SqlSessiontry (SqlSession sqlSession = sqlSessionFactory.openSession()) {// 执行删除操作int affectedRows = sqlSession.delete("com.example.mapper.UserMapper.deleteUser", userIdToDelete);// 提交事务sqlSession.commit();// 打印删除结果System.out.println("Deleted user. Affected rows: " + affectedRows);}} catch (IOException e) {e.printStackTrace();}}
}