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

[feature][plugin][sybase] datax support sybase plugins. #1780

Browse Source 
add sybaseWriter code
This commit is contained in:
xiaopengm 2023-05-10 10:40:19 +08:00
parent e03f869731
commit ec2402b546
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
sybasewriter/src/main/java/com/alibaba/datax/plugin/reader/sybasewriter/SybaseWriter.java → sybasewriter/src/main/java/com/alibaba/datax/plugin/writer/sybasewriter/SybaseWriter.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.reader.sybasewriter; package com.alibaba.datax.plugin.writer.sybasewriter;
import com.alibaba.datax.common.plugin.RecordReceiver; import com.alibaba.datax.common.plugin.RecordReceiver;
import com.alibaba.datax.common.spi.Writer; import com.alibaba.datax.common.spi.Writer;
@ -6,13 +6,14 @@ import com.alibaba.datax.common.util.Configuration;
import com.alibaba.datax.plugin.rdbms.util.DataBaseType; import com.alibaba.datax.plugin.rdbms.util.DataBaseType;
import com.alibaba.datax.plugin.rdbms.writer.CommonRdbmsWriter; import com.alibaba.datax.plugin.rdbms.writer.CommonRdbmsWriter;
import com.alibaba.datax.plugin.rdbms.writer.Key; import com.alibaba.datax.plugin.rdbms.writer.Key;
import com.alibaba.datax.plugin.rdbms.util.DataBaseType;
import java.util.List; import java.util.List;
public class SybaseWriter extends Writer { public class SybaseWriter extends Writer {
private static final DataBaseType DATABASE_TYPE = DataBaseType.SYBASE; private static final DataBaseType DATABASE_TYPE = DataBaseType.Sybase;
public static class Job extends Writer.Job { public static class Job extends Writer.Job {
private Configuration originalConfig = null; private Configuration originalConfig = null;
private CommonRdbmsWriter.Job commonRdbmsWriterJob; private CommonRdbmsWriter.Job commonRdbmsWriterJob;
@ -72,7 +73,6 @@ public class SybaseWriter extends Writer {
this.commonRdbmsWriterTask.prepare(this.writerSliceConfig); this.commonRdbmsWriterTask.prepare(this.writerSliceConfig);
} }
//TODO 改用连接池，确保每次获取的连接都是可用的（注意：连接可能需要每次都初始化其 session）
public void startWrite(RecordReceiver recordReceiver) { public void startWrite(RecordReceiver recordReceiver) {
this.commonRdbmsWriterTask.startWrite(recordReceiver, this.writerSliceConfig, this.commonRdbmsWriterTask.startWrite(recordReceiver, this.writerSliceConfig,
super.getTaskPluginCollector()); super.getTaskPluginCollector());