golang-mysql、sqlx

1.导包

go get -u github.com/go-sql-driver/mysql
import _ "github.com/go-sql-driver/mysql"

_ 表示只执行包中init函数，mysql包会在init函数中注册自己。

2.连接数据库

利用基本库database/sql连接数据库

	dsn := "root:123456@tcp(127.0.0.1:3306)/test_db"db, err := sql.Open("mysql", dsn)db.SetMaxIdleConns(10) //设立连接池的最大连接数if err != nil {panic(err)}defer db.Close()

3.CRUD操作

常用函数：

func (db *DB) Query(query string, args …any) (*Rows, error)
func (db *DB) QueryRow(query string, args …any) *Row //查询单行
func (db *DB) Exec(query string, args …any) (Result, error)

Query和Exec的主要区别是Query（查询）能够知道返回的结果集，而Exec（执行）只能知道最后插入的ID和影响的行数。

查询

	rows, err := db.Query("select * from test_db.user_table")for rows.Next() {var id, age intvar name stringerr := rows.Scan(&id, &name, &age)if err != nil {panic(err)}fmt.Println(id, name, age)}

查询单行：

	var id, age intvar name string_ = db.QueryRow("select * from test_db.user_table").Scan(&id, &name, &age)println(id, name, age)

插入

	result, err := db.Exec("insert into test_db.user_table values (?,?,?)", 4, "gi", 19)if err != nil {panic(err)}id, _ := result.LastInsertId()println("lastInsetId:", id)

更新，删除与插入类似，不多叙述。

事务

func Transaction(db *sql.DB) {//事务开启tx, err := db.Begin()if err != nil {tx.Rollback()log.Println(err)return}_, err = tx.Exec("update online_info set Status=? where User_id=?", "online", 1)if err != nil {tx.Rollback()log.Println(err)return}//提交事务err = tx.Commit()if err != nil {tx.Rollback()log.Println(err)return}
}

sqlx库

sqlx是sql的超集，能够兼容sql库的所有方法，包括db.Exec\Query\Queryrow等等。

sqlx特性

db.Get()：查询一行

在查询的时候将结果通过反射赋值给结构体。
注意：需要传入结构体实例的地址，结构体字段要大写！

	db, err := sqlx.Open("mysql", dsn)if err != nil {panic(err)}var a account  err= db.Get(&a,"select * from online_info where User_id=?", 1)

db.Select():查询多行结果

dest需要为slice类型的指针，

	var a []account = make([]account, 0)err = db.Select(&a, "select * from online_info where User_id=?", 1)if err != nil {panic(err)}fmt.Println(a)

namedQuery():将args参数绑定在sql中的:arg字段

rows, err := db.NamedQuery("select * from online_info where User_id=:id", map[string]interface{}{"id": 1
})

namedExec():与namedQuery作用相同，用于Exec()

StructScan():Scan增强版，直接将结果中的值赋给结构体变量。

连接池

源码分析：https://zhuanlan.zhihu.com/p/430993402

总结

只用 sqlx.Open() 函数创建连接池，此时只是初始化了连接池，并没有连接数据库，连接都是惰性的，只有调用 sqlx.DB 的方法时，此时才真正用到了连接，连接池才会去创建连接，连接池很重要，它直接影响着你的程序行为。

连接池的工作原理也非常简单，当调用 sqlx.DB 的方法时，会首先去向连接池请求要一个数据库连接，如果连接池有空闲的连接，则返回给方法中使用，否则连接池将创建一个新的连接给到方法中使用；一旦将数据库连接给到了方法中，连接就属于方法了。方法执行完毕后，要不把连接所属权还给连接池，要不传递给下一个需要数据库连接的方法中，最后都使用完将连接释放回到连接池中

请求数据库连接的方法有几个，执行完毕处理连接的方式也不同：

DB.Ping() 使用完毕后会马上把连接返回给连接池 DB.Exec() 使用完毕后会马上把连接返回给连接池，但是它返回的
Result 对象还保留着连接的引用，当后面的代码需要处理结果集的时候，连接将会被重新启用 DB.Query() 调用完毕后将连接传递给
sql.Rows 类型，当后者迭代完毕或者显示的调用 Close() 方法后，连接将会被释放到连接池 DB.QueryRow()
调用完毕后将连接传递给 sql.Row 类型，当 Scan() 方法调用完成后，连接将会被释放到连接池 DB.Begin()调用完毕后将连接传递给 sql.Tx 类型对象，当 Commit() 或 Rollback() 方法调用后释放连接

每个连接都是惰性的，如果验证 sqlx.Open() 调用之后，sqlx.DB 类型对象可用呢？通过 DB.Ping() 方法来初始化

连接池配置

DB.SetMaxIdleConns(n int) 设置连接池中的保持连接的最大连接数。默认也是0，表示连接池不会保持数据库连接的状态：即当连接释放回到连接池的时候，连接将会被关闭。这会导致连接再连接池中频繁的关闭和创建，我们可以设置一个合理的值。

DB.SetMaxOpenConns(n int) 设置打开数据库的最大连接数。包含正在使用的连接和连接池的连接。如果你的方法调用需要用到一个连接，并且连接池已经没有了连接或者连接数达到了最大连接数。此时的方法调用将会被 block，直到有可用的连接才会返回。设置这个值可以避免并发太高导致连接 mysql 出现 too many connections 的错误。该函数的默认设置是0，表示无限制

DB.SetConnMaxLifetime(d time.Duration) 设置连接可以被使用的最长有效时间，如果过期，连接将被拒绝

参考文章：https://www.cnblogs.com/kaichenkai/p/11140555.html