panbaolin/SourceTermAnalysisSystem_java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

数据同步修改

Browse Source
This commit is contained in:
hekaiyu 2025-12-12 16:28:53 +08:00
parent 80412011af
commit ad760018c3
3 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
jeecg-module-sync/src/main/java/org/jeecg/dataSource/controller/StasDataSourceController.java
View File

@ -100,7 +100,7 @@ public class StasDataSourceController extends JeecgController<StasDataSource, IS
@GetMapping(value = "/targetUser") @GetMapping(value = "/targetUser")
public Result<?> queryTargetUserList(@RequestParam(name="taskId",required=false) String taskId) { public Result<?> queryTargetUserList(@RequestParam(name="taskId",required=false) String taskId) {
StasTaskConfig taskConfig = stasTaskConfigService.getById(taskId); StasTaskConfig taskConfig = stasTaskConfigService.getById(taskId);
List<String> tableNameList= stasDataSourceService.queryUserList(taskConfig.getSourceId()); List<String> tableNameList= stasDataSourceService.queryUserList(taskConfig.getTargetId());
if (tableNameList != null && !"".equals(tableNameList)){ if (tableNameList != null && !"".equals(tableNameList)){
return Result.OK(tableNameList); return Result.OK(tableNameList);
} }

7
jeecg-module-sync/src/main/java/org/jeecg/dataSource/service/impl/StasDataSourceServiceImpl.java
View File

@ -87,7 +87,12 @@ public class StasDataSourceServiceImpl extends ServiceImpl<StasDataSourceMapper,
if(SourceDataTypeEnum.ORACLE.getKey() == stasDataSource.getType()){ if(SourceDataTypeEnum.ORACLE.getKey() == stasDataSource.getType()){
return queryDatabaseMetadata(stasDataSource, "SELECT username FROM ALL_USERS", "username"); return queryDatabaseMetadata(stasDataSource, "SELECT username FROM ALL_USERS", "username");
} else { } else {
return queryDatabaseMetadata(stasDataSource, "SELECT datname AS username FROM pg_database WHERE datistemplate = false ORDER BY datname;", "username"); return queryDatabaseMetadata(stasDataSource,
"SELECT schema_name username \n" +
"FROM information_schema.schemata\n" +
"WHERE schema_name NOT IN ('pg_catalog', 'information_schema')\n" +
"AND schema_name NOT LIKE 'pg_toast%'\n" +
"AND schema_name NOT LIKE 'pg_temp%'", "username");
} }
} }

4
jeecg-module-sync/src/main/java/org/jeecg/stasSyncStrategy/service/impl/StasSyncStrategyServiceImpl.java
View File

@ -257,8 +257,8 @@ public class StasSyncStrategyServiceImpl extends ServiceImpl<StasSyncStrategyMap
String targetOwner, String tableName) throws SQLException { String targetOwner, String tableName) throws SQLException {
StringBuilder sqlBuilder = new StringBuilder(); StringBuilder sqlBuilder = new StringBuilder();
//模式名称 //模式名称
// sqlBuilder.append("CREATE TABLE \"").append(targetOwner).append("\".\"").append(tableName).append("\" (\n"); sqlBuilder.append("CREATE TABLE \"").append(targetOwner).append("\".\"").append(tableName).append("\" (\n");
sqlBuilder.append("CREATE TABLE \"").append(tableName).append("\" (\n"); // sqlBuilder.append("CREATE TABLE \"").append(tableName).append("\" (\n");
// 获取列信息 // 获取列信息
String columnSql = "SELECT column_name, data_type, data_length, data_precision, data_scale, nullable " + String columnSql = "SELECT column_name, data_type, data_length, data_precision, data_scale, nullable " +