官方database/sql包介绍

介绍

在Go中访问数据库，需要使用sql.DB类型用于创建语句和事务，执行查询和获取结果
一个sql.DB不是一个数据库连接，它是一个数据库的抽象
sql.DB通过驱动程序打开或关闭与实际数据库的连接并根据需要管理一个连接池
database/sql包只是提供了接口，没有任何实现，因此还需要导入第三方数据库驱动
通常不应直接使用第三方驱动，而应该仅引用 database/sql 中定义的方法和类型，这有助于避免使你的代码取决于驱动程序

连接数据库

import ("database/sql"                             //只需导入你需要的驱动即可_ "github.com/go-sql-driver/mysql"          //mysql驱动_ "github.com/lib/pq"                        //postgres驱动
)func main() {//避免反复open，将db作为全局变量或参数db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbdemo")db, err := sql.Open("postgres", "postgres://bob:secret@1.2.3.4:5432/mydb?sslmode=verify-full")db, err = sql.Open("postgres", "user=bob password=secret host=1.2.3.4 port=5432 dbname=mydb sslmode=verify-full")if err != nil {log.Fatal(err)}//仅在最后关闭dbdefer db.Close()//测试与数据库的连通err = db.Ping()if err != nil {// do something here}
}

操作数据库

在MySQL中，参数占位符为?；在PostgreSQL中为$N，其中N为从1开始的数字；SQLite接受这两者之一；Oracle占位符中以冒号开始，并命名为:param1

查询

通用查询

var (id   intname string
)
rows, err := db.Query("SELECT id,name FROM users WHERE id = $1", 1)
if err != nil {log.Fatal(err)
}
//rows不被关闭，底层连接就处于忙，在连接池中不可用，将造成内存泄漏
defer rows.Close()
for rows.Next() {//处理过程中的异常err := rows.Scan(&id, &name)if err != nil {log.Fatal(err)}log.Println(id, name)
}
//处理结尾处的异常
err = rows.Err()
if err != nil {log.Fatal(err)
}

单行查询

var name string
//无需关闭row
err = db.QueryRow("SELECT name FROM users WHERE id = $1", 1).Scan(&name)
if err != nil {log.Fatal(err)
}
fmt.Println(name)

预编译查询

所谓预编译语句就是将此类 SQL 语句中的值用占位符替代，可以视为将 SQL 语句模板化
一次编译、多次运行，省去了解析优化等过程；此外预编译语句还能防止 SQL 注入

stmt,err := db.Prepare("SELECT id,name FROM users WHERE id = $1")
if err != nil {log.Fatal(err)
}
defer stmt.Close()
rows, err := stmt.Query(1)
if err != nil {log.Fatal(err)
}
defer rows.Close()
for rows.Next() {// ...
}
if err = rows.Err(); err != nil {log.Fatal(err)
}//预编译单行查询
stmt, err := db.Prepare("SELECT name FROM users WHERE id = $1")
if err != nil {log.Fatal(err)
}
var name string
err = stmt.QueryRow(1).Scan(&name)
if err != nil {log.Fatal(err)
}
fmt.Println(name)

修改

使用Exec()来完成，最好用一个预编译的语句来完成INSERT，UPDATE，DELETE或者其他不返回行的语句

stmt, err := db.Prepare("INSERT INTO users(name) VALUES($1)")
if err != nil {log.Fatal(err)
}
res, err := stmt.Exec("Dolly")
if err != nil {log.Fatal(err)
}
lastId, err := res.LastInsertId()
if err != nil {log.Fatal(err)
}
rowCnt, err := res.RowsAffected()
if err != nil {log.Fatal(err)
}
log.Printf("ID = %d, affected = %d
", lastId, rowCnt)

database/sql相关推荐

golang database/sql包简介
概述 sql.DB不是一个连接,它是数据库的抽象接口.它可以根据driver打开关闭数据库连接,管理连接池.正在使用的连接被标记为繁忙,用完后回到连接池等待下次使用.所以,如果你没有把连接释放回连接池 ...
go中的database/sql接口
Go与PHP不同的地方是Go官方没有提供数据库驱动,而是为开发数据库驱动定义了一些标准接口,开发者可以根据定义的接口来开发相应的数据库驱动,这样做有一个好处,只要是按照标准接口开发的代码, 以后需要迁 ...
oracle 在此 select 语句中缺少 into 子句,Go database/sql文档
No.1 文档概要在Golang中使用SQL或类似SQL的数据库的惯用方法是通过 database/sql 包操作.它为面向行的数据库提供了轻量级的接口.这篇文章是关于如何使用它,最常见的参考. 为 ...
go操作mysql（原生database/sql, sqlx库）GORM
GORM官网地址: GORM 指南 | GORM - The fantastic ORM library for Golang, aims to be developer friendly. 参考: ...
mysql pmt函数怎么用_在Golang中如何正确地使用database/sql包访问数据库
本文记录了我在实际工作中关于数据库操作上一些小经验,也是新手入门golang时我认为一定会碰到问题,没有什么高大上的东西,所以希望能抛砖引玉,也算是对这个问题的一次总结.其实我也是一个新手,机缘巧合几 ...
组件分享之后端组件——基于Golang实现的database/sql附加功能组件dbr
组件分享之后端组件--基于Golang实现的database/sql附加功能组件dbr 背景近期正在探索前端.后端.系统端各类常用组件与工具,对其一些常见的组件进行再次整理一下,形成标准化组件专题, ...
【旧文重新排版】借 Go 语言 database/sql 包谈数据库驱动和连接池设计
文 | jiayangchen 封面图片 | Unsplash 因为之前的文章感觉排版太差了,不容易阅读接下来会把一些旧文重新排版再发一下即使你不了解 Go 语言,阅读本文也不会有障碍 1. 什么 ...
数据库 DB database SQL DBMS
数据库 DB database 用来管理数据库的计算机管理系统称为,数据库管理系统 DBMS database management system 为啥专用系统来管理数据 1无法多人共享 ...
php查询sql2008数据库操作系统,使用 PHP 进行查询 - Azure SQL Database SQL Managed Instance | Microsoft Docs...
您现在访问的是微软AZURE全球版技术文档网站,若需要访问由世纪互联运营的MICROSOFT AZURE中国区技术文档网站,请访问 https://docs.azure.cn. 快速入门:使用 PHP ...

database/sql

介绍

连接数据库

操作数据库

查询

通用查询

单行查询

预编译查询

修改

database/sql相关推荐

最新文章

热门文章