Go操作MySQL

1、下载依赖

Go语言中的database/sql包提供了保证SQL或类SQL数据库的泛用接口，并不提供具体的数据库驱动。使用database/sql包时必须注入（至少）一个数据库驱动。

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

2、相关函数

2.1 Open()

func Open(driverName, dataSourceName string) (*DB, error)

Open打开一个dirverName指定的数据库，dataSourceName指定数据源，一般至少包括数据库文件名和其它连接必要的信息。例如 "admin:123456@tcp(192.168.3.128:3306)/sql_test"，依次对应的是"username:password@tcp(IP:Post)/dbname"

Open函数可能只是验证其参数格式是否正确，实际上并不创建与数据库的连接。如果要检查数据源的名称是否真实有效，应该调用Ping方法。

2.2 CRUD

2.2.1 单行查询

单行查询db.QueryRow()执行一次查询，并期望返回最多一行结果（即Row）。QueryRow总是返回非nil的值，直到返回值的Scan方法被调用时，才会返回被延迟的错误。（如：未找到结果）

func (db *DB) QueryRow(query string, args ...interface{}) *Row

2.2.2 多行查询

多行查询db.Query()执行一次查询，返回多行结果（即Rows），一般用于执行select命令。参数args表示query中的占位参数。

func (db *DB) Query(query string, args ...interface{}) (*Rows, error)

2.2.3 插入、更新和删除数据

插入、更新和删除操作都使用Exec方法。

func (db *DB) Exec(query string, args ...interface{}) (Result, error)

Exec执行一次命令（包括查询、删除、更新、插入等），返回的Result是对已执行的SQL命令的总结。参数args表示query中的占位参数。

2.2.4 举个例子

先在MySQL中创建一个名为sql_test的数据库

