下面看一篇关于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 '用户性别',  --phpfensi.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)  //phpfensi.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. } 

小结:整体上来说都比较简单,就是查询那边使用字典来存储返回数据比较复杂一些,既然说到数据库连接,通常应用中都会使用连接池来减少连接开销,关于连接池下次整理一下再放上来.

Tags: golang mysql增删改查

分享到：