golang连接mysql数据库实现增删改查

下面看一篇关于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. CREATETABLEIFNOTEXISTS`test`.`user`(
2. `user_id`INT(11)UNSIGNEDNOTNULLAUTO_INCREMENTCOMMENT'用户编号',
3. `user_name`VARCHAR(45)NOTNULLCOMMENT'用户名称',
4. `user_age`TINYINT(3)UNSIGNEDNOTNULLDEFAULT0COMMENT'用户年龄',
5. `user_sex`TINYINT(3)UNSIGNEDNOTNULLDEFAULT0COMMENT'用户性别',--phpfensi.com
6. PRIMARYKEY(`user_id`))
7. ENGINE=InnoDB
8. AUTO_INCREMENT=1
9. DEFAULTCHARACTERSET=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(`INSERTuser(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*FROMuser")
2. checkErr(err)
4. forrows.Next(){
5. varuserIdint
6. varuserNamestring
7. varuserAgeint
8. varuserSexint
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. fori:=rangevalues{
6. scanArgs[i]=&values[i]
7. }
9. forrows.Next(){
10. //将行数据保存到record字典
11. err=rows.Scan(scanArgs...)
12. record:=make(map[string]string)
13. fori,col:=rangevalues{
14. ifcol!=nil{
15. record[columns[i]]=string(col.([]byte))
16. }
17. }
18. fmt.Println(record)
19. }

修改操作:

1. stmt,err:=db.Prepare(`UPDATEuserSETuser_age=?,user_sex=?WHEREuser_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(`DELETEFROMuserWHEREuser_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. packagemain
3. import(
4. "database/sql"
5. "fmt"
6. _"github.com/go-sql-driver/mysql"
7. )
9. funcmain(){
10. insert()
11. }
13. //插入demo
14. funcinsert(){
15. db,err:=sql.Open("mysql","root:@/test?charset=utf8")
16. checkErr(err)
18. stmt,err:=db.Prepare(`INSERTuser(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. }
27. //查询demo
28. funcquery(){
29. db,err:=sql.Open("mysql","root:@/test?charset=utf8")
30. checkErr(err)
32. rows,err:=db.Query("SELECT*FROMuser")
33. checkErr(err)
35. //普通demo
36. //forrows.Next(){
37. //varuserIdint
38. //varuserNamestring
39. //varuserAgeint
40. //varuserSexint
42. //rows.Columns()
43. //err=rows.Scan(&userId,&userName,&userAge,&userSex)
44. //checkErr(err)
46. //fmt.Println(userId)
47. //fmt.Println(userName)
48. //fmt.Println(userAge)
49. //fmt.Println(userSex)
50. //}
52. //字典类型
53. //构造scanArgs、values两个数组，scanArgs的每个值指向values相应值的地址
54. columns,_:=rows.Columns()
55. scanArgs:=make([]interface{},len(columns))
56. values:=make([]interface{},len(columns))
57. fori:=rangevalues{
58. scanArgs[i]=&values[i]
59. }
61. forrows.Next(){
62. //将行数据保存到record字典
63. err=rows.Scan(scanArgs...)
64. record:=make(map[string]string)
65. fori,col:=rangevalues{
66. ifcol!=nil{
67. record[columns[i]]=string(col.([]byte))
68. }
69. }
70. fmt.Println(record)
71. }
72. }
74. //更新数据
75. funcupdate(){
76. db,err:=sql.Open("mysql","root:@/test?charset=utf8")
77. checkErr(err)
79. stmt,err:=db.Prepare(`UPDATEuserSETuser_age=?,user_sex=?WHEREuser_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. }
88. //删除数据
89. funcremove(){
90. db,err:=sql.Open("mysql","root:@/test?charset=utf8")
91. checkErr(err)
93. stmt,err:=db.Prepare(`DELETEFROMuserWHEREuser_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. }
102. funccheckErr(errerror){
103. iferr!=nil{
104. panic(err)
105. }
106. }

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