golang mysql包 database/sql的基本操作：增删改查 （go sql操作 保存这篇文章就足够了）

如果不是使用gorm，直接操作底层mysql命令，那么最常使用的是 database/sql 这个包了。

下面的是一些常见的操作，如果需要写底层sql语句，使用频率极高，值得收藏。
 

/*

 * @Author: 30daydo

 * @FilePath: /go110/go-012/g012.go

 * @Description: Go 数据库基本操作

 */

 

package main

 

import (

	"database/sql"

	"fmt"

	"runtime"

 

	_ "github.com/go-sql-driver/mysql"

)

 

/**

// 创建 user 表

CREATE TABLE `user` (

  `id` int NOT NULL AUTO_INCREMENT COMMENT '自增ID',

  `name` varchar(50) COLLATE utf8mb4_general_ci NOT NULL COMMENT '姓名',

  `age` int NOT NULL COMMENT '年龄',

  PRIMARY KEY (`id`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci COMMENT='用户信息表'

**/

 

// 全局对象 db

var db *sql.DB

 

// 定义一个 user 结构体接收数据：

type user struct {

	id   int

	age  int

	name string

}

 

// 始化数据库的函数

func initDB() (err error) {

 

	// 构建连接的 dsn 格式是："用户名:密码@tcp(IP:端口)/数据库?charset=utf8"

	dsn := "user:password@tcp(127.0.0.1:3306)/sql_test?charset=utf8mb4&parseTime=True"

 

	// 给全局变量赋值, 注意这里不要使用 :=

	db, err = sql.Open("mysql", dsn)

	if err != nil {

		fmt.Println("初始化数据库失败")

		return err

	}

 

	// 校验dsn是否正确

	fmt.Println("尝试与数据库建立连接...")

	err = db.Ping()

	if err != nil {

		fmt.Println("连接失败")

		return err

	}

	fmt.Println("连接成功")

 

	db.SetMaxOpenConns(2000) // 设置最大打开连接数

	db.SetMaxIdleConns(10)   // 设置最大空闲连接数

 

	return nil

}

 

// 插入数据

func insertRow(name string, age int) int64 {

 

	sqlStr := "INSERT INTO user(name, age) VALUES (?,?)"

 

	ret, err := db.Exec(sqlStr, name, age)

 

	if err != nil {

		fmt.Printf("插入失败, err: %v\n", err)

		return 0

	}

 

	// 新插入数据的 id

	insertId, err := ret.LastInsertId()

	if err != nil {

		fmt.Printf("获取新插入数据的 ID 失败, err:%v\n", err)

		return 0

	}

	fmt.Printf("插入成功, ID 为  %d.\n", insertId)

 

	return insertId

}

 

// 查询单条数据记录

func queryRow(rowId int64) {

	sqlStr := "SELECT id, name, age FROM user WHERE id = ?"

	var u user

	// 确保 QueryRow 之后调用 Scan 方法，释放持有的数据库链接

	err := db.QueryRow(sqlStr, rowId).Scan(&u.id, &u.name, &u.age)

	if err != nil {

		fmt.Printf("未找到记录, 查询失败, err: %v\n", err)

		return

	}

	fmt.Printf("查询数据成功, id: %d name: %s age: %d \n", u.id, u.name, u.age)

}

 

// 更新数据

func updateRow(rowId int64, newAge int) {

	sqlStr := "UPDATE user SET age=? WHERE id = ?"

	ret, err := db.Exec(sqlStr, newAge, rowId)

	if err != nil {

		fmt.Printf("更新失败 , err:%v\n", err)

		return

	}

	// 操作影响的行数

	n, err := ret.RowsAffected()

	if err != nil {

		fmt.Printf("获取影响函数失败, err: %v\n", err)

		return

	}

	fmt.Printf("更新成功, 影响行数为: %d\n", n)

}

 

// 删除数据

func deleteRow(rowId int64) {

	sqlStr := "DELETE FROM user WHERE id = ?"

	ret, err := db.Exec(sqlStr, rowId)

	if err != nil {

		fmt.Printf("删除失败, err: %v\n", err)

		return

	}

	n, err := ret.RowsAffected() // 操作影响的行数

	if err != nil {

		fmt.Printf("获取影响函数失败, err: %v\n", err)

		return

	}

	fmt.Printf("删除成功, 影响行数为: %d\n", n)

}

 

// 查询多行

func queryMultiRow() {

	sqlStr := "SELECT id, name, age FROM user WHERE id > ?"

	rows, err := db.Query(sqlStr, 0)

	if err != nil {

		fmt.Printf("查询失败, err:%v\n", err)

		return

	}

	// 重要：关闭 rows, 释放持有的数据库链接

	defer rows.Close()

 

	// 循环读取结果集中的数据

	for rows.Next() {

		var u user

		err := rows.Scan(&u.id, &u.name, &u.age)

		if err != nil {

			fmt.Printf("查询多行数据失败, err:%v\n", err)

			return

		}

		fmt.Printf("当前数据 id: %d name: %s age: %d\n", u.id, u.name, u.age)

	}

}

 

func main() {

	// 使用内置函数打印

	println("Hello", "菜鸟实战")

 

	// 初始化数据库

	initDB()

 

	// 插入数据

	var id1 = insertRow("唐遇春", 17)

	var id2 = insertRow("冯显", 38)

	var id3 = insertRow("花千里", 20)

 

	// 查询多行数据

	queryMultiRow()

 

	// 更新数据

	updateRow(id2, 35)

 

	// 查询单行数据

	queryRow(id2)

 

	// 删除数据

	deleteRow(id1)

 

	// 查询多行数据

	queryMultiRow()

	queryRow(id3)

 

	// 当前版本

	fmt.Printf("版本: %s \n", runtime.Version())

}

 
当然，上面的语句也可以不用Prepare的写法，直接插入进去:
 

func insertDirect() {

    db, err := sql.Open("mysql",

    "username:password@tcp(127.0.0.1:3306)/test_db")

    if err != nil {

    log.Fatal(err)

    }

    defer db.Close()

    sql := "INSERT INTO user(id, name, pwd) VALUES(?, ?, ?)"

    res, err := db.Exec(sql, 13, "Jobs", "444555")

    checkErr(err)

    fmt.Println(res.LastInsertId())



}