-
-
jen 初学数据Lv2
发表于2021-4-27 14:39
悬赏1
已解决
楼主
ETL中Mysql抽到informix报错。MYsql抽取到Oracle不报错。
报错情况如下：
2021-04-27 14:33:35 开始执行ETL过程：[copyof_11]
2021-04-27 14:33:35 开始执行组件：picc_yx_mdqd
2021-04-27 14:33:35 结束执行组件：picc_yx_mdqd
2021-04-27 14:33:35 开始执行组件：picc_yx_mdqd
2021-04-27 14:33:35 结束执行组件：picc_yx_mdqd
2021-04-27 14:33:35 开始执行组件：picc_yx_mdqd
2021-04-27 14:33:39 组件对应的输入SQL：
SELECT T0.PYM_PIID AS PYM_PIID,T0.PYM_FINISHSTATUS AS PYM_FINISHSTATUS,T0.PYM_COMCODE AS PYM_COMCODE,T0.PYM_COMNAME AS PYM_COMNAME,T0.PYM_COMCODE1 AS PYM_COMCODE1,T0.PYM_COMNAME1 AS PYM_COMNAME1,T0.PYM_USERCODE AS PYM_USERCODE,T0.PYM_USERNAME AS PYM_USERNAME,T0.PYM_USERID AS PYM_USERID,T0.PYM_CUSTOMERCNAME AS PYM_CUSTOMERCNAME,T0.PYM_CUSTID AS PYM_CUSTID,T0.PYM_CARID AS PYM_CARID,T0.PYM_FRAMENO AS PYM_FRAMENO,T0.PYM_LICENSENO AS PYM_LICENSENO,T0.PYM_ENROLLDATE AS PYM_ENROLLDATE,T0.PYM_ENDDATE AS PYM_ENDDATE,T0.PYM_INSERTTIMEFORHIS AS PYM_INSERTTIMEFORHIS,T0.PYM_ACTIVITYID AS PYM_ACTIVITYID,T0.PYM_ACTIVITYNAME AS PYM_ACTIVITYNAME,T0.PYM_ACTIVITYHQTYPE AS PYM_ACTIVITYHQTYPE,T0.PYM_FLAG AS PYM_FLAG,T0.PYM_YYFLAG AS PYM_YYFLAG,T0.PYM_BDCS AS PYM_BDCS,T0.PYM_THCS AS PYM_THCS,T0.PYM_YXTHCS AS PYM_YXTHCS,T0.PYM_ZTS AS PYM_ZTS,T0.PYM_YXTS AS PYM_YXTS,T0.PYM_STARTTIME AS PYM_STARTTIME,T0.PYM_ENDTIME AS PYM_ENDTIME,T0.PYM_GZZQ AS PYM_GZZQ,T0.PYM_CBFLAG AS PYM_CBFLAG,T0.PYM_PREMIUM AS PYM_PREMIUM,T0.PYM_TJDATE AS PYM_TJDATE,T0.PYM_ZXCBFLAG AS PYM_ZXCBFLAG,T0.PYM_TDCBFLAG AS PYM_TDCBFLAG,T0.PYM_DSCBFLAG AS PYM_DSCBFLAG,T0.PYM_QSCBFLAG AS PYM_QSCBFLAG,T0.PYM_ZXPREMIUM AS PYM_ZXPREMIUM,T0.PYM_TDPREMIUM AS PYM_TDPREMIUM,T0.PYM_DSPREMIUM AS PYM_DSPREMIUM,T0.PYM_QSPREMIUM AS PYM_QSPREMIUM,T0.TRACKTRADESTATUS AS TRACKTRADESTATUS,T0.NOTICETIME AS NOTICETIME,T0.JSFLAG AS JSFLAG,T0.CODECNAME AS CODECNAME,T0.REMARK AS REMARK,T0.PYM_CDFLAG AS PYM_CDFLAG
FROM (select * from (
SELECT T0.pym_piid AS PYM_PIID,T0.pym_finishstatus AS PYM_FINISHSTATUS,T0.pym_comcode AS PYM_COMCODE,T0.pym_comname AS PYM_COMNAME,T0.pym_comcode1 AS PYM_COMCODE1,T0.pym_comname1 AS PYM_COMNAME1,T0.pym_usercode AS PYM_USERCODE,T0.pym_username AS PYM_USERNAME,T0.pym_userid AS PYM_USERID,T0.pym_customercname AS PYM_CUSTOMERCNAME,T0.pym_custid AS PYM_CUSTID,T0.pym_carid AS PYM_CARID,T0.pym_frameno AS PYM_FRAMENO,T0.pym_licenseno AS PYM_LICENSENO,T0.pym_enrolldate AS PYM_ENROLLDATE,T0.pym_enddate AS PYM_ENDDATE,T0.pym_inserttimeforhis AS PYM_INSERTTIMEFORHIS,T0.pym_activityid AS PYM_ACTIVITYID,T0.pym_activityname AS PYM_ACTIVITYNAME,T0.pym_activityhqtype AS PYM_ACTIVITYHQTYPE,T0.pym_flag AS PYM_FLAG,T0.pym_yyflag AS PYM_YYFLAG,T0.pym_bdcs AS PYM_BDCS,T0.pym_thcs AS PYM_THCS,T0.pym_yxthcs AS PYM_YXTHCS,T0.pym_zts AS PYM_ZTS,T0.pym_yxts AS PYM_YXTS,T0.pym_starttime AS PYM_STARTTIME,T0.pym_endtime AS PYM_ENDTIME,T0.pym_gzzq AS PYM_GZZQ,T0.pym_cbflag AS PYM_CBFLAG,T0.pym_premium AS PYM_PREMIUM,T0.pym_tjdate AS PYM_TJDATE,T0.pym_zxcbflag AS PYM_ZXCBFLAG,T0.pym_tdcbflag AS PYM_TDCBFLAG,T0.pym_dscbflag AS PYM_DSCBFLAG,T0.pym_qscbflag AS PYM_QSCBFLAG,T0.pym_zxpremium AS PYM_ZXPREMIUM,T0.pym_tdpremium AS PYM_TDPREMIUM,T0.pym_dspremium AS PYM_DSPREMIUM,T0.pym_qspremium AS PYM_QSPREMIUM,T0.tracktradestatus AS TRACKTRADESTATUS,T0.noticetime AS NOTICETIME,T0.jsflag AS JSFLAG,T0.codecname AS CODECNAME,T0.remark AS REMARK,T0.pym_cdflag AS PYM_CDFLAG
FROM he1300public.picc_yx_mdqd T0 ) as temp_ limit 10) T0
2021-04-27 14:33:39 开始迁移到目标表：picc_yx_mdqd
SELECT T0.PYM_PIID AS PYM_PIID,T0.PYM_FINISHSTATUS AS PYM_FINISHSTATUS,T0.PYM_COMCODE AS PYM_COMCODE,T0.PYM_COMNAME AS PYM_COMNAME,T0.PYM_COMCODE1 AS PYM_COMCODE1,T0.PYM_COMNAME1 AS PYM_COMNAME1,T0.PYM_USERCODE AS PYM_USERCODE,T0.PYM_USERNAME AS PYM_USERNAME,T0.PYM_USERID AS PYM_USERID,T0.PYM_CUSTOMERCNAME AS PYM_CUSTOMERCNAME,T0.PYM_CUSTID AS PYM_CUSTID,T0.PYM_CARID AS PYM_CARID,T0.PYM_FRAMENO AS PYM_FRAMENO,T0.PYM_LICENSENO AS PYM_LICENSENO,T0.PYM_ENROLLDATE AS PYM_ENROLLDATE,T0.PYM_ENDDATE AS PYM_ENDDATE,T0.PYM_INSERTTIMEFORHIS AS PYM_INSERTTIMEFORHIS,T0.PYM_ACTIVITYID AS PYM_ACTIVITYID,T0.PYM_ACTIVITYNAME AS PYM_ACTIVITYNAME,T0.PYM_ACTIVITYHQTYPE AS PYM_ACTIVITYHQTYPE,T0.PYM_FLAG AS PYM_FLAG,T0.PYM_YYFLAG AS PYM_YYFLAG,T0.PYM_BDCS AS PYM_BDCS,T0.PYM_THCS AS PYM_THCS,T0.PYM_YXTHCS AS PYM_YXTHCS,T0.PYM_ZTS AS PYM_ZTS,T0.PYM_YXTS AS PYM_YXTS,T0.PYM_STARTTIME AS PYM_STARTTIME,T0.PYM_ENDTIME AS PYM_ENDTIME,T0.PYM_GZZQ AS PYM_GZZQ,T0.PYM_CBFLAG AS PYM_CBFLAG,T0.PYM_PREMIUM AS PYM_PREMIUM,T0.PYM_TJDATE AS PYM_TJDATE,T0.PYM_ZXCBFLAG AS PYM_ZXCBFLAG,T0.PYM_TDCBFLAG AS PYM_TDCBFLAG,T0.PYM_DSCBFLAG AS PYM_DSCBFLAG,T0.PYM_QSCBFLAG AS PYM_QSCBFLAG,T0.PYM_ZXPREMIUM AS PYM_ZXPREMIUM,T0.PYM_TDPREMIUM AS PYM_TDPREMIUM,T0.PYM_DSPREMIUM AS PYM_DSPREMIUM,T0.PYM_QSPREMIUM AS PYM_QSPREMIUM,T0.TRACKTRADESTATUS AS TRACKTRADESTATUS,T0.NOTICETIME AS NOTICETIME,T0.JSFLAG AS JSFLAG,T0.CODECNAME AS CODECNAME,T0.REMARK AS REMARK,T0.PYM_CDFLAG AS PYM_CDFLAG
FROM (select * from (
SELECT T0.pym_piid AS PYM_PIID,T0.pym_finishstatus AS PYM_FINISHSTATUS,T0.pym_comcode AS PYM_COMCODE,T0.pym_comname AS PYM_COMNAME,T0.pym_comcode1 AS PYM_COMCODE1,T0.pym_comname1 AS PYM_COMNAME1,T0.pym_usercode AS PYM_USERCODE,T0.pym_username AS PYM_USERNAME,T0.pym_userid AS PYM_USERID,T0.pym_customercname AS PYM_CUSTOMERCNAME,T0.pym_custid AS PYM_CUSTID,T0.pym_carid AS PYM_CARID,T0.pym_frameno AS PYM_FRAMENO,T0.pym_licenseno AS PYM_LICENSENO,T0.pym_enrolldate AS PYM_ENROLLDATE,T0.pym_enddate AS PYM_ENDDATE,T0.pym_inserttimeforhis AS PYM_INSERTTIMEFORHIS,T0.pym_activityid AS PYM_ACTIVITYID,T0.pym_activityname AS PYM_ACTIVITYNAME,T0.pym_activityhqtype AS PYM_ACTIVITYHQTYPE,T0.pym_flag AS PYM_FLAG,T0.pym_yyflag AS PYM_YYFLAG,T0.pym_bdcs AS PYM_BDCS,T0.pym_thcs AS PYM_THCS,T0.pym_yxthcs AS PYM_YXTHCS,T0.pym_zts AS PYM_ZTS,T0.pym_yxts AS PYM_YXTS,T0.pym_starttime AS PYM_STARTTIME,T0.pym_endtime AS PYM_ENDTIME,T0.pym_gzzq AS PYM_GZZQ,T0.pym_cbflag AS PYM_CBFLAG,T0.pym_premium AS PYM_PREMIUM,T0.pym_tjdate AS PYM_TJDATE,T0.pym_zxcbflag AS PYM_ZXCBFLAG,T0.pym_tdcbflag AS PYM_TDCBFLAG,T0.pym_dscbflag AS PYM_DSCBFLAG,T0.pym_qscbflag AS PYM_QSCBFLAG,T0.pym_zxpremium AS PYM_ZXPREMIUM,T0.pym_tdpremium AS PYM_TDPREMIUM,T0.pym_dspremium AS PYM_DSPREMIUM,T0.pym_qspremium AS PYM_QSPREMIUM,T0.tracktradestatus AS TRACKTRADESTATUS,T0.noticetime AS NOTICETIME,T0.jsflag AS JSFLAG,T0.codecname AS CODECNAME,T0.remark AS REMARK,T0.pym_cdflag AS PYM_CDFLAG
FROM he1300public.picc_yx_mdqd T0 ) as temp_ limit 10) T0
2021-04-27 14:33:39 开始迁移到目标表：picc_yx_mdqd
2021-04-27 14:33:39 数据查询耗时：83毫秒结果集结构：
PYM_PIID(C|100),PYM_FINISHSTATUS(C|100),PYM_COMCODE(C|100),PYM_COMNAME(C|100),PYM_COMCODE1(C|100),PYM_COMNAME1(C|100),PYM_USERCODE(C|100),PYM_USERNAME(C|100),PYM_USERID(C|100),PYM_CUSTOMERCNAME(C|100),PYM_CUSTID(C|100),PYM_CARID(C|100),PYM_FRAMENO(C|100),PYM_LICENSENO(C|100),PYM_ENROLLDATE(C|100),PYM_ENDDATE(C|100),PYM_INSERTTIMEFORHIS(C|100),PYM_ACTIVITYID(C|100),PYM_ACTIVITYNAME(C|100),PYM_ACTIVITYHQTYPE(C|100),PYM_FLAG(C|100),PYM_YYFLAG(C|100),PYM_BDCS(C|100),PYM_THCS(C|100),PYM_YXTHCS(C|100),PYM_ZTS(C|100),PYM_YXTS(C|100),PYM_STARTTIME(C|100),PYM_ENDTIME(C|100),PYM_GZZQ(C|100),PYM_CBFLAG(C|100),PYM_PREMIUM(C|100),PYM_TJDATE(C|100),PYM_ZXCBFLAG(C|100),PYM_TDCBFLAG(C|100),PYM_DSCBFLAG(C|100),PYM_QSCBFLAG(C|100),PYM_ZXPREMIUM(C|100),PYM_TDPREMIUM(C|100),PYM_DSPREMIUM(C|100),PYM_QSPREMIUM(C|100),TRACKTRADESTATUS(C|100),NOTICETIME(C|100),JSFLAG(C|100),CODECNAME(C|100),REMARK(C|255),PYM_CDFLAG(C|20)
2021-04-27 14:33:39 数据迁移插入SQL：
insert into picc_yx_mdqd("pym_piid","pym_finishstatus","pym_comcode","pym_comname","pym_comcode1","pym_comname1","pym_usercode","pym_username","pym_userid","pym_customercname","pym_custid","pym_carid","pym_frameno","pym_licenseno","pym_enrolldate","pym_enddate","pym_inserttimeforhis","pym_activityid","pym_activityname","pym_activityhqtype","pym_flag","pym_yyflag","pym_bdcs","pym_thcs","pym_yxthcs","pym_zts","pym_yxts","pym_starttime","pym_endtime","pym_gzzq","pym_cbflag","pym_premium","pym_tjdate","pym_zxcbflag","pym_tdcbflag","pym_dscbflag","pym_qscbflag","pym_zxpremium","pym_tdpremium","pym_dspremium","pym_qspremium","tracktradestatus","noticetime","jsflag","codecname","remark","pym_cdflag") values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
2021-04-27 14:33:40 com.esen.exception.RuntimeException4I18N: 执行数据迁移时出现异常
at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:408)
at com.informix.jdbc.IfxSqli.a(IfxSqli.java:3140)
at com.informix.jdbc.IfxSqli.D(IfxSqli.java:3420)
at com.informix.jdbc.IfxSqli.dispatchMsg(IfxSqli.java:2333)
at com.informix.jdbc.IfxSqli.receiveMessage(IfxSqli.java:2258)
at com.informix.jdbc.IfxSqli.executePrepare(IfxSqli.java:1234)
at com.informix.jdbc.IfxPreparedStatement.f(IfxPreparedStatement.java:307)
at com.informix.jdbc.IfxPreparedStatement.a(IfxPreparedStatement.java:288)
at com.informix.jdbc.IfxPreparedStatement.(IfxPreparedStatement.java:181)
at com.informix.jdbc.IfxSqliConnect.h(IfxSqliConnect.java:6070)
at com.informix.jdbc.IfxSqliConnect.prepareStatement(IfxSqliConnect.java:2412)
at com.esen.jdbc.pool.PooledConnection.prepareStatement(PooledConnection.java:418)
at com.esen.edf.data.migrate.jdbc.JdbcWriter.doSingleInsert(JdbcWriter.java:196)
at com.esen.edf.data.migrate.jdbc.JdbcWriter.doBatchInsert(JdbcWriter.java:186)
at com.esen.edf.data.migrate.common.buffer.DataReceiverRequestTask.call(DataReceiverRequestTask.java:75)
at com.esen.edf.data.migrate.common.buffer.DataReceiverRequestTask.call(DataReceiverRequestTask.java:29)
at com.esen.ethreadpool.req.RequestTaskFutureImpl.call(RequestTaskFutureImpl.java:100)
at com.esen.scheduling.LocaleTask.call(LocaleTask.java:56)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: com.esen.exception.RuntimeException4I18N: 接收数据时出现异常
... 22 more
Caused by: java.sql.SQLException: A syntax error has occurred.
... 22 more
Caused by: java.sql.SQLException
at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:408)
at com.informix.jdbc.IfxSqli.D(IfxSqli.java:3425)
... 19 more
2021-04-27 14:33:40 执行ETL过程[copyof_11]出现异常：com.esen.exception.RuntimeException4I18N: 执行数据迁移时出现异常
at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:408)
at com.informix.jdbc.IfxSqli.a(IfxSqli.java:3140)
at com.informix.jdbc.IfxSqli.D(IfxSqli.java:3420)
at com.informix.jdbc.IfxSqli.dispatchMsg(IfxSqli.java:2333)
at com.informix.jdbc.IfxSqli.receiveMessage(IfxSqli.java:2258)
at com.informix.jdbc.IfxSqli.executePrepare(IfxSqli.java:1234)
at com.informix.jdbc.IfxPreparedStatement.f(IfxPreparedStatement.java:307)
at com.informix.jdbc.IfxPreparedStatement.a(IfxPreparedStatement.java:288)
at com.informix.jdbc.IfxPreparedStatement.(IfxPreparedStatement.java:181)
at com.informix.jdbc.IfxSqliConnect.h(IfxSqliConnect.java:6070)
at com.informix.jdbc.IfxSqliConnect.prepareStatement(IfxSqliConnect.java:2412)
at com.esen.jdbc.pool.PooledConnection.prepareStatement(PooledConnection.java:418)
at com.esen.edf.data.migrate.jdbc.JdbcWriter.doSingleInsert(JdbcWriter.java:196)
at com.esen.edf.data.migrate.jdbc.JdbcWriter.doBatchInsert(JdbcWriter.java:186)
at com.esen.edf.data.migrate.common.buffer.DataReceiverRequestTask.call(DataReceiverRequestTask.java:75)
at com.esen.edf.data.migrate.common.buffer.DataReceiverRequestTask.call(DataReceiverRequestTask.java:29)
at com.esen.ethreadpool.req.RequestTaskFutureImpl.call(RequestTaskFutureImpl.java:100)
at com.esen.scheduling.LocaleTask.call(LocaleTask.java:56)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: com.esen.exception.RuntimeException4I18N: 接收数据时出现异常
... 22 more
Caused by: java.sql.SQLException: A syntax error has occurred.
... 22 more
Caused by: java.sql.SQLException
at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:408)
at com.informix.jdbc.IfxSqli.D(IfxSqli.java:3425)
... 19 more
PYM_PIID(C|100),PYM_FINISHSTATUS(C|100),PYM_COMCODE(C|100),PYM_COMNAME(C|100),PYM_COMCODE1(C|100),PYM_COMNAME1(C|100),PYM_USERCODE(C|100),PYM_USERNAME(C|100),PYM_USERID(C|100),PYM_CUSTOMERCNAME(C|100),PYM_CUSTID(C|100),PYM_CARID(C|100),PYM_FRAMENO(C|100),PYM_LICENSENO(C|100),PYM_ENROLLDATE(C|100),PYM_ENDDATE(C|100),PYM_INSERTTIMEFORHIS(C|100),PYM_ACTIVITYID(C|100),PYM_ACTIVITYNAME(C|100),PYM_ACTIVITYHQTYPE(C|100),PYM_FLAG(C|100),PYM_YYFLAG(C|100),PYM_BDCS(C|100),PYM_THCS(C|100),PYM_YXTHCS(C|100),PYM_ZTS(C|100),PYM_YXTS(C|100),PYM_STARTTIME(C|100),PYM_ENDTIME(C|100),PYM_GZZQ(C|100),PYM_CBFLAG(C|100),PYM_PREMIUM(C|100),PYM_TJDATE(C|100),PYM_ZXCBFLAG(C|100),PYM_TDCBFLAG(C|100),PYM_DSCBFLAG(C|100),PYM_QSCBFLAG(C|100),PYM_ZXPREMIUM(C|100),PYM_TDPREMIUM(C|100),PYM_DSPREMIUM(C|100),PYM_QSPREMIUM(C|100),TRACKTRADESTATUS(C|100),NOTICETIME(C|100),JSFLAG(C|100),CODECNAME(C|100),REMARK(C|255),PYM_CDFLAG(C|20)
2021-04-27 14:33:39 数据迁移插入SQL：
insert into picc_yx_mdqd("pym_piid","pym_finishstatus","pym_comcode","pym_comname","pym_comcode1","pym_comname1","pym_usercode","pym_username","pym_userid","pym_customercname","pym_custid","pym_carid","pym_frameno","pym_licenseno","pym_enrolldate","pym_enddate","pym_inserttimeforhis","pym_activityid","pym_activityname","pym_activityhqtype","pym_flag","pym_yyflag","pym_bdcs","pym_thcs","pym_yxthcs","pym_zts","pym_yxts","pym_starttime","pym_endtime","pym_gzzq","pym_cbflag","pym_premium","pym_tjdate","pym_zxcbflag","pym_tdcbflag","pym_dscbflag","pym_qscbflag","pym_zxpremium","pym_tdpremium","pym_dspremium","pym_qspremium","tracktradestatus","noticetime","jsflag","codecname","remark","pym_cdflag") values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
2021-04-27 14:33:40 com.esen.exception.RuntimeException4I18N: 执行数据迁移时出现异常
at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:408)
at com.informix.jdbc.IfxSqli.a(IfxSqli.java:3140)
at com.informix.jdbc.IfxSqli.D(IfxSqli.java:3420)
at com.informix.jdbc.IfxSqli.dispatchMsg(IfxSqli.java:2333)
at com.informix.jdbc.IfxSqli.receiveMessage(IfxSqli.java:2258)
at com.informix.jdbc.IfxSqli.executePrepare(IfxSqli.java:1234)
at com.informix.jdbc.IfxPreparedStatement.f(IfxPreparedStatement.java:307)
at com.informix.jdbc.IfxPreparedStatement.a(IfxPreparedStatement.java:288)
at com.informix.jdbc.IfxPreparedStatement.(IfxPreparedStatement.java:181)
at com.informix.jdbc.IfxSqliConnect.h(IfxSqliConnect.java:6070)
at com.informix.jdbc.IfxSqliConnect.prepareStatement(IfxSqliConnect.java:2412)
at com.esen.jdbc.pool.PooledConnection.prepareStatement(PooledConnection.java:418)
at com.esen.edf.data.migrate.jdbc.JdbcWriter.doSingleInsert(JdbcWriter.java:196)
at com.esen.edf.data.migrate.jdbc.JdbcWriter.doBatchInsert(JdbcWriter.java:186)
at com.esen.edf.data.migrate.common.buffer.DataReceiverRequestTask.call(DataReceiverRequestTask.java:75)
at com.esen.edf.data.migrate.common.buffer.DataReceiverRequestTask.call(DataReceiverRequestTask.java:29)
at com.esen.ethreadpool.req.RequestTaskFutureImpl.call(RequestTaskFutureImpl.java:100)
at com.esen.scheduling.LocaleTask.call(LocaleTask.java:56)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: com.esen.exception.RuntimeException4I18N: 接收数据时出现异常
... 22 more
Caused by: java.sql.SQLException: A syntax error has occurred.
... 22 more
Caused by: java.sql.SQLException
at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:408)
at com.informix.jdbc.IfxSqli.D(IfxSqli.java:3425)
... 19 more
2021-04-27 14:33:40 执行ETL过程[copyof_11]出现异常：com.esen.exception.RuntimeException4I18N: 执行数据迁移时出现异常
at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:408)
at com.informix.jdbc.IfxSqli.a(IfxSqli.java:3140)
at com.informix.jdbc.IfxSqli.D(IfxSqli.java:3420)
at com.informix.jdbc.IfxSqli.dispatchMsg(IfxSqli.java:2333)
at com.informix.jdbc.IfxSqli.receiveMessage(IfxSqli.java:2258)
at com.informix.jdbc.IfxSqli.executePrepare(IfxSqli.java:1234)
at com.informix.jdbc.IfxPreparedStatement.f(IfxPreparedStatement.java:307)
at com.informix.jdbc.IfxPreparedStatement.a(IfxPreparedStatement.java:288)
at com.informix.jdbc.IfxPreparedStatement.(IfxPreparedStatement.java:181)
at com.informix.jdbc.IfxSqliConnect.h(IfxSqliConnect.java:6070)
at com.informix.jdbc.IfxSqliConnect.prepareStatement(IfxSqliConnect.java:2412)
at com.esen.jdbc.pool.PooledConnection.prepareStatement(PooledConnection.java:418)
at com.esen.edf.data.migrate.jdbc.JdbcWriter.doSingleInsert(JdbcWriter.java:196)
at com.esen.edf.data.migrate.jdbc.JdbcWriter.doBatchInsert(JdbcWriter.java:186)
at com.esen.edf.data.migrate.common.buffer.DataReceiverRequestTask.call(DataReceiverRequestTask.java:75)
at com.esen.edf.data.migrate.common.buffer.DataReceiverRequestTask.call(DataReceiverRequestTask.java:29)
at com.esen.ethreadpool.req.RequestTaskFutureImpl.call(RequestTaskFutureImpl.java:100)
at com.esen.scheduling.LocaleTask.call(LocaleTask.java:56)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: com.esen.exception.RuntimeException4I18N: 接收数据时出现异常
... 22 more
Caused by: java.sql.SQLException: A syntax error has occurred.
... 22 more
Caused by: java.sql.SQLException
at com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:408)
at com.informix.jdbc.IfxSqli.D(IfxSqli.java:3425)
... 19 more
