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

修改查询语句

master
lwj 2024-09-09 02:13:44 +08:00
parent 90b1cebf4f
commit 886e768c36
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java
View File

@ -129,10 +129,10 @@ public class MySqlDataSource extends BaseDataAbsSource {
.build();
map.put(i,build);
if (c <= one && i <= columnCount) {
dataValues[c - 1][i - 1] = build;
}
// dataValues[c][i-1]=build;
// if (c <= one && i <= columnCount) {
// dataValues[c - 1][i - 1] = build;
// }
dataValues[c][i-1]=build;
}else {
DataValue build = DataValue.builder()
@ -141,16 +141,16 @@ public class MySqlDataSource extends BaseDataAbsSource {
.value(resultSet.getObject(i, map.get(i).getType().getTargetType()))
.type(map.get(i).getType())
.build();
// dataValues[c][i-1]=build;
dataValues[c][i-1]=build;
if (c <= one && i <= columnCount) {
dataValues[c - 1][i - 1] = build;
}
}
}
if (c <= one) {
c++;
}
// if (c <= one) {
// c++;
// }
c++;
}
} catch (SQLException e) {
throw new RuntimeException(e);