Go Web编程--应用数据库

全自动废纸液压打包机 · · 1127 次点击 · · 开始浏览    

今天我们继续接着前几篇关于Go Web编程的文章往下延伸。在Web应用程序中几乎每个应用场景都需要存储和检索数据库中的数据。当你处理动态内容,为用户提供表单以输入数据或存储登录名和密码凭据以供用户进行身份验证时,都需要用到数据库。 MySQL数据库是整个互联网中最常用的数据库。MySQL已经存在了很长时间,还在不停的进化并且随着互联网一起发展已多次证明了其位置和稳定性。

本文我们将探究Go中数据库访问的基础知识,在开始之前我们先更新一下我们使用的开发环境,之前在文章用Docker快速搭建Go开发环境中我们只应用了一个运行 go的容器,现在我们为开发环境加上数据库。

关注文末公众号,回复gohttp04获取容器编排文件和文章中用到的源代码。

在开发环境中增加MySQL容器

打开我们之前编写的docker-compose.yml文件,添加如下配置:

version:'3'services:......# The Database  database:    image:mysql:5.7    volumes:      - dbdata:/var/lib/mysql    environment:      -"MYSQL_DATABASE=go_web"      -"MYSQL_USER=go_web"      -"MYSQL_PASSWORD=go_web"      -"MYSQL_ROOT_PASSWORD=secret"    ports:      -"33063:3306"volumes:  dbdata:复制代码

因为容器退出时会销毁容器内的所有文件,所以对于MySQL这种存储持久化数据的容器需要与外部宿主机做文件映射,这样再次启动MySQL容器后就会从数据映射中读取之前的数据。

在编排文件的中我们通过volumes命令创建了一个名为dbdata的数据卷(dbdata后面的冒号是有意写上去的,这是 YML 文件的一个语法限制,不用太关心)

定义完数据卷后,在上面我们使用dbdata:/var/lib/mysql的格式,通知 Docker,将dbdata数据卷挂在到容器中的/var/lib/mysql目录上。

environments中设置的是MySQL容器需要的四个必要参数。

ports端口映射中,我们将本地电脑的33063端口映射到容器的3306端口,这样我们就能通过电脑上的数据库工具连接到 容器内的MySQL了。

添加完MySQL后完整的编排文件就变成:

version:'3'services:# The Application  app:    image:golang:latest    working_dir:/go/src/example.com/http_demo    volumes:      -/$GOPATH/src/example.com/http_demo:/go/src/code.qschou.com/http_demo      -/$GOPATH/src:/go/src    ports:      -"8000:8080"    environment:      WORKING_DIR:/go/src/e.qschou.com/practice/http_demo    command:gorun/go/src/example.com/http_demo/main.go# The Database  database:    image:mysql:5.7    volumes:      - dbdata:/var/lib/mysql    environment:      -"MYSQL_DATABASE=go_web"      -"MYSQL_USER=go_web"      -"MYSQL_PASSWORD=go_web"      -"MYSQL_ROOT_PASSWORD=secret"    ports:      -"33063:3306"volumes:  dbdata:复制代码

可以公众号内发送gohttp04获取Docker编排文件和文章中用到的源代码。

安装go-sql-driver/mysql包

Go语言标准库中database / sql包,用于查询各种SQL数据库。它将所有通用SQL功能抽象到一个API中供开发者使用。 但是Go的标准库中不包括数据库驱动程序。数据库驱动程序由特定软件包提供的,用于实现特定数据库底层的封装。这对于向前兼容很有用,也使得Go不会变的臃肿。因为在创建所有Go软件包时,开发人员无法预见未来会有什么数据库会被投入使用,而且要支持每个可能的数据库将需要进行大量维护工作。

使用下面命令安装MySQL驱动包:

go get -u github.com/go-sql-driver/mysql复制代码

连接MySQL数据库

要检查我们是否可以连接到数据库,我们需要导入database/sql和go-sql-driver/mysql两个包,并连接数据库:

import("database/sql"_"github.com/go-sql-driver/mysql""log")funcMysqlDemoCode(){db, err := sql.Open("mysql","go_web:go_web@tcp(127.0.0.1:3306)/go_web")iferr !=nil{log.Fatal(err)}deferdb.Close()iferr := db.Ping(); err !=nil{log.Fatal(err)}}复制代码

你的代码应仅引用在database/sql中定义的类型和函数。这有助于避免使代码依赖于特定驱动程序,从而使你可以通过最少的代码更改来更改使用的数据库驱动(相应也会更改使用的数据库类型)。

