package com.gkhy.safePlatform.config.database;
|
|
import com.atomikos.icatch.jta.UserTransactionImp;
|
import com.atomikos.icatch.jta.UserTransactionManager;
|
import com.mysql.cj.jdbc.MysqlXADataSource;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.boot.jta.atomikos.AtomikosDataSourceBean;
|
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.context.annotation.Primary;
|
import org.springframework.core.env.Environment;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.jta.JtaTransactionManager;
|
|
import javax.sql.DataSource;
|
import javax.transaction.UserTransaction;
|
import java.util.Properties;
|
|
/**
|
* Druid配置
|
*
|
*
|
*/
|
@Component
|
@Configuration
|
public class DruidConfig {
|
|
@Autowired
|
private DataCourceProperties dataCourceProperties;
|
|
@Bean(name = "dsGoalManage")
|
@Primary
|
@Autowired
|
public DataSource dsGoalManage(Environment env) {
|
final MysqlXADataSource mysqlXADataSource = new MysqlXADataSource();
|
Properties prop = build(env, "spring.datasource.goalmanage.");
|
mysqlXADataSource.setUrl(dataCourceProperties.getGoalmanage().getUrl());
|
mysqlXADataSource.setUser(dataCourceProperties.getGoalmanage().getUsername());
|
mysqlXADataSource.setPassword(dataCourceProperties.getGoalmanage().getPassword());
|
final AtomikosDataSourceBean ds = new AtomikosDataSourceBean();
|
ds.setXaDataSource(mysqlXADataSource);
|
ds.setUniqueResourceName("goalmanage");
|
ds.setPoolSize(dataCourceProperties.getGoalmanage().getInitialSize());
|
ds.setMinPoolSize(dataCourceProperties.getGoalmanage().getMinIdle());
|
ds.setMaxPoolSize(dataCourceProperties.getGoalmanage().getMaxActive());
|
ds.setXaProperties(prop);
|
ds.setMaxIdleTime(3600);
|
ds.setMaxLifetime(3000);
|
ds.setTestQuery(dataCourceProperties.getGoalmanage().getValidationQuery());
|
return ds;
|
}
|
|
|
@Autowired
|
@Primary
|
@Bean(name = "dsEmergency")
|
public AtomikosDataSourceBean dsEmergency(Environment env) {
|
final MysqlXADataSource mysqlXADataSource = new MysqlXADataSource();
|
Properties prop = build(env, "spring.datasource.emergency.");
|
mysqlXADataSource.setUrl(dataCourceProperties.getEmergency().getUrl());
|
mysqlXADataSource.setUser(dataCourceProperties.getEmergency().getUsername());
|
mysqlXADataSource.setPassword(dataCourceProperties.getEmergency().getPassword());
|
final AtomikosDataSourceBean ds = new AtomikosDataSourceBean();
|
ds.setXaDataSource(mysqlXADataSource);
|
ds.setUniqueResourceName("emergency");
|
ds.setPoolSize(dataCourceProperties.getEmergency().getInitialSize());
|
ds.setMinPoolSize(dataCourceProperties.getEmergency().getMinIdle());
|
ds.setMaxPoolSize(dataCourceProperties.getEmergency().getMaxActive());
|
ds.setXaProperties(prop);
|
ds.setMaxIdleTime(3600);
|
ds.setMaxLifetime(3000);
|
ds.setTestQuery(dataCourceProperties.getEmergency().getValidationQuery());
|
return ds;
|
}
|
|
@Autowired
|
@Primary
|
@Bean(name = "dsIncidentManage")
|
public AtomikosDataSourceBean dsIncidentManage(Environment env) {
|
final MysqlXADataSource mysqlXADataSource = new MysqlXADataSource();
|
Properties prop = build(env, "spring.datasource.incidentmanage.");
|
mysqlXADataSource.setUrl(dataCourceProperties.getIncidentmanage().getUrl());
|
mysqlXADataSource.setUser(dataCourceProperties.getIncidentmanage().getUsername());
|
mysqlXADataSource.setPassword(dataCourceProperties.getIncidentmanage().getPassword());
|
final AtomikosDataSourceBean ds = new AtomikosDataSourceBean();
|
ds.setXaDataSource(mysqlXADataSource);
|
ds.setUniqueResourceName("incidentmanage");
|
ds.setPoolSize(dataCourceProperties.getIncidentmanage().getInitialSize());
|
ds.setMinPoolSize(dataCourceProperties.getIncidentmanage().getMinIdle());
|
ds.setMaxPoolSize(dataCourceProperties.getIncidentmanage().getMaxActive());
|
ds.setXaProperties(prop);
|
ds.setMaxIdleTime(3600);
|
ds.setMaxLifetime(3000);
|
ds.setTestQuery(dataCourceProperties.getIncidentmanage().getValidationQuery());
|
return ds;
|
}
|
|
@Autowired
|
@Primary
|
@Bean(name = "dsEquipment")
|
public AtomikosDataSourceBean dsEquipment(Environment env) {
|
final MysqlXADataSource mysqlXADataSource = new MysqlXADataSource();
|
Properties prop = build(env, "spring.datasource.equipment.");
|
mysqlXADataSource.setUrl(dataCourceProperties.getEquipment().getUrl());
|
mysqlXADataSource.setUser(dataCourceProperties.getEquipment().getUsername());
|
mysqlXADataSource.setPassword(dataCourceProperties.getEquipment().getPassword());
|
final AtomikosDataSourceBean ds = new AtomikosDataSourceBean();
|
ds.setXaDataSource(mysqlXADataSource);
|
ds.setUniqueResourceName("equipment");
|
ds.setPoolSize(dataCourceProperties.getEquipment().getInitialSize());
|
ds.setMinPoolSize(dataCourceProperties.getEquipment().getMinIdle());
|
ds.setMaxPoolSize(dataCourceProperties.getEquipment().getMaxActive());
|
ds.setXaProperties(prop);
|
ds.setMaxIdleTime(3600);
|
ds.setMaxLifetime(3000);
|
ds.setTestQuery(dataCourceProperties.getEquipment().getValidationQuery());
|
return ds;
|
}
|
|
|
/**
|
* 注入事物管理器
|
* @return
|
*/
|
@Bean(name = "xatx")
|
public JtaTransactionManager regTransactionManager () {
|
UserTransactionManager userTransactionManager = new UserTransactionManager();
|
UserTransaction userTransaction = new UserTransactionImp();
|
return new JtaTransactionManager(userTransaction, userTransactionManager);
|
}
|
|
|
private Properties build(Environment env, String prefix) {
|
|
Properties prop = new Properties();
|
prop.put("url", env.getProperty(prefix + "url"));
|
prop.put("username", env.getProperty(prefix + "username"));
|
prop.put("password", env.getProperty(prefix + "password"));
|
prop.put("driverClassName", env.getProperty(prefix + "driver-class-name", ""));
|
// prop.put("initialSize", env.getProperty(prefix + "initialSize", Integer.class));
|
// prop.put("maxActive", env.getProperty(prefix + "maxActive", Integer.class));
|
// prop.put("minIdle", env.getProperty(prefix + "minIdle", Integer.class));
|
// prop.put("maxWait", env.getProperty(prefix + "maxWait", Integer.class));
|
// prop.put("poolPreparedStatements", env.getProperty(prefix + "poolPreparedStatements", Boolean.class));
|
//
|
// prop.put("maxPoolPreparedStatementPerConnectionSize",
|
// env.getProperty(prefix + "maxPoolPreparedStatementPerConnectionSize", Integer.class));
|
//
|
// prop.put("maxPoolPreparedStatementPerConnectionSize",
|
// env.getProperty(prefix + "maxPoolPreparedStatementPerConnectionSize", Integer.class));
|
// prop.put("validationQuery", env.getProperty(prefix + "validationQuery"));
|
// prop.put("validationQueryTimeout", env.getProperty(prefix + "validationQueryTimeout", Integer.class));
|
// prop.put("testOnBorrow", env.getProperty(prefix + "testOnBorrow", Boolean.class));
|
// prop.put("testOnReturn", env.getProperty(prefix + "testOnReturn", Boolean.class));
|
// prop.put("testWhileIdle", env.getProperty(prefix + "testWhileIdle", Boolean.class));
|
// prop.put("timeBetweenEvictionRunsMillis",
|
// env.getProperty(prefix + "timeBetweenEvictionRunsMillis", Integer.class));
|
// prop.put("minEvictableIdleTimeMillis", env.getProperty(prefix + "minEvictableIdleTimeMillis", Integer.class));
|
// prop.put("filters", env.getProperty(prefix + "filters"));
|
|
return prop;
|
}
|
|
}
|
