From 543a67273f70bd434ef6352cb78c702d63d2b664 Mon Sep 17 00:00:00 2001
From: xiaopengm <602012854@qq.com>
Date: Tue, 9 May 2023 17:20:23 +0800
Subject: [PATCH] [feature][plugin][sybase] datax support sybase plugins.
#1780
update package
---
sybasereader/src/main/assembly/package.xml | 8 ++++----
.../datax/plugin/reader/sybasereader/SybaseReader.java | 3 ++-
2 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/sybasereader/src/main/assembly/package.xml b/sybasereader/src/main/assembly/package.xml
index a954a30d..40060050 100755
--- a/sybasereader/src/main/assembly/package.xml
+++ b/sybasereader/src/main/assembly/package.xml
@@ -14,21 +14,21 @@
plugin.json
plugin_job_template.json
- plugin/reader/oraclereader
+ plugin/reader/sybasereader
target/
- oraclereader-0.0.1-SNAPSHOT.jar
+ sybasereader-0.0.1-SNAPSHOT.jar
- plugin/reader/oraclereader
+ plugin/reader/sybasereader
false
- plugin/reader/oraclereader/libs
+ plugin/reader/sybasereader/libs
runtime
diff --git a/sybasereader/src/main/java/com/alibaba/datax/plugin/reader/sybasereader/SybaseReader.java b/sybasereader/src/main/java/com/alibaba/datax/plugin/reader/sybasereader/SybaseReader.java
index d0bbefac..f0a0ac1a 100755
--- a/sybasereader/src/main/java/com/alibaba/datax/plugin/reader/sybasereader/SybaseReader.java
+++ b/sybasereader/src/main/java/com/alibaba/datax/plugin/reader/sybasereader/SybaseReader.java
@@ -15,7 +15,7 @@ import com.alibaba.datax.plugin.rdbms.reader.Constant;
public class SybaseReader extends Reader {
- private static final DataBaseType DATABASE_TYPE = DataBaseType.Oracle;
+ private static final DataBaseType DATABASE_TYPE = DataBaseType.Sybase;
public static class Job extends Reader.Job {
private static final Logger LOG = LoggerFactory
@@ -63,6 +63,7 @@ public class SybaseReader extends Reader {
com.alibaba.datax.plugin.rdbms.reader.Constant.FETCH_SIZE,
Constants.DEFAULT_FETCH_SIZE);
if (fetchSize < 1) {
+ LOG.warn("对 sybasereader 需要配置 fetchSize, 对性能提升有较大影响 请配置fetchSize.");
}
originalConfig.set(
com.alibaba.datax.plugin.rdbms.reader.Constant.FETCH_SIZE,