From d40ef264dcb8937ed7a01d0eaaa97965c2aa5e86 Mon Sep 17 00:00:00 2001 From: "ranyu.zyh" Date: Thu, 10 Apr 2025 13:56:41 +0800 Subject: [PATCH] fix:direct path date type processing --- .../oceanbasev10writer/task/DirectPathInsertTask.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/DirectPathInsertTask.java b/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/DirectPathInsertTask.java index e39ec0c7..18532158 100644 --- a/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/DirectPathInsertTask.java +++ b/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/DirectPathInsertTask.java @@ -5,6 +5,8 @@ import java.util.Arrays; import java.util.List; import java.util.Queue; +import com.alibaba.datax.common.element.Column; +import com.alibaba.datax.common.element.Column.Type; import com.alibaba.datax.common.element.Record; import com.alibaba.datax.common.util.Configuration; import com.alibaba.datax.plugin.writer.oceanbasev10writer.common.Table; @@ -44,7 +46,13 @@ public class DirectPathInsertTask extends AbstractInsertTask { Object[] values = new Object[columnNumber]; for (Record record : records) { for (int i = 0; i < columnNumber; i++) { - values[i] = record.getColumn(i).getRawData(); + Column column = record.getColumn(i); + //处理一下时间类型 + if (column.getType().equals(Type.DATE)) { + values[i] = record.getColumn(i).asString(); + } else { + values[i] = record.getColumn(i).getRawData(); + } } stmt.addBatch(values); }