KSQL执行批量insert报错

青鱼

Biz层代码执行失败
Iterator<String> it = newrows.iterator();
StringBuffer sb = new StringBuffer();
while(it.hasNext()){
sb.append("insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ");
sb.append("('"+it.next()+"','"+fPromoprojBID4+"',0);");
}
KSQL.executeUpdate(sb.toString(), null, "/TH/promotionERP/data", null);


报错内容
Caused by: com.justep.exception.BusinessException: 编码: JUSTEP150210; 提示: 执行KSQL出错, KSQL: insert into TH_PROJEXECUTE  (TH_PROJEXECUTE,fPromoprojBID4,version) values ('R2A44FDD9EE93BDF9MDL','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');
        at com.justep.exception.BusinessException.create(Unknown Source)
        at com.justep.system.data.impl.TableUtilsImplement.ksqlInsert(Unknown Source)
        at com.justep.system.data.impl.TableUtilsImplement.ksqlExecuteUpdate(Unknown Source)
        at com.justep.system.data.KSQL.executeUpdate(Unknown Source)
        at com.justep.system.data.KSQL.executeUpdate(Unknown Source)
        at com.justep.system.data.KSQL.executeUpdate(Unknown Source)
        at PromotionERP.queryTH_PROJEXECUTE(PromotionERP.java:147)
        ... 30 more
