feature: support oceanbase oracle AT mode

core/src/main/java/io/seata/core/protocol/Version.java

@@ -36,7 +36,7 @@ public class Version {
     /**
      * The constant CURRENT.
      */
-    private static final String CURRENT = VersionInfo.VERSION;
+    private static final String CURRENT = "2.0.0-SNAPSHOT";
     private static final String VERSION_0_7_1 = "0.7.1";
     private static final String VERSION_1_5_0 = "1.5.0";
     private static final int MAX_VERSION_DOT = 3;

core/src/main/java/io/seata/core/store/db/sql/lock/OceanBaseOracleLockStoreSql.java

@@ -0,0 +1,27 @@
+/*
+ *  Copyright 1999-2019 Seata.io Group.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+package io.seata.core.store.db.sql.lock;
+
+import io.seata.common.loader.LoadLevel;
+
+/**
+ * Database lock store sql for OceanBaseOracle
+ *
+ * @author hsien999
+ */
+@LoadLevel(name = "oceanbase_oracle")
+public class OceanBaseOracleLockStoreSql extends OracleLockStoreSql {
+}

core/src/main/java/io/seata/core/store/db/sql/log/OceanBaseOracleLogStoreSqls.java

@@ -0,0 +1,27 @@
+/*
+ *  Copyright 1999-2019 Seata.io Group.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+package io.seata.core.store.db.sql.log;
+
+import io.seata.common.loader.LoadLevel;
+
+/**
+ * Database log store sql for OceanBaseOracle
+ *
+ * @author hsien999
+ */
+@LoadLevel(name = "oceanbase_oracle")
+public class OceanBaseOracleLogStoreSqls extends OracleLogStoreSqls {
+}

core/src/main/resources/META-INF/services/io.seata.core.store.db.sql.lock.LockStoreSql

@@ -6,4 +6,5 @@ io.seata.core.store.db.sql.lock.H2LockStoreSql
 io.seata.core.store.db.sql.lock.SqlServerLockStoreSql
 io.seata.core.store.db.sql.lock.MariadbLockStoreSql
 io.seata.core.store.db.sql.lock.PolarDBXLockStoreSql
-io.seata.core.store.db.sql.lock.DmLockStoreSql
+io.seata.core.store.db.sql.lock.DmLockStoreSql
+io.seata.core.store.db.sql.lock.OceanBaseOracleLockStoreSql

core/src/main/resources/META-INF/services/io.seata.core.store.db.sql.log.LogStoreSqls

@@ -6,4 +6,5 @@ io.seata.core.store.db.sql.log.H2LogStoreSqls
 io.seata.core.store.db.sql.log.SqlServerLogStoreSqls
 io.seata.core.store.db.sql.log.MariadbLogStoreSqls
 io.seata.core.store.db.sql.log.PolarDBXLogStoreSqls
-io.seata.core.store.db.sql.log.DmLogStoreSqls
+io.seata.core.store.db.sql.log.DmLogStoreSqls
+io.seata.core.store.db.sql.log.OceanBaseOracleLogStoreSqls

rm-datasource/src/main/java/io/seata/rm/datasource/DataSourceProxy.java

@@ -102,7 +102,7 @@ private void init(DataSource dataSource, String resourceGroupId) {
         try (Connection connection = dataSource.getConnection()) {
             jdbcUrl = connection.getMetaData().getURL();
             dbType = JdbcUtils.getDbType(jdbcUrl);
-            if (JdbcConstants.ORACLE.equals(dbType)) {
+            if (JdbcConstants.ORACLE.equals(dbType) || JdbcConstants.OCEANBASE_ORACLE.equals(dbType)) {
                 userName = connection.getMetaData().getUserName();
             } else if (JdbcConstants.MYSQL.equals(dbType)) {
                 validMySQLVersion(connection);
@@ -239,6 +239,8 @@ private void initResourceId() {
             initSqlServerResourceId();
         } else if (JdbcConstants.DM.equals(dbType)) {
             initDMResourceId();
+        } else if (JdbcConstants.OCEANBASE_ORACLE.equals(dbType) && userName != null) {
+            initOceanBaseOracleResourceId();
         } else {
             initDefaultResourceId();
         }
@@ -266,6 +268,25 @@ private void initOracleResourceId() {
         }
     }
 
+    private void initOceanBaseOracleResourceId() {
+        String startsWith = "jdbc:oceanbase:loadbalance://";
+        if (jdbcUrl.startsWith(startsWith)) {
+            String url;
+            if (jdbcUrl.contains("?")) {
+                url = jdbcUrl.substring(0, jdbcUrl.indexOf('?'));
+            } else {
+                url = jdbcUrl;
+            }
+            resourceId = url.replace(",", "|");
+        } else {
+            if (jdbcUrl.contains("?")) {
+                resourceId = jdbcUrl.substring(0, jdbcUrl.indexOf('?')) + "/" + userName;
+            } else {
+                resourceId = jdbcUrl + "/" + userName;
+            }
+        }
+    }
+
     /**
      * prevent mysql url like
      * jdbc:mysql:loadbalance://192.168.100.2:3306,192.168.100.1:3306/seata

rm-datasource/src/main/java/io/seata/rm/datasource/exec/oceanbaseoracle/OceanBaseOracleInsertExecutor.java

@@ -0,0 +1,38 @@
+/*
+ *  Copyright 1999-2019 Seata.io Group.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+package io.seata.rm.datasource.exec.oceanbaseoracle;
+
+import io.seata.common.loader.LoadLevel;
+import io.seata.common.loader.Scope;
+import io.seata.rm.datasource.StatementProxy;
+import io.seata.rm.datasource.exec.StatementCallback;
+import io.seata.rm.datasource.exec.oracle.OracleInsertExecutor;
+import io.seata.sqlparser.SQLRecognizer;
+import io.seata.sqlparser.util.JdbcConstants;
+
+/**
+ * Insert executor for OceanBaseOracle
+ *
+ * @author hsien999
+ */
+@LoadLevel(name = JdbcConstants.OCEANBASE_ORACLE, scope = Scope.PROTOTYPE)
+public class OceanBaseOracleInsertExecutor extends OracleInsertExecutor {
+
+    public OceanBaseOracleInsertExecutor(StatementProxy statementProxy, StatementCallback statementCallback,
+                                SQLRecognizer sqlRecognizer) {
+        super(statementProxy, statementCallback, sqlRecognizer);
+    }
+}