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

昝辉Zac Zac的SEO博客，坚持12年，优化成为生活。

下面看一篇关于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. }

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

相关广告
  • golang连接mysql数据库实现增删改查 golang连接mysql数据库实现增删改查 golang连接mysql数据库实现增删改查
相关阅读

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

2019/10/10 17:32:09 | 谷歌SEO算法 | 手机网站制作