|
发表于 2014-10-29 14:36:34
|
显示全部楼层
参考下面代码:
- public static Table DamoQuery(){
- String ksql = "select DE_DEMO.* from DE_DEMO DE_DEMO";
- Table table = KSQL.select(ksql,null, "/demo/db/data", null);
- Iterator<Row> rows = table.iterator();
- if (rows.hasNext()) {
- Row row = rows.next();
- String fid = row.getString("DE_DEMO");
- String fZDMC = row.getString("fZDMC");
- Date sDate = row.getDate("fKSSJ");
- Date eDate = row.getDate("fJSSJ");
- String fDWMC = row.getString("fDWMC");
- String fRWMC = row.getString("fRWMC");
- String[] strs = fDWMC.split(",");
- System.out.println(fDWMC);
- if(strs.length != 0) {
- for(int i = 0; i < strs.length; i++) {
- Row toRow = table.appendRow();
- toRow.setValue("DE_DEMO", CommonUtils.createGUID());
- toRow.setValue("fZDMC", fZDMC);
- toRow.setValue("fRQFW", sDate.toString() + "至" + eDate.toString());
- toRow.setValue("fRWMC", fRWMC);
- toRow.setValue("fDWMC", strs[i]);
- }
- table.getMetaData().setKeyColumn("DE_DEMO");
- table.deleteRows(fid);
- }
- table.getProperties().put(Table.PROP_NAME_ROWID, "DE_DEMO");
- }
- return table;
- }
复制代码
|
|