From ec2402b546e21907a8353bbc199d26b92f5babad Mon Sep 17 00:00:00 2001 From: xiaopengm <602012854@qq.com> Date: Wed, 10 May 2023 10:40:19 +0800 Subject: [PATCH] [feature][plugin][sybase] datax support sybase plugins. #1780 add sybaseWriter code --- .../{reader => writer}/sybasewriter/SybaseWriter.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) rename sybasewriter/src/main/java/com/alibaba/datax/plugin/{reader => writer}/sybasewriter/SybaseWriter.java (93%) diff --git a/sybasewriter/src/main/java/com/alibaba/datax/plugin/reader/sybasewriter/SybaseWriter.java b/sybasewriter/src/main/java/com/alibaba/datax/plugin/writer/sybasewriter/SybaseWriter.java similarity index 93% rename from sybasewriter/src/main/java/com/alibaba/datax/plugin/reader/sybasewriter/SybaseWriter.java rename to sybasewriter/src/main/java/com/alibaba/datax/plugin/writer/sybasewriter/SybaseWriter.java index 220e6233..51b90d66 100755 --- a/sybasewriter/src/main/java/com/alibaba/datax/plugin/reader/sybasewriter/SybaseWriter.java +++ b/sybasewriter/src/main/java/com/alibaba/datax/plugin/writer/sybasewriter/SybaseWriter.java @@ -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.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.writer.CommonRdbmsWriter; import com.alibaba.datax.plugin.rdbms.writer.Key; +import com.alibaba.datax.plugin.rdbms.util.DataBaseType; + import java.util.List; 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 { private Configuration originalConfig = null; private CommonRdbmsWriter.Job commonRdbmsWriterJob; @@ -72,7 +73,6 @@ public class SybaseWriter extends Writer { this.commonRdbmsWriterTask.prepare(this.writerSliceConfig); } - //TODO 改用连接池,确保每次获取的连接都是可用的(注意:连接可能需要每次都初始化其 session) public void startWrite(RecordReceiver recordReceiver) { this.commonRdbmsWriterTask.startWrite(recordReceiver, this.writerSliceConfig, super.getTaskPluginCollector());