1 mybatis依赖配置
依赖如下:
org.mybatis mybatis 3.5.7 mysql mysql-connector-java 8.0.27
额外的依赖如:
junit junit 4.13.1 test org.projectlombok lombok 1.18.22 org.springframework spring-webmvc 5.3.14
整个pom.xml如下:
4.0.0 org.example Ymybatis 1.0-SNAPSHOT 8 8 org.mybatis mybatis 3.5.7 mysql mysql-connector-java 8.0.27 junit junit 4.13.1 test org.projectlombok lombok 1.18.22 org.springframework spring-webmvc 5.3.14 src/main/java ***.xml false
2 创建数据库和相应的表
数据库环境为mysql8,在workbench上连接本地的mysql,新建数据库和数据表,创建myuser表(表名只能是小写)
查看具体的表结构信息:
插入测试数据:
3 创建User实体类
tips:domain意思,和pojo、entity都是实体类的意思
package com.xiaoxu.domain;
import lombok.Data;
import java.math.BigDecimal;
@Data
public class User {
//属性名和列名一样
private int id;
private String name;
private byte age;
private BigDecimal money;
@Override
public String toString() {
return "用户实体信息{" +
"id=" + id +
", name='" + name + ''' +
", age=" + age +
", money=" + money +
'}';
}
}
mybatis文档如下:https://mybatis.net.cn/getting-started.html
4 创建UserDao接口和UserDao.xml:
UserDao.xml放在UserDao一个目录下:
UserDao接口:
package com.xiaoxu.dao;
import com.xiaoxu.domain.User;
public interface UserDao {
User selectUserById(int id);
}
UserDao.xml:
拷贝接口的全限定类名称如下操作:
5 创建mybatis主配置文件
resource目录下新建mybatis.xml:
注意:mapper的resource使用的UserDao.xml是src/main/java目录下的,pom.xml中一定要配置资源插件!
resource目录下新建jdbc.properties文件:
driver=com.mysql.jdbc.Driver #如果数据库连接直接写在xml中,是:jdbc:mysql://localhost:3306/xiaoxu?useUnicode=true&characterEncoding=utf8mb4 url=jdbc:mysql://localhost:3306/xiaoxu?useUnicode=true&characterEncoding=utf8mb4 username=root password=******
6 测试类
import com.xiaoxu.domain.User;
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 java.io.IOException;
import java.io.InputStream;
public class MyTest {
@Test
public void test_select() throws IOException {
//调用mybatis某个对象的方法,执行mapper文件中的sql语句
//mybatis核心类:SqlSessionFactory
//1.定义mybatis主配置文件的位置,从类路径开始的相对路径
String conf="mybatis.xml";
//2.读取主配置文件,使用mybatis框架中的Resources类
InputStream inputStream=Resources.getResourceAsStream(conf);
//3.创建SqlSessionFactory对象,使用SqlSessionFactoryBuilder类
SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream);
//4.获取SqlSession对象
SqlSession session=sqlSessionFactory.openSession();
//5.指定要执行的sql语句的id
//sql的id = namespace+"."+select|update|insert|delete标签的id属性值
String sqlId = "com.xiaoxu.dao.UserDao"+"."+"selectUserById";
//6.通过SqlSession的方法,执行sql语句:
User u=session.selectOne(sqlId);
System.out.println("查询用户如下所示:"+u);
//7.关闭SqlSession对象
session.close();
}
}
执行单测抛错:
需要在pom.xml中添加上资源插件,用于处理src/main/java目录中的xml:
src/main/java ***.xml false
再次执行:
修改配置文件:
driver=com.mysql.cj.jdbc.Driver #如果数据库连接直接写在xml中,是:jdbc:mysql://localhost:3306/xiaoxu?useUnicode=true&characterEncoding=utf8mb4 url=jdbc:mysql://localhost:3306/xiaoxu?useUnicode=true&characterEncoding=utf8mb4 username=root password=******
再次执行:
原因是mybatis不支持数据库的编码是utf8mb4,但是可以改为utf-8(这样配置可以连接数据库编码是utf8mb4的):
driver=com.mysql.cj.jdbc.Driver #如果数据库连接直接写在xml中,是:jdbc:mysql://localhost:3306/xiaoxu?useUnicode=true&characterEncoding=utf8mb4 url=jdbc:mysql://localhost:3306/xiaoxu?useUnicode=true&characterEncoding=utf-8 username=root password=******
重新执行单测结果如下:
7 编写Mybatis工具类
在com.xiaoxu.utils下新建Mybatis的工具类:
package com.xiaoxu.utils;
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 MybatisUtil {
private static SqlSessionFactory factory=null;
private static Boolean auto_commit=null;
static {
String config="mybatis.xml";
try {
InputStream inputStream = Resources.getResourceAsStream(config);
factory = new SqlSessionFactoryBuilder().build(inputStream);
auto_commit=false;
} catch (IOException e) {
e.printStackTrace();
}
}
public static SqlSession getSqlSession(){
SqlSession sqlSession=null;
if(factory!=null){
sqlSession=factory.openSession(auto_commit);
}
return sqlSession;
}
public static SqlSession getAutoCommitSqlSession(){
SqlSession sqlSession=null;
if(factory!=null){
sqlSession = factory.openSession(true);
}
return sqlSession;
}
}
上面的Mybatis获取sqlSession的工具类,在openSession中可以传入布尔值决定事务是否自动提交(如果为true,则为自动提交事务),mybatis在使用除了select语句外的其他语句(如insert、update、delete)时,事务自动提交是关闭的,要真正执行这些sql语句,需要使用如下语句:
sqlSession.commit();
但是在使用SqlSeesion工厂创建SqlSeesion时,openSession(true)效果等同于执行了sqlSession.commit()。
增加dao.UserDao接口方法:
package com.xiaoxu.dao;
import com.xiaoxu.domain.User;
import java.util.List;
public interface UserDao {
User selectUserById(int id);
List selectUsers();
int insertUsers(List userList);
}
修改Mapper(UserDao.xml):
UserDaoImpl实现UserDao的接口方法:
package com.xiaoxu.impl;
import com.xiaoxu.dao.UserDao;
import com.xiaoxu.domain.User;
import com.xiaoxu.utils.MybatisUtil;
import org.apache.ibatis.session.SqlSession;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public class UserDaoImpl implements UserDao {
@Override
public User selectUserById(int id) {
SqlSession s= MybatisUtil.getSqlSession();
String sqlId="com.xiaoxu.dao.UserDao.selectUserById";
User u=s.selectOne(sqlId,id);
System.out.println(u);
s.close();
return u;
}
@Override
public List selectUsers() {
SqlSession s= MybatisUtil.getSqlSession();
String sqlId = "com.xiaoxu.dao.UserDao.selectStudents";
List userList = s.selectList(sqlId);
userList.forEach(System.out::println);
s.close();
return userList;
}
@Override
public int insertUsers(List userList) {
SqlSession s = MybatisUtil.getAutoCommitSqlSession();
String sqlId = "com.xiaoxu.dao.UserDao.insertUsers";
int rows = s.insert(sqlId,userList);
System.out.println("插入的数据的行数为:"+rows);
s.close();
return rows;
}
}
新建spring的配置类:
com.xiaoxu.config包中:
package com.xiaoxu.config;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
@Configuration
@ComponentScan(basePackages = {"com.xiaoxu"})
public class MyConfig {
}
新建Mybatis工具类的使用测试类:
import com.xiaoxu.config.MyConfig;
import com.xiaoxu.dao.UserDao;
import com.xiaoxu.domain.User;
import com.xiaoxu.impl.UserDaoImpl;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.List;
public class MybatisUtilTest {
@Test
public void test_01(){
ApplicationContext context = new AnnotationConfigApplicationContext(MyConfig.class);
UserDao u = context.getBean("userDaoImpl",UserDaoImpl.class);
u.selectUserById(2);
u.selectUserById(1);
}
@Test
public void test_02(){
ApplicationContext context = new AnnotationConfigApplicationContext(MyConfig.class);
UserDao u = context.getBean("userDaoImpl", UserDaoImpl.class);
u.selectUsers();
}
@Test
public void test_03(){
ApplicationContext context = new AnnotationConfigApplicationContext(MyConfig.class);
UserDao u = context.getBean("userDaoImpl",UserDaoImpl.class);
User u1 = new User();
u1.setName("小王");
u1.setAge((byte) 28);
u1.setMoney(new BigDecimal("9.99"));
User u2 = new User();
u2.setName("小张");
u2.setAge((byte) 55);
u2.setMoney(new BigDecimal("12.89"));
List my_user_list = new ArrayList(){{
add(u1);
add(u2);
}};
u.insertUsers(my_user_list);
}
}
在执行测试类前,开启Mybatis的sql日志打印出来:
修改mybatis.xml:
预备数据库数据:
测试类执行效果如下:
test_01:
test_02:
test_03:
插入后,表中新增自增id为9和10的数据:



