首页 > 后端开发 > Golang > golang简单实现mysql

golang简单实现mysql

WBOY
发布: 2023-05-15 11:45:07
原创
781 人浏览过

使用 Golang 编写程序来操作数据库非常简便,这一点在 MySQL 数据库中也不例外。下面将为大家介绍 Golang 简单实现 MySQL 操作的方法。

首先,确保你已经正确安装了 Golang 和 MySQL,同时也需要安装 Go 的 MySQL 驱动程序。这可以通过以下命令轻松完成:

go get -u github.com/go-sql-driver/mysql
登录后复制

在创建 Go 程序之前,我们还需要创建一个 MySQL 数据库以及一张表来演示使用 Golang 进行数据库操作的方法。

假设我们已经创建了一个名为 "test_db" 的数据库,并且其中包含一张名为 "users" 的表。表的结构如下:

CREATE TABLE IF NOT EXISTS `users` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(50) NOT NULL,
  `email` varchar(50) NOT NULL,
  `age` smallint(6) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
登录后复制

接下来,我们就可以开始编写 Golang 程序了。以下是一个简单的程序示例,展示了如何使用 Golang 驱动程序来连接 MySQL 数据库,并执行一些基本的查询操作:

package main

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

func main() {
    // 连接 MySQL 数据库
    db, err := sql.Open("mysql", "username:password@tcp(127.0.0.1:3306)/test_db?charset=utf8mb4")
    if err != nil {
        panic(err.Error())
    }
    defer db.Close()

    // 执行查询操作
    rows, err := db.Query("SELECT * FROM users")
    if err != nil {
        panic(err.Error())
    }
    defer rows.Close()

    // 遍历查询结果
    for rows.Next() {
        var id int
        var name string
        var email string
        var age int
        err := rows.Scan(&id, &name, &email, &age)
        if err != nil {
            panic(err.Error())
        }
        fmt.Println(id, name, email, age)
    }

    // 检查是否存在错误
    err = rows.Err()
    if err != nil {
        panic(err.Error())
    }
}
登录后复制

通过运行以上程序,我们可以成功连接 MySQL 数据库,并使用 "SELECT" 语句查询 "users" 表中的所有记录,并将结果打印输出。

除了查询外,我们还可以使用 Golang 驱动程序来执行其他常见的 MySQL 操作,如插入、更新和删除等。以下是一个简单的程序示例:

package main

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

func main() {
    // 连接 MySQL 数据库
    db, err := sql.Open("mysql", "username:password@tcp(127.0.0.1:3306)/test_db?charset=utf8mb4")
    if err != nil {
        panic(err.Error())
    }
    defer db.Close()

    // 插入一条记录
    stmt, err := db.Prepare("INSERT INTO users(name, email, age) VALUES(?, ?, ?)")
    if err != nil {
        panic(err.Error())
    }
    defer stmt.Close()

    result, err := stmt.Exec("Tom", "tom@email.com", 30)
    if err != nil {
        panic(err.Error())
    }
    lastInsertId, _ := result.LastInsertId()
    fmt.Println("新增记录的 ID:", lastInsertId)

    // 更新一条记录
    stmt, err = db.Prepare("UPDATE users SET name=?, age=? WHERE id=?")
    if err != nil {
        panic(err.Error())
    }
    defer stmt.Close()

    result, err = stmt.Exec("Jerry", 25, 1)
    if err != nil {
        panic(err.Error())
    }
    affectRow, _ := result.RowsAffected()
    fmt.Println("受影响的行数:", affectRow)

    // 删除一条记录
    stmt, err = db.Prepare("DELETE FROM users WHERE id=?")
    if err != nil {
        panic(err.Error())
    }
    defer stmt.Close()

    result, err = stmt.Exec(1)
    if err != nil {
        panic(err.Error())
    }
    affectRow, _ = result.RowsAffected()
    fmt.Println("受影响的行数:", affectRow)
}
登录后复制

通过以上程序示例,我们可以成功执行插入、更新和删除等常见 MySQL 操作。

总体来说,使用 Golang 驱动程序实现 MySQL 数据库操作非常简单。无论是查询、插入、更新还是删除等各种操作,都可以通过 Golang 驱动程序轻松实现。

以上是golang简单实现mysql的详细内容。更多信息请关注PHP中文网其他相关文章!

来源:php.cn
本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板