TreeData
/
cloud-etl-source
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改添加

master
lwj 2024-09-08 20:13:49 +08:00
parent 50590e3fa8
commit 788efab769
2 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/SourceController.java
View File

@ -96,14 +96,8 @@ public class SourceController extends BaseController {
//同步资产结构
@PostMapping("/structure")
public Result structure(@RequestBody Source source) throws ServletException {
if(source.getDatabaseType().equals("mysql")){
return toAjax(sourceService.structure(source));
}
if(source.getDatabaseType().equals("redis")){
return toAjax(sourceService.redis(source));
}
return toAjax(0);
}

4
cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceServiceImpl.java
View File

@ -14,6 +14,7 @@ import com.muyu.domain.Structure;
import com.muyu.domain.TableInfo;
import com.muyu.domain.req.SourceReq;
import groovy.lang.Lazy;
import lombok.extern.java.Log;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import redis.clients.jedis.Jedis;
@ -26,6 +27,7 @@ import java.util.Date;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@Log
@Service
public class SourceServiceImpl extends ServiceImpl<SourceMapper, Source> implements SourceService {
@Autowired
@ -124,6 +126,7 @@ public class SourceServiceImpl extends ServiceImpl<SourceMapper, Source> impleme
String url = "jdbc:" + databaseType + "://" + host + ":" + port + "/" + databaseName + "?" + source.getConnectionParams();
String user = source.getUsername();
String password = source.getPassword();
Connection conn = null;
try {
conn = DriverManager.getConnection(url, user, password);
@ -168,6 +171,7 @@ public class SourceServiceImpl extends ServiceImpl<SourceMapper, Source> impleme
rowCount++;
}
log.info("添加的表名有"+tableName);
TableInfo build = TableInfo.builder()
.basicId(source.getId())
.tableName(tableName)