root
/
DataX
mirror of https://github.com/alibaba/DataX.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

fix:direct path date type processing

This commit is contained in:
ranyu.zyh 2025-04-10 13:56:41 +08:00
parent f95319ab4f
commit d40ef264dc
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/DirectPathInsertTask.java
View File

@ -5,6 +5,8 @@ import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.Queue; 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.element.Record;
import com.alibaba.datax.common.util.Configuration; import com.alibaba.datax.common.util.Configuration;
import com.alibaba.datax.plugin.writer.oceanbasev10writer.common.Table; import com.alibaba.datax.plugin.writer.oceanbasev10writer.common.Table;
@ -44,8 +46,14 @@ public class DirectPathInsertTask extends AbstractInsertTask {
Object[] values = new Object[columnNumber]; Object[] values = new Object[columnNumber];
for (Record record : records) { for (Record record : records) {
for (int i = 0; i < columnNumber; i++) { for (int i = 0; i < columnNumber; i++) {
Column column = record.getColumn(i);
//处理一下时间类型
if (column.getType().equals(Type.DATE)) {
values[i] = record.getColumn(i).asString();
} else {
values[i] = record.getColumn(i).getRawData(); values[i] = record.getColumn(i).getRawData();
} }
}
stmt.addBatch(values); stmt.addBatch(values);
} }