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