Go语言操作MySQL

软件发布|下载排行|最新软件

当前位置:首页IT学院IT技术

Go语言操作MySQL

yi个俗人   2022-09-29 我要评论

前言

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.Closeerr之后,是因为可能打开不成功,关闭一个没有打开的连接。

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() :用于执行insertupdatedelete等不需要返回结果集的操作。

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

Copyright 2022 版权所有 软件发布 访问手机版

声明:所有软件和文章来自软件开发商或者作者 如有异议 请与本站联系 联系我们