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 版权协议,转载请附上原文出处链接和本声明。