Merge pull request #1497 from pablomatiasgomez/reduce-memory-usage-co…

…mpressor

change container provider, verify close conn error in tests

conn.go

@@ -223,6 +223,7 @@ func (c *connect) close() error {
 	}
 
 	c.buffer = nil
+	c.compressor = nil
 
 	c.readerMutex.Lock()
 	c.reader = nil

tests/conn_test.go

@@ -358,8 +358,7 @@ func TestConnectionExpiresIdleConnection(t *testing.T) {
 			defer wg.Done()
 			r, err := conn.Query(ctx, "SELECT 1")
 			require.NoError(t, err)
-
-			r.Close()
+			require.NoError(t, r.Close())
 		}()
 	}
 	wg.Wait()
@@ -390,8 +389,8 @@ func TestConnectionCloseIdle(t *testing.T) {
 		conn, err := TestClientWithDefaultSettings(testEnv)
 		require.NoError(t, err)
 		err = conn.Ping(ctx)
-		conn.Close()
 		require.NoError(t, err)
+		require.NoError(t, conn.Close())
 	}
 	time.Sleep(100 * time.Millisecond) // wait for all connections closed
 	finalGoroutine := runtime.NumGoroutine()

tests/utils.go

@@ -127,7 +127,7 @@ func CreateClickHouseTestEnvironment(testSet string) (ClickHouseTestEnvironment,
 	// create a ClickHouse Container
 	ctx := context.Background()
 	// attempt use docker for CI
-	provider, err := testcontainers.ProviderDocker.GetProvider()
+	provider, err := testcontainers.ProviderDefault.GetProvider()
 	if err != nil {
 		fmt.Printf("Docker is not running and no clickhouse connections details were provided. Skipping tests: %s\n", err)
 		os.Exit(0)