Go连接Mysql

本篇是Go从零实现ORM框架MyGORM的第一篇。

目的

MYSQL 的基础操作（连接数据库，创建表、增删记录等）。
使用 Go 语言标准库 database/sql 连接并操作 MYSQL 数据库。

Go连接MYSQL

Go原生提供了连接数据库操作的支持，在用 Golang进行开发的时候，如果需要在和数据库交互，则可以使用database/sql包。这是一个对关系型数据库的通用抽象，它提供了标准的、轻量的、面向行的接口。

在Go中访问数据库需要用到sql.DB接口：它可以创建语句(statement)和事务(transaction)，执行查询，获取结果。

使用数据库时，除了database/sql包本身，还需要引入想使用的特定数据库驱动，我使用的驱动为 github.com/go-sql-driver/mysql

建表

在执行数据库操作前，先建一张数据表

mg_user.sql

CREATE TABLE `mg_user` (
  `id` int unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(20) NOT NULL COMMENT '姓名',
  `birthday` date NOT NULL COMMENT '出生日期',
  `gender` tinyint unsigned NOT NULL DEFAULT '1' COMMENT '1男 2女 3保密',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;

导包

1	go get github.com/go-sql-driver/mysql

初始化数据库连接

main.go

package main

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


func main() {
	db, err := sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/my-gorm")
	if err != nil {
		fmt.Println(err)
		return
	}

	//设置与数据库的最大打开连接数
	db.SetMaxOpenConns(100)
	//设置空闲中的最大连接数
	db.SetMaxIdleConns(10)
	if err := db.Ping(); err != nil {
		fmt.Println("打开数据库失败")
		return
	}
	fmt.Println("数据库连接 success")
}

包名前面的”_”作用:

当导入一个包时，该包下的文件里所有init()函数都会被执行，然而，有些时候我们并不需要把整个包都导入进来，仅仅是是希望它执行init()函数而已。这个时候就可以使用 import _ 引用该包。
上面的mysql驱动中引入的就是mysql包中各个init()方法。

database/sql简介

sql.Open()中的数据库连接串格式为：”用户名:密码@tcp(IP:端口)/数据库?charset=utf8”。
DB的类型为:*sql.DB，有了DB之后我们就可以执行CRUD操作。Go将数据库操作分为两类：Query与Exec。两者的区别在于前者会返回结果，而后者不会。
Query表示查询，它会从数据库获取查询结果（一系列行，可能为空）。
Exec表示执行语句，它不会返回行。
此外还有两种常见的数据库操作模式：QueryRow表示只返回一行的查询，作为Query的一个常见特例。Prepare表示准备一个需要多次使用的语句，供后续执行用，通常用于批量处理语句。

查询操作

//发送查询到数据库，获取结果集Rows
rows, err := db.Query("SELECT * FROM mg_user")
if err != nil {
    fmt.Println(err)
    return
}
//关闭结果集，释放连接。
defer rows.Close()

type User struct {
    id       int
    name     string
    birthday string
    gender   uint8
}

var user User

//作为循环条件，迭代读取结果集。
for rows.Next() {
    //Scan从结果集中获取一行结果。
    err := rows.Scan(&user.id, &user.name, &user.birthday, &user.gender)
    if err != nil {
        fmt.Println(err)
        return
    }

    fmt.Println(user)
}

上面的操作流程如下：

使用db.Query()来发送查询到数据库，获取结果集Rows，并检查错误。
使用rows.Next()作为循环条件，迭代读取结果集。
使用rows.Scan从结果集中获取一行结果。
使用rows.Err()在退出迭代后检查错误。
使用rows.Close()关闭结果集，释放连接。

执行 go run main.go，输出如下:

1
2
3

go run student.go
数据库连接 success
{1 张三 1992-06-30 1}

掌握了基础的 SQL 语句和 Go 标准库 database/sql 的使用，可以开始实现 ORM 框架的雏形了。