add lob test

test/single/all_test.go

@@ -46,6 +46,8 @@ func setup() {
 	test.CreateTable(testVarbinaryCreateStatement)
 	test.CreateTable(testDatetimeCreateStatement)
 	test.CreateTable(testTimestampCreateStatement)
+	test.CreateTable(testBlobCreateStatement)
+	test.CreateTable(testClobCreateStatement)
 }
 
 func teardown() {
@@ -65,6 +67,8 @@ func teardown() {
 	test.DropTable(testVarbinaryTableName)
 	test.DropTable(testDatetimeTableName)
 	test.DropTable(testTimestampTableName)
+	test.DropTable(testBlobTableName)
+	test.DropTable(testClobTableName)
 
 	test.CloseDB()
 }

test/single/blob_table_test.go

@@ -0,0 +1,254 @@
+/*-
+ * #%L
+ * OBKV Table Client Framework
+ * %%
+ * Copyright (C) 2021 OceanBase
+ * %%
+ * OBKV Table Client Framework is licensed under Mulan PSL v2.
+ * You can use this software according to the terms and conditions of the Mulan PSL v2.
+ * You may obtain a copy of Mulan PSL v2 at:
+ *          http://license.coscl.org.cn/MulanPSL2
+ * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND,
+ * EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT,
+ * MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE.
+ * See the Mulan PSL v2 for more details.
+ * #L%
+ */
+
+package single
+
+import (
+	"context"
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+
+	"github.com/oceanbase/obkv-table-client-go/client/option"
+	"github.com/oceanbase/obkv-table-client-go/table"
+	"github.com/oceanbase/obkv-table-client-go/test"
+)
+
+const (
+	testBlobTableName       = "test_blob"
+	testBlobCreateStatement = "create table if not exists test_blob(c1 int(12) primary key, c2 int(12) default null, c3 blob not null);"
+)
+
+func TestBlob_insert(t *testing.T) {
+	tableName := testBlobTableName
+	defer test.DeleteTable(tableName)
+
+	// 1. insert
+	rowKey := []*table.Column{table.NewColumn("c1", int32(0))}
+	mutateColumns := []*table.Column{table.NewColumn("c3", []byte("abc"))}
+	affectRows, err := cli.Insert(
+		context.TODO(),
+		tableName,
+		rowKey,
+		mutateColumns,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 1, affectRows)
+
+	// 2. get
+	res, err := cli.Get(
+		context.TODO(),
+		tableName,
+		rowKey,
+		nil,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 0, res.Value("c1"))
+	assert.EqualValues(t, []byte("abc"), res.Value("c3"))
+}
+
+func TestBlob_delete(t *testing.T) {
+	tableName := testBlobTableName
+	defer test.DeleteTable(tableName)
+
+	// 1. insert
+	rowKey := []*table.Column{table.NewColumn("c1", int32(0))}
+	mutateColumns := []*table.Column{table.NewColumn("c3", []byte("abc"))}
+	affectRows, err := cli.Insert(
+		context.TODO(),
+		tableName,
+		rowKey,
+		mutateColumns,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 1, affectRows)
+
+	// 2. delete
+	affectRows, err = cli.Delete(
+		context.TODO(),
+		tableName,
+		rowKey,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 1, affectRows)
+
+	// 3. get
+	res, err := cli.Get(
+		context.TODO(),
+		tableName,
+		rowKey,
+		nil,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, nil, res.Value("c3"))
+}
+
+func TestBlob_update(t *testing.T) {
+	tableName := testBlobTableName
+	defer test.DeleteTable(tableName)
+
+	// 1. insert
+	rowKey := []*table.Column{table.NewColumn("c1", int32(0))}
+	mutateColumns := []*table.Column{table.NewColumn("c3", []byte("abc"))}
+	affectRows, err := cli.Insert(
+		context.TODO(),
+		tableName,
+		rowKey,
+		mutateColumns,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 1, affectRows)
+
+	// 2. update
+	mutateColumns = []*table.Column{table.NewColumn("c3", []byte("efg"))}
+	affectRows, err = cli.Update(
+		context.TODO(),
+		tableName,
+		rowKey,
+		mutateColumns,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 1, affectRows)
+
+	// 3. get
+	res, err := cli.Get(
+		context.TODO(),
+		tableName,
+		rowKey,
+		nil,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, []byte("efg"), res.Value("c3"))
+}
+
+func TestBlob_replace(t *testing.T) {
+	tableName := testBlobTableName
+	defer test.DeleteTable(tableName)
+
+	// 1. insert
+	rowKey := []*table.Column{table.NewColumn("c1", int32(0))}
+	mutateColumns := []*table.Column{table.NewColumn("c3", []byte("abc"))}
+	affectRows, err := cli.Insert(
+		context.TODO(),
+		tableName,
+		rowKey,
+		mutateColumns,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 1, affectRows)
+
+	// 2. replace
+	mutateColumns = []*table.Column{table.NewColumn("c3", []byte("efg"))}
+	affectRows, err = cli.Replace(
+		context.TODO(),
+		tableName,
+		rowKey,
+		mutateColumns,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 2, affectRows)
+
+	// 3. get
+	res, err := cli.Get(
+		context.TODO(),
+		tableName,
+		rowKey,
+		nil,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, []byte("efg"), res.Value("c3"))
+}
+
+func TestBlob_insertUp(t *testing.T) {
+	tableName := testBlobTableName
+	defer test.DeleteTable(tableName)
+
+	// 1. insertUp(insert)
+	rowKey := []*table.Column{table.NewColumn("c1", int32(0))}
+	mutateColumns := []*table.Column{table.NewColumn("c3", []byte("abc"))}
+	affectRows, err := cli.InsertOrUpdate(
+		context.TODO(),
+		tableName,
+		rowKey,
+		mutateColumns,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 1, affectRows)
+
+	// 2. insertUp(update)
+	mutateColumns = []*table.Column{table.NewColumn("c3", []byte("efg"))}
+	affectRows, err = cli.InsertOrUpdate(
+		context.TODO(),
+		tableName,
+		rowKey,
+		mutateColumns,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 1, affectRows)
+
+	// 3. get
+	res, err := cli.Get(
+		context.TODO(),
+		tableName,
+		rowKey,
+		nil,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 0, res.Value("c1"))
+	assert.EqualValues(t, []byte("efg"), res.Value("c3"))
+}
+
+func TestBlob_append(t *testing.T) {
+	tableName := testBlobTableName
+	defer test.DeleteTable(tableName)
+
+	// 1. insert
+	rowKey := []*table.Column{table.NewColumn("c1", int32(0))}
+	mutateColumns := []*table.Column{table.NewColumn("c3", []byte("abc"))}
+	affectRows, err := cli.Insert(
+		context.TODO(),
+		tableName,
+		rowKey,
+		mutateColumns,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 1, affectRows)
+
+	// 2. append, not expired, success
+	mutateColumns = []*table.Column{table.NewColumn("c3", []byte("efg"))}
+	res, err := cli.Append(
+		context.TODO(),
+		tableName,
+		rowKey,
+		mutateColumns,
+		option.WithReturnAffectedEntity(true),
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 1, affectRows)
+	assert.EqualValues(t, []byte("abcefg"), res.Value("c3"))
+
+	// 3. get
+	res, err = cli.Get(
+		context.TODO(),
+		tableName,
+		rowKey,
+		nil,
+	)
+	assert.Equal(t, nil, err)
+	assert.EqualValues(t, 0, res.Value("c1"))
+	assert.EqualValues(t, []byte("abcefg"), res.Value("c3"))
+}