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

测试

master
陈思豪 2024-09-10 16:04:56 +08:00
parent 68d928ab4d
commit d9b49f0afc
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cloud-etl-client/src/main/java/com/muyu/mysql/MySqlDataSource.java
View File

@ -351,7 +351,7 @@ public class MySqlDataSource extends BaseDataAbsSource {
//壮法 //壮法
@Override @Override
public DataValue[][] getRows () { public DataValue[][] getRows () {
log.info("数据源开始调用111"); log.info("数据源开始aaazz调用111");
MySqlQuery query = getQuery(); MySqlQuery query = getQuery();
log.info("拿到的值query{}",query.getSql()); log.info("拿到的值query{}",query.getSql());
Integer one = Math.toIntExact(query.getOne()); Integer one = Math.toIntExact(query.getOne());
@ -383,12 +383,14 @@ public class MySqlDataSource extends BaseDataAbsSource {
int c = 0; int c = 0;
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()){
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));
String remarks =null; String remarks =null;
while (columns.next()){ while (columns.next()){
remarks = columns.getString("REMARKS"); remarks = columns.getString("REMARKS");
@ -412,9 +414,10 @@ public class MySqlDataSource extends BaseDataAbsSource {
dataValues[c][i-1]=build; dataValues[c][i-1]=build;
} }
} }
log.info("askldkjjjsk查询完毕啊{}",c);
c++; c++;
} }
log.info("askldk查询完毕");
} catch (SQLException e) { } catch (SQLException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
}finally { }finally {