go连接mysql

package main

import (
	"database/sql"
	"fmt"
	_ "github.com/go-sql-driver/mysql" //只导入初始化方法
)

const (
	_selectUser = "select id,name,age from student where id = ?"
	_selectUserAll = "select id,name,age from student"
	_updateUser = "update student set name = ? where id = ?"
	_insertUser = "insert student (name,age) values (?,?)"
	_deleteUser = "delete from student where id = ?"
)

func main()  {
	//Go标准库中没有数据库驱动
	//第⼀步：打开数据库,格式是 ⽤户名：密码@/数据库名称？编码⽅式
	db, err := sql.Open("mysql", "root:shenning@tcp(127.0.0.1:3306)/test?charset=utf8")
	//判断是否空
	if err != nil {
		panic(err) //抛出异常
	}

	//insert(*db)
	//update(*db)
	//delete(*db)
	selectAll(*db)
	//关闭数据库
	defer db.Close()
}

func insert(db sql.DB)  {
	// Exec方法，执行一段sql语句
	result,err := db.Exec(_insertUser, "朱春雨", 20)
	if err != nil {
		fmt.Println(err)
		return
	}
	// result这个对象，他有两个方法，RowsAffected(),LastInsertId(),
	// 分别返回影响的行数，还有就是最后插入的id
	// 我们这里执行的是更新语句，就看这个方法就好了RowsAffected

	fmt.Println(result.RowsAffected())
}
func delete(db sql.DB)  {
	// Exec方法，执行一段sql语句
	result,err := db.Exec(_deleteUser,  4)
	if err != nil {
		fmt.Println(err)
		return
	}
	delNums, _ := result.RowsAffected()
	// result这个对象，他有两个方法，RowsAffected(),LastInsertId(),
	// 分别返回影响的行数，还有就是最后插入的id
	// 我们这里执行的是更新语句，就看这个方法就好了RowsAffected
	fmt.Println(delNums)
}
func update(db sql.DB)  {
	// Exec方法，执行一段sql语句
	result,err := db.Exec(_updateUser, "shenning", 4)
	if err != nil {
		fmt.Println(err)
		return
	}
	// result这个对象，他有两个方法，RowsAffected(),LastInsertId(),
	// 分别返回影响的行数，还有就是最后插入的id
	// 我们这里执行的是更新语句，就看这个方法就好了RowsAffected

	fmt.Println(result.RowsAffected())
}
func selectAll(db sql.DB)  {
	// Exec方法，执行一段sql语句
	//rows3 := db.QueryRow(_selectUser,  6)
	rows3,err := db.Query(_selectUserAll)
	if err !=nil {
		panic(err)
	}
	for rows3.Next(){
		var id int
		var name string
		var age int
		rows3.Scan(&id,&name,&age)
		fmt.Println(id,name,age)
	}


}