添加测试

test/v1/sync_test.go

@@ -2,7 +2,9 @@ package v1
 
 import (
 	"git.sxidc.com/service-supports/dps-sdk/client"
+	"sync"
 	"testing"
+	"time"
 )
 
 var tableModelDescribe1 = map[string]string{
@@ -27,7 +29,7 @@ func TestSync(t *testing.T) {
 	name1 := "name1"
 	name2 := "name2"
 
-	newToolKit(t).
+	toolKit := newToolKit(t).
 		autoMigrate(&client.AutoMigrateRequest{
 			Items: []client.AutoMigrateItem{
 				{
@@ -61,101 +63,44 @@ func TestSync(t *testing.T) {
 				AddColumnValueString("id", id2).
 				AddColumnValueString("name2", name2),
 			UserID: "test",
-		}).
-		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
-			TablePrefixWithSchema: tablePrefix1,
-			Version:               "v1",
-			Where: client.NewClause().Equal("id", id1).
-				Equal("name1", name1),
-			PageNo:   0,
-			PageSize: 0,
-		}, nil).
-		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
-			TablePrefixWithSchema: tablePrefix2,
-			Version:               "v1",
-			Where: client.NewClause().Equal("id", id2).
-				Equal("name2", name2),
-			PageNo:   0,
-			PageSize: 0,
-		}, nil).
-		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
-			TablePrefixWithSchema: tablePrefix1,
-			Version:               "v1",
-			Where: client.NewClause().Equal("id", id1).
-				Equal("name1", name1),
-			PageNo:   0,
-			PageSize: 0,
-		}, nil).
-		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
-			TablePrefixWithSchema: tablePrefix2,
-			Version:               "v1",
-			Where: client.NewClause().Equal("id", id2).
-				Equal("name2", name2),
-			PageNo:   0,
-			PageSize: 0,
-		}, nil).
-		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
-			TablePrefixWithSchema: tablePrefix1,
-			Version:               "v1",
-			Where: client.NewClause().Equal("id", id1).
-				Equal("name1", name1),
-			PageNo:   0,
-			PageSize: 0,
-		}, nil).
-		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
-			TablePrefixWithSchema: tablePrefix2,
-			Version:               "v1",
-			Where: client.NewClause().Equal("id", id2).
-				Equal("name2", name2),
-			PageNo:   0,
-			PageSize: 0,
-		}, nil).
-		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
-			TablePrefixWithSchema: tablePrefix1,
-			Version:               "v1",
-			Where: client.NewClause().Equal("id", id1).
-				Equal("name1", name1),
-			PageNo:   0,
-			PageSize: 0,
-		}, nil).
-		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
-			TablePrefixWithSchema: tablePrefix2,
-			Version:               "v1",
-			Where: client.NewClause().Equal("id", id2).
-				Equal("name2", name2),
-			PageNo:   0,
-			PageSize: 0,
-		}, nil).
-		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
-			TablePrefixWithSchema: tablePrefix1,
-			Version:               "v1",
-			Where: client.NewClause().Equal("id", id1).
-				Equal("name1", name1),
-			PageNo:   0,
-			PageSize: 0,
-		}, nil).
-		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
-			TablePrefixWithSchema: tablePrefix2,
-			Version:               "v1",
-			Where: client.NewClause().Equal("id", id2).
-				Equal("name2", name2),
-			PageNo:   0,
-			PageSize: 0,
-		}, nil).
-		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
-			TablePrefixWithSchema: tablePrefix1,
-			Version:               "v1",
-			Where: client.NewClause().Equal("id", id1).
-				Equal("name1", name1),
-			PageNo:   0,
-			PageSize: 0,
-		}, nil).
-		queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
-			TablePrefixWithSchema: tablePrefix2,
-			Version:               "v1",
-			Where: client.NewClause().Equal("id", id2).
-				Equal("name2", name2),
-			PageNo:   0,
-			PageSize: 0,
-		}, nil)
+		})
+
+	wg := sync.WaitGroup{}
+	wg.Add(2)
+
+	go func() {
+		for i := 0; i < 100; i++ {
+			toolKit.queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
+				TablePrefixWithSchema: tablePrefix1,
+				Version:               "v1",
+				Where: client.NewClause().Equal("id", id1).
+					Equal("name1", name1),
+				PageNo:   0,
+				PageSize: 0,
+			}, nil)
+
+			time.Sleep(100 * time.Millisecond)
+		}
+
+		wg.Done()
+	}()
+
+	go func() {
+		for i := 0; i < 100; i++ {
+			toolKit.queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
+				TablePrefixWithSchema: tablePrefix2,
+				Version:               "v1",
+				Where: client.NewClause().Equal("id", id2).
+					Equal("name2", name2),
+				PageNo:   0,
+				PageSize: 0,
+			}, nil)
+
+			time.Sleep(100 * time.Millisecond)
+		}
+
+		wg.Done()
+	}()
+
+	wg.Wait()
 }