文档章节

Go操作MySQL数据库

秋风醉了
 秋风醉了
发布于 2016/08/13 18:00
字数 607
阅读 181
收藏 4

3 月,跳不动了?>>>

Go操作MySQL数据库

主要的结构体DB和基于该结构体的方法

type DB
func (db DB) Begin() (Tx, error)
func (db *DB) Close() error
func (db *DB) Driver() driver.Driver
func (db *DB) Exec(query string, args ...interface{}) (Result, error)
func (db *DB) Prepare(query string) (*Stmt, error)
func (db *DB) Query(query string, args ...interface{}) (*Rows, error)
func (db *DB) QueryRow(query string, args ...interface{}) *Row

Query && QueryRow

如下代码示例,

package main

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

func main() {

	//完整的数据库连接字符串
	//username:password@protocol(address)/dbname?param=value
	db, err := sql.Open("mysql", "root:034039@tcp(127.0.0.1:3306)/account")
	defer db.Close()

	if err != nil {
		log.Println(err)
	}

	rows, err := db.Query("SELECT vin,no FROM vehicle_gps where type= ?", 2)

	if err != nil {
		log.Println(err)
	}

	var vin, no string
	for rows.Next() {
		err := rows.Scan(&vin, &no) //获取字段,select几个字段就传入几个变量
		if err != nil {
			log.Println(err)
		}
		fmt.Println(vin, no)
	}

	// 查询单条记录
	singledRow := db.QueryRow("SELECT id,type FROM vehicle_gps where id = ?", 3901)
	var id, kind int
	singledRow.Scan(&id, &kind)
	fmt.Println(id, kind)
}

Exec

如下代码示例,

package main

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

func main() {

	//完整的数据库连接字符串
	//username:password@protocol(address)/dbname?param=value
	db, err := sql.Open("mysql", "root:034039@tcp(127.0.0.1:3306)/account")

	if err != nil {
		log.Println(err)
	}

	//在这里进行一些数据库操作
	defer db.Close()

	//db.Exec 执行查询
	//rand.Intn(100) 返回100 以内随机数
	rand.Seed(time.Now().Unix()) //设置随机数的种子
	random := rand.Intn(100)

	result, err := db.Exec("update vehicle_gps set type = ? where id = ?", random, 8033)
	if err != nil {
		fmt.Println("db.Exec error")
		log.Println(err)
	}
	n, _ := result.RowsAffected()
	fmt.Println(n)
}

Prepare

如下代码示例

package main

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

func main() {
	db, err := sql.Open("mysql", "root:034039@tcp(127.0.0.1:3306)/account")
	defer db.Close()

	if err != nil {
		log.Println(err)
	}

	stmt, err := db.Prepare("update vehicle_gps set type = ? where vin = ?")
	defer stmt.Close()

	if err != nil {
		log.Println(err)
	}
	//rand.Intn(10) 返回10 以内随机数
	rand.Seed(time.Now().Unix()) //设置随机数的种子
	random := rand.Intn(100)

	//Exec方法返回的是sql.Result对象
	result, err := stmt.Exec(random, "JM7CW09FXC0106372")

	if err != nil {
		log.Println(err)
	}

	rows, err := db.Query("select type from vehicle_gps where vin = ?", "JM7CW09FXC0106372")

	if err != nil {
		log.Println(err)
	}

	var t int
	for rows.Next() {
		rows.Scan(&t)
		fmt.Println(t)
		if t != random {
			panic("update type error")
		}
	}

	n, _ := result.RowsAffected()
	fmt.Println(n)
}

事务的支持

如下代码示例

package main

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

func main() {
	db, err := sql.Open("mysql", "root:034039@tcp(127.0.0.1:3306)/account")
	defer db.Close()

	if err != nil {
		log.Println(err)
	}

	tx, err := db.Begin() //开启一个事物
	defer tx.Commit()     //一定要commit

	if err != nil {
		log.Println(err)
	}

	stmt, err := tx.Prepare("update vehicle_gps set type = ? where vin = ?")
	defer stmt.Close()

	if err != nil {
		log.Println(err)
	}
	//rand.Intn(10) 返回10 以内随机数
	rand.Seed(time.Now().Unix()) //设置随机数的种子
	random := rand.Intn(100)
	result, err := stmt.Exec(random, "JM7CW09FXC0106372")

	if err != nil {
		log.Println(err)
	}
	fmt.Println(random)

	if n, _ := result.RowsAffected(); n == 2 {
		fmt.Println("rollback")
		tx.Rollback() //回滚事务后同时也要提交
	}
}

