Fix pg replication test

main.go

@@ -184,11 +184,10 @@ func main() {
 			logrus.WithError(err).Fatalln("Failed to create the `public` schema")
 		}
 
-		pgserver.InitSuperuser(superuserPassword)
-
 		pgServer, err := pgserver.NewServer(
 			provider, pool,
 			address, postgresPort,
+			superuserPassword,
 			func() *sql.Context {
 				session := backend.NewSession(memory.NewSession(sql.NewBaseSession(), provider), provider, pool)
 				return sql.NewContext(context.Background(), sql.WithSession(session))

pgserver/server.go

@@ -2,6 +2,7 @@ package pgserver
 
 import (
 	"fmt"
+
 	"github.com/apecloud/myduckserver/backend"
 	"github.com/apecloud/myduckserver/catalog"
 	"github.com/dolthub/go-mysql-server/server"
@@ -16,7 +17,8 @@ type Server struct {
 	NewInternalCtx func() *sql.Context
 }
 
-func NewServer(provider *catalog.DatabaseProvider, connPool *backend.ConnectionPool, host string, port int, newCtx func() *sql.Context, options ...ListenerOpt) (*Server, error) {
+func NewServer(provider *catalog.DatabaseProvider, connPool *backend.ConnectionPool, host string, port int, password string, newCtx func() *sql.Context, options ...ListenerOpt) (*Server, error) {
+	InitSuperuser(password)
 	addr := fmt.Sprintf("%s:%d", host, port)
 	l, err := server.NewListener("tcp", addr, "")
 	if err != nil {

pgtest/server.go

@@ -54,6 +54,7 @@ func CreateTestServer(t *testing.T, port int) (ctx context.Context, pgServer *pg
 	pgServer, err = pgserver.NewServer(
 		provider, pool,
 		"127.0.0.1", port,
+		"",
 		func() *sql.Context {
 			session := backend.NewSession(memory.NewSession(sql.NewBaseSession(), provider), provider, pool)
 			return sql.NewContext(context.Background(), sql.WithSession(session))