|
@@ -4,7 +4,6 @@ import (
|
|
|
"git.sxidc.com/service-supports/dps-sdk/client"
|
|
|
"sync"
|
|
|
"testing"
|
|
|
- "time"
|
|
|
)
|
|
|
|
|
|
var tableModelDescribe1 = map[string]string{
|
|
@@ -69,6 +68,8 @@ func TestSync(t *testing.T) {
|
|
|
wg.Add(2)
|
|
|
|
|
|
go func() {
|
|
|
+ defer wg.Done()
|
|
|
+
|
|
|
for i := 0; i < 100; i++ {
|
|
|
toolKit.queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
|
|
|
TablePrefixWithSchema: tablePrefix1,
|
|
@@ -78,14 +79,12 @@ func TestSync(t *testing.T) {
|
|
|
PageNo: 0,
|
|
|
PageSize: 0,
|
|
|
}, nil)
|
|
|
-
|
|
|
- time.Sleep(100 * time.Millisecond)
|
|
|
}
|
|
|
-
|
|
|
- wg.Done()
|
|
|
}()
|
|
|
|
|
|
go func() {
|
|
|
+ defer wg.Done()
|
|
|
+
|
|
|
for i := 0; i < 100; i++ {
|
|
|
toolKit.queryOnlyByWhereAndOrderBy(&client.QueryByWhereAndOrderByRequest{
|
|
|
TablePrefixWithSchema: tablePrefix2,
|
|
@@ -95,11 +94,7 @@ func TestSync(t *testing.T) {
|
|
|
PageNo: 0,
|
|
|
PageSize: 0,
|
|
|
}, nil)
|
|
|
-
|
|
|
- time.Sleep(100 * time.Millisecond)
|
|
|
}
|
|
|
-
|
|
|
- wg.Done()
|
|
|
}()
|
|
|
|
|
|
wg.Wait()
|