=========END=========

© 著作权归作者所有

秋风醉了
粉丝 253
博文 532
码字总数 405557
作品 0
朝阳
程序员
私信 提问
加载中

评论(0)

【Java Web开发】数据库及SQL/MySQL基础

详细课程链接:【Java Web开发】数据库及SQL/MySQL基础 —— 阿里云大学 MySQL概述 什么是数据库 ?  答:数据的仓库,如:在ATM的示例中我们创建了一个 db 目录,称其为数据库 什么是 MySQ...

阿里云大学云百科
2019/04/26
31
0
MySQL 主从复制与读写分离概念及架构分析

1.MySQL主从复制入门 首先,我们看一个图: 影响MySQL-A数据库的操作,在数据库执行后,都会写入本地的日志系统A中。 假设,实时的将变化了的日志系统中的数据库事件操作,在MYSQL-A的3306端...

摩西
2016/10/27
20
0
Mysql权限控制 - 允许用户远程连接

Mysql为了安全性,在默认情况下用户只允许在本地登录,可是在有此情况下,还是需要使用用户进行远程连接,因此为了使其可以远程需要进行如下操作: 一、允许root用户在任何地方进行远程登录,...

whoisliang
2019/04/03
21
0
MYSQL远程登录权限设置 ,可以让Navicat远程连接服务器的数据库

MYSQL远程登录权限设置 ,可以让Navicat远程连接服务器的数据库 Mysql默认关闭远程登录权限,如下操作允许用户在任意地点登录: 1. 进入mysql,GRANT ALL PRIVILEGES ON . TO 'root'@'%' IDE...

xiaocao13140
2018/06/06
0
0
干货 | MySQL数据库安全之审计

2 Query OK, 1 row affected (0.03 sec)3 MySQL> flush privileges;4 Query OK, 0 rows affected (0.00 sec) 2 initconnect='insert into auditdb.accesslog(connectionid, connectionuser,l......

京东云技术新知
2019/05/31
110
0

没有更多内容

加载失败,请刷新页面

加载更多

每年营收翻倍的 AfterShip 是如何体系化做新员工培训(下)

AfterShip 自 2012 年成立以来,每年业务都可实现 100% 的复合增长。对于这家公司来说,组建团队是一件更重要的事情,并且尤为重视工程师团队文化的建设,他们推崇团队文化多元化及相互包容性...

爱客科技
9分钟前
10
0
如何在企业内部实现云信私有化

在信息安全愈发重要的今天,企业越来越重视和业务有关的数据,视其为企业的生命线,云信针对这一特点专门构建了一整套私有化方案,并且在多家行业龙头企业内部稳定运行,成为企业内部发展的助...

真正稳定的网易云信
9分钟前
10
0
动态代理的实际应用

原文链接 前言 最近在用 Python 的 SQLAlchemy 库时(一个类似于 Hibernate 的 ORM 框架),发现它的 Events 事件还挺好用。 简单说就是当某张表的数据发生变化(曾、删、改)时会有一个事件...

crossoverJie
13分钟前
5
0
视频直播技术之如何搭建流媒体服务器?

实时视频直播是这两年非常火的技术形态,已经渗透到教育、在线互娱等各种业务场景中。但要搭建一套实时视频直播系统,并非易事,下面针对直播系统的的搭建做一下说明: 1.1 通常的直播系统的...

图玩智能科技
14分钟前
16
0
SpringTask任务调度详解+SpringBoot整合

1 定时任务的框架 Quartz:整合了Spring SpringTask:轻量 SpringBoot整合SpringTask:两行代码即可搞定 1.1.说说定时任务的应用场景 1. 月底扣话费2. 会员到期3. 生日祝福4. qq好友生日祝...

漫路h
15分钟前
7
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部