添加测试

test/v1/sync_test.go

@@ -0,0 +1,161 @@
+package v1
+
+import (
+	"git.sxidc.com/service-supports/dps-sdk/client"
+	"testing"
+)
+
+var tableModelDescribe1 = map[string]string{
+	"ID":    "gorm:\"primary_key;type:varchar(32);comment:id;\"",
+	"Name1": "gorm:\"not null;type:varchar(128);comment:数据库名称;\"",
+}
+
+var tableModelDescribe2 = map[string]string{
+	"ID":    "gorm:\"primary_key;type:varchar(32);comment:id;\"",
+	"Name2": "gorm:\"not null;type:varchar(128);comment:数据库名称;\"",
+}
+
+func TestSync(t *testing.T) {
+	initClient(t, "localhost:30170", "ee2d7dabe56646ce835d80873348ee0e")
+	defer destroyClient(t, "ee2d7dabe56646ce835d80873348ee0e")
+
+	tablePrefix1 := "test.test1"
+	tablePrefix2 := "test.test2"
+
+	id1 := simpleUUID()
+	id2 := simpleUUID()
+	name1 := "name1"
+	name2 := "name2"
+
+	newToolKit(t).
+		autoMigrate(&client.AutoMigrateRequest{
+			Items: []client.AutoMigrateItem{
+				{
+					TablePrefixWithSchema: tablePrefix1,
+					Version:               "v1",
+					TableModelDescribe:    tableModelDescribe1,
+					NoEvent:               false,
+				},
+				{
+					TablePrefixWithSchema: tablePrefix2,
+					Version:               "v1",
+					TableModelDescribe:    tableModelDescribe2,
+					NoEvent:               false,
+				},
+			},
+		}).
+		insert(&client.InsertRequest{
+			TablePrefixWithSchema: tablePrefix1,
+			Version:               "v1",
+			KeyColumns:            []string{"id"},
+			TableRow: client.NewTableRow().
+				AddColumnValueString("id", id1).
+				AddColumnValueString("name1", name1),
+			UserID: "test",
+		}).
+		insert(&client.InsertRequest{
+			TablePrefixWithSchema: tablePrefix2,
+			Version:               "v1",
+			KeyColumns:            []string{"id"},
+			TableRow: client.NewTableRow().
+				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)
+}