本章節將介紹如何使用 Go 客戶端以及具體的接口。
連接 OceanBase 數據庫
您可使用 Go 客戶端登錄 OceanBase，具體方法可參考 通過 Go 客戶端連接 OceanBase 數據庫。
執行 CREATE TABLE 指令創建表。
CREATE TABLE IF NOT EXISTS `test_varchar_table_00` (
`c1` varchar(20) NOT NULL,
`c2` varchar(20) DEFAULT NULL,
`c3` varchar(20) DEFAULT NULL,
PRIMARY KEY (`c1`)
);
insert 接口
您可使用該接口插入一行記錄，但如果主鍵沖突（即行已存在），則插入失敗。
示例如下：
long insert(String tableName, Object rowkey, String[] columns, Object[] values);
long insert(String tableName, Object[] rowkeys, String[] columns, Object[] values);
// 樣例，rowkey 對應表中的 primary key
client.insert( "testHash",
new Object[] { 1L, "partition".getBytes(), timeStamp },
new String[] { "V" },
new Object[] { "value".getBytes() }
);
參數說明：
tableName：表名
rowkey：主鍵值
columns：插入的列名（一列或多列）
values：插入的列值
long：返回值，表示具體的插入數量（1行）
get 接口
您可使用該接口取回一行記錄，如果行存在，則取回行，否則返回 empty。
示例如下：
Map<String, Object> get(String tableName, Object rowkey, String[] columns);
Map<String, Object> get(String tableName, Object[] rowkeys, String[] columns);
// rowkey 即 primary key
Map<String, Object> res = client.get("testHash",
new Object[] { 1L, "partition".getBytes(), timestamp },
new String[] { "K", "Q", "T","V" }
);
// 返回的結果 value 是 object，直接強轉一下就行 例如 Long k = (Long) res.get("K");
參數說明：
tableName：表名
rowkey：主鍵值
columns：獲取的列名（一行或多列）
Map<String, Object>：返回值，成功返回所選列結果，失敗返回 empty
delete 接口
您可使用該接口刪除一行記錄，如果該行不存在，返回 affectrows = 0，否則返回具體刪除的行數量（1）。
示例如下：
long delete(String tableName, Object rowkey);
long delete(String tableName, Object[] rowkeys);
// 樣例，rowkey 對應表中的 primary key
client.delete("testHash", new Object[] { 1L, "partition".getBytes(), timeStamp });
// 返回結果表示 affectrows， 這里返回 1L
參數說明：
tableName：表名
rowkey：需要刪除的主鍵記錄
long：返回值，表示具體刪除的行數量（1行）
update 接口
您可使用該接口更新一行記錄，如果目標行不存在，返回 affectrows = 0，否則返回具體更新的行數量（1）。
示例如下：
long update(String tableName, Object rowkey, String[] columns, Object[] values);
long update(String tableName, Object[] rowkeys, String[] columns, Object[] values);
// 樣例，rowkey 為表的 primary_key
client.update("testHash",
new Object[] { 1L, "partition".getBytes(), timeStamp },
new String[] { "V" },
new Object[] { "value1L".getBytes() }
);
// 返回結果表示 affectrows， 這里返回 1L
參數說明：
tableName：表名
rowkey：更新的主鍵名
columns：更新的目標列（一列或多列）
values：需要更新的列值（一列或多列）
long 返回值，表示具體更新的行數量（1行）
replace 接口
您可使用該接口替換一行記錄，使用該接口會出現以下三種情況：
目標行不存在，則插入記錄。
目標行已存在（即主鍵沖突），則刪除原紀錄，然后再插入這行記錄。
如果有唯一索引沖突，則刪除所有引起沖突的行，然后再插入這行記錄。
示例如下：
long replace(String tableName, Object rowkey, String[] columns, Object[] values);
long replace(String tableName, Object[] rowkeys, String[] columns, Object[] values);
// 樣例，rowkey 為表的 primary_key
client.replace("testHash",
new Object[] { 1L, "partition".getBytes(), timeStamp },
new String[] { "V" },
new Object[] { "value1L".getBytes() }
);
// 返回結果表示 affectrows， 這里返回 1L
參數說明：
tableName：表名
rowkey：主鍵名
columns：替換目標的列名（一列或多列）
values：替換目標的列值 （一列或多列）
long：返回值，表示具體 replace 的行數量（1行）
insertOrupdate 接口
您可使用該接口插入或修改一行記錄，使用該接口會出現以下三種情況：
目標行不存在，則插入記錄。
目標行已存在（即主鍵沖突），則更新這行記錄。
如果插入有唯一索引沖突，則也執行更新操作。
示例如下：
long insertOrUpdate(String tableName, Object rowkey, String[] columns, Object[] values);
long insertOrUpdate(String tableName, Object[] rowkeys, String[] columns, Object[] values);
// 樣例，rowkey 為表的 primary_key
client.insertOrUpdate("testHash",
new Object[] { 1L, "partition".getBytes(), timestamp },
new String[] { "V" },
new Object[] { "bb".getBytes() }
);
// 返回結果表示 affectrows，這里返回 1L
參數說明：
tableName：表名
rowkey：主鍵名
columns：操作的目標列名（一列或多列）
values：目標列值（一列或多列）
long：返回值，表示具體 insert_or_update 的行數量（1行）
increment 接口
您可使用該接口把指定列的值原子地增加某個增量值（可以為負數），使用該接口會出現以下三種情況：
計算結果溢出列類型的值域，報錯。
目標行不存在，則插入，把增量值設置為初值（即等價于原值為 0）。
目標行存在，但是指定列的值為 NULL，把增量值設置為初值（即等價于原值為 0）。
示例如下：
Map<String, Object> increment(String tableName, Object rowkey, String[] columns,Object[] values, boolean withResult);
Map<String, Object> increment(String tableName, Object[] rowkeys, String[] columns, Object[] values, boolean withResult);
// 樣例，rowkey 為表的 primary_key，默認為 null， 所以最后結果為 c2=1,c3=2
Client.increment("test_increment",
"test_null",
new String[] { "c2", "c3" },
new Object[] { 1, 2 }, true );
參數說明：
tableName：表名
rowkey：主鍵值
columns：自增目標列名（一列或多列）
values：目標列自增值 （一列或多列）
withResult：判斷是否返回自增結果集
Map<String, Object>：返回值，如果 withResult = false ，返回結果為 Map.empty。
append 接口
您可使用該接口把指定列的值原子地追加某個串，使用該接口會出現以下三種情況：
計算結果溢出列類型的值域，報錯。
目標行不存在，則插入，把增量值設置為初值（即等價于原值為空串）。
目標行存在，但是指定列的值為 NULL，把增量值設置為初值（即等價于原值為空串）。
示例如下：
Map<String, Object> append(String tableName, Object rowkey, String[] columns, Object[] values,boolean withResult);
Map<String, Object> append(String tableName, Object[] rowkeys, String[] columns, Object[] values, boolean withResult);
// 先插入一條數據 c2 = {1} , c3 = {"P"}
client.insert("test_append", "test_normal", new String[] { "c2", "c3" }, new Object[] { new byte[] { 1 }, "P" });
// append 以后， c2 = {1, 2}, c3 = {"PY"}
Map<String, Object> res = client.append("test_append", "test_normal", new String[] { "c2", "c3" }, new Object[] { new byte[] { 2 }, "Y" }, true);
參數說明：
tableName：表名
rowkey：主鍵值
columns：增加串的目標列名（一列或多列）
values：目標列增加串值 （一列或多列）
withResult：判斷是否返回增加串結果集
Map<String, Object>：返回值，如果 withResult = false ，返回結果為 Map.empty。
scan 接口
您可使用該接口進行范圍查找，支持根據主鍵或主鍵的前綴進行范圍掃描，也可以不指定主鍵，根據索引或者索引前綴范圍進行掃描查詢，接口支持多 range 掃描和逆序掃描。
示例如下：
// 樣例
TableQuery tableQuery = client.query("table_name"); // 根據表名，創建掃描對象
re"sultSet = tableQuery.select("column2").primaryIndex().addScanRange("min1", "max1).addScanRange("min2", "max2").setBatchSize(batch_size).execute();
while(resultSet.next()) {
Map<String, Object> value = resultSet.getRow();
}
參數說明：
table_name：待掃描的表名。
primaryIndex：設定根據主鍵值掃描。
column2：設定獲取結果的列，例如一張表有 4 列，column1~column4，而只需要返回 column2 這一列的數據。
addScanRange：添加查找范圍，其中 min，max 為范圍的左右區間值。
batch_size：在滿足掃描條件的行記錄中，每一批需要返回的數量。
batch 接口
您可使用該接口批量執行多種操作組合。
示例如下：
TableBatchOps batchOps = client.batch("test_varchar_table");
batchOps.insert("foo", new String[] { "c2" }, new String[] { "bar" });
batchOps.get("foo", new String[] { "c2" });
batchOps.delete("foo");
List<Object> results = batchOps.execute();
// 上面返回結果的list， insert 返回 affectedRows, get 返回 map 結果，delete 返回 affectedRows
參數說明：
TableBatchOps：操作對象，通過 ObTableClient 對象創建，如上述的 client.batch(table_name)。
List<Object>：返回值，包含所有操作的結果集合，如上述的 insert、get、delete。