我有一个调用 sql 连接的 api。这是到某个远程服务器的 sql 连接。执行查询时出现错误“dial tcp xxx:xxx:xxx:xxx:3306: connect: connection refused”
sql连接代码
func ConnectToMysqlDB(dbUser, dbPassword, dbHost, dbName string) *sql.DB {
connstr := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s", dbUser, dbPassword, dbHost, "3306", dbName)
var err error
log.Println("Carrying mysql query", connstr)
dB, err := sql.Open("mysql", connstr)
if err != nil {
log.Fatalf("error connection to mysql [%v] ..!!", err)
}
log.Print("mysql initialized ..!!")
return dB
}
查询功能
func GetUserIDs(dB *sql.DB, users []string) []int {
var newUsers []int
var newUser int
query := "SELECT id FROM phplist_user_user WHERE foreignkey in (%s)"
var usersStr string
for _, val := range users {
usersStr = usersStr + "'" + val + "'" + ","
}
usersStr = strings.TrimSuffix(usersStr, ",")
query = fmt.Sprintf(query, usersStr)
rows, err := dB.Query(query)
if err != nil {
fmt.Printf("Error in query : [%v]", err)
}
defer rows.Close()
for rows.Next() {
rows.Scan(&newUser)
newUsers = append(newUsers, newUser)
}
return newUsers
}
我收到错误的原因是什么:查询错误:[dial tcp xxx.xxx.xxx.xxx:3306: connect: connection refused]
慕神8447489
相关分类