Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-8834

Support CURDATE and CURTIME functions for MySQL DDL

XMLWordPrintable

    • 1
    • False
    • Hide

      None

      Show
      None
    • False

      [2025-03-23 09:59:30,377] WARN [mysql-uds_user_test-dd_ods_uds_user_test_1h-connector|task-0] Ignoring unparseable DDL statement 'CREATE TABLE trace_info (
      id bigint(20) NOT NULL AUTO_INCREMENT,
      trace_code varchar(20) NOT NULL DEFAULT '' COMMENT '溯源码',
      whole_order_no varchar(20) NOT NULL DEFAULT '' COMMENT '购物订单号',
      order_no varchar(20) NOT NULL DEFAULT '' COMMENT '购物子订单号',
      express_no varchar(30) NOT NULL DEFAULT '' COMMENT '快递单号',
      shipped_time datetime DEFAULT NULL COMMENT '发货时间',
      received_time datetime DEFAULT NULL COMMENT '收货时间',
      sku_code varchar(50) DEFAULT NULL COMMENT '商品sku',
      sku_name varchar(255) DEFAULT '' COMMENT '商品名称',
      is_refund tinyint(4) DEFAULT 0 COMMENT '是否退货,0,否,1是',
      is_exchange tinyint(4) DEFAULT 0 COMMENT '是否换货,0,否,1是',
      sap_code varchar(50) NOT NULL DEFAULT '' COMMENT '商品物料号',
      create_time datetime DEFAULT curtime() COMMENT '创建时间',
      update_time datetime DEFAULT NULL COMMENT '更新时间',
      PRIMARY KEY (id),
      UNIQUE KEY idx_unique_key (trace_code,order_no,sku_code),
      KEY idx_order_no (order_no)
      ) ENGINE=InnoDB AUTO_INCREMENT=123 DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC' (io.debezium.connector.binlog.BinlogDatabaseSchema:315)
      io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'CREATE TABLE trace_info (
      id bigint(20) NOT NULL AUTO_INCREMENT,
      trace_code varchar(20) NOT NULL DEFAULT '' COMMENT '溯源码',
      whole_order_no varchar(20) NOT NULL DEFAULT '' COMMENT '购物订单号',
      order_no varchar(20) NOT NULL DEFAULT '' COMMENT '购物子订单号',
      express_no varchar(30) NOT NULL DEFAULT '' COMMENT '快递单号',
      shipped_time datetime DEFAULT NULL COMMENT '发货时间',
      received_time datetime DEFAULT NULL COMMENT '收货时间',
      sku_code varchar(50) DEFAULT NULL COMMENT '商品sku',
      sku_name varchar(255) DEFAULT '' COMMENT '商品名称',
      is_refund tinyint(4) DEFAULT 0 COMMENT '是否退货,0,否,1是',
      is_exchange tinyint(4) DEFAULT 0 COMMENT '是否换货,0,否,1是',
      sap_code varchar(50) NOT NULL DEFAULT '' COMMENT '商品物料号',
      create_time datetime DEFAULT curtime() COMMENT '创建时间',
      update_time datetime DEFAULT NULL COMMENT '更新时间',
      PRIMARY KEY (id),
      UNIQUE KEY idx_unique_key (trace_code,order_no,sku_code),
      KEY idx_order_no (order_no)
      ) ENGINE=InnoDB AUTO_INCREMENT=123 DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC'
      no viable alternative at input 'CREATE TABLE trace_info (\n id bigint(20) NOT NULL AUTO_INCREMENT,\n trace_code varchar(20) NOT NULL DEFAULT '' COMMENT '溯源码',\n whole_order_no varchar(20) NOT NULL DEFAULT '' COMMENT '购物订单号',\n order_no varchar(20) NOT NULL DEFAULT '' COMMENT '购物子订单号',\n express_no varchar(30) NOT NULL DEFAULT '' COMMENT '快递单号',\n shipped_time datetime DEFAULT NULL COMMENT '发货时间',\n received_time datetime DEFAULT NULL COMMENT '收货时间',\n sku_code varchar(50) DEFAULT NULL COMMENT '商品sku',\n sku_name varchar(255) DEFAULT '' COMMENT '商品名称',\n is_refund tinyint(4) DEFAULT 0 COMMENT '是否退货,0,否,1是',\n is_exchange tinyint(4) DEFAULT 0 COMMENT '是否换货,0,否,1是',\n sap_code varchar(50) NOT NULL DEFAULT '' COMMENT '商品物料号',\n create_time datetime DEFAULT curtime'
      at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43)
      at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41)
      at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:543)
      at org.antlr.v4.runtime.DefaultErrorStrategy.reportNoViableAlternative(DefaultErrorStrategy.java:310)
      at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:136)
      at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1264)
      at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:980)
      at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:74)
      at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:48)
      at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:76)
      at io.debezium.connector.binlog.BinlogDatabaseSchema.parseDdl(BinlogDatabaseSchema.java:311)
      at io.debezium.connector.binlog.BinlogDatabaseSchema.parseSnapshotDdl(BinlogDatabaseSchema.java:243)
      at io.debezium.connector.binlog.BinlogSnapshotChangeEventSource.addSchemaEvent(BinlogSnapshotChangeEventSource.java:287)
      at io.debezium.connector.binlog.BinlogSnapshotChangeEventSource.lambda$createSchemaEventsForTables$6(BinlogSnapshotChangeEventSource.java:417)
      at java.base/java.util.HashMap.forEach(HashMap.java:1421)
      at io.debezium.connector.binlog.BinlogSnapshotChangeEventSource.createSchemaEventsForTables(BinlogSnapshotChangeEventSource.java:417)
      at io.debezium.connector.binlog.BinlogSnapshotChangeEventSource.readTableStructure(BinlogSnapshotChangeEventSource.java:364)
      at io.debezium.connector.binlog.BinlogSnapshotChangeEventSource.readTableStructure(BinlogSnapshotChangeEventSource.java:67)
      at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:163)
      at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:96)
      at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:297)
      at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:281)
      at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:192)
      at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:143)
      at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
      at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
      at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
      at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
      at java.base/java.lang.Thread.run(Thread.java:833)
      Caused by: org.antlr.v4.runtime.NoViableAltException
      at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2028)
      at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467)
      at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393)
      at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1056)
      ... 23 more

              anmohant Anisha Mohanty (Inactive)
              835367344@qq.com fei yang (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

                Created:
                Updated:
                Resolved: