|
|
@@ -1,6 +1,7 @@
|
|
|
package mysql
|
|
|
|
|
|
import (
|
|
|
+ "context"
|
|
|
"fmt"
|
|
|
"math/rand"
|
|
|
"strings"
|
|
|
@@ -129,7 +130,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -217,7 +218,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -264,7 +265,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -327,7 +328,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -352,7 +353,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -378,7 +379,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -473,7 +474,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -495,7 +496,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -517,7 +518,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -539,7 +540,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -561,7 +562,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -583,7 +584,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -605,7 +606,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -627,7 +628,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -649,7 +650,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -671,7 +672,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -693,7 +694,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -716,7 +717,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -741,7 +742,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -802,7 +803,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
queryResult := resp.Results["Deploys"]
|
|
|
So(err, ShouldBeNil)
|
|
|
So(len(queryResult.Tables[0].Rows), ShouldEqual, 3)
|
|
|
@@ -825,7 +826,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
queryResult := resp.Results["Tickets"]
|
|
|
So(err, ShouldBeNil)
|
|
|
So(len(queryResult.Tables[0].Rows), ShouldEqual, 3)
|
|
|
@@ -851,7 +852,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -881,7 +882,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -911,7 +912,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -941,7 +942,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -969,7 +970,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|
|
|
@@ -997,7 +998,7 @@ func TestMySQL(t *testing.T) {
|
|
|
},
|
|
|
}
|
|
|
|
|
|
- resp, err := endpoint.Query(nil, nil, query)
|
|
|
+ resp, err := endpoint.Query(context.Background(), nil, query)
|
|
|
So(err, ShouldBeNil)
|
|
|
queryResult := resp.Results["A"]
|
|
|
So(queryResult.Error, ShouldBeNil)
|