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

日志

master
陈思豪 2024-09-09 15:09:40 +08:00
parent f15083573a
commit a7bc6b1fad
1 changed files with 2 additions and 4 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/mysql/MySqlDataSource.java
View File

@ -285,8 +285,8 @@ 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++) {
log.info("喜欢次数为===={}",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));
@ -294,7 +294,6 @@ public class MySqlDataSource extends BaseDataAbsSource {
while (columns.next()) { while (columns.next()) {
remarks = columns.getString("REMARKS"); remarks = columns.getString("REMARKS");
log.info("字段备注:" + remarks);
} }
DataValue build = DataValue.builder() DataValue build = DataValue.builder()
.key(metaData.getColumnName(i)) .key(metaData.getColumnName(i))
@ -307,7 +306,6 @@ 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())
@ -323,7 +321,7 @@ public class MySqlDataSource extends BaseDataAbsSource {
c++; c++;
} }
} }
log.info("返回日志"); log.info("返回数据{}",dataValues.length);
return dataValues; return dataValues;
} catch (SQLException e) { } catch (SQLException e) {
throw new RuntimeException(e); throw new RuntimeException(e);