go mysqldb
1.go 支持mysqldb
go get -u github.com/go-sql-driver/mysql
现在，我们将看看如何在 Go 中使用 MySQL。这里我们使用准备好的语句。这是处理 SQL 数据库的最佳方式。
require (
...
github.com/go-sql-driver/mysql v1.6.0 // indirect
...
）
2.数据库结构
2.1定义一个查询
package main
import (
"database/sql"
"fmt"
_ "github.com/go-sql-driver/mysql"
)
type Orderstruct {
OrderNumberint
OrderDatestring
Statusstring
}
func PingDB(db *sql.DB) {
err := db.Ping()
ErrorCheck(err)
}
func ErrorCheck(errerror) {
if err !=nil {
panic(err.Error())
}
}
func main() {
// ...
db, e :=sql.Open("mysql", "db_user:db_pass@tcp(remotehostname：3306)/order")
// query all data
rows, e := db.Query("select order_number,Order_Date,status from orders where order_number=131824")
ErrorCheck(e)
// declare empty post variable
var order =Order{}
// iterate over rows
for rows.Next() {
e = rows.Scan(&order.OrderNumber, &order.OrderDate, &order.Status)
ErrorCheck(e)
fmt.Println(order)
}
}
2.2执行结果
go build testdb.go
2.3 插入
// INSERT INTO DB
// prepare
stmt, e := db.Prepare("insert into order(order_number, order_date, status) values (?, ?, ?)")
ErrorCheck(e)
//execute
res, e := stmt.Exec("1", now(), "createorder")
ErrorCheck(e)
id, e := res.LastInsertId()
ErrorCheck(e)
fmt.Println("Insert id", id)
2.4 更新
//Update db
stmt, e := db.Prepare("update order set status=? where order_number=?")
ErrorCheck(e)
// execute
res, e := stmt.Exec("OK", "1")
ErrorCheck(e)
a, e := res.RowsAffected()
ErrorCheck(e)
fmt.Println(a) // 1 表示更新成功，如果是0，需要查看数据库配置是否有update权限。
2.5 删除
// delete data
stmt, e := db.Prepare("delete from order where id=?")
ErrorCheck(e)
// delete 5th post
res, e := stmt.Exec("5")
ErrorCheck(e)
// affected rows
a, e := res.RowsAffected()
ErrorCheck(e)
fmt.Println(a) // 删除成功
