(1) . 导入相关依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>compile</scope>
</dependency>
<!-- 使用 阿里的druid 数据源作为数据库连接池，代替springboot中默认的 Hikari 数据源-->
<!-- 可以不配置，根据自己的需要是否需要 ， 不过做后台任务一般建议使用 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.23</version>
</dependency>
(2) . 配置 application.yaml
spring:
datasource:
# druid数据源配置
type: com.alibaba.druid.pool.DruidDataSource
initialSize: 10
minIdle: 10
maxActive: 200
# 配置获取连接等待超时的时间
maxWait: 60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
timeBetweenEvictionRunsMillis: 60000
# 配置一个连接在池中最小生存的时间，单位是毫秒
minEvictableIdleTimeMillis: 30000
validationQuery: select 'x'
testWhileIdle: true
testOnBorrow: false
testOnReturn: false
# 打开PSCache，并且指定每个连接上PSCache的大小
poolPreparedStatements: true
maxPoolPreparedStatementPerConnectionSize: 20
# 配置监控统计拦截的filters
filters: stat,wall,slf4j
# 通过connectProperties属性来打开mergeSql功能；慢SQL记录
connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
# 23个站点数据库配置
mysql:
jp:
name: 日本
url: jdbc:mysql://localhost:3306/zmkm?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=Asia/Shanghai&autoReconnect=true&failOverReadOnly=false&rewriteBatchedStatements=true
username: root
password: "123456"
driver-class-name: com.mysql.cj.jdbc.Driver
rom:
name: 罗马尼亚
url: jdbc:mysql://localhost:3306/rom?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=Asia/Shanghai&autoReconnect=true&failOverReadOnly=false&rewriteBatchedStatements=true
username: root
password: "123456"
driver-class-name: com.mysql.cj.jdbc.Driver
(3) . 配置 DruidDataSource 并绑定到容器
package com.wangjun.daxingxing.configuration;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;
import javax.servlet.Filter;
import javax.sql.DataSource;
import java.sql.SQLException;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;
/**
* 子站点数据源
*/
@Configuration
public class MysqlSiteConfiguration {
@Value("${mysql.jp.name}")
private String jpName;
@Value("${mysql.rom.name}")
private String romName;
// 日本站点的数据源 ，默认使用 harki数据源
@Bean // 默认的Bean名称就是方法名
@ConfigurationProperties(prefix = "mysql.jp")
public DataSource jpDatasource(){
// return DataSourceBuilder.create().build();
DruidDataSource dataSource = new DruidDataSource();
dataSource.setInitialSize(10);
dataSource.setMinIdle(10);
dataSource.setMaxActive(200);
dataSource.setMaxWait(60000);
dataSource.setTimeBetweenEvictionRunsMillis(60000);
dataSource.setMinEvictableIdleTimeMillis(30000);
dataSource.setValidationQuery("select 1");
dataSource.setTestWhileIdle(true);
dataSource.setTestOnBorrow(false);
dataSource.setTestOnReturn(false);
dataSource.setPoolPreparedStatements(true);
dataSource.setMaxPoolPreparedStatementPerConnectionSize(20);
/**
* 这个是用来配置 druid 监控sql语句的 非常有用 如果你有两个数据源 这个配置哪个数据源就监控哪个数据源的sql 同时配置那就都监控
*/
try {
dataSource.setFilters("stat,wall,slf4j");
} catch (SQLException e) {
e.printStackTrace();
}
dataSource.setName(jpName);
dataSource.setConnectionProperties("druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000");
return dataSource;
}
// 日本站点的jdbc实例
@Bean // 默认的Bean名称就是方法名
public JdbcTemplate jpJdbcTemplate(
@Qualifier("jpDatasource") DataSource dataSource
){
return new JdbcTemplate(dataSource);
}
// 罗马尼亚站点的数据源 ，默认使用 harki数据源
@Bean // 默认的Bean名称就是方法名
@ConfigurationProperties(prefix = "mysql.rom")
public DataSource romDatasource(){
DruidDataSource dataSource = new DruidDataSource();
dataSource.setInitialSize(10);
dataSource.setMinIdle(10);
dataSource.setMaxActive(200);
dataSource.setMaxWait(60000);
dataSource.setTimeBetweenEvictionRunsMillis(60000);
dataSource.setMinEvictableIdleTimeMillis(30000);
dataSource.setValidationQuery("select 1");
dataSource.setTestWhileIdle(true);
dataSource.setTestOnBorrow(false);
dataSource.setTestOnReturn(false);
dataSource.setPoolPreparedStatements(true);
dataSource.setMaxPoolPreparedStatementPerConnectionSize(20);
dataSource.setName(romName);
/**
* 这个是用来配置 druid 监控sql语句的 非常有用 如果你有两个数据源 这个配置哪个数据源就监控哪个数据源的sql 同时配置那就都监控
*/
try {
dataSource.setFilters("stat,wall,slf4j");
} catch (SQLException e) {
e.printStackTrace();
}
dataSource.setConnectionProperties("druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000");
return dataSource;
}
// 罗马尼亚站点的jdbc实例
@Bean // 默认的Bean名称就是方法名
public JdbcTemplate romJdbcTemplate(
@Qualifier("romDatasource") DataSource dataSource
){
return new JdbcTemplate(dataSource);
}
// 配置 druid 监控 的web面板
@Bean
public ServletRegistrationBean staViewServlet(){
ServletRegistrationBean<StatViewServlet> bean = new ServletRegistrationBean<>(new StatViewServlet(), "/druid/*");
Map<String,String> initParams = new HashMap<>();
//设置servlet初始化参数
initParams.put("loginUsername","admin");// druid登陆名
initParams.put("loginPassword","123456");// druid密码
initParams.put("allow","");//默认就是允许所有访问
initParams.put("deny","192.168.15.21");//拒绝相对应的id访问
bean.setInitParameters(initParams);
//加载到容器中
return bean;
}
//2.配置一个web监控的filter
@Bean
public FilterRegistrationBean webStatFilter(){
FilterRegistrationBean<Filter> bean = new FilterRegistrationBean<>();
bean.setFilter(new WebStatFilter());
Map<String,String> initParams = new HashMap<>();
//设置filter初始化参数、
initParams.put("exclusions","*.js,*.gif,*.jpg,*.bmp,*.png,*.css,*.ico,/druid/*");//排除静态资源和请求
bean.setInitParameters(initParams);
//拦截所有请求
bean.setUrlPatterns(Arrays.asList("/*"));
//加载到容器中
return bean;
}
}
// 配置成功后,访问 http://localhost:8080/druid 即可以查看druid监控面板
image.png
(4) . 基本使用
@Autowired // 依赖注入 日本站点数据库
@Qualifier("jpJdbcTemplate")
JdbcTemplate jpJdbcTemplate;
@Autowired // 依赖注入 jdbcTemplate
@Qualifier("romJdbcTemplate") # 数据源 rom
JdbcTemplate romJdbcTemplate;
@Override
public void run(String... args) {
logger.error("框架初始化加载执行的代码");
String sql = "insert into user(name,password,is_active,createtime) values (?,?,?,?)";
KeyHolder keyHolder = new GeneratedKeyHolder();
int r = 0;
try{
r = template.update(new PreparedStatementCreator() {
@Override
public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {
String name = "wangjun";
String pwd = "123456";
String password = null;
try {
password = DigestUtils.sha1Hex(pwd.getBytes("UTF-8"));
} catch (UnsupportedEncodingException e) {
logger.error("sha1Hex failed"); // 记录日志
}
byte is_active = 0;
PreparedStatement preparedStatement = connection.prepareStatement(sql, new String[]{"id"});
preparedStatement.setString(1, name);
preparedStatement.setString(2, password);
preparedStatement.setByte(3,is_active);
preparedStatement.setDate(4,new java.sql.Date(System.currentTimeMillis()));
return preparedStatement;
}
}, keyHolder);
}catch(Throwable e){
logger.error("execute error: " + e.getMessage()); // 记录日志
}
if(r > 0){
long id = keyHolder.getKey().longValue();
System.out.println("主键 -> " + id);
} else{
System.out.println("写入数据库失败");
}
// 数据源如果为 HikariDataSource,则表示使用默认的 jdbc操作mysql
System.out.println("数据源:"+jpJdbcTemplate.getDataSource().getClass().toString()); // 查看数据源是否为 Druid
}
网友评论