GO使用mysql增删改查

使用go mysql第三方库

go get github.com/go-sql-driver/mysql

go get github.com/jmoiron/sqlx

package main

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

//用户结构体
type Logs struct {
 Op_admin string    `db:"op_admin"`
 Op_content string `db:"op_content"`
 Op_ip      string `db:"op_ip"`
 Op_formal    string `db:"op_formal"`
 Op_table    string `db:"op_table"`
}

//数据库指针
var db *sqlx.DB

//初始化数据库连接，init()方法系统会在动在main方法之前执行。
func init() {
 database, err := sqlx.Open("mysql", "connector:root@tcp(192.168.1.39:3306)/connector?parseTime=true")
 if err != nil {
  fmt.Println("open mysql failed,", err)
 }
 db = database
}

func main() {

 // 新增
 // sql := "insert into cw_sys_log(op_admin,op_content, op_ip,op_formal,op_table)values (?,?,?,?,?)"
 // value := [5]string{"test", "test", "127.0.0.1","test","cw_sys_log"}

 // //执行SQL语句
 // r, err := db.Exec(sql, value[0], value[1], value[2],value[3],value[4])
 // if err != nil {
 //  fmt.Println("exec failed,", err)
 //  return
 // }

 // //查询最后一天用户ID，判断是否插入成功
 // id, err := r.LastInsertId()
 // if err != nil {
 //  fmt.Println("exec failed,", err)
 //  return
 // }
 // fmt.Println("insert succ", id)

 // 查询
 // var logs []Logs
 // sql := "select op_admin,op_content, op_ip,op_formal,op_table from cw_sys_log where id =? "
 // err := db.Select(&logs, sql, 455)
 // if err != nil {
 //  fmt.Println("exec failed, ", err)
 //  return
 // }
 // fmt.Println("select succ:", logs)

 // 更新
 //执行SQL语句
 // sql := "update cw_sys_log set op_admin =? where id = ?"
 // res, err := db.Exec(sql, "user002", 455)

 // if err != nil {
 //  fmt.Println("exec failed,", err)
 //  return
 // }

 // //查询影响的行数，判断修改插入成功
 // row, err := res.RowsAffected()
 // if err != nil {
 //  fmt.Println("rows failed", err)
 // }

 // fmt.Println("update succ:", row)

 // 删除
 sql := "delete from cw_sys_log where id=?"

 res, err := db.Exec(sql, 455)
 if err != nil {
  fmt.Println("exce failed,", err)
  return
 }

 row, err := res.RowsAffected()
 if err != nil {
  fmt.Println("row failed, ", err)
 }
 fmt.Println("delete succ: ", row)

}