|
KSQL语句 利用子查询向表中插入数据时报错,求助是不是KSQL的问题?这个KSQL我应该怎么写?
错误如下- Caused by: java.lang.RuntimeException: 执行ksql:insert into HEIZ_XETZD HEIZ_XETZD (HEIZ_XETZD.KCXED1_LSBH,HEIZ_KCDYD.KCXED1_SJDH) (select HEIZ_XETZD.KCXED1_LSBH,H
- EIZ_XETZD.KCXED1_SJDH from HEIZ_XETZD HEIZ_XETZD where HEIZ_XETZD.KCXED1_LSBH = '31812')时出错!
- at DYProcess.dYProcessAfterStart(DYProcess.java:44)
复制代码 KSQL:- String insert_heiz_kcdyd = "insert into HEIZ_XETZD HEIZ_XETZD " +
- "(HEIZ_XETZD.KCXED1_LSBH,HEIZ_KCDYD.KCXED1_SJDH) " +
- "(select HEIZ_XETZD.KCXED1_LSBH,HEIZ_XETZD.KCXED1_SJDH from HEIZ_XETZD HEIZ_XETZD " +
- "where HEIZ_XETZD.KCXED1_LSBH = '" + key + "')";
- KSQL.executeUpdate(insert_heiz_kcdyd,null,"/DY_process/Dy_process/data",null);
复制代码 在这之前写了个update的KSQL:- String update_c10_kSql = "update KCXED1 KCXED1 set KCXED1.KCXED1_C10= 'justep' " +
- "where KCXED1.KCXED1_LSBH = '" + key + "'";
- KSQL.executeUpdate(update_c10_kSql,null,"/DY_process/Dy_process/data",null);
复制代码 运行正常
|
|