当前位置:首页 > Mysql教程 > 列表

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

发布:smiling 来源: PHP粉丝网  添加日期:2015-04-20 15:57:49 浏览: 评论:0 

下面看一篇关于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:[email protected](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) 

这里查询的方式使用声明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. for rows.Next() { 
  9.     //将行数据保存到record字典 
  10.     err = rows.Scan(scanArgs...) 
  11.     record := make(map[string]string) 
  12.     for i, col := range values { 
  13.         if col != nil { 
  14.             record[columns[i]] = string(col.([]byte)) 
  15.         } 
  16.     } 
  17.     fmt.Println(record) 

修改操作:

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

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

Tags: golang mysql增删改查

分享到: