|

楼主 |
发表于 2018-5-4 16:51:56
|
显示全部楼层
List<Object> listValue = new ArrayList<Object>();
Collection<String> columns = table.getColumnNames();
Iterator<Row> rows = table.iterator();
if (rows.hasNext()) {
Row row = rows.next();
for (String column : columns) {
Object value = row.getValue(column);
listValue.add(value);
}
}
从list里拿出来值 作为ksql的 参数
StringBuilder sql = new StringBuilder(
"insert into CH_TaskManagement a(a,a.fAccessory,a.fCreatePeople,a.fCreateTime) values");
sql.append("('" + fid + "','" + accessory + "','" + caeatePeople + "',stringToDateTime('" +listValue.get(3) + "'))");
String sql1 = sql.toString();
System.out.println(sql1);
KSQL.executeUpdate(sql1, null, "/chwn/taskManagement/data", null); |
|