golang连接mysql
安装：
go get -u /go-sql-driver/mysql
构建连接, 格式是：”用户名:密码@tcp(IP:端口)/数据库?charset=utf8”
打开数据库,前者是驱动名，所以要导入：_ “/go-sql-driver/mysql”
初始化
func init(){
db,err:=sql.Open("mysql","root:1111@tcp(127.0.0.1:3306)/test?charset=utf8")
if err!=nil{
fmt.Println("dbiniterr:",err)
}
}
插入数据 insert
插入前需要提前登录mysql创建表对应的字段。
typeDBworkerstruct{
Db*sql.DB
}
//插入数据测试
func(dbw*DBWorker)insertData(){
//stmt,_:=dbw.Db.Prepare(`INSERTINTOuser1(name,age)VALUES(?,?)`)
//deferstmt.Close()
stmt,err:=dbw.Db.Prepare("INSERTINTO user1 (`user`,`age`) VALUES (?,?)")
if err!=nil{
fmt.Println("Preparefail",err)
return
}
ret,err:=stmt.Exec(1,23)
if err!=nil{
fmt.Printf("insertdataerror:%v\n",err)
return
}
if LastInsertId,err:=ret.LastInsertId();err==nil{
fmt.Printf("LastInsertId%d\n",LastInsertId)
}
if RowsAffected,err:=ret.RowsAffected();err==nil{
fmt.Printf("RowsAffected%d\n",RowsAffected)
}
}
查询数据测试
func (dbw *DBWorker) queryData() {
stmt, _ := dbw.Db.Prepare("SELECT * FROM user WHERE age = ?")
defer stmt.Close()
user := userTB{}
//查询user表中age等于23的数据
rows, err := stmt.Query(23)
defer rows.Close()
if err != nil {
fmt.Printf("query data error : %v\n", err)
return;
}
