test: add HTTP protocol coverage for issue 1839

Author: chaewonkong

tests/issues/1839_test.go

@@ -4,8 +4,10 @@ import (
 	"context"
 	"testing"
 
-	clickhouse_tests "github.com/ClickHouse/clickhouse-go/v2/tests"
 	"github.com/stretchr/testify/require"
+
+	"github.com/ClickHouse/clickhouse-go/v2"
+	clickhouse_tests "github.com/ClickHouse/clickhouse-go/v2/tests"
 )
 
 func Test1839(t *testing.T) {
@@ -16,10 +18,10 @@ func Test1839(t *testing.T) {
 	t.Cleanup(func() { conn.Close() })
 
 	require.NoError(t, conn.Exec(t.Context(), `
-			CREATE TABLE test_1839 (
+		CREATE TABLE test_1839 (
 		  col Enum8('a\'b' = 1, 'c\'d' = 2, 'a\'b\'c' = 3)
 		) ENGINE = MergeTree ORDER BY tuple()
-		`), "Create table failed")
+	`), "Create table failed")
 
 	t.Cleanup(func() {
 		if err := conn.Exec(context.Background(), "DROP TABLE IF EXISTS test_1839"); err != nil {
@@ -47,3 +49,43 @@ func Test1839(t *testing.T) {
 	require.NoError(t, rows.Err(), "Scan failed")
 	require.Equal(t, []string{"a'b", "c'd", "a'b'c"}, results)
 }
+
+func Test1839HTTP(t *testing.T) {
+	testEnv, err := clickhouse_tests.GetTestEnvironment("issues")
+	require.NoError(t, err)
+	conn, err := clickhouse_tests.GetConnection("issues", t, clickhouse.HTTP, clickhouse_tests.TestClientDefaultSettings(testEnv), nil, nil)
+	require.NoError(t, err)
+	t.Cleanup(func() { conn.Close() })
+
+	require.NoError(t, conn.Exec(t.Context(), `
+		CREATE TABLE test_1839_http (
+		  col Enum8('a\'b' = 1, 'c\'d' = 2, 'a\'b\'c' = 3)
+		) ENGINE = MergeTree ORDER BY tuple()
+	`), "Create table failed")
+
+	t.Cleanup(func() {
+		if err := conn.Exec(context.Background(), "DROP TABLE IF EXISTS test_1839_http"); err != nil {
+			t.Logf("DROP TABLE test_1839_http failed: %v", err)
+		}
+	})
+
+	batch, err := conn.PrepareBatch(t.Context(), "INSERT INTO test_1839_http")
+	require.NoError(t, err, "PrepareBatch failed")
+	require.NoError(t, batch.Append("a'b"), "Append failed for %q", "a'b")
+	require.NoError(t, batch.Append("c'd"), "Append failed for %q", "c'd")
+	require.NoError(t, batch.Append("a'b'c"), "Append failed for %q", "a'b'c")
+	require.NoError(t, batch.Send(), "Send failed")
+
+	rows, err := conn.Query(t.Context(), "SELECT col FROM test_1839_http ORDER BY col")
+	require.NoError(t, err, "SELECT col failed")
+	defer rows.Close()
+
+	var results []string
+	for rows.Next() {
+		var s string
+		require.NoError(t, rows.Scan(&s))
+		results = append(results, s)
+	}
+	require.NoError(t, rows.Err(), "Scan failed")
+	require.Equal(t, []string{"a'b", "c'd", "a'b'c"}, results)
+}