(1)获取核心配置文件的输入流,这里有个类是Resources,是org.apache.ibatis.io里面的,这里面提供了一个getResourceAsStream,这个是获取当前某个文件所对应的字节输入流,我们的核心配置文件记录的是如何配置连接数据库,核心配置文件也引入了映射文件,也就是映射文件的SQL,所以要是想实现mybatis的功能,我们需要知道核心配置文件写了什么。
- //获取核心配置文件的输入流
- InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
(2)MyBatis不像原来的JDBC,它是封装了JDBC,我们这时候不会去把JDBC过程再写一遍,所以我们需要找一个入口,找到能帮我们执行SQL语句的对象。
这个对象是SqlSessionFactoryBuilder,这是个工厂对象,使用的是工厂模式,这个对象获取完了,接下来就获取SqlSessionFactory对象,SqlSessionFactoryBuilder里面有个build方法,这个build是个构建的方法,可以直接通过输入流获取,这个输入流指的就是当前读取核心配置文件输入流获取的
- //获取sqlSessionFactoryBuilder对象
- SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
- //获取SqlSessionFactory对象
- SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(is);
(3)工厂对象获取之后,就可以获取sql的会话对象SqlSession,它是MyBatis提供的操作数据库的对象,在MyBatis,SqlSession是我们的核心对象。
- //获取sql的会话对象SqlSession,是MyBatis提供的操作数据库的对象
- SqlSession sqlSession = sqlSessionFactory.openSession();
(4)那么接下来就是要来执行SQL语句的,而当前SQL语句是跟Mapper接口中的方法对应的,那么现在就需要创建Mapper接口的对象,调用其中的方法,但是Mapper是个接口,接口不能直接创建实例化对象,我们必须要重写接口中的抽象方法,那么我们要做的就是获取UserMapper的代理实现类对象,sqlSession里面有个getMapper的方法,这个方法传进去的是某个类型的Class对象,返回的是这个类型的实例化对象。在这个方法的底层会去创建这个接口的实现类,然后把当前实现类的对象进行返回,在这个方法的底层,用了代理模式。
通过代理模式帮助我们创建Mapper接口的代理实现类,既然是个实现类,那么肯定是帮我们实现了UserMapper的接口,那么就一定要帮我们重写这个接口中的方法,那么我们自动生成的这个代理实现类中,它是怎么帮我们重写的这个方法??
通过UserMapper接口的全类名,来找到当前的映射文件,也就是UserMapper.xml里的mapper标签的namespace属性,然后再通过我们要调用的方法,找到映射文件的sql语句执行,并进行返回。
- //获取UserMapper的代理实现对象
- UserMapper mapper = sqlSession.getMapper(UserMapper.class);
(5)接下来就可以调用mapper接口中的方法来实现添加用户信息的功能,会话是一个过程,最后要把会话关闭掉。
这时候会发现,返回结果1,确实执行了,可是我们去数据看,数据没有添加进去
这是因为我们以这种方式创建SqlSession,通过SqlSession来执行Sql语句,这个时候事务是需要我们自己设置的,需要我们自己设置提交回滚等,所以我们这合理还少一个步骤
- public class MyBatisTest {
-
- @Test
- public void testInsert() throws IOException {
- //获取核心配置文件的输入流
- InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
- //获取sqlSessionFactoryBuilder对象
- SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
- //获取SqlSessionFactory对象
- SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(is);
- //获取sql的会话对象SqlSession,是MyBatis提供的操作数据库的对象
- SqlSession sqlSession = sqlSessionFactory.openSession();
- //获取UserMapper的代理实现对象
- UserMapper mapper = sqlSession.getMapper(UserMapper.class);
- //调用mapper接口中的方法,实现添加用户信息的功能
- int result = mapper.insertUser();
- System.out.println("结果:"+result);
- //提交事务
- sqlSession.commit();
- //关闭sqlSession
- sqlSession.close();
- }
- }
这里id是2,是因为之前还没提交的事务,占用了id为1,所以这次提交了id是2
那么我们之前会发现不会自动提交事务,每一次都要执行完一个SQL语句添加一个提交事务也挺麻烦的,我们现在开启一个自动提交事务。这一步在获取SqlSession的时候就可以设置
- //获取sql的会话对象SqlSession(不会自动提交事务),是MyBatis提供的操作数据库的对象
- SqlSession sqlSession = sqlSessionFactory.openSession();
-
- //获取sql的会话对象SqlSession(自动提交事务),是MyBatis提供的操作数据库的对象
- SqlSession sqlSession = sqlSessionFactory.openSession(true);
也就是在原来的方法里面有个autoCommit参数,我们设置为true
那么我们每次获取Mapper的代理实现类对象的时候,都要通过SqlSession来获取,但是有一点,前面的步骤既然是固定的,那么我们可以进行封装,创建一个工具类,提供一个方法,将SqlSession对象进行返回。
- public class SqlSessionUtil {
-
- public static SqlSession getSqlSession(){
- SqlSession sqlSession = null;
- //获取核心配置文件输入流
- try {
- //获取核心配置文件的输入流
- InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
- //获取SqlSessionFactoryBuilder
- SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
- //获取SqlSessionFactory
- SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(is);
- //获取SqlSession对象
- sqlSession=sqlSessionFactory.openSession(true);
- } catch (IOException e) {
- e.printStackTrace();
- }
- return sqlSession;
- }
- }
接下来我们来试一下更新的操作
- public interface UserMapper {
-
- /**
- * 添加用户信息
- * @return
- */
- int insertUser();
-
- /**
- * 修改用户信息,这里用void和int都可以
- */
- void updateUser();
-
- }
- "1.0" encoding="UTF-8" ?>
- mapper
- PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
- "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-
- <mapper namespace="com.godairo.mybatis.mapper.UserMapper">
-
-
-
-
- <insert id="insertUser">
- insert into t_user values(null,'admin','123456',23,'男','563923245@qq.com')
- insert>
-
-
- <update id="updateUser">
- update t_user set username='root',password='123' where id=3;
- update>
-
- mapper>
删除也是一样的道理,只是sql语句变了
- <delete id="deleteUser">
- delete from t_user where id = 4;
- delete>
查询会麻烦点,我们之前写查询,查询出来需要转换成实体类对象,如果查出来的是一条对象,那就转换为实体对象,如果是多条数据,就需要转换为实体类对象集合。在Mybatis没有这么复杂,但是和增删改肯定是有区别的。
那么我们先测试一下用增删改的方法进行查询功能。
- /**
- * 根据id查询用户信息
- * @return
- */
- User getUserById();
- <select id="getUserById">
- select * from t_user where id=1;
- select>
- @Test
- public void testGetUserById(){
- SqlSession sqlSession = SqlSessionUtil.getSqlSession();
- UserMapper mapper = sqlSession.getMapper(UserMapper.class);
- mapper.getUserById();
- sqlSession.close();
- }
这里就报错了,具体信息为:我们在查询执行的时候,没有一个Result Maps 被发现,这个Result Maps是结果映射,也就是说把结果集查询出来之后,我们该和哪个实体类进行映射。
这里又说,没有一个Result Type 也没有 Result Map被声明。
这里要注意Result Type和Result Map只能设置其中一个。
那么这东西需要在哪声明?
在这个查询标签里有这些属性
这个resultType是结果类型,设置当前查询出来的数据要转换为java的类型
resultMap是自定义映射,如果字段名和属性名不一致,需要用到自定义映射,或者一对多,多对一的映射需要用到resultMap。
字段名一样只需要设置resultType就行,那么我们就在resultType里面需要写的就是实体类的全类名。
- <select id="getUserById" resultType="com.godairo.mybatis.pojo.User">
- select * from t_user where id=1;
- select>
此时我们设置了结果类型之后,再进行查询
- @Test
- public void testGetUserById(){
- SqlSession sqlSession = SqlSessionUtil.getSqlSession();
- UserMapper mapper = sqlSession.getMapper(UserMapper.class);
- User userById = mapper.getUserById();
- System.out.println(userById);
- sqlSession.close();
- }
这里要注意,resultType:设置结果类型,即查询的数据要转换为的java类型,并不是说转换为实体类的类型,而是java类型,为什么这么说呢?我们以后去查的话,还会把一些数据查询为其他类型,比如说我们查询单行单列的数据,单行单列查询出来的数据,要么是个字符串,要么是个double、float,我们肯定不能设置为实体类,而是java中相对应的类型,还有后面的各种查询,把一条数据查询为一个Map集合,这时候Map集合也是以后常用的查询方式。
- /**
- * 查询所有用户信息
- * @return
- */
- List
getAllUser();
- <select id="getAllUser" resultType="com.godairo.mybatis.pojo.User">
- select * from t_user;
- select>
- @Test
- public void testgetAllUser(){
- SqlSession sqlSession = SqlSessionUtil.getSqlSession();
- UserMapper mapper = sqlSession.getMapper(UserMapper.class);
- List
list = mapper.getAllUser(); - list.forEach(System.out::println);
- sqlSession.close();
- }