diff --git a/internal/sqladapter/testing/adapter.go.tpl b/internal/sqladapter/testing/adapter.go.tpl index 9f185d9016f7a8b5ef992236d092659c4d32fe5d..6cc8dc27c03e8259bb792de77705bc029077d353 100644 --- a/internal/sqladapter/testing/adapter.go.tpl +++ b/internal/sqladapter/testing/adapter.go.tpl @@ -1381,21 +1381,21 @@ func TestStressPreparedStatementCache(t *testing.T) { t.Fatal(err) } - var wg sync.WaitGroup - - for i := 1; i < 1000; i++ { - wg.Add(1) - go func(i int) { - defer wg.Done() - res := sess.Collection("artist").Find().Select(db.Raw(fmt.Sprintf("COUNT(%d)", i%5))) - var data map[string]interface{} - if err := res.One(&data); err != nil { - tFatal(err) - } - }(i) - } - - wg.Wait() + var wg sync.WaitGroup + + for i := 1; i < 1000; i++ { + wg.Add(1) + go func(i int) { + defer wg.Done() + res := sess.Collection("artist").Find().Select(db.Raw(fmt.Sprintf("COUNT(%d)", i%5))) + var data map[string]interface{} + if err := res.One(&data); err != nil { + tFatal(err) + } + }(i) + } + + wg.Wait() } func TestExhaustConnectionPool(t *testing.T) {