feathers mysql_Go 语言操作 MySQL 之 CURD 操作
友情提示:此篇文章大约需要阅读 10分钟52秒,不足之处请多指教,感谢你的阅读。
MySQL 是目前开发中最常见的关系型数据库,使用 Go 语言进行操控数据库需要使用 Go 自带database/sql和驱动go-sql-driver/mysql来实现,
创建好 Go 项目,需要引用驱动依赖:
go get -u github.com/go-sql-driver/mysql
使用 MySQL 驱动:
func Open(driverName, dataSourceName string) (*DB, error)
Open 打开一个 dirverName 指定的数据库,dataSourceName 指定数据源,一般至少包括数据库文件名和其它连接必要的信息。
初始化连接
var db *sql.DB //声明一个全局的 db 变量
// 初始化 MySQL 函数
func initMySQL() (err error) {
dsn := "root:password@tcp(127.0.0.1:3306)/dbname"
db, err = sql.Open("mysql", dsn)
if err != nil {
return
}
err = db.Ping()
if err != nil {
return
}
return
}
func main() {
// 初始化 MySQL
err := initMySQL()
if err != nil {
panic(err)
}
defer db.Close()
}
初始化连接 MySQL 后需要借助 db.Ping 函数来判断连接是否成功。
SetMaxOpenConns
func (db *DB) SetMaxOpenConns(n int)
SetMaxOpenConns设置与数据库建立连接的最大数目。
如果 n 大于 0 且小于最大闲置连接数,会将最大闲置连接数减小到匹配最大开启连接数的限制。
如果 n <= 0,不会限制最大开启连接数,默认为0(无限制)。
SetMaxIdleConns
func (db *DB) SetMaxIdleConns(n int)
SetMaxIdleConns设置连接池中的最大闲置连接数。
如果 n 大于最大开启连接数,则新的最大闲置连接数会减小到匹配最大开启连接数的限制。
如果 n <= 0,不会保留闲置连接。
CURD
进行 CURD 操作,需要对数据库建立连接,同时有供操作的数据(数据库与数据表):
初始化数据
建立数据库 sql_demo
CREATE DATABASE sql_demo;
USE sql_demo;
创建数据表 user
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;
查询 SELECT
便于接收数据,定义一个 user 结构体接收数据:
type user struct {
id int
age int
name string
}
查询一行数据
db.QueryRow() 执行一次查询,并期望返回最多一行结果(即 Row )。QueryRow 总是返回非 nil 的值,直到返回值的 Scan 方法被调用时,才会返回被延迟的错误。(如:未找到结果)
func (db *DB) QueryRow(query string, args ...interface{}) *Row
实例代码如下:
// 查询一行数据
func queryRowDemo() (u1 *user, err error) {
// 声明查询语句
sqlStr := "SELECT id,name,age FROM user WHERE id = ?"
// 声明一个 user 类型的变量
var u user
// 执行查询并且扫描至 u
err = db.QueryRow(sqlStr, 1).Scan(&u.id, &u.age, &u.name)
if err != nil {
return nil, err
}
u1 = &u
return
}
func main() {
// 初始化 MySQL
err := initMySQL()
if err != nil {
panic(err)
}
defer db.Close()
u1, err := queryRowDemo()
if err != nil {
fmt.Printf("err:%s", err)
}
fmt.Printf("id:%d, age:%d, name:%s\n", u1.id, u1.age, u1.name)
」
结果如下:
id:1, age:111, name:22
多行查询
db.Query()执行一次查询,返回多行结果(即 Rows ),一般用于执行 select 命令。参数 args 表示 query 中的占位参数。
func (db *DB) Query(query string, args ...interface{}) (*Rows, error)
实例代码如下:
// 查询多行数据
func queryMultiRowDemo() {
sqlStr := "SELECT id,name,age FROM user WHERE id > ?"
rows, err := db.Query(sqlStr, 0)
if err != nil {
fmt.Printf("query data failed,err:%s\n", err)
return
}
// 查询完数据后需要进行关闭数据库链接
defer rows.Close()
for rows.Next() {
var u user
err := rows.Scan(&u.id, &u.age, &u.name)
if err != nil {
fmt.Printf("scan data failed, err:%v\n", err)
return
}
fmt.Printf("id:%d name:%s age:%d\n", u.id, u.name, u.age)
}
}
执行结果:
id:1 name:111 age:22
id:3 name:张三 age:22
使用 rows.Next() 循环读取结果集中的数据。
增加数据 INSERT
增加、删除、更新操作均使用 Exec 方法。
func (db *DB) Exec(query string, args ...interface{}) (Result, error)
实例代码如下:
// 增加一行数据
func insertRowDemo() {
sqlStr := "INSERT INTO user(name, age) VALUES(?, ?)"
result, err := db.Exec(sqlStr, "小羽", 22)
if err != nil {
fmt.Printf("insert data failed, err:%v\n", err)
return
}
id, err := result.LastInsertId()
if err != nil {
fmt.Printf("get insert lastInsertId failed, err:%v\n", err)
return
}
fmt.Printf("insert success, id:%d\n", id)
}
执行结果:
insert success, id:4
更新数据 UPDATE
// 更新一组数据
func updateRowDemo() {
sqlStr := "UPDATE user SET age = ? WHERE id = ?"
result, err := db.Exec(sqlStr, 22, 1)
if err != nil {
fmt.Printf("update data failed, err:%v\n", err)
return
}
n, err := result.RowsAffected()
if err != nil {
fmt.Printf("get rowsaffected failed, err:%v\n", err)
return
}
fmt.Printf("update success, affected rows:%d\n", n)
}
删除数据 DELETE
// 删除一行数据
func deleteRowDemo() {
sqlStr := "DELETE FROM user WHERE id = ?"
result, err := db.Exec(sqlStr, 2)
if err != nil {
fmt.Printf("delete data failed, err:%d\n", err)
return
}
n, err := result.RowsAffected()
if err != nil {
fmt.Printf("get affected failed, err:%v\n", err)
return
}
fmt.Printf("delete success, affected rows:%d\n", n)
}
本文同步分享在 博客“Meng小羽”(other)。
如有侵权,请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”,欢迎正在阅读的你也加入,一起分享。
feathers mysql_Go 语言操作 MySQL 之 CURD 操作相关推荐
- golang mysql curd_Go 语言操作 MySQL 之 CURD 操作
本文转载于SegmentFault社区 作者:Meng小羽 MySQL 是目前开发中最常见的关系型数据库,使用 Go 语言进行操控数据库需要使用 Go 自带database/sql和驱动go-sql- ...
- C语言对mysql数据库的操作
C语言对mysql数据库的操作 原文:C语言对mysql数据库的操作 这已经是一相当老的话题.不过今天我才首次使用,把今天的一些体会写下来,也许能给一些新手带来一定的帮助,更重要的是供自己今后忘记的怎 ...
- mysql 空间数据操作,MySQL 空间数据 简单操作
在做的项目中需要,自己绘制区域图形,并存储起来,后面还有更新的需要,存文件不方面,想到现在数据库都支持空间数据库. 现在用的就是 MySQL ,就继续用 MySQL 来存储.管理空间数据.下面就做一些 ...
- python3操作mysql教程_python3操作mysql教程
一.下载\安装\配置 1. python3 当前最新版本是python3.2,下载地址是 http://www.python.org/ftp/python/3.2.3/python-3.2.3.msi ...
- php操作mysql数据_PHP - 操作MySQL数据库
第16章 PHP操作MySQL 学习要点: 1.PHP连接到MySQL 2.增删改查 3.其他常用函数 如果你已经具有了使用PHP.SQL和MySQL的丰富经验,现在就可以把所有这些技术组合在一起.P ...
- linux shell操作mysql,Linux shell操作mysql数据库的方法
摘要 腾兴网为您分享:Linux shell操作mysql数据库的方法,鱼乐贝贝,宜信,嘻嘻动漫,西餐菜谱等软件知识,以及包装效果图,德州人社,evasi0n.com,ios迅雷,民革e家,动态表情, ...
- mysql crud操作_c#操作mysql数据库CRUD操作
[实例简介] c#操作mysql数据库 CRUD [实例截图] [核心代码] class SqlHelper { //返回链接数据库的字符串 public static string ConnStri ...
- MySQL数据CURD操作
大圣网络 2017-01-28 08:23 我们平时90%以上都是对表中数据进行增删改查,而其中的查是使用最多最频繁的操作.今天,说说几个入门级的sql语句. 新增数据 新增一条数据 方案1: 给全表 ...
- jdbc连接操作mysql,直接操作和预处理方式
步骤: 1. 加载sql数据库驱动 Class.forName("com.mysql.jdbc.Driver"); 2. 连接数据库 con = DriverManager.get ...
- PDF.NET数据开发框架操作MySQL实体类操作实例
在我们最近的项目中,SQL-MAP使用较多,但是实体类用的很少,实际上,"PDF.NET数据开发框架"的实体类相当强大,下面的测试程序是在MySQL中操作的实例. 1,首先在App ...
最新文章
- C#强化系列:HttpModule,HttpHandler,HttpHandlerFactory简单使用
- Tensorflow:Tensorboard使用
- BZOJ 1951: [Sdoi2010]古代猪文 [Lucas定理 中国剩余定理]
- c语言编手机蓝牙软件的代码,51单片机C语言的简易蓝牙锁代码
- 软件测试知识产权保护,一种软件测试方法及软件测试系统专利_专利申请于2017-09-07_专利查询 - 天眼查...
- 背景图层和普通图层的区别_图层样式(一)—高级混合选项
- Vmware安装Centos7上网问题的解决
- 网页版bpc电波对时_bpc电波对时app下载
- 简单实用的php爬虫系统
- 前端实现很哇塞的浏览器端扫码功能
- 【vant】爬坑引用本地图片
- 匿名发送邮件python_邮箱伪造之搭建匿名SMTP服务器
- U3D资源导出至Laya
- 求两个数的最小公倍数; 两种方法
- 一行命令,瞬间从“马赛克”到高清影像!
- ARM CM0 push和pop指令
- 为什么有很深的windows基础还是不能动摇linux半步
- web项目开发---部署
- Dell服务器出错代码和含义
- matlab实现移位寄存器,基于matlab的移位寄存器法m序列的产生