|
@@ -56,7 +56,7 @@ func TestTransaction(t *testing.T) {
|
|
|
newTableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
|
|
|
|
|
|
var count int64
|
|
|
- resultMap := make(map[string]any)
|
|
|
+ resultTableRow := client.NewTableRow()
|
|
|
|
|
|
newToolKit(t).
|
|
|
autoMigrate(&client.AutoMigrateRequest{
|
|
@@ -73,12 +73,11 @@ func TestTransaction(t *testing.T) {
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyColumns: []string{"id"},
|
|
|
- TableRow: map[string]any{
|
|
|
- "id": id,
|
|
|
- "name": name,
|
|
|
- "time": now,
|
|
|
- "table_num": tableNum,
|
|
|
- },
|
|
|
+ TableRow: client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id).
|
|
|
+ AddColumnValueString("name", name).
|
|
|
+ AddColumnValueTime("time", now).
|
|
|
+ AddColumnValueInt("table_num", tableNum),
|
|
|
UserID: "test",
|
|
|
})
|
|
|
if err != nil {
|
|
@@ -93,22 +92,21 @@ func TestTransaction(t *testing.T) {
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyValues: map[string]string{"id": id},
|
|
|
- }, &resultMap).
|
|
|
- assertEqual(id, resultMap["id"], "ID不一致").
|
|
|
- assertEqual(name, resultMap["name"], "名称不一致").
|
|
|
- assertEqual(now.Unix(), resultMap["time"].(time.Time).Unix(), "时间不一致").
|
|
|
- assertEqual(uint64(tableNum), resultMap["table_num"], "表数量不一致").
|
|
|
+ }, resultTableRow).
|
|
|
+ assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
|
|
|
+ assertEqual(name, resultTableRow.ColumnValueString("name"), "名称不一致").
|
|
|
+ assertEqual(now.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
|
|
|
+ assertEqual(tableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
|
|
|
transaction(func(tx client.Transaction) error {
|
|
|
statement, err := tx.UpdateTx(&client.UpdateRequest{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyValues: map[string]string{"id": id},
|
|
|
- NewTableRow: map[string]any{
|
|
|
- "id": id,
|
|
|
- "name": newName,
|
|
|
- "time": newNow,
|
|
|
- "table_num": newTableNum,
|
|
|
- },
|
|
|
+ NewTableRow: client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id).
|
|
|
+ AddColumnValueString("name", newName).
|
|
|
+ AddColumnValueTime("time", newNow).
|
|
|
+ AddColumnValueInt("table_num", newTableNum),
|
|
|
UserID: "test",
|
|
|
})
|
|
|
if err != nil {
|
|
@@ -123,22 +121,21 @@ func TestTransaction(t *testing.T) {
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyValues: map[string]string{"id": id},
|
|
|
- }, &resultMap).
|
|
|
- assertEqual(id, resultMap["id"], "ID不一致").
|
|
|
- assertEqual(newName, resultMap["name"], "名称不一致").
|
|
|
- assertEqual(newNow.Unix(), resultMap["time"].(time.Time).Unix(), "时间不一致").
|
|
|
- assertEqual(uint64(newTableNum), resultMap["table_num"], "表数量不一致").
|
|
|
+ }, resultTableRow).
|
|
|
+ assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
|
|
|
+ assertEqual(newName, resultTableRow.ColumnValueString("name"), "名称不一致").
|
|
|
+ assertEqual(newNow.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
|
|
|
+ assertEqual(newTableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
|
|
|
transaction(func(tx client.Transaction) error {
|
|
|
statement, err := tx.UpdateTx(&client.UpdateRequest{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyValues: map[string]string{"id": id},
|
|
|
- NewTableRow: map[string]any{
|
|
|
- "id": id,
|
|
|
- "name": name,
|
|
|
- "time": now,
|
|
|
- "table_num": tableNum,
|
|
|
- },
|
|
|
+ NewTableRow: client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id).
|
|
|
+ AddColumnValueString("name", name).
|
|
|
+ AddColumnValueTime("time", now).
|
|
|
+ AddColumnValueInt("table_num", tableNum),
|
|
|
UserID: "test",
|
|
|
})
|
|
|
if err != nil {
|
|
@@ -188,7 +185,7 @@ func TestTransactionBatch(t *testing.T) {
|
|
|
tableNum2 := rand.New(rand.NewSource(now2.Unix())).Intn(10)
|
|
|
|
|
|
var count int64
|
|
|
- resultMap := make(map[string]any)
|
|
|
+ resultTableRow := client.NewTableRow()
|
|
|
|
|
|
newToolKit(t).
|
|
|
autoMigrate(&client.AutoMigrateRequest{
|
|
@@ -207,19 +204,17 @@ func TestTransactionBatch(t *testing.T) {
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyColumns: []string{"id"},
|
|
|
- TableRows: []map[string]any{
|
|
|
- {
|
|
|
- "id": id1,
|
|
|
- "name": name1,
|
|
|
- "time": now1,
|
|
|
- "table_num": tableNum1,
|
|
|
- },
|
|
|
- {
|
|
|
- "id": id2,
|
|
|
- "name": name2,
|
|
|
- "time": now2,
|
|
|
- "table_num": tableNum2,
|
|
|
- },
|
|
|
+ TableRows: []*client.TableRow{
|
|
|
+ client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id1).
|
|
|
+ AddColumnValueString("name", name1).
|
|
|
+ AddColumnValueTime("time", now1).
|
|
|
+ AddColumnValueInt("table_num", tableNum1),
|
|
|
+ client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id2).
|
|
|
+ AddColumnValueString("name", name2).
|
|
|
+ AddColumnValueTime("time", now2).
|
|
|
+ AddColumnValueInt("table_num", tableNum2),
|
|
|
},
|
|
|
},
|
|
|
},
|
|
@@ -236,20 +231,20 @@ func TestTransactionBatch(t *testing.T) {
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyValues: map[string]string{"id": id1},
|
|
|
- }, &resultMap).
|
|
|
- assertEqual(id1, resultMap["id"], "ID不一致").
|
|
|
- assertEqual(name1, resultMap["name"], "名称不一致").
|
|
|
- assertEqual(now1.Unix(), resultMap["time"].(time.Time).Unix(), "时间不一致").
|
|
|
- assertEqual(uint64(tableNum1), resultMap["table_num"], "表数量不一致").
|
|
|
+ }, resultTableRow).
|
|
|
+ assertEqual(id1, resultTableRow.ColumnValueString("id"), "ID不一致").
|
|
|
+ assertEqual(name1, resultTableRow.ColumnValueString("name"), "名称不一致").
|
|
|
+ assertEqual(now1.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
|
|
|
+ assertEqual(tableNum1, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
|
|
|
queryByKeys(&client.QueryByKeysRequest{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyValues: map[string]string{"id": id2},
|
|
|
- }, &resultMap).
|
|
|
- assertEqual(id2, resultMap["id"], "ID不一致").
|
|
|
- assertEqual(name2, resultMap["name"], "名称不一致").
|
|
|
- assertEqual(now2.Unix(), resultMap["time"].(time.Time).Unix(), "时间不一致").
|
|
|
- assertEqual(uint64(tableNum2), resultMap["table_num"], "表数量不一致").
|
|
|
+ }, resultTableRow).
|
|
|
+ assertEqual(id2, resultTableRow.ColumnValueString("id"), "ID不一致").
|
|
|
+ assertEqual(name2, resultTableRow.ColumnValueString("name"), "名称不一致").
|
|
|
+ assertEqual(now2.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
|
|
|
+ assertEqual(tableNum2, resultTableRow.ColumnValueInt("table_num"), "表数量不一致").
|
|
|
transaction(func(tx client.Transaction) error {
|
|
|
statement, err := tx.DeleteBatchTx(&client.DeleteBatchRequest{
|
|
|
Items: []client.DeleteTableRowItem{
|
|
@@ -301,7 +296,7 @@ func TestInsert(t *testing.T) {
|
|
|
now := time.Now().Local()
|
|
|
tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
|
|
|
|
|
|
- resultMap := make(map[string]any)
|
|
|
+ resultTableRow := client.NewTableRow()
|
|
|
|
|
|
newToolKit(t).
|
|
|
autoMigrate(&client.AutoMigrateRequest{
|
|
@@ -317,23 +312,22 @@ func TestInsert(t *testing.T) {
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyColumns: []string{"id"},
|
|
|
- TableRow: map[string]any{
|
|
|
- "id": id,
|
|
|
- "name": name,
|
|
|
- "time": now,
|
|
|
- "table_num": tableNum,
|
|
|
- },
|
|
|
+ TableRow: client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id).
|
|
|
+ AddColumnValueString("name", name).
|
|
|
+ AddColumnValueTime("time", now).
|
|
|
+ AddColumnValueInt("table_num", tableNum),
|
|
|
UserID: "test",
|
|
|
}).
|
|
|
queryByKeys(&client.QueryByKeysRequest{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyValues: map[string]string{"id": id},
|
|
|
- }, &resultMap).
|
|
|
- assertEqual(id, resultMap["id"], "ID不一致").
|
|
|
- assertEqual(name, resultMap["name"], "名称不一致").
|
|
|
- assertEqual(now.Unix(), resultMap["time"].(time.Time).Local().Unix(), "时间不一致").
|
|
|
- assertEqual(uint64(tableNum), resultMap["table_num"], "表数量不一致")
|
|
|
+ }, resultTableRow).
|
|
|
+ assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
|
|
|
+ assertEqual(name, resultTableRow.ColumnValueString("name"), "名称不一致").
|
|
|
+ assertEqual(now.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
|
|
|
+ assertEqual(tableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致")
|
|
|
}
|
|
|
|
|
|
func TestInsertBatch(t *testing.T) {
|
|
@@ -352,7 +346,7 @@ func TestInsertBatch(t *testing.T) {
|
|
|
now2 := time.Now().Local()
|
|
|
tableNum2 := rand.New(rand.NewSource(now2.Unix())).Intn(10)
|
|
|
|
|
|
- resultsMap := make([]map[string]any, 0)
|
|
|
+ resultTableRows := new(client.TableRows)
|
|
|
var totalCount int64
|
|
|
|
|
|
newToolKit(t).
|
|
@@ -371,19 +365,17 @@ func TestInsertBatch(t *testing.T) {
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyColumns: []string{"id"},
|
|
|
- TableRows: []map[string]any{
|
|
|
- {
|
|
|
- "id": id1,
|
|
|
- "name": name1,
|
|
|
- "time": now1,
|
|
|
- "table_num": tableNum1,
|
|
|
- },
|
|
|
- {
|
|
|
- "id": id2,
|
|
|
- "name": name2,
|
|
|
- "time": now2,
|
|
|
- "table_num": tableNum2,
|
|
|
- },
|
|
|
+ TableRows: []*client.TableRow{
|
|
|
+ client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id1).
|
|
|
+ AddColumnValueString("name", name1).
|
|
|
+ AddColumnValueTime("time", now1).
|
|
|
+ AddColumnValueInt("table_num", tableNum1),
|
|
|
+ client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id2).
|
|
|
+ AddColumnValueString("name", name2).
|
|
|
+ AddColumnValueTime("time", now2).
|
|
|
+ AddColumnValueInt("table_num", tableNum2),
|
|
|
},
|
|
|
},
|
|
|
},
|
|
@@ -396,12 +388,12 @@ func TestInsertBatch(t *testing.T) {
|
|
|
},
|
|
|
PageNo: 1,
|
|
|
PageSize: 1,
|
|
|
- }, &resultsMap, &totalCount).
|
|
|
+ }, resultTableRows, &totalCount).
|
|
|
assertEqual(1, int(totalCount), "总数不一致").
|
|
|
- assertEqual(id1, resultsMap[0]["id"], "ID不一致").
|
|
|
- assertEqual(name1, resultsMap[0]["name"], "名称不一致").
|
|
|
- assertEqual(now1.Unix(), resultsMap[0]["time"].(time.Time).Local().Unix(), "时间不一致").
|
|
|
- assertEqual(uint64(tableNum1), resultsMap[0]["table_num"], "表数量不一致").
|
|
|
+ assertEqual(id1, (*resultTableRows)[0].ColumnValueString("id"), "ID不一致").
|
|
|
+ assertEqual(name1, (*resultTableRows)[0].ColumnValueString("name"), "名称不一致").
|
|
|
+ assertEqual(now1.Unix(), (*resultTableRows)[0].ColumnValueTime("time").Unix(), "时间不一致").
|
|
|
+ assertEqual(tableNum1, (*resultTableRows)[0].ColumnValueInt("table_num"), "表数量不一致").
|
|
|
commonQuery(&client.CommonQueryRequest{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
@@ -410,12 +402,12 @@ func TestInsertBatch(t *testing.T) {
|
|
|
},
|
|
|
PageNo: 1,
|
|
|
PageSize: 1,
|
|
|
- }, &resultsMap, &totalCount).
|
|
|
+ }, resultTableRows, &totalCount).
|
|
|
assertEqual(1, int(totalCount), "总数不一致").
|
|
|
- assertEqual(id2, resultsMap[0]["id"], "ID不一致").
|
|
|
- assertEqual(name2, resultsMap[0]["name"], "名称不一致").
|
|
|
- assertEqual(now2.Unix(), resultsMap[0]["time"].(time.Time).Local().Unix(), "时间不一致").
|
|
|
- assertEqual(uint64(tableNum2), resultsMap[0]["table_num"], "表数量不一致").
|
|
|
+ assertEqual(id2, (*resultTableRows)[0].ColumnValueString("id"), "ID不一致").
|
|
|
+ assertEqual(name2, (*resultTableRows)[0].ColumnValueString("name"), "名称不一致").
|
|
|
+ assertEqual(now2.Unix(), (*resultTableRows)[0].ColumnValueTime("time").Unix(), "时间不一致").
|
|
|
+ assertEqual(tableNum2, (*resultTableRows)[0].ColumnValueInt("table_num"), "表数量不一致").
|
|
|
queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
@@ -424,11 +416,11 @@ func TestInsertBatch(t *testing.T) {
|
|
|
},
|
|
|
PageNo: 1,
|
|
|
PageSize: 1,
|
|
|
- }, &resultsMap).
|
|
|
- assertEqual(id1, resultsMap[0]["id"], "ID不一致").
|
|
|
- assertEqual(name1, resultsMap[0]["name"], "名称不一致").
|
|
|
- assertEqual(now1.Unix(), resultsMap[0]["time"].(time.Time).Local().Unix(), "时间不一致").
|
|
|
- assertEqual(uint64(tableNum1), resultsMap[0]["table_num"], "表数量不一致").
|
|
|
+ }, resultTableRows).
|
|
|
+ assertEqual(id1, (*resultTableRows)[0].ColumnValueString("id"), "ID不一致").
|
|
|
+ assertEqual(name1, (*resultTableRows)[0].ColumnValueString("name"), "名称不一致").
|
|
|
+ assertEqual(now1.Unix(), (*resultTableRows)[0].ColumnValueTime("time").Unix(), "时间不一致").
|
|
|
+ assertEqual(tableNum1, (*resultTableRows)[0].ColumnValueInt("table_num"), "表数量不一致").
|
|
|
commonQueryOnly(&client.CommonQueryRequest{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
@@ -437,11 +429,11 @@ func TestInsertBatch(t *testing.T) {
|
|
|
},
|
|
|
PageNo: 1,
|
|
|
PageSize: 1,
|
|
|
- }, &resultsMap).
|
|
|
- assertEqual(id2, resultsMap[0]["id"], "ID不一致").
|
|
|
- assertEqual(name2, resultsMap[0]["name"], "名称不一致").
|
|
|
- assertEqual(now2.Unix(), resultsMap[0]["time"].(time.Time).Local().Unix(), "时间不一致").
|
|
|
- assertEqual(uint64(tableNum2), resultsMap[0]["table_num"], "表数量不一致")
|
|
|
+ }, resultTableRows).
|
|
|
+ assertEqual(id2, (*resultTableRows)[0].ColumnValueString("id"), "ID不一致").
|
|
|
+ assertEqual(name2, (*resultTableRows)[0].ColumnValueString("name"), "名称不一致").
|
|
|
+ assertEqual(now2.Unix(), (*resultTableRows)[0].ColumnValueTime("time").Unix(), "时间不一致").
|
|
|
+ assertEqual(tableNum2, (*resultTableRows)[0].ColumnValueInt("table_num"), "表数量不一致")
|
|
|
}
|
|
|
|
|
|
func TestUpdate(t *testing.T) {
|
|
@@ -458,7 +450,7 @@ func TestUpdate(t *testing.T) {
|
|
|
newNow := time.Now().Local()
|
|
|
newTableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
|
|
|
|
|
|
- resultMap := make(map[string]any)
|
|
|
+ resultTableRow := client.NewTableRow()
|
|
|
|
|
|
newToolKit(t).
|
|
|
autoMigrate(&client.AutoMigrateRequest{
|
|
@@ -474,35 +466,33 @@ func TestUpdate(t *testing.T) {
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyColumns: []string{"id"},
|
|
|
- TableRow: map[string]any{
|
|
|
- "id": id,
|
|
|
- "name": name,
|
|
|
- "time": now,
|
|
|
- "table_num": tableNum,
|
|
|
- },
|
|
|
+ TableRow: client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id).
|
|
|
+ AddColumnValueString("name", name).
|
|
|
+ AddColumnValueTime("time", now).
|
|
|
+ AddColumnValueInt("table_num", tableNum),
|
|
|
UserID: "test",
|
|
|
}).
|
|
|
update(&client.UpdateRequest{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyValues: map[string]string{"id": id},
|
|
|
- NewTableRow: map[string]any{
|
|
|
- "id": id,
|
|
|
- "name": newName,
|
|
|
- "time": newNow,
|
|
|
- "table_num": newTableNum,
|
|
|
- },
|
|
|
+ NewTableRow: client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id).
|
|
|
+ AddColumnValueString("name", newName).
|
|
|
+ AddColumnValueTime("time", newNow).
|
|
|
+ AddColumnValueInt("table_num", newTableNum),
|
|
|
UserID: "test",
|
|
|
}).
|
|
|
queryByKeys(&client.QueryByKeysRequest{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyValues: map[string]string{"id": id},
|
|
|
- }, &resultMap).
|
|
|
- assertEqual(id, resultMap["id"], "ID不一致").
|
|
|
- assertEqual(newName, resultMap["name"], "名称不一致").
|
|
|
- assertEqual(newNow.Unix(), resultMap["time"].(time.Time).Local().Unix(), "时间不一致").
|
|
|
- assertEqual(uint64(newTableNum), resultMap["table_num"], "表数量不一致")
|
|
|
+ }, resultTableRow).
|
|
|
+ assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
|
|
|
+ assertEqual(newName, resultTableRow.ColumnValueString("name"), "名称不一致").
|
|
|
+ assertEqual(newNow.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
|
|
|
+ assertEqual(newTableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致")
|
|
|
}
|
|
|
|
|
|
func TestDelete(t *testing.T) {
|
|
@@ -532,12 +522,11 @@ func TestDelete(t *testing.T) {
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyColumns: []string{"id"},
|
|
|
- TableRow: map[string]any{
|
|
|
- "id": id,
|
|
|
- "name": name,
|
|
|
- "time": now,
|
|
|
- "table_num": tableNum,
|
|
|
- },
|
|
|
+ TableRow: client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id).
|
|
|
+ AddColumnValueString("name", name).
|
|
|
+ AddColumnValueTime("time", now).
|
|
|
+ AddColumnValueInt("table_num", tableNum),
|
|
|
UserID: "test",
|
|
|
}).
|
|
|
delete(&client.DeleteRequest{
|
|
@@ -590,19 +579,17 @@ func TestDeleteBatch(t *testing.T) {
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyColumns: []string{"id"},
|
|
|
- TableRows: []map[string]any{
|
|
|
- {
|
|
|
- "id": id1,
|
|
|
- "name": name1,
|
|
|
- "time": now1,
|
|
|
- "table_num": tableNum1,
|
|
|
- },
|
|
|
- {
|
|
|
- "id": id2,
|
|
|
- "name": name2,
|
|
|
- "time": now2,
|
|
|
- "table_num": tableNum2,
|
|
|
- },
|
|
|
+ TableRows: []*client.TableRow{
|
|
|
+ client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id1).
|
|
|
+ AddColumnValueString("name", name1).
|
|
|
+ AddColumnValueTime("time", now1).
|
|
|
+ AddColumnValueInt("table_num", tableNum1),
|
|
|
+ client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id2).
|
|
|
+ AddColumnValueString("name", name2).
|
|
|
+ AddColumnValueTime("time", now2).
|
|
|
+ AddColumnValueInt("table_num", tableNum2),
|
|
|
},
|
|
|
},
|
|
|
},
|
|
@@ -638,7 +625,7 @@ func TestReply(t *testing.T) {
|
|
|
now := time.Now().Local()
|
|
|
tableNum := rand.New(rand.NewSource(now.Unix())).Intn(10)
|
|
|
|
|
|
- resultMap := make(map[string]any)
|
|
|
+ resultTableRow := client.NewTableRow()
|
|
|
|
|
|
newToolKit(t).
|
|
|
autoMigrate(&client.AutoMigrateRequest{
|
|
@@ -654,12 +641,11 @@ func TestReply(t *testing.T) {
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyColumns: []string{"id"},
|
|
|
- TableRow: map[string]any{
|
|
|
- "id": id,
|
|
|
- "name": name,
|
|
|
- "time": now,
|
|
|
- "table_num": tableNum,
|
|
|
- },
|
|
|
+ TableRow: client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id).
|
|
|
+ AddColumnValueString("name", name).
|
|
|
+ AddColumnValueTime("time", now).
|
|
|
+ AddColumnValueInt("table_num", tableNum),
|
|
|
UserID: "test",
|
|
|
}).
|
|
|
reply(&client.ReplayRequest{
|
|
@@ -672,11 +658,11 @@ func TestReply(t *testing.T) {
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyValues: map[string]string{"id": id},
|
|
|
- }, &resultMap).
|
|
|
- assertEqual(id, resultMap["id"], "ID不一致").
|
|
|
- assertEqual(name, resultMap["name"], "名称不一致").
|
|
|
- assertEqual(now.Unix(), resultMap["time"].(time.Time).Local().Unix(), "时间不一致").
|
|
|
- assertEqual(uint64(tableNum), resultMap["table_num"], "表数量不一致")
|
|
|
+ }, resultTableRow).
|
|
|
+ assertEqual(id, resultTableRow.ColumnValueString("id"), "ID不一致").
|
|
|
+ assertEqual(name, resultTableRow.ColumnValueString("name"), "名称不一致").
|
|
|
+ assertEqual(now.Unix(), resultTableRow.ColumnValueTime("time").Unix(), "时间不一致").
|
|
|
+ assertEqual(tableNum, resultTableRow.ColumnValueInt("table_num"), "表数量不一致")
|
|
|
}
|
|
|
|
|
|
func TestEventQuery(t *testing.T) {
|
|
@@ -710,24 +696,22 @@ func TestEventQuery(t *testing.T) {
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyColumns: []string{"id"},
|
|
|
- TableRow: map[string]any{
|
|
|
- "id": id,
|
|
|
- "name": name,
|
|
|
- "time": now,
|
|
|
- "table_num": tableNum,
|
|
|
- },
|
|
|
+ TableRow: client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id).
|
|
|
+ AddColumnValueString("name", name).
|
|
|
+ AddColumnValueTime("time", now).
|
|
|
+ AddColumnValueInt("table_num", tableNum),
|
|
|
UserID: "test",
|
|
|
}).
|
|
|
update(&client.UpdateRequest{
|
|
|
TablePrefixWithSchema: tablePrefix,
|
|
|
Version: "v1",
|
|
|
KeyValues: map[string]string{"id": id},
|
|
|
- NewTableRow: map[string]any{
|
|
|
- "id": id,
|
|
|
- "name": newName,
|
|
|
- "time": newNow,
|
|
|
- "table_num": newTableNum,
|
|
|
- },
|
|
|
+ NewTableRow: client.NewTableRow().
|
|
|
+ AddColumnValueString("id", id).
|
|
|
+ AddColumnValueString("name", newName).
|
|
|
+ AddColumnValueTime("time", newNow).
|
|
|
+ AddColumnValueInt("table_num", newTableNum),
|
|
|
UserID: "test",
|
|
|
}).
|
|
|
countEventByKeys(&client.CountEventByKeysRequest{
|