1 mybatis依赖配置
依赖如下:
org.mybatis mybatis3.5.7 mysql mysql-connector-java8.0.27
额外的依赖如:
junit junit4.13.1 test org.projectlombok lombok1.18.22 org.springframework spring-webmvc5.3.14
整个pom.xml如下:
4.0.0 org.example Ymybatis1.0-SNAPSHOT 8 8 org.mybatis mybatis3.5.7 mysql mysql-connector-java8.0.27 junit junit4.13.1 test org.projectlombok lombok1.18.22 org.springframework spring-webmvc5.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); ListselectUsers(); 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 ListselectUsers() { 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")); Listmy_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的数据:
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)