package main import ( _"mysql" "database/sql" "fmt" ) func check(err error){ if err!=nil{ fmt.Println(err) } } func main(){ db,err:=sql.Open("mysql","root:123456@tcp(127.0.0.1:3306)/employee") check(err) //query type info struct { id int `db:"id"` name string `db:"name"` age int `db:"age"` sex string `db:"sex"` salary int `db:"salary"` work string `db:"work"` inparty string `db:"inparty"` } //query rows,err:=db.Query("SELECT * FROM message") for rows.Next(){ var s info err=rows.Scan(&s.id,&s.name,&s.age,&s.sex,&s.salary,&s.work,&s.inparty) check(err) fmt.Println(s) } rows.Close() //insert db.Exec("INSERT INTO message(id,name,age,sex,salary,work,inparty)VALUES (?,?,?,?,?,?,?)",7,"李白",80,"男",1000,"中","是") //update results,err:=db.Exec("UPDATE message SET salary=? where id=?",8900,3) check(err) fmt.Println(results.RowsAffected()) //delete results,err:=db.Exec("DELETE FROM message where id=?",2) check(err) fmt.Println(results.RowsAffected()) }