go连mysql数据,并实现增删改查

 1.需要先下载mysql驱动:命令执行 go get -u github.com/go-sql-driver/mysql

 2.开始编码

package main

import (
   "database/sql"
   "fmt"
   _ "github.com/go-sql-driver/mysql"
)

func main() {
   db, err := sql.Open("mysql", "root:xxxx@tcp(xx.xx.xx.xx:3306)/db_user?charset=utf8")
   checkErr(err)
   fmt.Printf("connect mysql failed! [%s]", err)
   // insert
   stmt, err := db.Prepare("INSERT tbl_user SET username=?,alias=?,address=?,telephone=?,sex=?,card=?,createTime=?")
   checkErr(err)
   res, err := stmt.Exec("go同志", " gogogo", "深圳市南山区","15117953278","1","33031212112123412","201812081400")
   checkErr(err)
   //获取插入数据的主键id
   id, err := res.LastInsertId()
   checkErr(err)
   fmt.Println("新插入记录的ID为",id)

   // update
   stmt, err = db.Prepare("update tbl_user SET username=?,alias=?,address=?,telephone=?,sex=?,card=?,createTime=? where userID=?")
   checkErr(err)
   res, err = stmt.Exec("go同志1", " gogogo1", "深圳市南山区1","151179532781","11","330312121121234121","20181208140745", id)
   checkErr(err)
   affect, err := res.RowsAffected()
   checkErr(err)
   fmt.Println(affect)



    delete
   //stmt, err = db.Prepare("delete from tbl_user where id=?")
   //checkErr(err)
   //res, err = stmt.Exec(1)
   //checkErr(err)
   //
    query
   //rows, err := db.Query("SELECT userID,userName,alias FROM tbl_user")
   //checkErr(err)
   //
   //for rows.Next() {
   // var uid int
   // var username string
   // var alias string
   // err = rows.Scan(&uid, &username,&alias)
   // checkErr(err)
   // fmt.Println(uid)
   // fmt.Println(username)
   // fmt.Println(alias)
   //}

   db.Close()

}

func checkErr(err error) {
   if err != nil {
      panic(err)
   }
}

版权声明:本文为baojunhu999原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
原文链接:https://blog.csdn.net/baojunhu999/article/details/84893153