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