Skip to content

B
baihang-report
Commit a4221f9b authored by 郝彦辉's avatar 郝彦辉
Browse files
Options

tidb的call_record表历史数据初始化

parent e3e9fa6f
Hide whitespace changes
Inline Side-by-side
Showing with 41 additions and 81 deletions
src/main/java/cn/quantgroup/report/utils/HikDataSource.java deleted 100644 → 0
View file @ e3e9fa6f
package cn.quantgroup.report.utils;
import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import javax.sql.DataSource;
/**
* Created by renfeng on 2019/4/22.
*/
public enum HikDataSource {
HIK_DATA_SOURCE;
public DataSource dataSourceJdbc;
public DataSource dataSource2;
HikDataSource(){
if(dataSourceJdbc==null){
System.out.println("======创建数据库连接dataSource1======");
HikariConfig config = new HikariConfig();
// config.setJdbcUrl("jdbc:mysql://10.17.115.6:4010/rc_comservice_data_pool_v2?useUnicode=true&characterEncoding=UTF8&rewriteBatchedStatements=true");
// config.setUsername("rc_comservice_data_pool_v2_w");
// config.setPassword("w9pr8IPJkLmUSBe4");
//以下是腾讯云的tidb的配置
// config.setJdbcUrl("jdbc:mysql://172.18.3.21:4010/rc_comservice_data_pool_v3?useUnicode=true&characterEncoding=UTF8&rewriteBatchedStatements=true");
// config.setUsername("rc_comservice_data_pool_v3_w");
// config.setPassword("L4letZzT1LmPCxAt");
// config.setJdbcUrl("jdbc:mysql://10.17.115.6:4010/rc_comservice_data_pool_v2?useUnicode=true&characterEncoding=UTF8&rewriteBatchedStatements=true");
// config.setUsername("rc_comservice_data_pool_v2_w");
// config.setPassword("w9pr8IPJkLmUSBe4");
// config.setJdbcUrl("jdbc:mysql://xyqb-app-db.quantgroups.com:6607/business_flow?useUnicode=true&characterEncoding=UTF8&rewriteBatchedStatements=true");
// config.setUsername("business_flow_w");
// config.setPassword("w5XM330jD7kyR8ZH");
// config.setDriverClassName("com.mysql.jdbc.Driver");
// config.setMaximumPoolSize(50);
// config.setMinimumIdle(20);
// config.addDataSourceProperty("cachePrepStmts", "true");
// config.addDataSourceProperty("prepStmtCacheSize", "250");
// config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048");
// dataSource = new HikariDataSource(config);
config.setJdbcUrl("jdbc:mysql://xyqb-rule-db.quantgroups.com:6606/risk_datasource?useUnicode=true&characterEncoding=UTF8&rewriteBatchedStatements=true");
config.setUsername("risk_datasource_w");
config.setPassword("50GjQLd6hUOSeTMB");
// config.setJdbcUrl("jdbc:mysql://172.30.220.9:3306/project?useUnicode=true&characterEncoding=UTF8&rewriteBatchedStatements=true");
// config.setUsername("qa");
// config.setPassword("qatest");
config.setDriverClassName("com.mysql.jdbc.Driver");
config.setMaximumPoolSize(50);
config.setMinimumIdle(20);
config.addDataSourceProperty("cachePrepStmts", "true");
config.addDataSourceProperty("prepStmtCacheSize", "250");
config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048");
dataSourceJdbc = new HikariDataSource(config);
System.out.println("创建数据库连接完毕");
}
// if(dataSource2==null){
// System.out.println("======创建数据库连接dataSource2======");
// HikariConfig config = new HikariConfig();
// config.setJdbcUrl("jdbc:mysql://172.20.6.29:4010/rc_real_time_data_pool?useUnicode=true&characterEncoding=UTF8");
// config.setDriverClassName("com.mysql.jdbc.Driver");
//// config.setUsername("rc_comservice_data_pool_v2_w");
//// config.setPassword("w9pr8IPJkLmUSBe4");
// config.setUsername("rc_real_time_data_pool_r");
// config.setPassword("0lSEnS1HtvysJbP5");
// config.setMaximumPoolSize(5);
// config.setMinimumIdle(5);
// config.addDataSourceProperty("cachePrepStmts", "true");
// config.addDataSourceProperty("prepStmtCacheSize", "250");
// config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048");
// dataSource2 = new HikariDataSource(config);
// }else{
// System.out.println("======无需在创建======");
// }
}
}
src/main/java/cn/quantgroup/report/utils/HikDataSourceTidbRisk.java 0 → 100644
View file @ a4221f9b
package cn.quantgroup.report.utils;
import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import javax.sql.DataSource;
/**
* Created by renfeng on 2019/4/22.
*/
public enum HikDataSourceTidbRisk {
HIK_DATA_SOURCE_TIDB_RISK;
public DataSource dataSourceJdbc;
HikDataSourceTidbRisk(){
if(dataSourceJdbc==null){
System.out.println("======tidb.risk_datasource创建数据库连接dataSource1======");
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:mysql://fengkong-tidb.quantgroups.com:4010/risk_datasource?useUnicode=true&characterEncoding=UTF8&rewriteBatchedStatements=true");
config.setUsername("risk_datasource_w");
config.setPassword("50GjQLd6hUOSeTMB");
config.setDriverClassName("com.mysql.jdbc.Driver");
config.setMaximumPoolSize(50);
config.setMinimumIdle(20);
config.addDataSourceProperty("cachePrepStmts", "true");
config.addDataSourceProperty("prepStmtCacheSize", "250");
config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048");
dataSourceJdbc = new HikariDataSource(config);
System.out.println("tidb.risk_datasource创建数据库连接完毕");
}
}
}
src/main/java/cn/quantgroup/report/utils/JdbcUtils.java
View file @ a4221f9b
......@@ -8,6 +8,8 @@ import javax.sql.DataSource;
import java.sql.*;
import java.util.List;
import static cn.quantgroup.report.utils.HikDataSourceTidbRisk.HIK_DATA_SOURCE_TIDB_RISK;
/**
* @Author fengjunkai
*/
......@@ -63,7 +65,10 @@ public class JdbcUtils {
Connection conn = null;
PreparedStatement ps = null;
try {
conn = dataSourceJdbc.getConnection();
//conn = dataSourceJdbc.getConnection(); //这样的慢，rewriteBatchedStatements=true不生效
conn = HIK_DATA_SOURCE_TIDB_RISK.dataSourceJdbc.getConnection();
ps = conn.prepareStatement(sql);
conn.setAutoCommit(false);
//"INSERT INTO `call_record` (`request_url`, `channel_type`, `channel_id`, `transaction_id`, `uuid`, `url_type`, `code`, `created_at`, `updated_at`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?);"
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment