@@ -2,14 +2,15 @@ package gitbase_test
2
2
3
3
import (
4
4
"context"
5
+ "fmt"
5
6
"io/ioutil"
6
7
"os"
7
8
"testing"
8
9
9
10
"github.com/src-d/gitbase"
10
- "github.com/stretchr/testify/require"
11
11
"github.com/src-d/go-mysql-server/sql"
12
12
"github.com/src-d/go-mysql-server/sql/index/pilosa"
13
+ "github.com/stretchr/testify/require"
13
14
yaml "gopkg.in/yaml.v2"
14
15
)
15
16
@@ -20,13 +21,12 @@ type Query struct {
20
21
}
21
22
22
23
func TestRegressionQueries (t * testing.T ) {
23
- require := require .New (t )
24
-
25
- engine , pool , cleanup := setup (t )
24
+ _ , pool , cleanup := setup (t )
26
25
defer cleanup ()
27
26
27
+ engine := newSquashEngine (pool )
28
28
tmpDir , err := ioutil .TempDir (os .TempDir (), "pilosa-idx-gitbase" )
29
- require .NoError (err )
29
+ require .NoError (t , err )
30
30
defer os .RemoveAll (tmpDir )
31
31
engine .Catalog .RegisterIndexDriver (pilosa .NewDriver (tmpDir ))
32
32
@@ -36,20 +36,27 @@ func TestRegressionQueries(t *testing.T) {
36
36
)
37
37
38
38
queries , err := loadQueriesYaml ("./_testdata/regression.yml" )
39
- require .NoError (err )
39
+ require .NoError (t , err )
40
40
41
41
for _ , q := range queries {
42
- for _ , stmt := range q .Statements {
43
- _ , iter , err := engine .Query (ctx , stmt )
44
- if err != nil {
45
- require .Failf (err .Error (), "ID: %s, Name: %s, Statement: %s" , q .ID , q .Name , stmt )
46
- }
42
+ t .Run (q .ID , func (t * testing.T ) {
43
+ require := require .New (t )
44
+ for _ , stmt := range q .Statements {
45
+ _ , iter , err := engine .Query (ctx , stmt )
46
+ if err != nil {
47
+ require .Failf (err .Error (), "ID: %s, Name: %s, Statement: %s" , q .ID , q .Name , stmt )
48
+ }
49
+
50
+ rows , err := sql .RowIterToRows (iter )
51
+ if err != nil {
52
+ require .Failf (err .Error (), "ID: %s, Name: %s, Statement: %s" , q .ID , q .Name , stmt )
53
+ }
47
54
48
- _ , err = sql . RowIterToRows ( iter )
49
- if err != nil {
50
- require . Failf ( err . Error (), "ID: %s, Name: %s, Statement: %s" , q . ID , q . Name , stmt )
55
+ for _ , row := range rows {
56
+ fmt . Println ( row )
57
+ }
51
58
}
52
- }
59
+ })
53
60
}
54
61
}
55
62
0 commit comments