--------------------siwuxie095
对实体类的 CRUD 操作
1、创建数据库和表
（1）创建一个 MySQL 连接：mybatis_conn
（2）创建一个数据库：mybatis_db，其中：字符集 和 排序规则
可不选，图中显示即为默认值
（3）在 mybatis_db 数据库中创建一张表：t_user，其中：uid 为主键，
且设为自动增长
（4）在 t_user 表中插入若干数据
2、创建实体类
User.java：
|
package com.siwuxie095.entity;
// 实体类 public class User { private Integer uid; private String username; private String password; private String address; public Integer getUid() { return uid; } public void setUid(Integer uid) { this.uid = uid; } 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; } public String getAddress() { return address; } public void setAddress(String address) { this.address = address; } @Override public String toString() { return "User [uid=" + uid + ", username=" + username + ", password=" + password + ", address=" + address + "]"; } } |
3、创建 MyBatis 映射配置文件
UserMapper.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 属性：命名空间，由于这里没有使用 MyBatis 的动态代理，所以不需要遵循任何规范， 可任意，唯一即可 --> <mapper namespace="demo">
<!-- select 标签：配置映射查询语句 id 属性：在当前命名空间中的唯一标识符 parameterType 属性：指定参数的 Java 类型，进行参数映射 resultType 属性：指定返回结果的 Java 类型，进行结果映射 注：parameterType 属性是可选的，即可以不写，将自动进行参数映射 --> <select id="getUser" parameterType="java.lang.Integer" resultType="com.siwuxie095.entity.User"> <!-- 具体的 SQL 语句，其中：通过 #{} 占位符获取传入的参数 注意：因为这里只有一个参数，所以大括号中可任意，建议 和实体类属性对应（不是和数据库表字段对应，这里相同只 是巧合） --> select * from t_user where uid = #{uid} </select> <!-- 注意： 1、返回结果是 List<> 时，resultType 指定为 List<> 中包含的对象类型 2、parameterType 本来就是可选的 --> <select id="listUser" resultType="com.siwuxie095.entity.User"> select * from t_user </select> <!-- insert 标签：配置映射插入语句 注意：由于这里在数据库中已经将 uid 设为自增，所以 uid 处传入 null --> <insert id="saveUser" parameterType="com.siwuxie095.entity.User"> <!-- 注意：实际上这里依然是只有一个参数，那就是 User 对象 --> insert into t_user (uid, username, password, address) values (null, #{username}, #{password}, #{address}) </insert> <!-- update 标签：配置映射更新语句 注意：由于这里在数据库中已经将 uid 设为自增，所以 uid 不用更新 --> <update id="updateUser" parameterType="com.siwuxie095.entity.User"> update t_user set username=#{username}, password=#{password}, address=#{address} where uid=#{uid} </update>
<!-- delete 标签：配置映射删除语句 --> <delete id="removeUser" parameterType="java.lang.Integer"> delete * from t_user where uid=#{uid} </delete> </mapper> |
4、创建映射器接口及其实现类
UserMapper.java：
|
package com.siwuxie095.mapper;
import java.util.List;
import com.siwuxie095.entity.User;
public interface UserMapper { public User getUser(int uid); public List<User> listUser(); public void saveUser(User user); public void updateUser(User user); public void removeUser(int uid); } |
UserMapperImpl.java：
|
package com.siwuxie095.mapper.impl;
import java.util.List;
import org.apache.ibatis.session.SqlSession;
import com.siwuxie095.entity.User; import com.siwuxie095.mapper.UserMapper;
/** * 这里没有使用 MyBatis 动态代理，直接实现了 UserMapper 接口 * * 本来 UserMapper.xml 被建议放在映射器接口所在包下，即 UserMapper.java * 所在包下，但这里实现了 UserMapper 接口，所以就将 UserMapper.xml 放在 * 了映射器接口实现类所在包下，即当前包下 * * 注意：在调用映射语句时，通过 namespace.id 来调用 */ public class UserMapperImpl implements UserMapper { private SqlSession sqlSession; public UserMapperImpl(SqlSession sqlSession) { this.sqlSession=sqlSession; }
@Override public User getUser(int uid) { return sqlSession.selectOne("demo.getUser", uid); }
@Override public List<User> listUser() { return sqlSession.selectList("demo.listUser"); }
@Override public void saveUser(User user) { sqlSession.insert("demo.saveUser", user); }
@Override public void updateUser(User user) { sqlSession.update("demo.updateUser", user); }
@Override public void removeUser(int uid) { sqlSession.delete("demo.removeUser", uid); }
} |
5、创建 MyBatis 核心配置文件
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 根标签 --> <configuration> <!-- 第一部分：配置环境 配置环境(environments)：包括事务管理和连接池 environments 标签其中可以添加多个 environment 标签， 即多个环境 default 属性表示默认环境（从配置的多个环境选一个） --> <environments default="development"> <environment id="development"> <!-- 配置事务管理器 --> <transactionManager type="JDBC" /> <!-- 配置数据源：这里使用 MyBatis 内置连接池 --> <dataSource type="POOLED"> <property name="driver" value="com.mysql.jdbc.Driver" /> <!-- jdbc:mysql://localhost:3306/mybatis_db 可省略为 jdbc:mysql:///mybatis_db --> <property name="url" value="jdbc:mysql:///mybatis_db" /> <property name="username" value="root" /> <property name="password" value="8888" /> </dataSource> </environment> </environments> <!-- 第二部分：其它配置 由于这个例子很简单，没什么好配置的 ... 所以就不配置 --> <!-- 第三部分：引入映射配置文件 由于这个例子比较的简单，所以就没有创建映射器接口，也就没有所谓 的映射器接口所在包，这里将 UserMapper.xml 直接放在 src 下， 而不是像建议的那样放在映射器接口所在包下 --> <mappers> <mapper resource="com/siwuxie095/mapper/impl/UserMapper.xml" /> </mappers> <!-- 注意： 这三部分的配置顺序并不是这里的第一部分、第二部分、第三部分的顺序 关于 MyBatis 核心配置文件中的配置顺序，可参照如下链接中从上至下的 标签顺序 http://www.mybatis.org/mybatis-3/zh/configuration.html --> </configuration> |
6、测试：对实体类的 CRUD 操作
MyBatisTest.java：
|
package com.siwuxie095.test;
import java.io.IOException; import java.io.InputStream; import java.util.List;
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.Test;
import com.siwuxie095.entity.User; import com.siwuxie095.mapper.UserMapper; import com.siwuxie095.mapper.impl.UserMapperImpl;
public class MyBatisTest { /** * 单个查询操作 * * 手动加上 @Test 以进行单元测试（将自动导入 JUnit 4 的 jar 包） * * 选中方法名，右键->Run As->JUint Test */ @Test public void testGet() throws IOException { /* * 第一步：加载 MyBatis 核心配置文件 * * 直接到 src 下查找 mybatis-config.xml 文件 */ String resource="mybatis-config.xml"; InputStream inputStream=Resources.getResourceAsStream(resource); /* * 第二步：创建 SqlSessionFactory 对象 * * 通过 SqlSessionFactoryBuilder 匿名对象调用 build() 方法进行创建 */ SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream); /* * 第三步：使用 SqlSessionFactory 创建 SqlSession 对象 * * 调用 sqlSessionFactory 的 openSession() 方法进行创建 */ SqlSession sqlSession=sqlSessionFactory.openSession(); /* * 第四步：编写具体的逻辑：CRUD 操作 * * 调用 userMapper 的 getUser() 方法实现单个查询 */ UserMapper userMapper=new UserMapperImpl(sqlSession); User user=userMapper.getUser(1); System.out.println(user); /* * 第五步：提交事务 * * 注意：这里是查，所以跳过提交事务这一步 */ /* * 第六步：关闭资源 * * 关闭 SqlSession 会话 */ sqlSession.close(); } /** * 批量查询操作 */ @Test public void testList() throws IOException { /* * 第一步：加载 MyBatis 核心配置文件 * * 直接到 src 下查找 mybatis-config.xml 文件 */ String resource="mybatis-config.xml"; InputStream inputStream=Resources.getResourceAsStream(resource); /* * 第二步：创建 SqlSessionFactory 对象 * * 通过 SqlSessionFactoryBuilder 匿名对象调用 build() 方法进行创建 */ SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream); /* * 第三步：使用 SqlSessionFactory 创建 SqlSession 对象 * * 调用 sqlSessionFactory 的 openSession() 方法进行创建 */ SqlSession sqlSession=sqlSessionFactory.openSession(); /* * 第四步：编写具体的逻辑：CRUD 操作 * * 调用 userMapper 的 listUser() 方法实现批量查询 */ UserMapper userMapper=new UserMapperImpl(sqlSession); List<User> list=userMapper.listUser(); for (User user : list) { System.out.println(user); } /* * 第五步：提交事务 * * 注意：这里是查，所以跳过提交事务这一步 */ /* * 第六步：关闭资源 * * 关闭 SqlSession 会话 */ sqlSession.close(); } /** * 添加操作 */ @Test public void testSave() throws IOException { /* * 第一步：加载 MyBatis 核心配置文件 * * 直接到 src 下查找 mybatis-config.xml 文件 */ String resource="mybatis-config.xml"; InputStream inputStream=Resources.getResourceAsStream(resource); /* * 第二步：创建 SqlSessionFactory 对象 * * 通过 SqlSessionFactoryBuilder 匿名对象调用 build() 方法进行创建 */ SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream); /* * 第三步：使用 SqlSessionFactory 创建 SqlSession 对象 * * 调用 sqlSessionFactory 的 openSession() 方法进行创建 */ SqlSession sqlSession=sqlSessionFactory.openSession(); /* * 第四步：编写具体的逻辑：CRUD 操作 * * 调用 userMapper 的 saveUser() 方法实现添加 */ UserMapper userMapper=new UserMapperImpl(sqlSession); User user=new User(); user.setUsername("小强"); user.setPassword("4444"); user.setAddress("美国"); userMapper.saveUser(user); /* * 第五步：提交事务 */ sqlSession.commit(); /* * 第六步：关闭资源 * * 关闭 SqlSession 会话 */ sqlSession.close(); } /** * 修改操作 */ @Test public void testUpdate() throws IOException { /* * 第一步：加载 MyBatis 核心配置文件 * * 直接到 src 下查找 mybatis-config.xml 文件 */ String resource="mybatis-config.xml"; InputStream inputStream=Resources.getResourceAsStream(resource); /* * 第二步：创建 SqlSessionFactory 对象 * * 通过 SqlSessionFactoryBuilder 匿名对象调用 build() 方法进行创建 */ SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream); /* * 第三步：使用 SqlSessionFactory 创建 SqlSession 对象 * * 调用 sqlSessionFactory 的 openSession() 方法进行创建 */ SqlSession sqlSession=sqlSessionFactory.openSession(); /* * 第四步：编写具体的逻辑：CRUD 操作 * * 调用 userMapper 的 updateUser() 方法实现修改 */ UserMapper userMapper=new UserMapperImpl(sqlSession); User user=userMapper.getUser(1); user.setPassword("1111"); userMapper.updateUser(user); /* * 第五步：提交事务 */ sqlSession.commit(); /* * 第六步：关闭资源 * * 关闭 SqlSession 会话 */ sqlSession.close(); } /** * 删除操作 */ @Test public void testRemove() throws IOException { /* * 第一步：加载 MyBatis 核心配置文件 * * 直接到 src 下查找 mybatis-config.xml 文件 */ String resource="mybatis-config.xml"; InputStream inputStream=Resources.getResourceAsStream(resource); /* * 第二步：创建 SqlSessionFactory 对象 * * 通过 SqlSessionFactoryBuilder 匿名对象调用 build() 方法进行创建 */ SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream); /* * 第三步：使用 SqlSessionFactory 创建 SqlSession 对象 * * 调用 sqlSessionFactory 的 openSession() 方法进行创建 */ SqlSession sqlSession=sqlSessionFactory.openSession(); /* * 第四步：编写具体的逻辑：CRUD 操作 * * 调用 userMapper 的 removeUser() 方法实现删除 */ UserMapper userMapper=new UserMapperImpl(sqlSession); userMapper.removeUser(1); /* * 第五步：提交事务 */ sqlSession.commit(); /* * 第六步：关闭资源 * * 关闭 SqlSession 会话 */ sqlSession.close(); } } |
工程结构目录一览：
【made by siwuxie095】