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 {