零基础Go语言从入门到精通（数据库编程: 01-Go *** 作 MySQL 数据库）

学习目标 掌握Go *** 作MySQL数据库方法掌握gorm *** 作MySQL以及gin＋gorm项目案例应用掌握Redis基本命令以及Go如何 *** 作Redis

提示：MySQL和Redis在Go Web项目中应用广泛（MySQL： 存储基本数据；Redis 存储缓冲数据，两者一般都是配合运用）

大家学习有问题，请及时留言，并可以加入交流群学习。

Go *** 作 MySQL 数据库 1. 背景

在实际开发中，要用到数据库存储数据。MySQL是一个关系型数据库管理系统 使用非常广泛。在Go语言开发中，会选择一个 *** 作数据的类库来帮助我们完成工作。

2. 简单介绍 2.1 MySQL 数据库介绍

MySQL是一个关系型数据库管理系统，由瑞典MySQL AB 公司开发，属于 Oracle 旗下产品。MySQL 是最流行的关系型数据库管理系统之一，在 WEB 应用方面，MySQL是最好的 RDBMS (Relational Database Management System，关系数据库管理系统) 应用软件之一。

2.2 MySQL 安装

关于MySQL安装这里不做更多的讲解，自行通过上网资料进行安装。

2.3 Go 语言标准库中的 database/sql 包介绍

database/sql 包提供了一个围绕sql（或类似sql）数据库的通用接口

3. *** 作 MySQL 数据库的准备工作

3.1 加载驱动

 

*** 作mysql需要 mysql 的驱动，由于我使用 go mod 来管理依赖，直接导入包就行。

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

3.2 导入包

 

方法同上，导入包即可。

import "database/sql"

3.3 打开数据库

调用 sql.Open 方法打开数据库

db, err := sql.Open("mysql", dataSourceName) defer db.Close() if err != nil { return }

在执行了Open 后，并没有立即建立数据库连接。直到你发起数据库请求后才真正建立连接。 你可以使用 Ping 来验证连接是否通畅。

3.4 验证连接是否通畅

if err := db.Ping(); err != nil {
    log.Fatal(err)
} else {
    fmt.Println("连接成功")
}

*** 作mysql需要 mysql 的驱动，由于我使用 go mod 来管理依赖，直接导入包就行。

4. 一些基本 *** 作

4.1 创建数据库和表结构

创建数据库

mysql> create database ginsql;

创建数据表

CREATE TABLE IF NOT EXISTS `person`(

   `id` INT AUTO_INCREMENT,

   `name` VARCHAR(20),

   `age` int,

   PRIMARY KEY ( `id` )

)ENGINE=InnoDB DEFAULT CHARSET=utf8;

4.2 增（插入数据）

使用 db.Exec 方法插入数据

//增（插入数据）

db.Exec("INSERT INTO person(name,age) VALUES(?,?);", "zhangsan", 20)

db.Exec("INSERT INTO person(name,age) VALUES(?,?);", "lisi", 40)

db.Exec("INSERT INTO person(name,age) VALUES(?,?);", "wangwu", 30)

fmt.Println("插入成功")

4.3 查询

使用 db.Query 方法 执行查询SQL，rows.Next 方法遍历结果集，rows.Scan 读取数据到指定的变量中。

//查询数据库

    rows, err := db.Query("select name,age  from person ")

    if err != nil {

        log.Fatal(err)

    }

    for rows.Next() {

        var name, age string

        rows.Scan(&name, &age)

        fmt.Println("name=", name, "age=", age)

    }

4.4 改 （更新）

使用 db.Exec 执行 SQL 预计，执行后同构 result3.RowsAffected() 获得 影响行数。

// 更新 (update)

    //update person set age = 50 where name = 'zhangsan'

    result3, err2 := db.Exec("update person set  age = ?  where name = ?", 100, "zhangsan")

    if err != nil {

        fmt.Println("ERROR:", err2)

        log.Fatal(err)

    }

    if result3 != nil {

        //插入数据后的主键id

        lastInsertID, _ := result3.LastInsertId()

        //影响行数

        rowsaffected, _ := result3.RowsAffected()

        fmt.Println("#UPDATE lastInsertID=", lastInsertID, "RowsAffected=", rowsaffected)

    }

4.5 删 （删除数据）

使用 db.Exec 执行删除SQL语句，判断 result.RowsAffected() 影响行数。

    //删 （删除数据）

    _, err3 := db.Exec("delete from person where name=?", "lisi")

    if err3 != nil {

        fmt.Println("ERROR:", err3)

        log.Fatal(err)

    }