CREATE DATABASE sql_test;
use sql_test;# 创建一张用于测试的数据表
CREATE TABLE `user` (`id` BIGINT(20) NOT NULL AUTO_INCREMENT,`name` VARCHAR(20) DEFAULT '',`age` INT(11) DEFAULT '0',PRIMARY KEY(`id`)
)ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4;
package mainimport ("database/sql""fmt"_ "github.com/go-sql-driver/mysql"
)// 定义一个全局对象db
var db *sql.DB// 定义好一个结构体来存储user表的数据
type user struct {id   intage  intname string
}// 定义一个初始化数据库的函数
func initDB() (err error) {// DSN: "username:password@tcp(IP:Post)/dbname"dsn := "admin:123456@tcp(192.168.3.128:3306)/sql_test"// 不会校验账号密码是否正确db, err = sql.Open("mysql", dsn)if err != nil {return err}// 尝试与数据库建立连接（校验dsn是否正确）err = db.Ping()if err != nil {return err}db.SetMaxOpenConns(20) // 最大连接数db.SetMaxIdleConns(5)  // 最大空闲连接数return
}// 查询单条数据示例
func querRowDemo() {sqlStr := "select id, name, age from user where id = ?" // ?代表占位符var u user// 非常重要：确保QueryRow之后调用Scan方法，否则持有的数据库链接不会被释放err := db.QueryRow(sqlStr, 1).Scan(&u.id, &u.name, &u.age) // 1，代表sql语句中的？的值是1if err != nil {fmt.Printf("scan falied, err = %v\n", err)return}fmt.Printf("id = %d, name = %s, age = %d\n", u.id, u.name, u.age)}// 查询多条数据示例
func queryMultiRowDemo() {sqlStr := "select id, name, age from user where id > ?"rows, err := db.Query(sqlStr, 0)if err != nil {fmt.Printf("query failed, err = %v\n", err)return}// 非常重要：关闭rows释放持有的数据库链接defer rows.Close()// 循环读取结果集中的数据for rows.Next() {var u usererr := rows.Scan(&u.id, &u.name, &u.age)if err != nil {fmt.Printf("scan failed, err = %v\n", err)return}fmt.Printf("id = %d, name = %s, age = %d\n", u.id, u.name, u.age)}
}// 插入数据
func insertRowDemo() {sqlStr := "insert into user(name, age) values (?,?)"ret, err := db.Exec(sqlStr, "王五", 38)if err != nil {fmt.Printf("insert failed, err:%v\n", err)return}var theID int64theID, err = ret.LastInsertId() // 新插入数据的idif err != nil {fmt.Printf("get lastinsert ID failed, err:%v\n", err)return}fmt.Printf("insert success, the id is %d.\n", theID)
}// 更新数据
func updateRowDemo() {sqlStr := "update user set age=? where id = ?"ret, err := db.Exec(sqlStr, 39, 3)if err != nil {fmt.Printf("update failed, err:%v\n", err)return}n, err := ret.RowsAffected() // 操作影响的行数if err != nil {fmt.Printf("get RowsAffected failed, err:%v\n", err)return}fmt.Printf("update success, affected rows:%d\n", n)
}// 删除数据
func deleteRowDemo() {sqlStr := "delete from user where id = ?"ret, err := db.Exec(sqlStr, 3)if err != nil {fmt.Printf("delete failed, err:%v\n", err)return}n, err := ret.RowsAffected() // 操作影响的行数if err != nil {fmt.Printf("get RowsAffected failed, err:%v\n", err)return}fmt.Printf("delete success, affected rows:%d\n", n)
}func main() {err := initDB() // 调用输出化数据库的函数if err != nil {fmt.Printf("init db failed,err:%v\n", err)return}defer db.Close() // 注意这行代码要写在上面err判断的下面fmt.Println("connect to db success")fmt.Println("\n查询单条数据")querRowDemo()fmt.Println("\n查询多条数据")queryMultiRowDemo()fmt.Println("\n插入新数据")insertRowDemo()fmt.Println("\n更新数据")updateRowDemo()fmt.Println("\n删除前数据")queryMultiRowDemo()fmt.Println("\n删除后数据")deleteRowDemo()queryMultiRowDemo()
}

2.3 预处理

1）普通SQL语句执行过程：

  1. 客户端对SQL语句进行占位符替换得到完整的SQL语句。
  2. 客户端发送完整SQL语句到MySQL服务端
  3. MySQL服务端执行完整的SQL语句并将结果返回给客户端。

2）预处理执行过程：

  1. 把SQL语句分成两部分，命令部分与数据部分。
  2. 先把命令部分发送给MySQL服务端，MySQL服务端进行SQL预处理。
  3. 然后把数据部分发送给MySQL服务端，MySQL服务端对SQL语句进行占位符替换。
  4. MySQL服务端执行完整的SQL语句并将结果返回给客户端。

database/sql中使用下面的Prepare方法来实现预处理操作。

func (db *DB) Prepare(query string) (*Stmt, error)

Prepare方法会先将sql语句发送给MySQL服务端，返回一个准备好的状态用于之后的查询和命令。返回值可以同时执行多个查询和命令。

2.3.1 示例

查询操作的预处理示例代码如下：

package mainimport ("database/sql""fmt"_ "github.com/go-sql-driver/mysql"
)// 定义一个全局对象db
var db *sql.DB// 定义好一个结构体来存储user表的数据
type user struct {id   intage  intname string
}// 定义一个初始化数据库的函数
func initDB() (err error) {// DSN: "username:password@tcp(IP:Post)/dbname"dsn := "admin:123456@tcp(192.168.3.128:3306)/sql_test"// 不会校验账号密码是否正确db, err = sql.Open("mysql", dsn)if err != nil {return err}// 尝试与数据库建立连接（校验dsn是否正确）err = db.Ping()if err != nil {return err}db.SetMaxOpenConns(20) // 最大连接数db.SetMaxIdleConns(5)  // 最大空闲连接数return
}// 预处理查询示例
func prepareQueryDemo() {sqlStr := "select id, name, age from user where id > ?"stmt, err := db.Prepare(sqlStr)if err != nil {fmt.Printf("prepare failed, err:%v\n", err)return}defer stmt.Close()rows, err := stmt.Query(0)if err != nil {fmt.Printf("query failed, err:%v\n", err)return}defer rows.Close()for rows.Next() {var u usererr := rows.Scan(&u.id, &u.name, &u.age)if err != nil {fmt.Printf("scan failed, err = %v\n", err)return}fmt.Printf("id = %d, name = %s, age = %d\n", u.id, u.name, u.age)}
}// 预处理插入示例
func prepareInsertDemo() {sqlStr := "insert into user(name, age) values (?,?)"stmt, err := db.Prepare(sqlStr)if err != nil {fmt.Printf("prepare failed, err:%v\n", err)return}defer stmt.Close()_, err = stmt.Exec("小王子", 18)if err != nil {fmt.Printf("insert failed, err:%v\n", err)return}_, err = stmt.Exec("沙河娜扎", 18)if err != nil {fmt.Printf("insert failed, err:%v\n", err)return}fmt.Println("insert success.")
}func main() {err := initDB() // 调用输出化数据库的函数if err != nil {fmt.Printf("init db failed,err:%v\n", err)return}defer db.Close() // 注意这行代码要写在上面err判断的下面fmt.Println("connect to db success")fmt.Println("\n插入前")prepareQueryDemo()prepareInsertDemo()fmt.Println("\n插入后")prepareQueryDemo()
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/179639.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

MySOL常见四种连接查询

MySOL常见四种连接查询

1、内联接 &#xff08;典型的联接运算&#xff0c;使用像 或 <> 之类的比较运算符&#xff09;。包括相等联接和自然联接。 内联接使用比较运算符根据每个表共有的列的值匹配两个表中的行。例如&#xff0c;检索 students和courses表中学生标识号相同的所有行。 2、…
阅读更多...
CVPR 2023 精选论文学习笔记：Towards Scalable Neural Representation for Diverse Videos

CVPR 2023 精选论文学习笔记：Towards Scalable Neural Representation for Diverse Videos

基于 MECE 原则，我们给出以下四个分类标准： 分类标准 1：表示类型 隐式神经表示（INR） 隐式神经表示（INR）是一类神经网络架构，将场景或对象表示为从 3D 点映射到颜色和不透明度值的连续函数。该函数通常从一组训练图像或视频中学习，然后可以用于渲染场景或对象的新视…
阅读更多...
机器学习之危险品车辆目标检测

机器学习之危险品车辆目标检测

危险品的运输涉及从离开仓库到由车辆运输到目的地的风险。监控事故、车辆运动动态以及车辆通过特定区域的频率对于监督车辆运输危险品的过程至关重要。 在线工具推荐&#xff1a; 三维数字孪生场景工具 - GLTF/GLB在线编辑器 - Three.js AI自动纹理化开发 - YOLO 虚幻合成数…
阅读更多...
使用STM32微控制器实现光电传感器的接口和数据处理

使用STM32微控制器实现光电传感器的接口和数据处理

光电传感器在许多领域中被广泛应用&#xff0c;例如工业自动化、智能家居等。本文将介绍如何使用STM32微控制器实现光电传感器的接口和数据处理的方案&#xff0c;包括硬件设计、引脚配置、数据采集、滤波和阈值判断等关键步骤&#xff0c;并给出相应的代码示例。 一、引言 光…
阅读更多...
[传智杯 #3 决赛] 课程

[传智杯 #3 决赛] 课程

题目背景 disangan233 喜欢数数&#xff0c;于是他想让你帮他回答一个问题。 题目描述 传智专修学院提供 A,B 两个课程&#xff0c;分别有 n,m 个学生报名。报名 A 的学生的编号为an​&#xff0c;报名 B 的学生的编号为 bm​&#xff0c;求有多少个学生同时报名了两个课程。…
阅读更多...
在awk中 sub函数 和 gsub函数 的区别

在awk中 sub函数 和 gsub函数 的区别

在awk中 sub函数 和 gsub函数 的区别 简单说就是正则加g和不加g的效果, sub匹配每行第一个,gsub匹配每行所有 在Awk中&#xff0c;sub函数和gsub函数都是用于字符串替换的函数&#xff0c;但它们之间存在一些区别。 sub函数&#xff1a; sub函数用于替换字符串中的第一个匹配…
阅读更多...
MySQL使用函数和存储过程实现：向数据表快速插入大量测试数据

MySQL使用函数和存储过程实现：向数据表快速插入大量测试数据

实现过程 1.创建表 CREATE TABLE user_info (id INT(11) NOT NULL AUTO_INCREMENT,name VARCHAR(20) DEFAULT NULL,age INT(3) DEFAULT NULL,pwd VARCHAR(20) DEFAULT NULL,phone_number VARCHAR(11) DEFAULT NULL,email VARCHAR(255) DEFAULT NULL,address VARCHAR(255) DEF…
阅读更多...
DHCP协议及实验omnipeek抓包工具分析 IPv4协议

DHCP协议及实验omnipeek抓包工具分析 IPv4协议

一 抓包命令 adb shell tcpdump -i wlan0 -w /data/tcpdump.pcap 抓包后截图如下 二 DHCP是什么 2.1 DHCP定义 DHCP（ Dynamic Host Configuration Protocol， 动态主机配置协议）定义： 存在于应用层（OSI） 前身是BOOTP（Bootstrap Protocol）协议 是一个使用UDP（User …
阅读更多...
Git命令汇总

Git命令汇总

每次git不常用的命令时东查西查&#xff0c;还是自己写一下&#xff0c;巩固下印象吧。。 删除分支 要删除远程分支&#xff0c;可以使用以下命令&#xff1a; git push origin --delete <branch_name> 其中&#xff0c;<branch_name>是要删除的分支的名称。 …
阅读更多...
asp.net core HttpContextAccessor类

asp.net core HttpContextAccessor类

在 ASP.NET Core 中 &#xff0c;HttpContextAccessor 是一个用于访问当前 HTTP 请求的工具类。它通常用于在应用程序中获取当前 HTTP 请求的上下文信息&#xff0c;例如请求的路由、头部信息、用户身份验证状态等。 HttpContextAccessor 类通常在需要访问当前 HTTP 请求上下文…
阅读更多...
如何编写自己的python包，并在本地进行使用

如何编写自己的python包，并在本地进行使用

如何编写自己的python包，并在本地进行使用 一、直接引用 1.创建Python项目pythonProject。 2.并且在此项目下创建pg_message包。 3.pg_message包下默认生成_init_.py文件。 Python中_init_.py是package的标志。init.py 文件的一个主要作用是将文件夹变为一个Python模块，Pyt…
阅读更多...
使用Jmeter进行http接口测试

使用Jmeter进行http接口测试

前言&#xff1a; 本文主要针对http接口进行测试&#xff0c;使用Jmeter工具实现。 Jmter工具设计之初是用于做性能测试的&#xff0c;它在实现对各种接口的调用方面已经做的比较成熟&#xff0c;因此&#xff0c;本次直接使用Jmeter工具来完成对Http接口的测试。 一、开发接口…
阅读更多...
杂记 | 使用Docker安装并配置MongoDB以支持事务（单副本，并解决了证书文件错误的问题）

杂记 | 使用Docker安装并配置MongoDB以支持事务（单副本，并解决了证书文件错误的问题）

文章目录 00 安装前的准备01 创建Docker Compose文件02 设置证书文件03 启动MongoDB04 初始化副本集和创建用户05 验证安装 00 安装前的准备 在开始之前&#xff0c;确保已经安装了Docker&#xff0c;本文基于Docker Compose进行示范&#xff0c;没有装Docker Compose也可将其…
阅读更多...
gitlab 代码提交账户信息修改

gitlab 代码提交账户信息修改

1&#xff0c;前提 刚来公司&#xff0c;去gitlab仓库拉取项目代码的时候需要一个用户&#xff0c;密码&#xff0c;邮件&#xff0c;当时随便设置了一个邮件&#xff0c; 后来公司实施了信息安全方面的措施&#xff0c;被限制只能固定后缀的用户邮件才能拉取提交代码&#xf…
阅读更多...
人大金仓亮相2023信息技术应用创新论坛

人大金仓亮相2023信息技术应用创新论坛

11月25日&#xff0c;2023信息技术应用创新论坛在常州开幕。人大金仓受邀分享信息技术应用创新行业应用典型成果&#xff0c;在论坛展览部分集中展示了最具代表性的新产品、应用及解决方案。 江苏省工业和信息化厅副厅长池宇、中国电子工业标准化技术协会理事长胡燕、常州市常务…
阅读更多...
量子力学技术前沿：探索、挑战与未来

量子力学技术前沿：探索、挑战与未来

量子力学技术前沿：探索、挑战与未来 一、引言 量子力学，这门揭示微观世界规律的学科，自诞生以来就在科技领域发挥着举足轻重的作用。随着科技的飞速发展，量子力学的应用也在不断拓展和深化。今天，我将带领大家一起领略量子力学技术的魅力，探讨其发展趋势和挑战。 二、量…
阅读更多...
flask五小时快速入门资料记录

flask五小时快速入门资料记录

视频推荐 使用Flask轻松实现Python Web应用的全流程&#xff01; 推荐博客 详细版&#xff1a; https://www.w3cschool.cn/flask/flask_http_methods.html https://tutorial.helloflask.com/template/ 简洁版&#xff1a; https://www.cnblogs.com/Zhengnengjin/p/Eternity…
阅读更多...
windows系统mobaxterm远程执行linux上ssh命令

windows系统mobaxterm远程执行linux上ssh命令

命令如下 start "" "%~dp0\MobaXterm_Personal_23.4.exe" -newtab "sshpass -p root ssh root192.168.11.92 mkdir 33" -p 是密码 左边是用户名&#xff0c;右边是服务器ip 后面跟的是服务器上执行的命令 第一次执行的时候要设置mobaxt…
阅读更多...
使用std::mutext与std::condition_variables实现信号量

使用std::mutext与std::condition_variables实现信号量

1. 信号量的定义 2. 使用std::mutext与std::condition_variables实现信号量 代码来自&#xff1a;https://zhuanlan.zhihu.com/p/462668211 #ifndef _SEMAPHORE_H #define _SEMAPHORE_H #include <mutex> #include <condition_variable> using namespace std;cla…
阅读更多...
ArrayList和顺序表

ArrayList和顺序表

目录 线性表 顺序表 实现顺序表&#xff1a; 1&#xff0c;添加元素的时候我们要判断是否需要扩容 2&#xff0c;写异常 3,数组清空 ArrayList&#xff1a; ArrayList的构造方法&#xff1a; ArrayList的add方法&#xff1a; ArrayList的subList 知识点补充&#xff…
阅读更多...
最新文章

Copyright @ 2022~2023