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

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

Browse Source 
update package
This commit is contained in:
xiaopengm 2023-05-09 17:20:23 +08:00
parent e158e5845b
commit 543a67273f
2 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
sybasereader/src/main/assembly/package.xml
View File

@ -14,21 +14,21 @@
<include>plugin.json</include> <include>plugin.json</include>
<include>plugin_job_template.json</include> <include>plugin_job_template.json</include>
</includes> </includes>
<outputDirectory>plugin/reader/oraclereader</outputDirectory> <outputDirectory>plugin/reader/sybasereader</outputDirectory>
</fileSet> </fileSet>
<fileSet> <fileSet>
<directory>target/</directory> <directory>target/</directory>
<includes> <includes>
<include>oraclereader-0.0.1-SNAPSHOT.jar</include> <include>sybasereader-0.0.1-SNAPSHOT.jar</include>
</includes> </includes>
<outputDirectory>plugin/reader/oraclereader</outputDirectory> <outputDirectory>plugin/reader/sybasereader</outputDirectory>
</fileSet> </fileSet>
</fileSets> </fileSets>
<dependencySets> <dependencySets>
<dependencySet> <dependencySet>
<useProjectArtifact>false</useProjectArtifact> <useProjectArtifact>false</useProjectArtifact>
<outputDirectory>plugin/reader/oraclereader/libs</outputDirectory> <outputDirectory>plugin/reader/sybasereader/libs</outputDirectory>
<scope>runtime</scope> <scope>runtime</scope>
</dependencySet> </dependencySet>
</dependencySets> </dependencySets>

3
sybasereader/src/main/java/com/alibaba/datax/plugin/reader/sybasereader/SybaseReader.java
View File

@ -15,7 +15,7 @@ import com.alibaba.datax.plugin.rdbms.reader.Constant;
public class SybaseReader extends Reader { 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 { public static class Job extends Reader.Job {
private static final Logger LOG = LoggerFactory private static final Logger LOG = LoggerFactory
@ -63,6 +63,7 @@ public class SybaseReader extends Reader {
com.alibaba.datax.plugin.rdbms.reader.Constant.FETCH_SIZE, com.alibaba.datax.plugin.rdbms.reader.Constant.FETCH_SIZE,
Constants.DEFAULT_FETCH_SIZE); Constants.DEFAULT_FETCH_SIZE);
if (fetchSize < 1) { if (fetchSize < 1) {
LOG.warn("对 sybasereader 需要配置 fetchSize, 对性能提升有较大影响 请配置fetchSize.");
} }
originalConfig.set( originalConfig.set(
com.alibaba.datax.plugin.rdbms.reader.Constant.FETCH_SIZE, com.alibaba.datax.plugin.rdbms.reader.Constant.FETCH_SIZE,