下面看一篇關于golang連接mysql數據庫實現增刪改查數據的例子,希望本文章能幫助到了解golang與mysql數據庫之間關系了.

golang本身沒有提供連接mysql的驅動,但是定義了標準接口供第三方開發驅動,這里連接mysql可以使用第三方庫,第三方庫推薦使用https://github.com/Go-SQL-Driver/MySQL這個驅動,更新維護都比較好,下面演示下具體的使用,完整代碼示例可以參考最后.

下載驅動:sudo go get github.com/go-sql-driver/mysql

如果提示這樣的失敗信息:cannot download, $GOPATH not set. For more details see: go help gopath,可以使用如下命令解決.

sudo env GOPATH=/Users/chenjiebin/golang go get github.com/go-sql-driver/mysql

GOPATH的值根據自行環境進行替換.

創建測試表,在mysql test庫中創建測試表,代碼如下:

1. CREATE TABLE IF NOT EXISTS `test`.`user` ( 
2.  `user_id` INT(11) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT '用戶編號', 
3.  `user_name` VARCHAR(45) NOT NULL COMMENT '用戶名稱', 
4.  `user_age` TINYINT(3) UNSIGNED NOT NULL DEFAULT 0 COMMENT '用戶年齡', 
5.  `user_sex` TINYINT(3) UNSIGNED NOT NULL DEFAULT 0 COMMENT '用戶性別',  --Vevb.com 
6.  PRIMARY KEY (`user_id`)) 
7.  ENGINE = InnoDB 
8.  AUTO_INCREMENT = 1 
9.  DEFAULT CHARACTER SET = utf8 
10.  COLLATE = utf8_general_ci 
11.  COMMENT = '用戶表' 

數據庫連接,數據庫連接使用datebase/sql Open函數進行連接,代碼如下:

db,err := sql.Open("mysql", "user:password@tcp(localhost:5555)/dbname?charset=utf8")

其中連接參數可以有如下幾種形式:

1. user@unix(/path/to/socket)/dbname?charset=utf8 
2. user:password@tcp(localhost:5555)/dbname?charset=utf8 
3. user:password@/dbname 
4. user:password@tcp([de:ad:be:ef::ca:fe]:80)/dbname 

通常我們都用第二種.

插入操作,代碼如下:

1. stmt, err := db.Prepare(`INSERT user (user_name,user_age,user_sex) values (?,?,?)`) 
2. checkErr(err) 
3. res, err := stmt.Exec("tony", 20, 1) 
4. checkErr(err) 
5. id, err := res.LastInsertId() 
6. checkErr(err) 
7. fmt.Println(id) 

這里使用結構化操作,不推薦使用直接拼接sql語句的方法.

查詢操作,代碼如下:

1. rows, err := db.Query("SELECT * FROM user") 
2. checkErr(err) 
3.  
4. for rows.Next() { 
5.     var userId int 
6.     var userName string 
7.     var userAge int 
8.     var userSex int 
9.     rows.Columns() 
10.     err = rows.Scan(&userId, &userName, &userAge, &userSex) 
11.     checkErr(err) 
12.     fmt.Println(userId) 
13.     fmt.Println(userName) 
14.     fmt.Println(userAge) 
15.     fmt.Println(userSex) 
16. } 

這里查詢的方式使用聲明4個獨立變量userId、userName、userAge、userSex來保存查詢出來的每一行的值,在實際開發中通常會封裝數據庫的操作,對這樣的查詢通常會考慮返回字典類型,代碼如下:

1. //構造scanArgs、values兩個數組，scanArgs的每個值指向values相應值的地址 
2. columns, _ := rows.Columns() 
3. scanArgs := make([]interface{}, len(columns)) 
4. values := make([]interface{}, len(columns)) 
5. for i := range values { 
6.     scanArgs[i] = &values[i] 
7. } 
8.  
9. for rows.Next() { 
10.     //將行數據保存到record字典 
11.     err = rows.Scan(scanArgs...) 
12.     record := make(map[string]string) 
13.     for i, col := range values { 
14.         if col != nil { 
15.             record[columns[i]] = string(col.([]byte)) 
16.         } 
17.     } 
18.     fmt.Println(record) 
19. } 

修改操作:

1. stmt, err := db.Prepare(`UPDATE user SET user_age=?,user_sex=? WHERE user_id=?`) 
2. checkErr(err) 
3. res, err := stmt.Exec(21, 2, 1) 
4. checkErr(err) 
5. num, err := res.RowsAffected() 
6. checkErr(err) 
7. fmt.Println(num) 

