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

修改查询语句

master
lwj 2024-09-09 09:32:45 +08:00
parent 883584aae3
commit ed92cc370a
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java
View File

@ -286,6 +286,7 @@ public class MySqlDataSource extends BaseDataAbsSource {
while (resultSet.next()) { while (resultSet.next()) {
for (int i = 1; i <= columnCount; i++) { for (int i = 1; i <= columnCount; i++) {
if (resultSet.isFirst()) { if (resultSet.isFirst()) {
log.info("进入第一次if判断");
String columnTypeName = metaData.getColumnTypeName(i); String columnTypeName = metaData.getColumnTypeName(i);
DatabaseMetaData metaDataColumns = conn.getMetaData(); DatabaseMetaData metaDataColumns = conn.getMetaData();
ResultSet columns = metaDataColumns.getColumns(null, null, metaData.getTableName(i), metaData.getColumnName(i)); ResultSet columns = metaDataColumns.getColumns(null, null, metaData.getTableName(i), metaData.getColumnName(i));
@ -306,6 +307,7 @@ public class MySqlDataSource extends BaseDataAbsSource {
dataValues[c - 1][i - 1] = build; dataValues[c - 1][i - 1] = build;
} }
} else { } else {
log.info("进入第二次elese判断");
DataValue build = DataValue.builder() DataValue build = DataValue.builder()
.key(metaData.getColumnName(i)) .key(metaData.getColumnName(i))
.label(map.get(i).getLabel()) .label(map.get(i).getLabel())