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

找报错

master
陈思豪 2024-09-10 17:40:09 +08:00
parent 21b8d7483c
commit eaf8ba8a83
1 changed files with 25 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -387,7 +387,7 @@ 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();
@ -397,16 +397,32 @@ public class MySqlDataSource extends BaseDataAbsSource {
while (columns.next()){ while (columns.next()){
remarks = columns.getString("REMARKS"); remarks = columns.getString("REMARKS");
log.info("字段备注:"+remarks); log.info("字段备注:"+remarks);
} }
log.info("字段备注提取完成");
Class clazz = DataType.convertType(columnTypeName);
log.info("字段类型：{}", clazz.getName());
Object object = resultSet.getObject(i, clazz);
log.info("字段类型：{}", object);
String key = metaData.getColumnName(i);
log.info("字段Key：{}", key);
log.info("columnTypeName{},",columnTypeName);
DataType bySqlType = DataType.findBySqlType(columnTypeName);
log.info("字段数据类型：{}", bySqlType);
DataValue build = DataValue.builder() DataValue build = DataValue.builder()
.key(metaData.getColumnName(i)) .key(key)
.label(remarks) .label(remarks)
.value(resultSet.getObject(i, DataType.convertType(columnTypeName))) .value(object)
.type(DataType.findBySqlType(columnTypeName)) .type(bySqlType)
.build(); .build();
DataValue dataValue = new DataValue();
dataValue.setKey(key);
dataValue.setValue(object);
dataValue.setType(bySqlType);
dataValue.setLabel(remarks);
log.info("Map插入内容：{}-{}-{}", i,build,dataValue);
map.put(i,build); map.put(i,build);
log.info("插入内容：{}-{}", c, i);
dataValues[c][i-1]=build; dataValues[c][i-1]=build;
}else { }else {
DataValue build = DataValue.builder() DataValue build = DataValue.builder()
@ -415,18 +431,19 @@ public class MySqlDataSource extends BaseDataAbsSource {
.value(resultSet.getObject(i, map.get(i).getType().getTargetType())) .value(resultSet.getObject(i, map.get(i).getType().getTargetType()))
.type(map.get(i).getType()) .type(map.get(i).getType())
.build(); .build();
log.info("插入内容：{}-{}", c, i);
dataValues[c][i-1]=build; dataValues[c][i-1]=build;
} }
log.info("反复循环的次数为：{}",i);
} }
c++; c++;
log.info("askldkjjjsk查询完毕啊{}",c); log.info("askldkjjjsk查询完毕啊{}",c);
} }
log.info("askldk查询完毕"); log.info("askldk查询完毕");
} catch (SQLException e) { } catch (Throwable e) {
log.error("执行发生异常：{}", e.getMessage(), e);
throw new RuntimeException(e); throw new RuntimeException(e);
}finally { }finally {
log.info("关闭连接池");
close(hikariDataSource); // 关闭数据源 close(hikariDataSource); // 关闭数据源
} }
log.info("拿到的值aaaa为{}",dataValues.length); log.info("拿到的值aaaa为{}",dataValues.length);