Go语言操作MySQL

时间:2022-09-29 yi个俗人人气:0

前言

MySQL 是目前开发中最常见的关系型数据库，也是程序员打交道最多的数据库。使用 Go 语言进行操控数据库需要使用 Go 自带database/sql和驱动go-sql-driver/mysql来实现。这篇文章主要总结一下怎么使用Go语言操作MySql数据库，需要的朋友可以参考以下内容，希望对大家有帮助。

下载依赖

database/sql是Go操作数据库的标准库之一，它提供了一系列接口方法，用于访问数据库(mysql,sqllite,oralce),但是它并不会提供数据库特有的方法，那些特有的方法需要交给数据库驱动去处理。

我们在通常工作中，用的更多的是jmoiron/sqlx包来操作数据库，sqlx是基于标准库的扩展，并且我们可以通过sqlx操作各种类型的数据。

go get -u github.com/go-sql-driver/mysql
go get -u github.com/jmoiron/sqlx

使用 MySQL 驱动

Open 打开一个 dirverName 指定的数据库，dataSourceName 指定数据源，一般至少包括数据库文件名和其它连接必要的信息。

func Open(driverName, dataSourceName string) (*DB, error)

它返回的是一个sql.DB数据库类型，它不是数据库连接，Go 中的连接来自内部实现的连接池，连接的建立是惰性的，连接将会在操作的时候，由连接池创建并维护，它可以安全地被多个goroutine同时使用。

示例：

package main

import (
	"database/sql"
	_ "github.com/go-sql-driver/mysql"
)


var db *sql.DB //声明一个全局的 db 变量

func main() {
	// 初始化 MySQL
	err := initDB()
	if err != nil {
		panic(err)
	}
	defer db.Close() // 注意这行代码要写在上面err判断的下面
}

//initDB 初始化MySQL
func initDB() (err error) {
    // 不会校验账号密码是否正确
	db, err = sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/test")
	if err != nil {
		return err
	}
    // 尝试与数据库建立连接（校验dsn是否正确）
	err = db.Ping()
	if err != nil {
		return err
	}
	return nil
}

注意：

sql.Open只会验证格式是否正确，不会连接数据库。
db.Ping会连接数据库，判断用户，密码，ip地址，端口是否正确。
db.Close在err之后，是因为可能打开不成功，关闭一个没有打开的连接。

SetMaxOpenConns

func (db *DB) SetMaxOpenConns(n int)

SetMaxOpenConns设置与数据库建立连接的最大数目。如果n大于0且小于最大闲置连接数，会将最大闲置连接数减小到匹配最大开启连接数的限制。如果n<=0，不会限制最大开启连接数，默认为0（无限制）。

SetMaxIdleConns

func (db *DB) SetMaxIdleConns(n int)

SetMaxIdleConns设置连接池中的最大闲置连接数。如果n大于最大开启连接数，则新的最大闲置连接数会减小到匹配最大开启连接数的限制。如果n<=0，不会保留闲置连接。

操作

func (db *DB) Query(query string, args ...interface{}) (*Rows, error)
func (db *DB) QueryRow(query string, args ...interface{}) *Row
func (db *DB) Exec(query string, args ...interface{}) (Result, error)
func (db *DB) Prepare(query string) (*Stmt, error)

db.Query(): 返回多行数据，需要依次遍历，并且需要自己关闭查询结果集。

db.QueryRow() :专门查询一行数据语法，返回ErrNoRow或者一行数据，不需要自己关闭结果集。

db.Exec() :用于执行insert、update、delete等不需要返回结果集的操作。

db.Prepare() :预先将一个数据库连接（con）和一个条sql语句绑定并返回stmt结构体代表这个绑定后的连接，然后运行stmt.Query()或者stmt.QueryRow()；stmt是并发安全的。之所以这样设计，是因为每次直接调用db.Prepare都会自动选择一个可用的con，每次选择的可能不是同一个con。

加载全部内容