From 2a9f596ea8285cc306d4fc569f00420e62ca510a Mon Sep 17 00:00:00 2001
From: loshiqi <553578653@qq.com>
Date: Tue, 15 Jul 2025 16:00:46 +0800
Subject: [PATCH] =?UTF-8?q?=E5=85=BC=E5=AE=B9pgsql?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 chain.go | 13 +++++++++++--
 db.go    |  6 +++++-
 2 files changed, 16 insertions(+), 3 deletions(-)

diff --git a/chain.go b/chain.go
index 49261d8..5167ee4 100644
--- a/chain.go
+++ b/chain.go
@@ -3,6 +3,7 @@ package dbquery
 import (
 	"database/sql"
 	"errors"
+	"github.com/jmoiron/sqlx"
 	"log"
 	"strconv"
 	"strings"
@@ -499,7 +500,11 @@ func (this *Query) UpdateStmt() error {
 	if this.conn == nil {
 		this.conn = DB
 	}
-
+	if DB_PROVIDER == "PgsqlDb" {
+		log.Println("PgsqlDb sql", sql)
+		sql = sqlx.Rebind(sqlx.DOLLAR, sql)
+		log.Println("PgsqlDb sql", sql)
+	}
 	stmt, err = this.conn.Prepare(sql)
 
 	if err != nil {
@@ -752,7 +757,11 @@ func (this *Query) CreateStmt() error {
 	if this.conn == nil {
 		this.conn = DB
 	}
-
+	if DB_PROVIDER == "PgsqlDb" {
+		log.Println("PgsqlDb sql", sql)
+		sql = sqlx.Rebind(sqlx.DOLLAR, sql)
+		log.Println("PgsqlDb sql", sql)
+	}
 	stmt, err = this.conn.Prepare(sql)
 
 	if err != nil {
diff --git a/db.go b/db.go
index 1720fc3..3ae47d5 100644
--- a/db.go
+++ b/db.go
@@ -637,7 +637,11 @@ func FetchRows(dbName, table_name, alias string, titles string, with, join [][]s
 	var err error
 	var queryNum int = 0
 	for queryNum < 2 { //如发生错误，继续查询2次，防止数据库连接断开问题
-
+		if DB_PROVIDER == "PgsqlDb" {
+			log.Println("PgsqlDb sql_str", sql_str)
+			sql_str = sqlx.Rebind(sqlx.DOLLAR, sql_str)
+			log.Println("PgsqlDb sql_str", sql_str)
+		}
 		rows, err = db.Query(sql_str, valueList...)
 
 		if err == nil {