java Embulk:使用具有多个主键的增量数据忽略最后一个记录值

6ie5vjzr  于 2023-01-11  发布在  Java
关注(0)|答案(1)|浏览(87)

为什么embulk跳过最后一个记录值?
是否有变通方案?
案例:一张错误的table

exec:<omit>
in:
  type: oracle
{% include 'inc/oracle_axlink' %}  # connection info
  query: |
    SELECT CTOIAWASE_NO, CTOIAWASE_YY, NSYDN_ORDER
    FROM TEST.TABLE1
    WHERE CTOIAWASE_NO >= :CTOIAWASE_NO
    AND   CTOIAWASE_YY >= :CTOIAWASE_YY
    AND   NSYDN_ORDER >= :NSYDN_ORDER
  use_raw_query_with_incremental: true
  incremental_columns: [ CTOIAWASE_NO, CTOIAWASE_YY, NSYDN_ORDER ]
  incremental: true
  last_record: [ "00100002", "2020", 1 ]
  options: {characterEncoding: MS932, characterSetResults: MS932,serverTimezone: JST}
  fetch_rows: 10000
  default_column_options:
     NUMERIC: { value_type: long }
     DECIMAL: { value_type: long }
out:<omit>

错误
x一个一个一个一个x一个一个二个x

8hhllhi2

8hhllhi21#

回答有点晚了,但你能试试这个吗?

in:
   type: oracle
   ...
   column_options:
     CTOIAWASE_NO: { value_type: long }
     CTOIAWASE_YY: { value_type: long }
     NSYDN_ORDER: { value_type: long }

(假设这些列是数字列)

相关问题