go get github.com/go-sql-driver/mysql
package main
import (
"database/sql"
"fmt"
_ "github.com/go-sql-driver/mysql"
)
func main() {
db, err := sql.Open("mysql", "root:root@(127.0.0.1)/test")
if err != nil {
fmt.Println("连接数据库失败")
return
} else {
fmt.Println("连接数据库成功")
}
defer db.Close()
// 1. Exec(适用于增删改)
result, err := db.Exec(
"INSERT INTO users (name, email, password, remember_token, created_at, updated_at) VALUES (?, ?, ?, ?, ?, ?)",
"gopher7",
"282816336@qq.com",
"gopher123",
"gopher123",
"2019-12-30 17:24:36",
"2019-12-30 17:24:36")
if err != nil {
fmt.Println("插入数据库失败")
return
} else {
fmt.Println("插入数据库成功")
return
}
fmt.Println(result.RowsAffected())
//2. 查询数据
rows, err := db.Query("SELECT name FROM users")
if err != nil {
fmt.Println("err = ", err)
return
}
for rows.Next() {
var name string
err := rows.Scan(&name)
if err != nil {
fmt.Println("err = ", err)
return
}
fmt.Printf("%s\n", name)
}
rows.Close()
}