mybatis 入门搭建

清疚 2022-10-01 10:55 135阅读 0赞

首先导包

依赖如下

  1. <dependencies>
  2.     <dependency>
  3.       <groupId>mysql</groupId>
  4.       <artifactId>mysql-connector-java</artifactId>
  5.       <version>8.0.15</version>
  6.     </dependency>
  7.     <dependency>
  8.       <groupId>org.mybatis</groupId>
  9.       <artifactId>mybatis</artifactId>
  10.       <version>3.5.1</version>
  11.     </dependency>
  12.     <dependency>
  13.       <groupId>junit</groupId>
  14.       <artifactId>junit</artifactId>
  15.       <version>4.11</version>
  16.       <scope>test</scope>
  17.     </dependency>
  18.   </dependencies>
  19. 复制代码

构建SqlSessionFactory

MyBatis应用是以SqlSessionFactory为中心的,实例可以通过SqlSessionFactoryBuilder获得. 其中SqlSessionFactory是工厂接口,任务用于创建SqlSession 配置文件将会解析配置XML文件在Configuration类对象中.

配置XML获取数据源,事务管理器,映射器

在resource文件下新建mybatis-config.xml文件 配置文件内容如下

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  3.         "http://mybatis.org/dtd/mybatis-3-config.dtd">
  4. <configuration>
  5.     <!-- 定义别名 -->
  6.     <typeAliases>
  7.         <typeAlias type="com.ming.Role" alias="role"/>
  8.     </typeAliases>
  10.     <!-- 定义数据库信息 -->
  11.     <environments default="development">
  12.         <environment id="development">
  13.             <!-- jdbc事物管理 -->
  14.             <transactionManager type="JDBC"></transactionManager>
  15.             <!-- 数据库链接信息 -->
  16.             <dataSource type="POOLED">
  17.                 <property name="driver" value="com.mysql.cj.jdbc.Driver"/>
  18.                 <property name="url" value="jdbc:mysql://47.94.95.84:32786/mybatis"/>
  19.                 <property name="username" value="mybatis"/>
  20.                 <property name="password" value="ABCcba20170607"/>
  21.             </dataSource>
  22.         </environment>
  23.     </environments>
  24. </configuration>
  25. 复制代码

新建类

  1. package com.ming;
  2. import org.apache.ibatis.io.Resources;
  3. import org.apache.ibatis.session.SqlSessionFactory;
  4. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
  6. import java.io.IOException;
  7. import java.io.InputStream;
  9. public class Role {
  10.     public String getSqlSessionFactory(){
  11.         String resource = "mybatis-config.xml";
  12.         try {// 获得输入流
  13.             InputStream inputStream;
  14.             inputStream = Resources.getResourceAsStream(resource);
  15.             // 获得SqlSessionFactory工厂
  16.             SqlSessionFactory sqlSessionFactory = null;
  17.             sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
  18.         }catch (IOException e){
  19.             e.printStackTrace();
  20.         }
  21.         return null;
  22.     }
  23. }
  25. 复制代码

最后新建测试类

  1. package com.ming;
  3. import org.junit.After;
  4. import org.junit.Before;
  5. import org.junit.Test;
  7. public class RoleTest {
  8.     private Role role = null;
  9.     @Before
  10.     public void setUp() throws Exception {
  11.         this.role = new Role();
  12.     }
  14.     @After
  15.     public void tearDown() throws Exception {
  16.     }
  18.     @Test
  19.     public void getSqlSessionFactory() {
  20.         role.getSqlSessionFactory();
  21.     }
  22. }
  23. 复制代码

此时的目录结构

代码方式构建

  1. public SqlSessionFactory getSqlSessionFactory1(){
  2.         // 创建数据库连接池
  3.         PooledDataSource dataSource = new PooledDataSource();
  4.         dataSource.setDriver("com.mysql.cj.jdbc.Driver");
  5.         dataSource.setUrl("jdbc:mysql://47.94.95.84:32786/mybatis");
  6.         dataSource.setUsername("mybatis");
  7.         dataSource.setPassword("ABCcba20170607");
  8.         // 构建数据库事物
  9.         TransactionFactory transactionFactory = new JdbcTransactionFactory();
  10.         // 创建数据库环境
  11.         Environment environment = new Environment("development", transactionFactory, dataSource);
  12.         // 构建Configuration对象
  13.         Configuration configuration = new Configuration(environment);
  14.         // 注册上下文别名
  15.         configuration.getTypeAliasRegistry().registerAlias("role", Role.class);
  16.         // 创建映射器
  17.         SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(configuration);
  18.         return sqlSessionFactory;
  19.     }
  20. 复制代码

