MyBatis 连接池与事务

浅浅的花香味﹌ 2024-04-18 23:53 84阅读 0赞

### 1.MyBatis的连接池技术 ###

**在 Mybatis 的 SqlMapConfig.xml 配置文件中，通过<dataSource type=”pooled”>来实 现 Mybatis 中连接池的配置。**

在MaBatis中我们将它的数据源dataSource分为一下几类:

![20190914164617905.png][]

可以明显的看出MyBatis将它的 **dataSource** 将它的数据源分为了三类

UNPOOLED 不使用连接池的数据源

POOLED 使用连接池的数据源

JNDI 使用JNDI实现的数据源

结构如下:

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3huaF81NjUxNzU5NDQ_size_16_color_FFFFFF_t_70][]

也就是说，MyBatis 内部分别定义实现了java.sql.DataSource 接口的 UnpooledDataSource，PooledDataSource 类来表示UNPOOLED、POOLED 类型的数据源

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3huaF81NjUxNzU5NDQ_size_16_color_FFFFFF_t_70 1][]

**在这三种数据源中，我们一般采用的是 POOLED 数据源（很多时候我们所说的数据源就是为了更好的管理数据库连接，也就是我们所说的连接池技术）。**

### 1.2 Mybatis 中数据源的配置 ###

我们的数据源配置就是在 SqlMapConfig.xml 文件中，具体配置如下：

<dataSource type="POOLED">
    
     <property name="driver" value="${jdbc.driver}"/> 
    
     <property name="url" value="${jdbc.url}"/> 
    
     <property name="username" value="${jdbc.username}"/>
    
     <property name="password" value="${jdbc.password}"/>
    </dataSource>
    MyBatis 在初始化时，根据<dataSource>的 type 属性来创建相应类型的的数据源 DataSource，即： type=”POOLED”：MyBatis 会创建 PooledDataSource 实例 
    type=”UNPOOLED” ： MyBatis 会创建 UnpooledDataSource 实例 
    type=”JNDI”：MyBatis 会从 JNDI 服务上查找 DataSource 实例，然后返回使用

### 1.3 Mybatis 中 DataSource 的存取 ###

MyBatis 是通过工厂模式来创建数据源 DataSource 对象的， MyBatis 定义了抽象的工厂接口:org.apache.ibatis.datasource.DataSourceFactory,通过其 getDataSource()方法返回数据源 DataSource

DataSourceFactory源码:

package org.apache.ibatis.datasource; 
    
    import java.util.Properties; 
    import javax.sql.DataSource;  
    
    public interface DataSourceFactory { 
      void setProperties(Properties props);
      DataSource getDataSource(); 
    }

### 1.4 Mybatis 中连接的获取过程分析 ###

**当我们需要创建 SqlSession 对象并需要执行 SQL 语句时，这时候 MyBatis 才会去调用 dataSource 对象 来创建java.sql.Connection对象。也就是说，java.sql.Connection对象的创建一直延迟到执行SQL语句 的时候。**

@Test public void testSql() throws Exception {
      InputStream in = Resources.getResourceAsStream("SqlMapConfig.xml");
      SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(in);
      SqlSession sqlSession  = factory.openSession();
      List<User> list = sqlSession.selectList("findUserById",41);  
      System.out.println(list.size()); 
    }

只有当第 4句sqlSession.selectList("findUserById")，才会触发MyBatis 在底层执行下面这个方 法来创建 java.sql.Connection 对象。

根据调试就可以发现，真正连接打开的时间点，只是在我们执行SQL语句时，才会进行。其实这样做我们也可以 进一步发现，数据库连接是我们最为宝贵的资源，只有在要用到的时候，才去获取并打开连接，当我们用完了就再 立即将数据库连接归还到连接池中。

工作原理如下:

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3huaF81NjUxNzU5NDQ_size_16_color_FFFFFF_t_70 2][]

### 2.MyBatis的事务控制 ###

**在 JDBC 中我们可以通过手动方式将事务的提交改为手动方式，通过 setAutoCommit()方法就可以调整。**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3huaF81NjUxNzU5NDQ_size_16_color_FFFFFF_t_70 3][]

那么我们的 Mybatis 框架因为是对 JDBC 的封装，所以 Mybatis 框架的事务控制方式，本身也是用 JDBC的 setAutoCommit()方法来设置事务提交方式的。

### 2.1 MyBatis中事务提交方式 ###

**上面说过，MyBatis框架其实用的也是JDBC的事务控制方式，所以我们也使用setAutoCommit() 来实现事务控制。**

测试代码如下:

@Test 
    public void testSaveUser() throws Exception {
       User user = new User();
       user.setUsername("mybatis user09"); 
      //6.执行操作
       int res = userDao.saveUser(user);
       System.out.println(res);
       System.out.println(user.getId());  
    }   
    @Before//在测试方法执行之前执行  
    public void init()throws Exception { 
      //1.读取配置文件
      in = Resources.getResourceAsStream("SqlMapConfig.xml");
      //2.创建构建者对象
      SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
      //3.创建 SqlSession 工厂对象
      factory = builder.build(in); 
      //4.创建 SqlSession 对象
      session = factory.openSession(); 
      //5.创建 Dao 的代理对象
      userDao = session.getMapper(IUserDao.class);  
    }   
    @After//在测试方法执行完成之后执行
    public void destroy() throws Exception{   
      //7.提交事务 
      session.commit();  
      //8.释放资源
      session.close();
      in.close();  
    }

**这里使用了注解的方式进行测试，在程序执行前代理Dao，测试程序结束的时候提交事务释放资源。**

因为创建了SqlSession工厂对象，我们的Connection的功能由SqlSession来实现，所以事务的提交也交给SqlSession。

DefaultSqlSessionFactory内控制事务的函数。

![20190914225407266.png][]

可以看出，我们可以在生成SqlSession工厂对象的时候，进行设置是否自动提交事务。

//4.创建 SqlSession 对象  
    session = factory.openSession(true);

[20190914164617905.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/8f0c6ac63a964c20a95dbc6c9359765f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3huaF81NjUxNzU5NDQ_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/177b4a6d41f14db38d52e6461e6a3237.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3huaF81NjUxNzU5NDQ_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/3be24a3c5dac43d3bd0d48368c5cd2e2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3huaF81NjUxNzU5NDQ_size_16_color_FFFFFF_t_70 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/a747b81a17ec4d9194e4af9ffabbaa4c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3huaF81NjUxNzU5NDQ_size_16_color_FFFFFF_t_70 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/bed93300ecdb4fa38ede1743e0057bc1.png
[20190914225407266.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/11a1c0e5b6d84cdf87fdc7ecbde3da41.png