刪除操作:

1. stmt, err := db.Prepare(`DELETE FROM user WHERE user_id=?`) 
2. checkErr(err) 
3. res, err := stmt.Exec(1) 
4. checkErr(err) 
5. num, err := res.RowsAffected() 
6. checkErr(err) 
7. fmt.Println(num) 

修改和刪除操作都比較簡單,同插入數據類似,只是使用RowsAffected來獲取影響的數據行數,完整代碼如下:

1. package main 
2.  
3. import ( 
4.     "database/sql" 
5.     "fmt" 
6.     _ "github.com/go-sql-driver/mysql" 
7. ) 
8.  
9. func main() { 
10.     insert() 
11. } 
12.  
13. //插入demo 
14. func insert() { 
15.     db, err := sql.Open("mysql", "root:@/test?charset=utf8") 
16.     checkErr(err) 
17.  
18.     stmt, err := db.Prepare(`INSERT user (user_name,user_age,user_sex) values (?,?,?)`) 
19.     checkErr(err) 
20.     res, err := stmt.Exec("tony", 20, 1) 
21.     checkErr(err) 
22.     id, err := res.LastInsertId() 
23.     checkErr(err) 
24.     fmt.Println(id) 
25. } 
26.  
27. //查詢demo 
28. func query() { 
29.     db, err := sql.Open("mysql", "root:@/test?charset=utf8") 
30.     checkErr(err) 
31.  
32.     rows, err := db.Query("SELECT * FROM user") 
33.     checkErr(err) 
34.  
35.     //普通demo 
36.     //for rows.Next() { 
37.     //    var userId int 
38.     //    var userName string 
39.     //    var userAge int 
40.     //    var userSex int 
41.  
42.     //    rows.Columns() 
43.     //    err = rows.Scan(&userId, &userName, &userAge, &userSex) 
44.     //    checkErr(err) 
45.  
46.     //    fmt.Println(userId) 
47.     //    fmt.Println(userName) 
48.     //    fmt.Println(userAge) 
49.     //    fmt.Println(userSex) 
50.     //} 
51.  
52.     //字典類型 
53.     //構造scanArgs、values兩個數組，scanArgs的每個值指向values相應值的地址 
54.     columns, _ := rows.Columns() 
55.     scanArgs := make([]interface{}, len(columns)) 
56.     values := make([]interface{}, len(columns)) 
57.     for i := range values { 
58.         scanArgs[i] = &values[i] 
59.     } 
60.  
61.     for rows.Next() { 
62.         //將行數據保存到record字典 
63.         err = rows.Scan(scanArgs...) 
64.         record := make(map[string]string) 
65.         for i, col := range values { 
66.             if col != nil { 
67.                 record[columns[i]] = string(col.([]byte)) 
68.             } 
69.         } 
70.         fmt.Println(record) 
71.     } 
72. } 
73.  
74. //更新數據 
75. func update() { 
76.     db, err := sql.Open("mysql", "root:@/test?charset=utf8") 
77.     checkErr(err) 
78.  
79.     stmt, err := db.Prepare(`UPDATE user SET user_age=?,user_sex=? WHERE user_id=?`) 
80.     checkErr(err) 
81.     res, err := stmt.Exec(21, 2, 1) 
82.     checkErr(err) 
83.     num, err := res.RowsAffected() 
84.     checkErr(err) 
85.     fmt.Println(num) 
86. } 
87.  
88. //刪除數據 
89. func remove() { 
90.     db, err := sql.Open("mysql", "root:@/test?charset=utf8") 
91.     checkErr(err) 
92.  
93.     stmt, err := db.Prepare(`DELETE FROM user WHERE user_id=?`) 
94.     checkErr(err)  //Vevb.com 
95.     res, err := stmt.Exec(1) 
96.     checkErr(err) 
97.     num, err := res.RowsAffected() 
98.     checkErr(err) 
99.     fmt.Println(num) 
100. } 
101.  
102. func checkErr(err error) { 
103.     if err != nil { 
104.         panic(err) 
105.     } 
106. } 

小結:整體上來說都比較簡單,就是查詢那邊使用字典來存儲返回數據比較復雜一些,既然說到數據庫連接,通常應用中都會使用連接池來減少連接開銷,關于連接池下次整理一下再放上來.