连接池
连接池就是用于存储数据库连接的一个容器,容器其实就是一个集合对象, 该集合必须是线程安全的,不能两个线程拿到同一连接 ,该集合还必须实现队列的特性:先进先出。
mybatis连接池提供了3种方式的配置
配置的位置:
主配置文件SqlMapConfig.xml中的dataSource标签,type属性就是表示采用何种连接池方式.
type属性的取值
- POOLDE:采用传统的javax.sql.DataSource规范中的连接池,mybatis中有针对规范的实现。MyBatis 会创建 PooledDataSource 实例
- UNPOOLDE:采用传统的获取连接的方式,虽然也实现Javax.sql.DataSource接口,但是并没有使用池的思想。在使用数据库连接时,何时用何时创建,使用完后直接关闭连接,不会放入数据库连接池。MyBatis 会创建 UnpooledDataSource 实例
- JNDI:采用服务器提供的JNDI技术实现,来获取DataSource对象,不同的服务器所能拿到DataSource是不一样。MyBatis 会从 JNDI 服务上查找 DataSource 实例,然后返回使用。注意:如果不是web或者maven的war工程,是不能使用的。
POOLDE:实现原理
private PooledConnection popConnection(String username, String password) throws SQLException {
boolean countedWait = false;
PooledConnection conn = null;
long t = System.currentTimeMillis();
int localBadConnectionCount = 0;
while (conn == null) {
synchronized (state) {
if (!state.idleConnections.isEmpty()) {
//如果有空闲,返回直接用
// Pool has available connection
conn = state.idleConnections.remove(0);
if (log.isDebugEnabled()) {
log.debug("Checked out connection " + conn.getRealHashCode() + " from pool.");
}
} else {
// Pool does not have available connection
if (state.activeConnections.size() < poolMaximumActiveConnections) {
//如果活动的连接小于设定的最大连接会创建一个新的连接
// Can create new connection
conn = new PooledConnection(dataSource.getConnection(), this);
if (log.isDebugEnabled()) {
log.debug("Created connection " + conn.getRealHashCode() + ".");
}
} else {
// Cannot create new connection
//无法创建连接时,获取活动连接最老的一个连接通过设置成为一个全新的连接使用
PooledConnection oldestActiveConnection = state.activeConnections.get(0);
long longestCheckoutTime = oldestActiveConnection.getCheckoutTime();
if (longestCheckoutTime > poolMaximumCheckoutTime) {
画图分析:
POOLDE和UNPOOLDE连接池的比较
由执行的日志结果就可以看出两者的区别:POOLDE每次使用完连接后都会把连接还到连接池中,UNPOOLDE每次使用完都是关闭连接。
事务: Mybatis中的是我们可以手动提交和自动提交
手动提交是通过SqlSession来完成的,通过commit()方法来提交
public class MybatisTest {
private InputStream in;
private SqlSessionFactoryBuilder builder;
private SqlSessionFactory factory;
private SqlSession session;
private UserMapper userMapper;
@Before
public void befor() throws Exception {
//读取SqlMapConfig.xml配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//创建SqlSessionFactory工厂
builder = new SqlSessionFactoryBuilder();
factory = builder.build(in);
//使用工厂生产SqlSession
session = factory.openSession();
//使用SqlSession创建dao接口代理对象
userMapper = session.getMapper(UserMapper.class);
}
@After
public void after() throws Exception{
session.commit();//手动提交事务
session.close();//关闭连接
in.close();//关闭流
}
/***
* @Description 删除用户
* @Param: []
* @return: void
* @Date: 2021/2/24
*/
@Test
public void testDeleteUserById(){
Integer i = userMapper.deleteUserById(16);
System.out.println(i);
}
}
自动提交事务
//使用工厂生产SqlSession
session = factory.openSession(true);