Caused by: com.justep.exception.KSQLException: 编码: JUSTEP154115; 提示: KSQL语法错误, H_PROJEXECUTE  ^^(TH_PROJEXECUTE中未找到需要的元素, 位置28期望是<Identifier>
        at com.justep.exception.KSQLException.create(Unknown Source)
        at com.justep.system.ksql.token.TokenManager.matchToken(Unknown Source)
        at com.justep.system.ksql.token.TokenManager.match(Unknown Source)
        at com.justep.system.ksql.parser.AbstractParser.modifyConceptNode(Unknown Source)
        at com.justep.system.ksql.parser.InsertParser.start(Unknown Source)
        at com.justep.system.ksql.parser.InsertParser.start(Unknown Source)
        at com.justep.system.ksql.parser.AbstractParser.parse(Unknown Source)
        ... 36 more

jishuang

确认是你发的代码吗？明显不一样，你的代码中别名，报错的是没有别名的

青鱼

jishuang 发表于 2019-7-11 08:47
确认是你发的代码吗？明显不一样，你的代码中别名，报错的是没有别名的

两种方式都试过的，下面最新的，批量insert

if(newrows != null && newrows.size() != 0){
Iterator<String> it = newrows.iterator();
StringBuffer sb = new StringBuffer();
while(it.hasNext()){
sb.append("insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ");
sb.append("('"+it.next()+"','"+fPromoprojBID4+"','0');");
}
KSQL.executeUpdate(sb.toString(), null, dataModel, null);
}



--报错
Caused by: com.justep.exception.BusinessException: 编码: JUSTEP150210; 提示: 执行KSQL出错, KSQL: insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R2A44FDD9EE93BDF9MDL','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('RB53F4CC0AD3819A36Q6','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('RB30D6F8C31474BD0HBL','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('RCFAB08731A97E7B9L6A','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R0B6D1345DD8FE4E4GOU','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R5B344BC40F3BC04FB0C','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R139AA4D9AA55B8D2KIY','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R40BE98EFAAE0091FCBW','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R743B65F4C0CCD295E22','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('RE093F7B804FA0150JL2','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R4F3240AD5B9B413AX6R','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R65C712C49D51A18A8M5','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('RFCAEF229B342C437TPA','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('RC2B4AA3AD78BDD6B6P7','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('RE1833F3FDB077CA7YNQ','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R310E77F13A6D184DLH2','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R743DC5D013B1ABAEG94','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('RE5BC5280214E0486OL5','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('RB505FFED0D024130AW6','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('RAEA0A9C4655800E8VU3','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R59E3BB12D203F45A7A6','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R2D552343BC8E46046NY','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('RB13C774965EF8558FVC','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('RC737782DEACEFA53UPU','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('RC2C5517597CE0A4D5JZ','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R5D98B1A652EA7FD7GXJ','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R137649590B755372O4J','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R10BA03099A1C0393N9C','42AAFF28583B4B019C5E8CEFC2EF4E6A','0');
        at com.justep.exception.BusinessException.create(Unknown Source)
        at com.justep.system.data.impl.TableUtilsImplement.ksqlInsert(Unknown Source)
        at com.justep.system.data.impl.TableUtilsImplement.ksqlExecuteUpdate(Unknown Source)
        at com.justep.system.data.KSQL.executeUpdate(Unknown Source)
        at com.justep.system.data.KSQL.executeUpdate(Unknown Source)
        at com.justep.system.data.KSQL.executeUpdate(Unknown Source)
        at PromotionERP.queryTH_PROJEXECUTE(PromotionERP.java:203)
        ... 30 more
Caused by: com.justep.exception.KSQLException: 编码: JUSTEP154115; 提示: KSQL语法错误, FC2EF4E6A','0')^^;insert into TH中未找到需要的元素, 位置130期望是<EOF>
        at com.justep.exception.KSQLException.create(Unknown Source)
        at com.justep.system.ksql.token.TokenManager.matchToken(Unknown Source)
        at com.justep.system.ksql.token.TokenManager.match(Unknown Source)
        at com.justep.system.ksql.parser.InsertParser.start(Unknown Source)
        at com.justep.system.ksql.parser.InsertParser.start(Unknown Source)
        at com.justep.system.ksql.parser.AbstractParser.parse(Unknown Source)
        ... 36 more

jishuang

没有这样执行的，在java标准的sql可以这样执行？

青鱼

jishuang 发表于 2019-7-11 09:29
没有这样执行的，在java标准的sql可以这样执行？

刚开始使用标准的mysql批量插入语句写的，也是执行不了，后面查了论坛文章（http://bbs.wex5.com/forum.php?mo ... mp;highlight=insert）如果不是，那请问KSQL批量插入数据要怎么写？

愤怒的橘子

青鱼 发表于 2019-7-11 10:07
刚开始使用标准的mysql批量插入语句写的，也是执行不了，后面查了论坛文章（http://bbs.wex5.com/forum.p ...

可以试试executeBatch批量插入

青鱼

愤怒的橘子 发表于 2019-7-11 10:17
可以试试executeBatch批量插入

KSQL有这个API吗？没有看到额

jishuang

不能这样追加字符串啊，要每个insert into都执行一次executeUpdate啊

你那样是把所有的语句按一个sql处理的，不是批量执行

青鱼

jishuang 发表于 2019-7-11 11:19
不能这样追加字符串啊，要每个insert into都执行一次executeUpdate啊

你那样是把所有的语句按一个sql处理 ...

单独执行一条sql也不行啊

Caused by: com.justep.exception.BusinessException: 编码: JUSTEP150210; 提示: 执行KSQL出错, KSQL: insert into TH_PROJEXECUTE p (p,p.fPromoprojBID4,p.version) values ('R2A44FDD9EE93BDF9MDL','8E81F7D5B5A34001A5BF0FFFF30867E4',0);
        at com.justep.exception.BusinessException.create(Unknown Source)
        at com.justep.system.data.impl.TableUtilsImplement.ksqlInsert(Unknown Source)
        at com.justep.system.data.impl.TableUtilsImplement.ksqlExecuteUpdate(Unknown Source)
        at com.justep.system.data.KSQL.executeUpdate(Unknown Source)
        at com.justep.system.data.KSQL.executeUpdate(Unknown Source)
        at com.justep.system.data.KSQL.executeUpdate(Unknown Source)
        at PromotionERP.queryTH_PROJEXECUTE(PromotionERP.java:213)
        ... 30 more
Caused by: com.justep.exception.KSQLException: 编码: JUSTEP154115; 提示: KSQL语法错误, FFFF30867E4',0)^^;中未找到需要的元素, 位置128期望是<EOF>
        at com.justep.exception.KSQLException.create(Unknown Source)
        at com.justep.system.ksql.token.TokenManager.matchToken(Unknown Source)
        at com.justep.system.ksql.token.TokenManager.match(Unknown Source)
        at com.justep.system.ksql.parser.InsertParser.start(Unknown Source)
        at com.justep.system.ksql.parser.InsertParser.start(Unknown Source)
        at com.justep.system.ksql.parser.AbstractParser.parse(Unknown Source)
        ... 36 more
正常通过其他工具执行是可以的

青鱼

结贴，直接用SQL批量执行，不用KSQL

  Iterator<String> it = newrows.iterator();
        StringBuffer sb = new StringBuffer();
        sb.append("insert into TH_PROJEXECUTE  (fID,fPromoprojBID4,version,fTs) values ");
        while(it.hasNext()){
                sb.append("('"+it.next()+"','"+fPromoprojBID4+"',0,sysdate()),");
        }
        sb.deleteCharAt(sb.length()-1);
        sb.append(";");
        SQL.executeUpdate(sb.toString(), null, dataModel, null);