diff --git a/oceanbasev10writer/src/main/libs/oceanbase-connector-java-3.2.0.jar b/oceanbasev10writer/src/main/libs/oceanbase-connector-java-3.2.0.jar
new file mode 100644
index 00000000..239f3dc4
Binary files /dev/null and b/oceanbasev10writer/src/main/libs/oceanbase-connector-java-3.2.0.jar differ
diff --git a/plugin-rdbms-util/pom.xml b/plugin-rdbms-util/pom.xml
index e6884fb1..282a39e8 100755
--- a/plugin-rdbms-util/pom.xml
+++ b/plugin-rdbms-util/pom.xml
@@ -63,5 +63,12 @@
guava
r05
-
+
+ com.alipay.oceanbase
+ oceanbase-client
+ 1.1.10
+ system
+ ${basedir}/src/main/libs/oceanbase-client-1.1.10.jar
+
+
diff --git a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DataBaseType.java b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DataBaseType.java
index 63a6f01e..205919fe 100755
--- a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DataBaseType.java
+++ b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DataBaseType.java
@@ -110,6 +110,14 @@ public enum DataBaseType {
break;
case Oscar:
break;
+ case OceanBase:
+ suffix = "yearIsDateType=false&zeroDateTimeBehavior=convertToNull&tinyInt1isBit=false&rewriteBatchedStatements=true";
+ if (jdbc.contains("?")) {
+ result = jdbc + "&" + suffix;
+ } else {
+ result = jdbc + "?" + suffix;
+ }
+ break;
default:
throw DataXException.asDataXException(DBUtilErrorCode.UNSUPPORTED_TYPE, "unsupported database type.");
}
diff --git a/plugin-rdbms-util/src/main/libs/oceanbase-client-1.1.10.jar b/plugin-rdbms-util/src/main/libs/oceanbase-client-1.1.10.jar
new file mode 100644
index 00000000..38162912
Binary files /dev/null and b/plugin-rdbms-util/src/main/libs/oceanbase-client-1.1.10.jar differ