书写测试用例如下

  1. package com.ming;
  3. import org.junit.After;
  4. import org.junit.Before;
  5. import org.junit.Test;
  7. public class RoleTest {
  8.     private Role role = null;
  9.     @Before
  10.     public void setUp() throws Exception {
  11.         this.role = new Role();
  12.     }
  14.     @After
  15.     public void tearDown() throws Exception {
  16.     }
  18.     @Test
  19.     public void getSqlSessionFactory() {
  20.         role.getSqlSessionFactory();
  21.     }
  23.     @Test
  24.     public void getSqlSessionFactory1() {
  25.         role.getSqlSessionFactory1();
  26.     }
  27. }
  28. 复制代码

创建SqlSession

SqlSession属于门面,通过SqlSession可以获得需要的什么信息

  1. SqlSession sqlSession = null;
  2.         try{
  3.             // 创建一个sqlsession会话
  4.             sqlSession = sqlSessionFactory.openSession();
  5.             sqlSession.commit();
  6.         }catch (Exception e){
  7.             // 输出错误信息
  8.             System.out.println(e.getMessage());
  9.             // 进行事物操作,回滚数据库数据
  10.             sqlSession.rollback();
  11.         }finally {
  12.             // 进行资源关闭
  13.             if(sqlSession != null){
  14.                 sqlSession.close();
  15.             }
  16.         }
  17. 复制代码

SqlSession作用,获取映射器,通过命名信息执行sql结果

映射器

映射器由java和xml文件共同组成,作用 定义参数类型 描述缓存 描述sql 定义查询结果和POJO映射关系

先给出java接口

  1. package com.ming;
  3. public interface RoleMapper {
  4.     public Role getRole(Long id);
  5. }
  7. 复制代码

根据给定的id获取角色对象

给出映射文件,然后在生成的时候会根据接口实现类,生成对象.

先编写POJO

  1. package com.ming;
  3. // POJO
  4. public class Role {
  5.     private int id;
  6.     private String roleName;
  7.     private String note;
  9.     public void setId(int id) {
  10.         this.id = id;
  11.     }
  13.     public void setRoleName(String roleName) {
  14.         this.roleName = roleName;
  15.     }
  17.     public void setNote(String note) {
  18.         this.note = note;
  19.     }
  21.     public int getId() {
  22.         return id;
  23.     }
  25.     public String getRoleName() {
  26.         return roleName;
  27.     }
  29.     public String getNote() {
  30.         return note;
  31.     }
  32. }
  34. 复制代码

在编写映射配置文件

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  3.         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  4. <!-- 定义接口类 -->
  5. <mapper namespace="com.ming.RoleMapper">
  6.     <!-- 定义的接口方法为getRole 类型参数为long 返回的结果为role 即之前定义在xml文件中定义的vo别名 -->
  7.     <select id="getRole" parameterType="int" resultType="role">
  8.         <!-- 定义sql语句-->
  9.         SELECT id, role_name as roleName, note FROM t_role WHERE id = #{id}
  10.     </select>
  11. </mapper>
  12. 复制代码

最后编写mybatis,添加映射器配置文件

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  3.         "http://mybatis.org/dtd/mybatis-3-config.dtd">
  4. <configuration>
  5.     <!-- 定义别名 -->
  6.     <typeAliases>
  7.         <typeAlias type="com.ming.Role" alias="role"/>
  8.     </typeAliases>
  10.     <!-- 定义数据库信息 -->
  11.     <environments default="development">
  12.         <environment id="development">
  13.             <!-- jdbc事物管理 -->
  14.             <transactionManager type="JDBC"></transactionManager>
  15.             <!-- 数据库链接信息 -->
  16.             <dataSource type="POOLED">
  17.                 <property name="driver" value="com.mysql.cj.jdbc.Driver"/>
  18.                 <property name="url" value="jdbc:mysql://47.94.95.84:32786/mybatis"/>
  19.                 <property name="username" value="mybatis"/>
  20.                 <property name="password" value="ABCcba20170607"/>
  21.             </dataSource>
  22.         </environment>
  23.     </environments>
  24.     <!-- 定义映射器 -->
  25.     <mappers>
  26.         <mapper resource="RoleMapper.xml"></mapper>
  27.     </mappers>
  28. </configuration>
  29. 复制代码

