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

修改方法

master
lwj 2024-09-10 16:42:39 +08:00
parent cb6ff86f50
commit 21b8d7483c
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -355,9 +355,13 @@ public class MySqlDataSource extends BaseDataAbsSource {
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());
log.info("参数一"+one);
Integer two = query.getTwo(); Integer two = query.getTwo();
log.info("参数二"+two);
String sql = query.getSql(); String sql = query.getSql();
log.info("sql值"+sql);
Long dataSourceId = query.getDataSourceId(); Long dataSourceId = query.getDataSourceId();
log.info("获取值"+dataSourceId);
ConcurrentHashMap<Integer, DataValue> map = new ConcurrentHashMap<>(); ConcurrentHashMap<Integer, DataValue> map = new ConcurrentHashMap<>();
System.out.println("aaaaaaaaaaaaa-----------"); System.out.println("aaaaaaaaaaaaa-----------");
Source dataSources = sourceRemote.findSourceById(dataSourceId); Source dataSources = sourceRemote.findSourceById(dataSourceId);
@ -383,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();
@ -414,9 +418,10 @@ public class MySqlDataSource extends BaseDataAbsSource {
dataValues[c][i-1]=build; dataValues[c][i-1]=build;
} }
log.info("反复循环的次数为：{}",i);
} }
log.info("askldkjjjsk查询完毕啊{}",c);
c++; c++;
log.info("askldkjjjsk查询完毕啊{}",c);
} }
log.info("askldk查询完毕"); log.info("askldk查询完毕");
} catch (SQLException e) { } catch (SQLException e) {