代码中对驱动包使用匿名包导入,将go-sql-driver/mysql的包别名设置为_,这样驱动程序导出的名称对我们的代码都是不可见的,但是在幕后go-sql-driver/mysql将自身注册为可用于database/sql的驱动包。一般而言,除了运行包的init函数外,不会发生任何其他事情。

sql.Open()不会建立与数据库的任何连接,也不会验证驱动程序的连接参数。它只是返回抽象数据库的对象以供后面使用。数据库连接在真正需要访问数据库的时候才会建立。

我们可以通过单元测试验证数据库是否能正确连接上,测试代码我就不贴了,可以通过文章的源码包里看到,唯一提醒一点,如果在本地机器里运行测试需要把上面sql.Open()配置的端口改为33063

创建表

我们接下来创建一个像这样的表:

idusernamepasswordcreated_at

1Joshuasecret2020-02-13 12:30:00

使用database/sql包执行建表语句就可以在我们的MySQL数据库中创建表:

query :=`

  CREATE TABLE users (

      id INT AUTO_INCREMENT,

      username TEXT NOT NULL,

      password TEXT NOT NULL,

      created_at DATETIME,

      PRIMARY KEY (id)

  );`// 执行后一定要检查err_, err := db.Exec(query)复制代码

插入新数据

默认情况下,Go使用准备好的语句(prepare)将动态数据插入到我们的SQL语句中,这是一种将用户提供的数据安全地传递到我们的数据库而不会造成任何损坏的方式。在Web编程的早期,程序员将数据和查询直接传递给数据库,这导致了巨大的漏洞,并可能破坏整个Web应用程序。

要将我们的第一个用户插入数据库表,我们将创建一个如下的SQL查询。语句中的问号告诉SQL驱动程序,它们是实际数据的占位符。下面你可以看到我们讨论的准备好的语句:

username :="johndoe"password :="secret"createdAt := time.Now()result, err := db.Exec(`INSERT INTO users (username, password, created_at) VALUES (?, ?, ?)`, username, password, createdAt)复制代码

结果包含最后插入的ID(自增ID)的信息以及此查询影响的行数。

// 获取新插入数据库的用户IDuserID, err := result.LastInsertId()复制代码

查询表数据

现在我们的表中有一个用户,我们想要查询它并获取其所有信息。使用database/sql包我们有两种查询表的方式。db.Query可以查询多行,以便我们进行迭代;db.QueryRow查询特定的行。

查询单行

我们首先声明一些变量来存储数据,然后查询单个数据库行:

var(    idintusernamestringpasswordstringcreatedAt time.Time)query :=`SELECT id, username, password, created_at FROM users WHERE id = ?`err := db.QueryRow(query,1).Scan(&id, &username, &password, &createdAt)复制代码

查询多行

上面我们演示了如何查询单个用户行, 接下来演示下如何查询多个数据行并将数据存储到结构体切片中:

typeuserstruct{    idintusernamestringpasswordstringcreatedAt time.Time}rows, err := db.Query(`SELECT id, username, password, created_at FROM users`)//检查错误deferrows.Close()varusers []userforrows.Next() {varu user    err := rows.Scan(&u.id, &u.username, &u.password, &u.createdAt)    users =append(users, u)}err := rows.Err()//检查错误复制代码

篇幅原因代码中所有的错误检查都被故意忽略了,在实际使用中一定要记得做错误检查。

users切片中存储的数据类似这样:

users {    user {        id:1,        username:"Joshua",        password:"secret",        createdAt: time.Time{wall:0x0, ext:63701044325, loc: (*time.Location)(nil)},    },    user {        id:2,        username:"alice",        password:"bob",        createdAt: time.Time{wall:0x0, ext:63701044622, loc: (*time.Location)(nil)},    },}复制代码

删除表数据

从我们的表中删除数据同创建表和插入数据一样也是使用.Exec:

result, err := db.Exec(`DELETE FROM users WHERE id = ?`,1)// 记得检查错误复制代码

后续

database/sql提供的MySQL查询功能还是很全面的使用的更多介绍可以参考http://go-database-sql.org/index.html,不过它是一个相对偏底层的库。实际开发中往往会使用一些在它的基础上封装的ORM库。ORM的查询使用起来更简单些,语法表达力更强也更方便于代码管理。所以今天的文章主要是对database/sql做一下简单介绍,入门即可,后续关于ORM库的使用时再介绍更多查询的使用方法。另外也在我们的Docker环境中增加了MySQL容器,大家也不要忘记更新。更新地址:https://www.jianshu.com/u/cd0205a5dcf4

本文来自:简书

感谢作者:全自动废纸液压打包机

查看原文:Go Web编程--应用数据库

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:muxilin131420 备注:入群;或加QQ群:977810755

1127 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传