SpringBoot+druid Mysql连接池使用

零、Mybatis与Mysql连接池使用

一、代码

1、POM依赖

implementation 'org.springframework.boot:spring-boot-starter-web'
implementation 'org.mybatis.spring.boot:mybatis-spring-boot-starter:2.1.4'
implementation group: 'mysql', name: 'mysql-connector-java', version: '8.0.25'
compile group: 'com.alibaba', name: 'druid', version: '1.2.4'

2、application.properties配置数据库

#数据库
jdbc.driverClassName=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://1.2.3.4:3306/TestDBMysql?allowMultiQueries=true
jdbc.username=admin
jdbc.password=123456
jdbc.maxActive=10
jdbc.maxIdle=10
jdbc.minIdle=2

druid配置文件 resources/applicationContext.xml

Mybatis的配置文件resources/mybatis-config.xml

3、MainApplication.java启动类配置

@SpringBootApplication
@importResource({"classpath:applicationContext.xml"})
public class SecurityApplication {
    public static void main(String[] args) {SpringApplication.run(SecurityApplication.class, args);}
}

4、Mybatis线程池工具类

com.longze.util.MyBatisUtil.java

package com.longze.security.util;

import org.apache.ibatis.session.SqlSession;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.context.WebApplicationContext;

@Component
public class MyBatisUtil {
    private static WebApplicationContext context;
    public static WebApplicationContext getContext() {
        return context;
    }
    @Autowired
    public void setContext(WebApplicationContext context) {
        setContextStatic(context);
    }
    public static SqlSession getSqlSession() {
        return (SqlSession) context.getBean("sqlSession");
    }
    public static void setContextStatic(WebApplicationContext context){
        MyBatisUtil.context=context;
    }
}

5、使用线程池工具类

@Service
public class MyBatisTestServiceImpl implements MyBatisTestService{
 @Override
    public int save(UserDTO dto){
        try {
            //使用线程池
            int i = MyBatisUtil.getSqlSession().insert("com.longze.dao.testDao.insertUser", dto);
            return i;
        } catch (Exception e) {
            throw  e;
        }
    }

}

二、多数据源应用