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

修复rdbmswriter插件，无法plugin.json下驱动，导致数据库连接报错问题

Browse Source
This commit is contained in:
liuzhai 2020-07-21 15:03:40 +08:00
parent d763fa33c6
commit 04d0937779
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
rdbmswriter/src/main/java/com/alibaba/datax/plugin/reader/rdbmswriter/RdbmsWriter.java
View File

@ -4,6 +4,7 @@ import com.alibaba.datax.common.exception.DataXException;
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;
import com.alibaba.datax.common.util.Configuration; import com.alibaba.datax.common.util.Configuration;
import com.alibaba.datax.plugin.rdbms.util.DBUtil;
import com.alibaba.datax.plugin.rdbms.util.DBUtilErrorCode; import com.alibaba.datax.plugin.rdbms.util.DBUtilErrorCode;
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;
@ -13,7 +14,10 @@ import java.util.List;
public class RdbmsWriter extends Writer { public class RdbmsWriter extends Writer {
private static final DataBaseType DATABASE_TYPE = DataBaseType.RDBMS; private static final DataBaseType DATABASE_TYPE = DataBaseType.RDBMS;
static {
//加载插件下面配置的驱动类
DBUtil.loadDriverClass("writer", "rdbms");
}
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 commonRdbmsWriterMaster; private CommonRdbmsWriter.Job commonRdbmsWriterMaster;