chore: refine the replica-setup-pg and its doc

devtools/load-from-pgdump/README.md

@@ -0,0 +1,33 @@
+# Loading Data from PostgreSQL to MyDuck using pg_dump
+
+This guide walks you through the process of loading data from an existing PostgreSQL instance to MyDuck Server.
+
+## Prerequisites
+
+Before you begin, ensure that:
+
+- **MyDuck Server** is installed and running on your server.
+- A **pg_dump** file is available.
+
+## Getting Started
+
+To let MyDuck Server replicate data from an existing PostgreSQL instance, run the provided `setup.sh` script.
+
+### Usage
+
+```bash
+bash setup.sh --pg_dump /path/to/pg_dump
+```
+
+### Parameters
+
+- **`--pg_dump`**: The path to the PostgreSQL dump file.
+- **`--myduck_port`**: The port on which MyDuck Server is listening connections.
+
+### Example
+
+```bash
+bash setup.sh --pg_dump pg_dump.sql
+```
+
+This command loads data from the PostgreSQL dump file `pg_dump.sql` into MyDuck Server.

devtools/load-from-pgdump/checker.sh

@@ -0,0 +1,9 @@
+#!/bin/bash
+
+# Function to check if a command was successful
+check_command() {
+    if [[ $? -ne 0 ]]; then
+        echo "Error: $1 failed."
+        exit 1
+    fi
+}

devtools/replica-setup-pg/replica_setup.sh → devtools/load-from-pgdump/setup.sh

@@ -62,34 +62,13 @@ if [[ -z $MYDUCK_DB ]]; then
     usage
 fi
 
-# Step 1: Check if psql exists, if not, install it
+# Step 1: Check if psql exists
 if ! command -v psql &> /dev/null; then
-    echo "psql not found, attempting to install..."
-    bash install_psql.sh
-    check_command "psql installation"
-else
-    echo "psql is already installed."
+    echo "Error: psql is not installed."
+    exit 1
 fi
 
-# Step 2: Check if replication has already been started
-#echo "Checking if replication has already been started..."
-#check_if_myduck_has_replica
-#if [[ $? -ne 0 ]]; then
-#    echo "Replication has already been started. Exiting."
-#    exit 1
-#fi
-
-# Step 3: Prepare MyDuck Server for replication
-#echo "Preparing MyDuck Server for replication..."
-#source prepare.sh
-#check_command "preparing MyDuck Server for replication"
-
-# Step 4: Establish replication
-#echo "Starting replication..."
-#source start_replication.sh
-#check_command "starting replication"
-
-# Step 5: Load the existing data from pg_dump file
+# Step 2: Load the existing data from pg_dump file
 if [[ -n "$PG_DUMP" ]]; then
     echo "Loading the snapshot from pg_dump to MyDuck Server..."
     source snapshot.sh

pgserver/connection_handler.go

@@ -1044,7 +1044,11 @@ func (h *ConnectionHandler) sendError(err error) {
 }
 
 // convertQuery takes the given Postgres query, and converts it as an ast.ConvertedQuery that will work with the handler.
-func (h *ConnectionHandler) convertQuery(query string) (ConvertedQuery, error) {
+func (h *ConnectionHandler) convertQuery(query string, modifiers ...QueryModifier) (ConvertedQuery, error) {
+	for _, modifier := range modifiers {
+		query = modifier(query)
+	}
+
 	parsable := true
 	stmts, err := parser.Parse(query)
 	if err != nil {

pgserver/query_modifier.go

@@ -0,0 +1,22 @@
+package pgserver
+
+import "regexp"
+
+type QueryModifier func(string) string
+
+func NewQueryReplacer(regex string, replacement string) QueryModifier {
+	r := regexp.MustCompile(regex)
+	return func(query string) string {
+		return r.ReplaceAllString(query, replacement)
+	}
+
+}
+
+func NewQueryRemover(regex string) QueryModifier {
+	return NewQueryReplacer(regex, "")
+}
+
+var (
+	removeLocaleProvider = NewQueryRemover(`(?i)LOCALE_PROVIDER = [^ ;]*`)
+	removeLocale         = NewQueryRemover(`(?i)LOCALE = [^ ;]*`)
+)