|
|
@@ -221,7 +221,7 @@ func TestTransactionBatch(t *testing.T) {
|
|
|
}).
|
|
|
transaction(func(tx client.Transaction) error {
|
|
|
statement, err := tx.InsertBatchTx(&client.InsertBatchRequest{
|
|
|
- Items: []*client.InsertTableItem{
|
|
|
+ Items: []*client.InsertTableRowItem{
|
|
|
{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
@@ -282,7 +282,7 @@ func TestTransactionBatch(t *testing.T) {
|
|
|
assertEqual(tableNum2, resultMap["table_num"], "表数量不一致").
|
|
|
transaction(func(tx client.Transaction) error {
|
|
|
statement, err := tx.DeleteBatchTx(&client.DeleteBatchRequest{
|
|
|
- Items: []*client.DeleteTableItem{
|
|
|
+ Items: []*client.DeleteTableRowItem{
|
|
|
{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
@@ -405,7 +405,7 @@ func TestInsertBatch(t *testing.T) {
|
|
|
},
|
|
|
}).
|
|
|
insertBatch(&client.InsertBatchRequest{
|
|
|
- Items: []*client.InsertTableItem{
|
|
|
+ Items: []*client.InsertTableRowItem{
|
|
|
{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
@@ -606,7 +606,7 @@ func TestDeleteBatch(t *testing.T) {
|
|
|
},
|
|
|
}).
|
|
|
insertBatch(&client.InsertBatchRequest{
|
|
|
- Items: []*client.InsertTableItem{
|
|
|
+ Items: []*client.InsertTableRowItem{
|
|
|
{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
@@ -635,7 +635,7 @@ func TestDeleteBatch(t *testing.T) {
|
|
|
UserID: "test",
|
|
|
}).
|
|
|
deleteBatch(&client.DeleteBatchRequest{
|
|
|
- Items: []*client.DeleteTableItem{
|
|
|
+ Items: []*client.DeleteTableRowItem{
|
|
|
{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|