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())
	
}