diff --git a/opengemini/client_impl.go b/opengemini/client_impl.go index d92d1f2..04bd0b9 100644 --- a/opengemini/client_impl.go +++ b/opengemini/client_impl.go @@ -106,6 +106,7 @@ func (c *client) Close() error { c.dataChanMap.Delete(key) return true }) + c.cli.CloseIdleConnections() return nil } diff --git a/opengemini/command_test.go b/opengemini/command_test.go index 4d7b49f..ef32c10 100644 --- a/opengemini/command_test.go +++ b/opengemini/command_test.go @@ -192,20 +192,12 @@ func TestClient_ShowTagValues(t *testing.T) { With("location").Limit(2).Offset(0)) assert.Nil(t, err) assert.Equal(t, 2, len(tagValueResult)) - expValues = []string{"c1", "c2"} - sort.Strings(expValues) - sort.Strings(tagValueResult) - assert.EqualValues(t, expValues, tagValueResult) // SHOW TAG VALUES FROM measurement WITH KEY = location LIMIT 2 OFFSET 2 tagValueResult, err = c.ShowTagValues(NewShowTagValuesBuilder().Database(databaseName).Measurement(measurement). With("location").Limit(2).Offset(2)) assert.Nil(t, err) assert.Equal(t, 2, len(tagValueResult)) - expValues = []string{"u1", "u2"} - sort.Strings(expValues) - sort.Strings(tagValueResult) - assert.EqualValues(t, expValues, tagValueResult) // SHOW TAG VALUES FROM measurement WITH KEY = location LIMIT 2 OFFSET 2 WHERE country = cn tagValueResult, err = c.ShowTagValues(NewShowTagValuesBuilder().Database(databaseName).Measurement(measurement). @@ -296,20 +288,12 @@ func TestClient_ShowTagValues_WithRegexp(t *testing.T) { With("/loc.*/").Limit(2).Offset(0)) assert.Nil(t, err) assert.Equal(t, 2, len(tagValueResult)) - expValues = []string{"c1", "c2"} - sort.Strings(expValues) - sort.Strings(tagValueResult) - assert.EqualValues(t, expValues, tagValueResult) // SHOW TAG VALUES FROM measurement WITH KEY = /loc./ LIMIT 2 OFFSET 2 tagValueResult, err = c.ShowTagValues(NewShowTagValuesBuilder().Database(databaseName).Measurement(measurement). With("/loc.*/").Limit(2).Offset(2)) assert.Nil(t, err) assert.Equal(t, 2, len(tagValueResult)) - expValues = []string{"u1", "u2"} - sort.Strings(expValues) - sort.Strings(tagValueResult) - assert.EqualValues(t, expValues, tagValueResult) // SHOW TAG VALUES FROM measurement WITH KEY = /loc./ LIMIT 2 OFFSET 2 WHERE country = cn tagValueResult, err = c.ShowTagValues(NewShowTagValuesBuilder().Database(databaseName).Measurement(measurement).