go語言操作mysql數據庫的關鍵在于掌握連接池、sql語句構建和錯誤處理。1. 安裝go-sql-driver/mysql驅動并正確構建連接字符串實現數據庫連接；2. 使用log.fatalf優雅處理錯誤，確保程序崩潰前輸出清晰的錯誤信息；3. 利用db.setmaxopenconns等方法配置連接池參數以優化資源管理；4. 通過db.prepare使用預編譯語句防止sql注入，保障數據安全；5. 借助db.begin開啟事務，結合tx.exec、tx.commit和tx.rollback保證多操作一致性；6. 使用sql.NULLString等類型處理空值，確保null字段的正確讀取與判斷。
go語言操作MySQL數據庫，入門其實并不難。關鍵在于理解連接池、sql語句構建以及錯誤處理這三個核心點。掌握了這幾個，就能輕松上手。
連接MySQL，執行CRUD操作，并進行適當的錯誤處理。
連接MySQL數據庫，首先需要安裝go-sql-driver/mysql驅動。
立即學習“go語言免費學習筆記（深入）”；
go get github.com/go-sql-driver/mysql
安裝完成后，就可以在代碼中導入并使用了。連接數據庫的關鍵在于構建連接字符串，這個字符串包含了數據庫的地址、端口、用戶名、密碼以及數據庫名。
package main import ( "database/sql" "fmt" "log" _ "github.com/go-sql-driver/mysql" // 導入但不直接使用，用于注冊驅動 ) func main() { // 構建連接字符串 dsn := "user:password@tcp(127.0.0.1:3306)/database_name" // 打開數據庫連接 db, err := sql.Open("mysql", dsn) if err != nil { log.Fatal(err) } defer db.Close() // 確保連接在使用完畢后關閉 // 檢查連接是否成功 err = db.Ping() if err != nil { log.Fatal(err) } fmt.Println("Successfully connected to MySQL database!") // 接下來可以進行數據庫操作，例如查詢、插入、更新、刪除等 }
上面的代碼首先構建了一個連接字符串dsn，你需要根據你的實際情況修改其中的用戶名、密碼、地址、端口和數據庫名。sql.Open函數用于打開數據庫連接，第一個參數是數據庫驅動的名稱，這里是mysql，第二個參數是連接字符串。注意，_ “github.com/go-sql-driver/mysql”這行代碼的作用是導入MySQL驅動，但是并不直接使用它，而是通過其init函數將驅動注冊到database/sql包中。db.Ping函數用于檢查數據庫連接是否成功。
如何優雅地處理數據庫連接錯誤？
錯誤處理是Go語言編程中非常重要的一部分，尤其是在操作數據庫時。如果連接失敗，程序應該能夠給出清晰的錯誤提示，而不是直接崩潰。
package main import ( "database/sql" "fmt" "log" "time" _ "github.com/go-sql-driver/mysql" ) func main() { dsn := "user:password@tcp(127.0.0.1:3306)/database_name" db, err := sql.Open("mysql", dsn) if err != nil { log.Fatalf("Failed to open database connection: %v", err) } defer db.Close() // 設置連接池參數 db.SetMaxOpenConns(10) // 最大打開的連接數 db.SetMaxIdleConns(5) // 最大空閑連接數 db.SetConnMaxLifetime(time.Hour) // 連接的最大生存時間 err = db.Ping() if err != nil { log.Fatalf("Failed to ping database: %v", err) } fmt.Println("Successfully connected to MySQL database!") // 示例：查詢數據 rows, err := db.Query("SELECT id, name FROM users") if err != nil { log.Fatalf("Failed to execute query: %v", err) } defer rows.Close() for rows.Next() { var id int var name string if err := rows.Scan(&id, &name); err != nil { log.Fatalf("Failed to scan row: %v", err) } fmt.Printf("ID: %d, Name: %sn", id, name) } if err := rows.Err(); err != nil { log.Fatalf("Error iterating over rows: %v", err) } }
在這個例子中，使用了log.Fatalf函數來記錄錯誤信息并終止程序。這樣做的好處是，可以清晰地看到錯誤發生的位置和原因。同時，也加入了連接池的設置，可以有效地管理數據庫連接，避免資源浪費。在查詢數據時，也對可能出現的錯誤進行了處理，例如查詢失敗、掃描行失敗以及迭代行失敗等。
如何編寫安全的SQL語句，防止sql注入？
SQL注入是一種常見的安全漏洞，攻擊者可以通過構造惡意的SQL語句來獲取或修改數據庫中的數據。為了防止SQL注入，應該使用預編譯語句（Prepared Statements）。
package main import ( "database/sql" "fmt" "log" _ "github.com/go-sql-driver/mysql" ) func main() { dsn := "user:password@tcp(127.0.0.1:3306)/database_name" db, err := sql.Open("mysql", dsn) if err != nil { log.Fatal(err) } defer db.Close() err = db.Ping() if err != nil { log.Fatal(err) } // 預編譯語句示例：插入數據 stmt, err := db.Prepare("INSERT INTO users(name, email) VALUES(?, ?)") if err != nil { log.Fatal(err) } defer stmt.Close() name := "Alice" email := "alice@example.com" result, err := stmt.Exec(name, email) if err != nil { log.Fatal(err) } rowsAffected, err := result.RowsAffected() if err != nil { log.Fatal(err) } fmt.Printf("Inserted %d rowsn", rowsAffected) // 預編譯語句示例：查詢數據 stmt, err = db.Prepare("SELECT id, name FROM users WHERE id = ?") if err != nil { log.Fatal(err) } defer stmt.Close() id := 1 var userName string err = stmt.QueryRow(id).Scan(&id, &userName) if err != nil { log.Fatal(err) } fmt.Printf("User ID: %d, Name: %sn", id, userName) }
在這個例子中，使用了db.Prepare函數來預編譯SQL語句。預編譯語句會將SQL語句的結構和數據分開，從而防止SQL注入。在執行SQL語句時，使用stmt.Exec或stmt.QueryRow函數，并將參數傳遞給這些函數。這樣，數據庫驅動會自動對參數進行轉義，從而避免SQL注入。
如何使用事務保證數據的一致性？
事務是一組原子性的操作，要么全部成功，要么全部失敗。在操作數據庫時，使用事務可以保證數據的一致性。
package main import ( "database/sql" "fmt" "log" _ "github.com/go-sql-driver/mysql" ) func main() { dsn := "user:password@tcp(127.0.0.1:3306)/database_name" db, err := sql.Open("mysql", dsn) if err != nil { log.Fatal(err) } defer db.Close() err = db.Ping() if err != nil { log.Fatal(err) } // 開啟事務 tx, err := db.Begin() if err != nil { log.Fatal(err) } // 執行SQL語句 _, err = tx.Exec("UPDATE accounts SET balance = balance - 100 WHERE id = 1") if err != nil { tx.Rollback() // 回滾事務 log.Fatal(err) } _, err = tx.Exec("UPDATE accounts SET balance = balance + 100 WHERE id = 2") if err != nil { tx.Rollback() // 回滾事務 log.Fatal(err) } // 提交事務 err = tx.Commit() if err != nil { log.Fatal(err) } fmt.Println("Transaction completed successfully!") }
在這個例子中，首先使用db.Begin函數開啟一個事務。然后，執行一系列的SQL語句。如果在執行過程中發生錯誤，使用tx.Rollback函數回滾事務，撤銷之前的操作。如果所有操作都成功，使用tx.Commit函數提交事務，將修改保存到數據庫中。
如何優雅地處理空值（NULL）？
在數據庫中，空值（NULL）表示缺少值或未知值。在Go語言中，需要使用特殊的類型來處理空值。
package main import ( "database/sql" "fmt" "log" _ "github.com/go-sql-driver/mysql" ) func main() { dsn := "user:password@tcp(127.0.0.1:3306)/database_name" db, err := sql.Open("mysql", dsn) if err != nil { log.Fatal(err) } defer db.Close() err = db.Ping() if err != nil { log.Fatal(err) } // 查詢數據，包含可能為空的字段 rows, err := db.Query("SELECT id, name, email FROM users WHERE id = 3") if err != nil { log.Fatal(err) } defer rows.Close() for rows.Next() { var id int var name string var email sql.NullString // 使用 sql.NullString 處理可能為空的字符串 if err := rows.Scan(&id, &name, &email); err != nil { log.Fatal(err) } fmt.Printf("ID: %d, Name: %s, Email: ", id, name) if email.Valid { fmt.Println(email.String) } else { fmt.Println("NULL") } } if err := rows.Err(); err != nil { log.Fatal(err) } }
在這個例子中，使用了sql.Nullstring類型來處理可能為空的字符串。sql.NullString類型有兩個字段：String和Valid。String字段存儲字符串的值，Valid字段表示該值是否有效（即是否為空）。在讀取數據時，首先檢查Valid字段的值，如果為true，則表示該值有效，可以使用String字段的值；如果為false，則表示該值為空。除了sql.NullString之外，還有sql.NullInt64、sql.NullFloat64等類型，用于處理可能為空的整數、浮點數等。
