diff --git a/go.mod b/go.mod index 1109bfcb296..ad9242a55d9 100644 --- a/go.mod +++ b/go.mod @@ -50,7 +50,7 @@ require ( github.com/grafana/grafana-aws-sdk v0.4.0 github.com/grafana/grafana-live-sdk v0.0.5 github.com/grafana/grafana-plugin-model v0.0.0-20190930120109-1fc953a61fb4 - github.com/grafana/grafana-plugin-sdk-go v0.93.0 + github.com/grafana/grafana-plugin-sdk-go v0.94.0 github.com/grafana/loki v1.6.2-0.20210510132741-f408e05ad426 github.com/grpc-ecosystem/go-grpc-middleware v1.3.0 github.com/hashicorp/go-hclog v0.16.0 diff --git a/go.sum b/go.sum index a86fdf24025..adfb54e24f2 100644 --- a/go.sum +++ b/go.sum @@ -242,8 +242,6 @@ github.com/aws/aws-sdk-go v1.35.30/go.mod h1:tlPOdRjfxPBpNIwqDj61rmsnA85v9jc0Ps9 github.com/aws/aws-sdk-go v1.35.31/go.mod h1:hcU610XS61/+aQV88ixoOzUoG7v3b31pl2zKMmprdro= github.com/aws/aws-sdk-go v1.37.8/go.mod h1:hcU610XS61/+aQV88ixoOzUoG7v3b31pl2zKMmprdro= github.com/aws/aws-sdk-go v1.38.3/go.mod h1:hcU610XS61/+aQV88ixoOzUoG7v3b31pl2zKMmprdro= -github.com/aws/aws-sdk-go v1.38.17 h1:1OfcfEtNrphUZYa+J0U35/1hxePbb3ASSQWdFS7L0Hs= -github.com/aws/aws-sdk-go v1.38.17/go.mod h1:hcU610XS61/+aQV88ixoOzUoG7v3b31pl2zKMmprdro= github.com/aws/aws-sdk-go v1.38.34 h1:JSAyS6hSDLbRmCAz9VAkwDf5oh/olt9mBTrVBWGJcU8= github.com/aws/aws-sdk-go v1.38.34/go.mod h1:hcU610XS61/+aQV88ixoOzUoG7v3b31pl2zKMmprdro= github.com/aws/aws-sdk-go-v2 v0.18.0/go.mod h1:JWVYvqSMppoMJC0x5wdwiImzgXTI9FuZwxzkQq9wy+g= @@ -917,10 +915,8 @@ github.com/grafana/grafana-plugin-model v0.0.0-20190930120109-1fc953a61fb4 h1:SP github.com/grafana/grafana-plugin-model v0.0.0-20190930120109-1fc953a61fb4/go.mod h1:nc0XxBzjeGcrMltCDw269LoWF9S8ibhgxolCdA1R8To= github.com/grafana/grafana-plugin-sdk-go v0.79.0/go.mod h1:NvxLzGkVhnoBKwzkst6CFfpMFKwAdIUZ1q8ssuLeF60= github.com/grafana/grafana-plugin-sdk-go v0.91.0/go.mod h1:Ot3k7nY7P6DXmUsDgKvNB7oG1v7PRyTdmnYVoS554bU= -github.com/grafana/grafana-plugin-sdk-go v0.93.0 h1:SPLOkEWrq70KV6xINvZqHCwUxGn33YS0zgU2fXT84QM= -github.com/grafana/grafana-plugin-sdk-go v0.93.0/go.mod h1:3VXz4nCv6wH5SfgB3mlW39s+c+LetqSCjFj7xxPC5+M= -github.com/grafana/loki v1.6.2-0.20210429132126-d88f3996eaa2 h1:6CTxmXZHpGhYDOUSW+EYETW69r16PsbEepst9RZvXaQ= -github.com/grafana/loki v1.6.2-0.20210429132126-d88f3996eaa2/go.mod h1:Jl38SKo8vU0dXswEG/51+01qJQH+MvbdKbfyVCkOe/E= +github.com/grafana/grafana-plugin-sdk-go v0.94.0 h1:S5Jk3QFzH2XXbVze9RDStwf/AjwpeDRUayVgC4LuczY= +github.com/grafana/grafana-plugin-sdk-go v0.94.0/go.mod h1:3VXz4nCv6wH5SfgB3mlW39s+c+LetqSCjFj7xxPC5+M= github.com/grafana/loki v1.6.2-0.20210510132741-f408e05ad426 h1:fVUMdXAjiHsx71Twl/oie1OLDH+dxL7+mBdQK/H2Wgs= github.com/grafana/loki v1.6.2-0.20210510132741-f408e05ad426/go.mod h1:IfQ9BWq2sVAk3iKB4Pahz6QNTs5D4WpfJj/AY8xzmNw= github.com/gregjones/httpcache v0.0.0-20180305231024-9cad4c3443a7/go.mod h1:FecbI9+v66THATjSRHfNgh1IVFe/9kFxbXtjV0ctIMA= diff --git a/pkg/tsdb/mssql/mssql_test.go b/pkg/tsdb/mssql/mssql_test.go index 989cdb51330..b13ff27f4ea 100644 --- a/pkg/tsdb/mssql/mssql_test.go +++ b/pkg/tsdb/mssql/mssql_test.go @@ -142,12 +142,16 @@ func TestMSSQL(t *testing.T) { resp, err := endpoint.DataQuery(context.Background(), nil, query) require.NoError(t, err) queryResult := resp.Results["A"] + require.NotNil(t, queryResult) + require.NoError(t, queryResult.Error) + require.NotNil(t, queryResult.Dataframes) - frames, _ := queryResult.Dataframes.Decoded() + frames, err := queryResult.Dataframes.Decoded() + require.NoError(t, err) require.Equal(t, 1, len(frames)) require.Equal(t, 24, len(frames[0].Fields)) - require.Equal(t, true, *frames[0].Fields[0].At(0).(*bool)) + require.Equal(t, true, frames[0].Fields[0].At(0).(bool)) require.Equal(t, int64(5), *frames[0].Fields[1].At(0).(*int64)) require.Equal(t, int64(20020), *frames[0].Fields[2].At(0).(*int64)) require.Equal(t, int64(980300), *frames[0].Fields[3].At(0).(*int64)) diff --git a/pkg/tsdb/mysql/mysql_test.go b/pkg/tsdb/mysql/mysql_test.go index 0770df42c84..cca34b62b4c 100644 --- a/pkg/tsdb/mysql/mysql_test.go +++ b/pkg/tsdb/mysql/mysql_test.go @@ -150,11 +150,11 @@ func TestMySQL(t *testing.T) { require.Equal(t, "def", *frameOne.Fields[2].At(0).(*string)) require.Equal(t, int32(1), frameOne.Fields[3].At(0).(int32)) require.Equal(t, int16(10), frameOne.Fields[4].At(0).(int16)) - require.Equal(t, int64(100), frameOne.Fields[5].At(0).(int64)) - require.Equal(t, int32(1420070400), frameOne.Fields[6].At(0).(int32)) + require.Equal(t, int64(100), *(frameOne.Fields[5].At(0).(*int64))) + require.Equal(t, int64(1420070400), *(frameOne.Fields[6].At(0).(*int64))) require.Equal(t, 1.11, *frameOne.Fields[7].At(0).(*float64)) require.Equal(t, 2.22, *frameOne.Fields[8].At(0).(*float64)) - require.Equal(t, float32(3.33), frameOne.Fields[9].At(0).(float32)) + require.Equal(t, float64(3.33), *(frameOne.Fields[9].At(0).(*float64))) require.WithinDuration(t, time.Now().UTC(), *frameOne.Fields[10].At(0).(*time.Time), 10*time.Second) require.WithinDuration(t, time.Now(), *frameOne.Fields[11].At(0).(*time.Time), 10*time.Second) require.Equal(t, "11:11:11", *frameOne.Fields[12].At(0).(*string)) diff --git a/pkg/tsdb/postgres/postgres_test.go b/pkg/tsdb/postgres/postgres_test.go index 6076d28b119..bc64256c32f 100644 --- a/pkg/tsdb/postgres/postgres_test.go +++ b/pkg/tsdb/postgres/postgres_test.go @@ -254,7 +254,7 @@ func TestPostgres(t *testing.T) { require.Len(t, frames, 1) require.Len(t, frames[0].Fields, 17) - require.Equal(t, int16(1), *frames[0].Fields[0].At(0).(*int16)) + require.Equal(t, int16(1), frames[0].Fields[0].At(0).(int16)) require.Equal(t, int32(2), *frames[0].Fields[1].At(0).(*int32)) require.Equal(t, int64(3), *frames[0].Fields[2].At(0).(*int64)) diff --git a/pkg/tsdb/sqleng/sql_engine.go b/pkg/tsdb/sqleng/sql_engine.go index a38141fc9c8..ac821a1609f 100644 --- a/pkg/tsdb/sqleng/sql_engine.go +++ b/pkg/tsdb/sqleng/sql_engine.go @@ -253,8 +253,8 @@ func (e *dataPlugin) executeQuery(query plugins.DataSubQuery, wg *sync.WaitGroup } // Convert row.Rows to dataframe - myCs := e.queryResultTransformer.GetConverterList() - frame, _, err := sqlutil.FrameFromRows(rows.Rows, rowLimit, myCs...) + stringConverters := e.queryResultTransformer.GetConverterList() + frame, err := sqlutil.FrameFromRows(rows.Rows, rowLimit, sqlutil.ToConverters(stringConverters...)...) if err != nil { errAppendDebug("convert frame from rows error", err) return