github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-03 03:40:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2286 from xxsc0529/master

Browse Source 
[FIX]:direct path date type processing
This commit is contained in:
dingxiaobo 2025-04-10 16:17:45 +08:00 committed by GitHub
commit 0824b45c5e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
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,7 +46,13 @@ 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++) {
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); stmt.addBatch(values);
} }