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

提交更新返回值

master
lwj 2024-09-08 11:23:41 +08:00
parent 06e6d09946
commit 5b61224161
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/ProductServiceImpl.java
View File

@ -53,7 +53,6 @@ public class ProductServiceImpl implements ProductService {
Connection finalConnection = connection; Connection finalConnection = connection;
executorService.submit(() -> { executorService.submit(() -> {
try { try {
addCount.addAndGet(insertRow(finalConnection, tableName, dataValueList)); addCount.addAndGet(insertRow(finalConnection, tableName, dataValueList));
} catch (SQLException e) { } catch (SQLException e) {
// 记录异常 // 记录异常
@ -160,20 +159,28 @@ public class ProductServiceImpl implements ProductService {
Object obj = value.getValue(); Object obj = value.getValue();
if (obj instanceof String) { if (obj instanceof String) {
ps.setString(index++, (String) obj); ps.setString(index++, (String) obj);
log.info("类型为String,值{}",obj);
} else if (obj instanceof Integer) { } else if (obj instanceof Integer) {
ps.setInt(index++, (Integer) obj); ps.setInt(index++, (Integer) obj);
log.info("类型为Integer,值{}",obj);
} else if (obj instanceof Double) { } else if (obj instanceof Double) {
ps.setDouble(index++, (Double) obj); ps.setDouble(index++, (Double) obj);
log.info("类型为Double,值{}",obj);
} else if (obj instanceof Date) { } else if (obj instanceof Date) {
ps.setDate(index++, new java.sql.Date(((Date) obj).getTime())); ps.setDate(index++, new java.sql.Date(((Date) obj).getTime()));
log.info("类型为Date,值{}",obj);
} else if (obj instanceof Boolean) { } else if (obj instanceof Boolean) {
ps.setBoolean(index++, (Boolean) obj); ps.setBoolean(index++, (Boolean) obj);
log.info("类型为Boolean,值{}",obj);
} else if (obj instanceof Float) { } else if (obj instanceof Float) {
ps.setFloat(index++, (Float) obj); ps.setFloat(index++, (Float) obj);
log.info("类型为Float,值{}",obj);
} else if (obj instanceof Long) { } else if (obj instanceof Long) {
ps.setLong(index++, (Long) obj); ps.setLong(index++, (Long) obj);
log.info("类型为Long,值{}",obj);
} else { } else {
ps.setObject(index++, obj); ps.setObject(index++, obj);
log.info("类型为Object,值{}",obj);
} }
} }
ps.addBatch(); ps.addBatch();