文档章节

Go操作MySQL数据库

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

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=========

© 著作权归作者所有

共有 人打赏支持
秋风醉了
粉丝 236
博文 578
码字总数 419908
作品 0
朝阳
程序员
Mysql使用binlog恢复数据解决误操作问题的两种方法

新搭建的个人博客,欢迎光临< 为保证没有其他参数配置影响,重新安装配置了一台最小化安装的CentOS7虚拟机 1. 基础知识 安装mysql5.6数据库 https://my.oschina.net/sgmder/blog/1631045 Mys...

Sgmder
03/07
0
0
MySQL 主从复制与读写分离概念及架构分析

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

摩西
2016/10/27
8
0
CentOS LAMP环境配置好后,拒绝访问远程服务器

当LAMP环境配置好后,我们在本机:192.168.0.130使用Navicat连接服务器:192.168.0.168的时候会出现远程MySQL不允许访问的错误,这是因为Mysql为了安全性,在默认情况下用户只允许在本地登录...

cheng-git
2015/09/06
46
0
CentOS 配置MySQL允许远程登录

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

Surjur
2014/09/02
0
0
Mysql允许用户远程连接及授权

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

那些年我们一起
2014/05/26
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Java程序员的书籍清单

我自己一路来,看过的书籍,都是经典,我自己也在不断地回溯,在这里分享给大家(排名不分先后,这里仅仅是我自己购买这些书籍的时间顺序排列): 《高效程序员的45个习惯 敏捷开发修炼之道》...

ChinaHYF
30分钟前
1
0
DeepMind 开源图神经网络的代码

用于支持论文《Relational inductive biases, deep learning, and graph networks》。 github A graph network takes a graph as input and returns a graph as output. The input graph has......

shengjuntu
52分钟前
2
0
python2编码详解、一

以前使用python3没觉的什么,跟着公司使用python2后被编码问题折磨的痛不欲生,好好研究了一下编码问题,参考了很多博文,加入自己的理解,这里只是对编码的介绍,下一篇是python2中编码问题...

hc321
今天
2
0
基于OpenSSL的一些常用加密签名算法

目前包括:MD5、SHA512、DES、RSA加解密、RSA+MD5签名验证算法,在openssl基础上再进行封装,使用简单,头文件需要包含openssl库,可以使用vcpkg自动管理,省去繁琐的配置工程的过程。 该RSA...

LoSingSang
今天
1
0
spring Data JPA

什么是JPA? 全称Java Persistence API,可以通过注解或者XML描述【对象-关系表】之间的映射关系,并将实体对象持久化到数据库中。 为我们提供了: 1)ORM映射元数据:JPA支持XML和注解两种元...

狼王黄师傅
今天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部