fix: refine the session variables accessing (#193) (#226)

* feat(pg): supports SET/SHOW statement (#193)

* fix: bypass the configuration of DuckDB setting to backend DuckDB connection

* fix: solve problems of getting and setting session variables

* fix: solve problems of unit test in binlogreplication

* fix: RESET ALL is not supported yet

* refactor: move handlers for pg_catalog to a new file

* fix: adopt CR feedback

binlogreplication/binlog_replication_reconnect_test.go

@@ -23,6 +23,7 @@ import (
 
 	"github.com/Shopify/toxiproxy/v2"
 	toxiproxyclient "github.com/Shopify/toxiproxy/v2/client"
+	"github.com/apecloud/myduckserver/test"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/rs/zerolog"
 	"github.com/stretchr/testify/require"
@@ -152,7 +153,7 @@ func showReplicaStatus(t *testing.T) map[string]interface{} {
 }
 
 func configureToxiProxy(t *testing.T) {
-	toxiproxyPort := findFreePort()
+	toxiproxyPort := test.FindFreePort()
 
 	metrics := toxiproxy.NewMetricsContainer(prometheus.NewRegistry())
 	toxiproxyServer := toxiproxy.NewServer(metrics, zerolog.Nop())
@@ -164,7 +165,7 @@ func configureToxiProxy(t *testing.T) {
 
 	toxiClient = toxiproxyclient.NewClient(fmt.Sprintf("localhost:%d", toxiproxyPort))
 
-	proxyPort = findFreePort()
+	proxyPort = test.FindFreePort()
 	var err error
 	mysqlProxy, err = toxiClient.CreateProxy("mysql",
 		fmt.Sprintf("localhost:%d", proxyPort), // downstream

binlogreplication/binlog_replication_restart_test.go

@@ -19,6 +19,7 @@ import (
 	"testing"
 	"time"
 
+	"github.com/apecloud/myduckserver/test"
 	"github.com/stretchr/testify/require"
 )
 
@@ -45,12 +46,15 @@ func TestBinlogReplicationServerRestart(t *testing.T) {
 
 	// Let the replica process a few transactions, then stop the server and pause a second
 	waitForReplicaToReachGtid(t, 3)
-	stopDuckSqlServer(t)
+	test.StopDuckSqlServer(t, duckProcess)
 	time.Sleep(1000 * time.Millisecond)
 
 	var err error
-	duckPort, duckProcess, err = startDuckSqlServer(testDir, nil)
+	testEnv := test.NewTestEnv()
+	setupTestEnv(testEnv)
+	err = test.StartDuckSqlServer(t, testDir, nil, testEnv)
 	require.NoError(t, err)
+	loadEnvFromTestEnv(testEnv)
 
 	// Check replication status on the replica and assert configuration persisted
 	status := showReplicaStatus(t)