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

Author: NoyException

devtools/replica-setup-pg/README.md

@@ -1,4 +1,4 @@
-# PostgreSQL to MyDuck Replication Setup
+# PostgreSQL to MyDuck Replication Setup (WIP)
 
 This guide walks you through configuring MyDuck Server as a replica of a running PostgreSQL instance.
 
@@ -11,23 +11,29 @@ Before you begin, ensure that:
 
 ## Getting Started
 
-To let MyDuck Server replicate data from an existing PostgreSQL instance, run the provided `replica_setup.sh` script. You will need to supply the PostgreSQL connection details as parameters.
+To let MyDuck Server replicate data from an existing PostgreSQL instance, run the provided `replica_setup.sh` script. There are two ways to run the script.
 
-### Usage
+### Method 1: Replicate Data from a PostgreSQL Dump File
+
+In this method, you will need to prepare a PostgreSQL dump file that contains the data you want to replicate.
 
 ```bash
 bash replica_setup.sh --pg_dump /path/to/pg_dump
 ```
 
-### Parameters
+The parameters are as follows:
 
 - **`--pg_dump`**: The path to the PostgreSQL dump file.
 - **`--myduck_port`**: The port on which MyDuck Server is listening connections.
 
-## Example
+For example:
 
 ```bash
-bash replica_setup.sh --pg_dump ../../backup.sql
+bash replica_setup.sh --pg_dump pg_dump.sql
 ```
 
-This command sets up MyDuck Server as a replica of the PostgreSQL instance running at `192.168.1.100` on port `3306` with the user `root` and password `mypassword`.
+This command sets up MyDuck Server as a replica of the PostgreSQL instance running at `192.168.1.100` on port `5432` with the user `root` and password `mypassword`.
+
+### Method 2: Replicate Data from a Running PostgreSQL Instance
+
+WIP

devtools/replica-setup-pg/install_psql.sh

@@ -62,13 +62,10 @@ 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
@@ -92,7 +89,7 @@ fi
 # Step 5: 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
+    source snapshot_dump.sh
     check_command "loading a snapshot from pg_dump"
 else
     echo "No pg_dump file specified. Skipping snapshot."

devtools/replica-setup-pg/replica_setup.sh

@@ -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 {

devtools/replica-setup-pg/snapshot.sh renamed to devtools/replica-setup-pg/snapshot_dump.sh

@@ -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 = [^ ;]*`)
+)