Keep the same sql script with the 1.x version and add create database script (#102)

* add DepentdentFilter and SingleColumnValueExcludeFilter

* add singleColumnValueExcludeFilter and DependentColumnFilter; add test cases and optimize bufferedMutator test cases

* hbase support batch (#84)

* Add DeleteFamilyVersion function and corresponding test cases (#85)

* add DepentdentFilter and SingleColumnValueExcludeFilter

* add singleColumnValueExcludeFilter and DependentColumnFilter; add test cases and optimize bufferedMutator test cases

* add single cf timerange setting in Get

* single cf setColumnFamilyTimeRange in Get and Scan

* optimize code

* add DeleteFamilyVersion and test cases

* add DeleteFamilyVersion; optimize test cases

* add DeleteFamilyVersion test case and pass

* format code

* delete useless self-defined table

* remove DeleteFamilyVersion file and move all cases to MultiColumnFamilyTest

* hbase support batchCallBack (#86)

* adjust bufferdMutatorImpl 1.x to new batch

* bufferedMutator do not retry, batch retry in table client

* hbase support batch (#84)

* add rpcTimeout and operationTimetout setting in bufferedMutator

* fix test

* Add DeleteFamilyVersion function and corresponding test cases (#85)

* add DepentdentFilter and SingleColumnValueExcludeFilter

* add singleColumnValueExcludeFilter and DependentColumnFilter; add test cases and optimize bufferedMutator test cases

* add single cf timerange setting in Get

* single cf setColumnFamilyTimeRange in Get and Scan

* optimize code

* add DeleteFamilyVersion and test cases

* add DeleteFamilyVersion; optimize test cases

* add DeleteFamilyVersion test case and pass

* format code

* delete useless self-defined table

* hbase support batchCallBack (#86)

* fix test

* fix test

* init hbase_2.0 bufferedMutatorImpl

* pass single bufferedMutator test

* remove useless comments

* format code

* add inherited interface in bufferedMutator; fix concurrent bug in bufferedMuator execution

* fix typo

* fix exception erros message

* update time to wait pool to shutdown

* add import

* pass test cases after merge

* keep the same test case and sql with 1.x version

---------

Co-authored-by: stuBirdFly <84010733+stuBirdFly@users.noreply.github.com>
Co-authored-by: miyuan-ljr <miyuan.ljr@antgroup.com>

Author: 3 people

src/test/java/com/alipay/oceanbase/hbase/OHConnectionTest.java

@@ -450,7 +450,7 @@ public void testBufferedMutatorUseNameSpaceWithFlush() throws Exception {
 
             // test Delete
             Delete del = new Delete(toBytes(key));
-            // test without setting family, delete all
+            del.addFamily(toBytes(family));
             bufferMutator.mutate(del);
             bufferMutator.flush();
 

src/test/java/unit_test_db.sql

@@ -168,15 +168,15 @@ CREATE TABLE `test$family'1` (
     `T` bigint(20) NOT NULL,
     `V` varbinary(1024) DEFAULT NULL,
     PRIMARY KEY (`K`, `Q`, `T`)
-);
+) TABLEGROUP = test;
 
 CREATE TABLE `test_t$family'1` (
     `K` varbinary(1024) NOT NULL,
     `Q` varbinary(256) NOT NULL,
     `T` bigint(20) NOT NULL,
     `V` varbinary(1024) DEFAULT NULL,
     PRIMARY KEY (`K`, `Q`, `T`)
-);
+) TABLEGROUP = test_t;
 
 CREATE TABLEGROUP test_multi_cf SHARDING = 'ADAPTIVE';
 
@@ -204,7 +204,6 @@ CREATE TABLE `test_multi_cf$family_with_group3` (
     PRIMARY KEY (`K`, `Q`, `T`) 
 ) TABLEGROUP = test_multi_cf PARTITION BY KEY(`K`) PARTITIONS 3;
 
----------------------------- n1 database ----------------------------
 CREATE DATABASE IF NOT EXISTS `n1`;
 USE `n1`;
 CREATE TABLE `n1:test$family1` (
@@ -230,7 +229,7 @@ CREATE TABLE `n1:test$family'1` (
     `T` bigint(20) NOT NULL,
     `V` varbinary(1024) DEFAULT NULL,
     PRIMARY KEY (`K`, `Q`, `T`)
-);
+) TABLEGROUP = `n1:test`;
 
 CREATE TABLE `n1:test$family_with_local_index` (
     `K` varbinary(1024) NOT NULL,
@@ -256,4 +255,3 @@ CREATE TABLE `n1:test$partitionFamily1` (
     `V` varbinary(1024) DEFAULT NULL,
     PRIMARY KEY (`K`, `Q`, `T`)
 ) partition by key(`K`) partitions 17;
-