之前，已經講過一些Golang的基礎的東西，感興趣的可以看看以前的文章，
今天簡單介紹下Golang是如何使用mysql數據庫的。下面主要從增刪查改以及事物等方面介紹go語言中mysql的使用。
一、安裝
由於Go本身不提供具體數據庫驅動，只提供驅動接口和管理。各個數據庫驅動需要第三方實現，並且註冊到Go中的驅動管理中。github上面的mysql驅動有好幾個，我在這裡選擇go-sql-driver。
github網址：https://github.com/go-sql-driver/mysql。
<code>admin:123456@tcp(10.2.1.5)/irisapp/<code>
二、連接數據庫
使用sql.Open()函數打開數據庫連接，數據庫的連接字符串（dsn）格式如下：
<code>func (f *mysql_db) mysql_insert() { //insert 添加數據
fmt.Println("開始插入")
stmt, err := f.db.Prepare("INSERT INTO depart(departName,memo) VALUES(?,?)")
//defer stmt.Close()
if err != nil {
fmt.Println("插入失敗")
return
}
stmt.Exec("dd", "adadcccda")
id,_ := result.LastInsertId()
fmt.Println("插入成功")
}/<code> 代碼如下：
<code>func (f *mysql_db) mysql_open() {
db, err := sql.Open("mysql", dbusername+":"+dbpassword+"@tcp("+dbhostsip+")/"+dbname)
if err != nil {
fmt.Println("鏈接失敗")
}
fmt.Println("鏈接成功")
f.db = db
}/<code>說明：返回的DB可以安全的被多個goroutine同時使用，並會維護自身的閒置連接池。這樣一來，Open函數只需調用一次。很少需要關閉DB。
三、增刪改查
簡單說明下是如何實現增刪改查的：
- 通過 Exec() 方法插入、修改和刪除數據的操作，返回的結果是 sql.Result 類型
- 通過Query() 方法執行查詢操作。
- 支持預備表達式，可以用來優化SQL查詢提高性能，減少SQL注入的風險, db.Prepare()和 tx.Prepare 都提供了對於預備表達式的支持。
- LastInsertId() 獲取插入第一條的id。
- RowsAffected() 獲取影響/插入的條數。
1、插入
<code>func (f *mysql_db) mysql_insert() { //insert 添加數據
fmt.Println("開始插入")
stmt, err := f.db.Prepare("INSERT INTO depart(departName,memo) VALUES(?,?)")
//defer stmt.Close()
if err != nil {
fmt.Println("插入失敗")
return
}
stmt.Exec("dd", "adadcccda")
id,_ := result.LastInsertId()
fmt.Println("插入成功")
}/<code>說明：
1. 可以通過LastInsertId() 獲取插入的id 。
2. 提供了對於預備表達式的支持 db.Prepare()，減少SQL注入的風險,。
2、查詢
<code>func (f *mysql_db) mysql_select(sql_data string) { //select 查詢數據
sql_data :="select departID,departName,memo from depart"
fmt.Println("sql:", sql_data)
rows, err := f.db.Query(sql_data)
if err != nil {
fmt.Println("查詢失敗")
}
for rows.Next() {
var departID int
var departName string
var memo string
err = rows.Scan(&departID, &departName, &memo)
if err != nil {
panic(err)
}
fmt.Println("departName:", departName)
}
}/<code>3、更新
<code>func (f *mysql_db) mysql_update() { //update 修改數據
stmt, err := f.db.Prepare("update depart set departName=?,memo =? where departId=?")
//defer stmt.Close()
if err != nil {
//錯誤處理
}
result,_ := stmt.Exec("aa","asdfadsadsfa",1)
if result == nil {
fmt.Println("修改失敗")
}
affect_count,_ := result.RowsAffected() //返回影響的條數,注意有兩個返回值
fmt.Println("%v",affect_count)
}/<code>說明：RowsAffected() 返回影響的條數,注意有兩個返回值。
4、刪除
<code>func (f *mysql_db) mysql_delete() { //delete 刪除數據
stmt, err := f.db.Prepare("delete from depart where departId=?")
//defer stmt.Close()
if err != nil {
//錯誤處理
}
stmt.Exec(2) //不返回任何結果
fmt.Println("刪除成功")
}/<code>四、使用事物
<code>func (f *mysql_db) mysql_tran(){
//事務
tx,err := f.db.Begin() //聲明一個事務的開始
if err != nil {
fmt.Println(err)
return
}
insert_sql := "insert into depart (departName,memo) VALUES(?,?)"
insert_stmt,insert_err := tx.Prepare(insert_sql)
if insert_err != nil {
fmt.Println(insert_err)
return
}
insert_res,insert_err := insert_stmt.Exec("ff","ff")
last_insert_id,_ := insert_res.LastInsertId()
fmt.Println(last_insert_id)
// defer tx.Rollback() //回滾之前上面的last_login_id是有的，但在回滾後該操作沒有被提交，被回滾了，所以上面打印的Last_login_id的這條數據是不存在與數據庫表中的
tx.Commit() //這裡提交了上面的操作，所以上面的執行的sql 會在數據庫中產生一條數據
}/<code>五、測試
<code>func main() {
db := &mysql_db{}
db.mysql_open()
db.mysql_insert()
db.mysql_update()
db.mysql_delete()
db.mysql_tran()
db.mysql_select()
db.mysql_close() //關閉
}/<code>啟動後輸出如下：
<code>D:\\Go_Path\\go\\src\\mysqldemo>go run mysqldemo.go
鏈接成功
開始插入
插入成功
0
刪除成功
10
sql: select departID,departName,memo from depart
departName: aa
departName: dd
departName: dd
departName: dd
departName: dd
departName: dd
departName: ff
departName: dd
departName: ff/<code>
總結
這裡只是簡單介紹了go語言開發中mysql在go語言開發中的基本使用，其實真正開發過程中還是主要使用orm相關第三方框架，但是底層原理還是要學的。分享關注（章為忠學架構）獲取完整代碼。
分享到:
閱讀更多 章為忠學架構 的文章
