diff --git a/db.go b/db.go index 9e0aaf1..b04035e 100644 --- a/db.go +++ b/db.go @@ -467,7 +467,7 @@ func GetRow(dbName, table_name, alias string, titles string, with, join [][]stri for queryNum < 2 { //如发生错误,继续查询2次,防止数据库连接断开问题 if DB_PROVIDER == "PgsqlDb" { sql_str = sqlx.Rebind(sqlx.DOLLAR, sql_str) - sql_str = strings.Replace(sql_str, "`", `"`, -1) + sql_str = SqlReplace(sql_str, "") } rows, err = db.Query(sql_str, valueList...) @@ -676,7 +676,7 @@ func FetchRows(dbName, table_name, alias string, titles string, with, join [][]s for queryNum < 2 { //如发生错误,继续查询2次,防止数据库连接断开问题 if DB_PROVIDER == "PgsqlDb" { sql_str = sqlx.Rebind(sqlx.DOLLAR, sql_str) - sql_str = strings.Replace(sql_str, "`", `"`, -1) + sql_str = SqlReplace(sql_str, "") } rows, err = db.Query(sql_str, valueList...) @@ -1058,7 +1058,7 @@ func DoQuery(args ...interface{}) ([]map[string]string, error) { if len(args) > 1 { if DB_PROVIDER == "PgsqlDb" { queryStr = sqlx.Rebind(sqlx.DOLLAR, queryStr) - queryStr = strings.Replace(queryStr, "`", `"`, -1) + queryStr = SqlReplace(queryStr, "") } rows, err = DB.Query(queryStr, args[1:]...) //strings.Join(args[1:], ",") if err != nil { diff --git a/prepare.go b/prepare.go index d0160bf..ffd46ac 100644 --- a/prepare.go +++ b/prepare.go @@ -407,7 +407,7 @@ func StmtForQuery(querysql string) (*sql.Stmt, error) { var err error if DB_PROVIDER == "PgsqlDb" { querysql = sqlx.Rebind(sqlx.DOLLAR, querysql) - querysql = strings.Replace(querysql, "`", `"`, -1) + querysql = SqlReplace(querysql, "") } stmt, err = DB.Prepare(querysql)