最后再编写执行sql的类

  1. package com.ming;
  2. import org.apache.ibatis.datasource.pooled.PooledDataSource;
  3. import org.apache.ibatis.io.Resources;
  4. import org.apache.ibatis.mapping.Environment;
  5. import org.apache.ibatis.session.Configuration;
  6. import org.apache.ibatis.session.SqlSession;
  7. import org.apache.ibatis.session.SqlSessionFactory;
  8. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
  9. import org.apache.ibatis.transaction.TransactionFactory;
  10. import org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory;
  12. import java.io.IOException;
  13. import java.io.InputStream;
  15. public class MyBatis {
  16.     public String getSqlSessionFactory(){
  17.         String resource = "mybatis-config.xml";
  18.         SqlSessionFactory sqlSessionFactory = null;
  19.         try {// 获得输入流
  20.             InputStream inputStream;
  21.             inputStream = Resources.getResourceAsStream(resource);
  22.             // 获得SqlSessionFactory工厂
  23.             sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
  24.         }catch (IOException e){
  25.             e.printStackTrace();
  26.         }
  27.         SqlSession sqlSession = null;
  28.         try{
  29.             // 创建一个sqlsession会话
  30.             sqlSession = sqlSessionFactory.openSession();
  31.             // 获得映射器
  32.             // 接口传入映射器中
  33.             RoleMapper roleMapper = sqlSession.getMapper(RoleMapper.class);
  34.             // 执行方法
  35.             Role role = roleMapper.getRole(0);
  36.             System.out.println(role.getRoleName());
  37.             // 刷新语句并提交链接
  38.             sqlSession.commit();
  39.         }catch (Exception e){
  40.             // 输出错误信息
  41.             System.out.println(e.getMessage());
  42.             // 进行事物操作,回滚数据库数据
  43.             sqlSession.rollback();
  44.         }finally {
  45.             // 进行资源关闭
  46.             if(sqlSession != null){
  47.                 sqlSession.close();
  48.             }
  49.         }
  50.         return null;
  51.     }
  53.     public SqlSessionFactory getSqlSessionFactory1(){
  54.         // 创建数据库连接池
  55.         PooledDataSource dataSource = new PooledDataSource();
  56.         dataSource.setDriver("com.mysql.cj.jdbc.Driver");
  57.         dataSource.setUrl("jdbc:mysql://47.94.95.84:32786/mybatis");
  58.         dataSource.setUsername("mybatis");
  59.         dataSource.setPassword("ABCcba20170607");
  60.         // 构建数据库事物
  61.         TransactionFactory transactionFactory = new JdbcTransactionFactory();
  62.         // 创建数据库环境
  63.         Environment environment = new Environment("development", transactionFactory, dataSource);
  64.         // 构建Configuration对象
  65.         Configuration configuration = new Configuration(environment);
  66.         // 注册上下文别名
  67.         configuration.getTypeAliasRegistry().registerAlias("role", MyBatis.class);
  68.         // 创建映射器
  69.         SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(configuration);
  70.         return sqlSessionFactory;
  71.     }
  72. }
  74. 复制代码

最后编写测试类

  1. package com.ming;
  3. import org.junit.After;
  4. import org.junit.Before;
  5. import org.junit.Test;
  7. public class MyBatisTest {
  8.     private MyBatis myBatis = null;
  9.     @Before
  10.     public void setUp() throws Exception {
  11.         this.myBatis = new MyBatis();
  12.     }
  14.     @After
  15.     public void tearDown() throws Exception {
  16.     }
  18.     @Test
  19.     public void getSqlSessionFactory() {
  20.         myBatis.getSqlSessionFactory();
  21.     }
  23.     @Test
  24.     public void getSqlSessionFactory1() {
  25.         myBatis.getSqlSessionFactory1();
  26.     }
  27. }
  28. 复制代码

执行单元测试 结果如下

即完成了MyBatis的一次查询

注解

定义接口

  1. package com.ming;
  3. import org.apache.ibatis.annotations.Select;
  5. public interface Role1 {
  6.     @Select (value="SELECT id, role_name as roleName, note FROM t_role WHERE id = #{id}")
  7.     public Role getRole(int id);
  8. }
  10. 复制代码

生命周期

SqlSessionFactoryBuilder

其是利用xml或者java编码构建SqlSessionFactory 可以构建多个SessionFactory 作用 构建器 根据构建器获得sqlSessionFactory

SqlSessionFactory

创建SqlSession 一个SqlSession相当于JDBC的Connection对象 此为单例管理 每创建一个SqlSession就会创建一个数据库连接

SqlSession

此为一个会话,相当于一个Connection连接 线程不安全 生命周期为一个应用的请求和操作,可以执行多条sql

转载于:https://juejin.im/post/5cab75f8e51d456e2a64b272

发表评论

表情：
评论列表 （有 0 条评论，135人围观）

还没有评论，来说两句吧...

相关阅读