diff --git a/cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java b/cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java index a7c55bd..adc89e8 100644 --- a/cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java +++ b/cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java @@ -351,7 +351,7 @@ public class MySqlDataSource extends BaseDataAbsSource { //壮法 @Override public DataValue[][] getRows () { - log.info("数据源开始调用111"); + log.info("数据源开始aaazz调用111"); MySqlQuery query = getQuery(); log.info("拿到的值query{}",query.getSql()); Integer one = Math.toIntExact(query.getOne()); @@ -383,12 +383,14 @@ public class MySqlDataSource extends BaseDataAbsSource { int c = 0; while (resultSet.next()){ for (int i = 1; i <= columnCount; i++) { +// log.info("反复循环的次数为:{}",i); if (resultSet.isFirst()){ String columnTypeName = metaData.getColumnTypeName(i); DatabaseMetaData metaDataColumns = conn.getMetaData(); ResultSet columns = metaDataColumns.getColumns(null, null, metaData.getTableName(i), metaData.getColumnName(i)); String remarks =null; + while (columns.next()){ remarks = columns.getString("REMARKS"); @@ -412,9 +414,10 @@ public class MySqlDataSource extends BaseDataAbsSource { dataValues[c][i-1]=build; } } + log.info("askldkjjjsk查询完毕啊{}",c); c++; } - + log.info("askldk查询完毕"); } catch (SQLException e) { throw new RuntimeException(e); }finally {