要連接MySQL數據庫,首先需要確保已經安裝了Go語言的MySQL驅動程序。常用的MySQL驅動程序有go-sql-driver/mysql
和mysql
。
然后,可以按照以下步驟連接MySQL數據庫:
import (
"database/sql"
_ "github.com/go-sql-driver/mysql"
)
db, err := sql.Open("mysql", "user:password@tcp(host:port)/database")
if err != nil {
// 處理連接錯誤
}
defer db.Close()
其中,user
是MySQL數據庫的用戶名,password
是密碼,host
是數據庫主機地址,port
是數據庫端口,database
是要連接的數據庫名。
err = db.Ping()
if err != nil {
// 處理連接錯誤
}
下面是一個完整的示例,展示如何連接MySQL數據庫并進行查詢操作:
package main
import (
"database/sql"
"fmt"
_ "github.com/go-sql-driver/mysql"
)
func main() {
db, err := sql.Open("mysql", "user:password@tcp(host:port)/database")
if err != nil {
panic(err.Error())
}
defer db.Close()
err = db.Ping()
if err != nil {
panic(err.Error())
}
rows, err := db.Query("SELECT * FROM table")
if err != nil {
panic(err.Error())
}
defer rows.Close()
for rows.Next() {
var id int
var name string
err = rows.Scan(&id, &name)
if err != nil {
panic(err.Error())
}
fmt.Println("ID:", id, "Name:", name)
}
err = rows.Err()
if err != nil {
panic(err.Error())
}
}
請注意,在使用實際的用戶名、密碼、主機地址、端口和數據庫名時,應替換示例中的占位符。