suzhou-jichuang-lanhai
/
YingJi3Sql
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

应急sql更新代码

Browse Source
master
dongdingding 9 months ago
parent d2a6bf2a43
commit 822cc48f42
4 changed files with 33 additions and 28 deletions
Show Stats Download Patch File Download Diff File

5
pom.xml
Unescape View File

@ -66,6 +66,11 @@
<version>2.3.1</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>io.swagger</groupId>
<artifactId>swagger-annotations</artifactId>
<version>1.6.6</version>
</dependency>
</dependencies>

5
src/main/java/com/example/demo/Demo4Application.java
Unescape View File

@ -2,14 +2,19 @@ package com.example.demo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.core.env.Environment;
import org.springframework.scheduling.annotation.EnableScheduling;
import java.net.InetAddress;
import java.net.UnknownHostException;
@EnableScheduling
@SpringBootApplication
public class Demo4Application {
public static void main(String[] args) {
SpringApplication.run(Demo4Application.class, args);
}
}

7
src/main/java/com/example/demo/config/DataSourceConfig.java
Unescape View File

@ -9,7 +9,7 @@ import javax.sql.DataSource;
@Configuration
public class DataSourceConfig {
//云坤
@Bean(name = "dataSource1")
public DataSource dataSource1() {
return DataSourceBuilder.create()
@ -18,7 +18,7 @@ public class DataSourceConfig {
.password("lt_admin@O$c&,")
.build();
}
//公司
@Bean(name = "dataSource2")
public DataSource dataSource2() {
return DataSourceBuilder.create()
@ -27,4 +27,7 @@ public class DataSourceConfig {
.password("Jichuang@2023")
.build();
}
}

44
src/main/java/com/example/demo/task/DataUpdateTask.java
Unescape View File

@ -1,9 +1,14 @@
package com.example.demo.task;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.List;
@ -17,35 +22,30 @@ import java.util.Map;
public class DataUpdateTask {
@Autowired
private JdbcTemplate masterJdbcTemplate;
@Autowired
private JdbcTemplate slaveJdbcTemplate;
// 每天早上7点执行一次任务
@Scheduled(cron = "0 0 7 * * ?")
// 每天早上5点执行一次任务 更新检查记录表
@Scheduled(cron = "0 0 5 * * ?")
public void updateData() {
System.out.println("hello");
// 获取远程数据库所有表名
List<String> tableNames = masterJdbcTemplate.queryForList(
"SELECT table_name FROM information_schema.tables WHERE table_schema = 'tc_zz'",
"SELECT table_name FROM information_schema.tables WHERE table_schema = 'ying_ji'",
String.class);
// 更新每个表的数据到另一个数据库
for (String tableName : tableNames) {
if (!tableName.equals("szs_enterprise_information") && tableName.startsWith("sz") ){
if (tableName.equals("sz_enfor_examine") ){
slaveJdbcTemplate.execute("SET FOREIGN_KEY_CHECKS = 0"); // 禁用外键检查
slaveJdbcTemplate.execute("delete FROM tc_zz." + tableName);
slaveJdbcTemplate.execute("delete FROM ying_ji." + tableName);
// ... 以此类推，根据实际表的数量进行删除操作
slaveJdbcTemplate.execute("SET FOREIGN_KEY_CHECKS = 1"); // 启用外键检查
String selectQuery = "SELECT * FROM tc_zz." + tableName;
String selectQuery = "SELECT * FROM ying_ji." + tableName;
List<Map<String, Object>> tableData = masterJdbcTemplate.queryForList(selectQuery);
for (Map<String, Object> row : tableData) {
StringBuilder insertQuery = new StringBuilder("INSERT INTO tc_zz.")
StringBuilder insertQuery = new StringBuilder("INSERT INTO ying_ji.")
.append(tableName)
.append(" (");
StringBuilder valuesClause = new StringBuilder(" VALUES (");
@ -69,17 +69,12 @@ public class DataUpdateTask {
}
// 每周日晚上5点执行一次任务
@Scheduled(cron = "0 0 17 ? * SUN")
// 每周一早上5点执行一次任务 更新企业原表
@Scheduled(cron = "0 0 5 ? * MON")
public void updateInformationData() {
System.out.println("hello");
// 获取远程数据库所有表名
List<String> tableNames = masterJdbcTemplate.queryForList(
"SELECT table_name FROM information_schema.tables WHERE table_schema = 'tc_zz'",
"SELECT table_name FROM information_schema.tables WHERE table_schema = 'ying_ji'",
String.class);
// 更新每个表的数据到另一个数据库
@ -87,14 +82,14 @@ public class DataUpdateTask {
if (tableName.equals("szs_enterprise_information") ) {
// 删除本地数据库所有表的数据
slaveJdbcTemplate.execute("SET FOREIGN_KEY_CHECKS = 0"); // 禁用外键检查
slaveJdbcTemplate.execute("delete FROM tc_zz." + tableName);
slaveJdbcTemplate.execute("delete FROM ying_ji." + tableName);
// ... 以此类推，根据实际表的数量进行删除操作
slaveJdbcTemplate.execute("SET FOREIGN_KEY_CHECKS = 1"); // 启用外键检查
String selectQuery = "SELECT * FROM tc_zz." + tableName;
String selectQuery = "SELECT * FROM ying_ji." + tableName;
List<Map<String, Object>> tableData = masterJdbcTemplate.queryForList(selectQuery);
for (Map<String, Object> row : tableData) {
StringBuilder insertQuery = new StringBuilder("INSERT INTO tc_zz.")
StringBuilder insertQuery = new StringBuilder("INSERT INTO ying_ji.")
.append(tableName)
.append(" (");
StringBuilder valuesClause = new StringBuilder(" VALUES (");
@ -105,17 +100,14 @@ public class DataUpdateTask {
valuesClause.append("?, ");
values.add(entry.getValue());
}
// 删除最后一个逗号和空格
insertQuery.delete(insertQuery.length() - 2, insertQuery.length());
valuesClause.delete(valuesClause.length() - 2, valuesClause.length());
insertQuery.append(")").append(valuesClause).append(")");
slaveJdbcTemplate.update(insertQuery.toString(), values.toArray());
}
}
}
}
}

Write Preview
Loading…
Cancel
Save