當前位置:首頁 > 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增刪改查

分享到:

天气网首页彩吧