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

add ob jar files.

Browse Source
This commit is contained in:
江煦 2021-05-20 19:49:06 +08:00
parent d3bd2c5fcf
commit 6061010e00
4 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

BIN
oceanbasev10writer/src/main/libs/oceanbase-connector-java-3.2.0.jar Normal file
View File

Binary file not shown.

7
plugin-rdbms-util/pom.xml
View File

@ -63,5 +63,12 @@
<artifactId>guava</artifactId> <artifactId>guava</artifactId>
<version>r05</version> <version>r05</version>
</dependency> </dependency>
<dependency>
<groupId>com.alipay.oceanbase</groupId>
<artifactId>oceanbase-client</artifactId>
<version>1.1.10</version>
<scope>system</scope>
<systemPath>${basedir}/src/main/libs/oceanbase-client-1.1.10.jar</systemPath>
</dependency>
</dependencies> </dependencies>
</project> </project>

8
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DataBaseType.java
View File

@ -110,6 +110,14 @@ public enum DataBaseType {
break; break;
case Oscar: case Oscar:
break; break;
case OceanBase:
suffix = "yearIsDateType=false&zeroDateTimeBehavior=convertToNull&tinyInt1isBit=false&rewriteBatchedStatements=true";
if (jdbc.contains("?")) {
result = jdbc + "&" + suffix;
} else {
result = jdbc + "?" + suffix;
}
break;
default: default:
throw DataXException.asDataXException(DBUtilErrorCode.UNSUPPORTED_TYPE, "unsupported database type."); throw DataXException.asDataXException(DBUtilErrorCode.UNSUPPORTED_TYPE, "unsupported database type.");
} }

BIN
plugin-rdbms-util/src/main/libs/oceanbase-client-1.1.10.jar Normal file
View File

Binary file not shown.