一. 命令行安装
go get github.com/jmoiron/sqlx
二. model设计
代码语言：txt复制package model
import "time"
type User_Sqlx struct {
UserId int `db:"user_id"`
UserName string `db:"user_name"`
Password string `db:"password"`
Sex int `db:"sex"`
Birthday time.Time `db:"birthday"`
LastLogin time.Time `db:"last_login"`
BindPhone string `db:"bind_phone"`
RegTime time.Time `db:"reg_time"`
}三. 数据库增删改查
代码语言：txt复制package order
import (
"fmt"
"sql-operator/model"
"time"
"github.com/jmoiron/sqlx"
)
var db_sqlx *sqlx.DB
func ConnectSqlxDatabases() {
var err error
db_sqlx, err = sqlx.Connect("mysql", "root:Xcy3329257@(localhost)/db_common?charset=utf8mb4&parseTime=True&loc=Local")
if err != nil {
fmt.Printf("connect DB failed, err:%vn", err)
return
}
println("sqlx数据库连接接成功")
}
func CloseSqlxDatabases() {
db_sqlx.Close()
println("sqlx数据库关闭成功")
}
func QueryUsers() {
sqlStr := "SELECT * FROM db_common.users"
var users []model.User_Sqlx
err := db_sqlx.Select(&users, sqlStr)
if err != nil {
fmt.Printf("get failed, err:%vn", err)
return
}
for i := 0; i < len(users); i {
fmt.Printf("i=%d value=%v n", i, users[i])
}
}
// 查询单条数据示例
func QueryRowUser() {
sqlStr := "select * from users where user_id=?"
var user model.User_Sqlx
err := db_sqlx.Get(&user, sqlStr, 1)
if err != nil {
fmt.Printf("get failed, err:%vn", err)
return
}
fmt.Printf("user_id:%d user_name:%s birthday:%v n", user.UserId, user.UserName, user.Birthday)
}
func InsertSqlxUser() {
_, err := db_sqlx.Exec("INSERT INTO users(user_name,password,sex,birthday,last_login,bind_phone,reg_time) VALUES (?,?,?,?,?,?,?)", "tomxiang_sqlx", "tomxiang_pwd", 1, time.Now(), time.Now(), "15817307777", time.Now())
if err != nil {
fmt.Printf("get failed, err:%vn", err)
return
}
println("sqlx数据库插入成功!")
println("sqlx插入之后的数据如下:")
QueryUsers()
}
func DeleteSqlxUser() {
_, err := db_sqlx.Exec("delete from users where user_id = ?", 17)
if err != nil {
fmt.Printf("get failed, err:%vn", err)
return
}
println("sqlx数据库删除成功!")
println("sqlx删除之后的数据如下:")
QueryUsers()
}
func UpdateSqlxUser() {
_, err := db_sqlx.Exec("update users set birthday = ? where user_id = 3", time.Now())
if err != nil {
fmt.Printf("get failed, err:%vn", err)
return
}
println("sqlx数据库更新成功!")
println("sqlx更新之后的数据如下:")
QueryUsers()
}参考链接
1.sqlx库使用指南
2.[Mac 10.13.4] 使用Homebrew安装Mysql全过程
