@@ -11,35 +11,12 @@ import (
11
11
"github.com/cashapp/blip/test"
12
12
)
13
13
14
- func TestPrepareForSingleLevelAndNoSourceOnMySQL57 (t * testing.T ) {
15
- // default source on MySQL 5.7 should be `blip`
16
- _ , db , err := test .Connection ("mysql57" )
17
- if err != nil {
18
- if test .Build {
19
- t .Skip ("mysql57 not running" )
20
- } else {
21
- t .Fatal (err )
22
- }
23
- }
24
- defer db .Close ()
25
-
26
- c := NewLag (db )
27
-
28
- defaultPlan := test .ReadPlan (t , "" )
29
- _ , err = c .Prepare (context .Background (), defaultPlan )
30
- if err != nil {
31
- t .Error (err )
32
- }
33
-
34
- assert .Equal (t , "blip" , c .lagWriterIn ["kpi" ])
35
- }
36
-
37
14
func TestPrepareForSingleLevelAndNoSourceOnMySQL80 (t * testing.T ) {
38
15
// default source on MySQL 8.0 should be `pfs`
39
16
_ , db , err := test .Connection ("mysql80" )
40
17
if err != nil {
41
18
if test .Build {
42
- t .Skip ("mysql57 not running" )
19
+ t .Skip ("mysql80 not running" )
43
20
} else {
44
21
t .Fatal (err )
45
22
}
@@ -61,7 +38,7 @@ func TestPrepareWithInvalidSource(t *testing.T) {
61
38
_ , db , err := test .Connection ("mysql80" )
62
39
if err != nil {
63
40
if test .Build {
64
- t .Skip ("mysql57 not running" )
41
+ t .Skip ("mysql80 not running" )
65
42
} else {
66
43
t .Fatal (err )
67
44
}
@@ -81,7 +58,7 @@ func TestCollectWithNoSource(t *testing.T) {
81
58
_ , db , err := test .Connection ("mysql80" )
82
59
if err != nil {
83
60
if test .Build {
84
- t .Skip ("mysql57 not running" )
61
+ t .Skip ("mysql80 not running" )
85
62
} else {
86
63
t .Fatal (err )
87
64
}
@@ -107,7 +84,7 @@ func TestCollectWithAllSources(t *testing.T) {
107
84
_ , db , err := test .Connection ("mysql80" )
108
85
if err != nil {
109
86
if test .Build {
110
- t .Skip ("mysql57 not running" )
87
+ t .Skip ("mysql80 not running" )
111
88
} else {
112
89
t .Fatal (err )
113
90
}
0 commit comments