- 数据库连接
使用open函数:func Open(driverName,databaseSourceName string)(*DB,error)
databseSourceName：用户名:密码@协议(地址:端口)/数据库?参数=参数值
db,err := sql.Open("mysql","root:200010@tcp(127.0.0.1:3306)/mytest?charset=utf8")
- DML:增删改查
1、直接使用EXEC函数
func (db *DB) Exec(query string,args ...interface{})(Result,errorr)
示例：
result,err := db.Exec("UPDATE userrinfo SET username = ?,deparment = ? WHERRE uid = ?","王小明","行政部",2)
2、使用Prerpare获得stmt声明，然后调用Exec调用
func (db *DB) Prepare(query string)(*stmt,error){
return db.PrepareContext(context.Backgrroud().querry)
}
//使用：
stmt,err:=db.Prepare("INSERT INTO userinfo(username,departname,created) values(?,?,?)")
//补充完整sql语句，并执行
result,err:=stmt.Exec("王小明","行政部","2018-11-21")
通常来说都是用Prepared Statement(预编译语句)
- 获取影响数据库的数据
行数：count,errr := rresult.RowsAffected()
获取自增id：id,err := result.LastInsertId()
- DQL操作：查询
func (db *DB) QueryRow(query string,args ...interface{}) *Row
因为golang是强类型语言，所以查询数据时先定义数据类型，但是查询数据库中的数据存在三种可能:存在值，存在零值，未赋值NULL 三种状态, 因为可以将待查询的数据类型定义为sql.Nullxxx类型，可以通过判断Valid值来判断查询到的值是否为赋值状态还是未赋值NULL状态.
查询多条数据: func (db *DB) Query(query string,args ...interface{}) (*Rows,err)
使用Scan来获取数据row.Scan(&x)
查询举例：
row,err := db.Query("SELECT uid,username,departname,created FROM userinfo")
if err != nil {
fmt.Println("查询有误")
return
}
datas := make([]User,0)
for row.Next(){
var uid int
var username,departname,created string
if err := row.Scan(&uid,&username,&departname,&created);err!=nil {
fmt.Println("获取失败")
}
user := User{uid,username,departname,created}
datas = append(datas,user)
}
- 事务
事务操作通过三个方法来实现：
Begin()开启事务，Commit()提交事务，Rollback()回滚事务。
示例：
db,_ := sql.Open("mysql","root:200010@tcp(127.0.0.1:3306)/mytest?charset=utf8")
//开启事务
tx,_ := db.Begin()
var aff1,aff2 int64 = 0,0
result1,_ := tx.Exec("UPDATE account SET money=1000 WHERE id=?",1)
result2,_ := tx.Exec("UPDATE account SET money=3000 WHERE id=?",2)
if result1 != nil {
aff1,_ = result1.RowsAffected()
}
if result2 != nil {
aff2,_ = result2.RowsAffected()
}
fmt.Printf("%d,%d",aff1,aff2)
if aff1 == 1 && aff2 == 1 {
tx.Commit() //提交事务
fmt.Println("操作成功")
}else{
tx.Rollback()
fmt.Println("操作失败，回滚数据")
}
开启一个事务后，一个TX会在整个生命周期中保存一个连接，然后调用commit()或Rollback()的时候释放掉。
- sqlx扩展包
sqlx在database/sql上加了很多扩展
连接数据库：
var Db *sqlx.DB
db,err := sqlx.Open("mysql","username:password@tcp(ip:port)/database?charset=utf8")
实现将获取的数据直接转换结构体实现：Get(dest interface{},.....)error
Select(dest interface{},....)error
GET和Select
这两个方法内部封装了StructScan进行转化，GET用于获取单个结果然后Scan，Select用来获取切片。
var users []User
Db.Select(&users,"SELECT uid,username,departname,created FROM userinfo")
查询的结果将直接村粗在users[]切片中