go 连接服务器 并存放图片_基于 Go 语言开发在线论坛(二):通过模型类与MySQL数据库交互...
在这篇教程中,我们将在 MySQL 中创建一个 chitchat
数据库作为论坛项目的数据库,然后在 Go 项目中编写模型类与之进行交互。你可以本地安装 MySQL 数据库,也可以基于 Docker 容器运行(后续会介绍容器化启动方法)。
1、项目初始化
开始之前,我们先来初始化项目目录,我们将项目名设置为 chitchat
,所以在 ~/Development/go/src/github.com/xueyuanjun
目录下创建这个项目目录,然后初始化目录结构如下:
重点看下红框内,各个子目录/文件的作用介绍如下:
main.go
:应用入口文件config.json
:全局配置文件handlers
:用于存放处理器代码(可类比为 MVC 模式中的控制器目录)logs
:用于存放日志文件models
:用于存放与数据库交互的模型类public
:用于存放前端资源文件,比如图片、CSS、JavaScript 等routes
:用于存放路由文件和路由器实现代码views
:用于存放视图模板文件
接下来,我们在 chitchat
目录下运行如下命令初始化 go.mod
,因为我们后续通过 Go Module 来管理依赖:
go mod init github.com/xueyuanjun/chitchat
2、创建数据表
开始正式编码之前,现在 chitchat
数据库中创建数据表,对应的 SQL 语句如下:
create table users ( id serial primary key, uuid varchar(64) not null unique, name varchar(255), email varchar(255) not null unique, password varchar(255) not null, created_at timestamp not null);create table sessions ( id serial primary key, uuid varchar(64) not null unique, email varchar(255), user_id integer references users(id), created_at timestamp not null);create table threads ( id serial primary key, uuid varchar(64) not null unique, topic text, user_id integer references users(id), created_at timestamp not null);create table posts ( id serial primary key, uuid varchar(64) not null unique, body text, user_id integer references users(id), thread_id integer references threads(id), created_at timestamp not null);
在 MySQL 客户端连接到 chitchat
数据库,运行上述 SQL 语句创建所有数据表:
3、与数据库交互
1)数据库驱动
数据表创建完成后,接下来,如何在 Go 应用代码中与数据库交互呢?Go 语言开发组并没有为此提供官方的数据库驱动实现,只是提供了数据库交互接口,我们可以通过实现这些接口的第三方扩展包完成与 MySQL 数据库的交互,本项目选择的扩展包是 go-mysql-driver 。
我们可以在 Go 应用中编写模型类基于这个扩展包提供的方法与 MySQL 交互完成增删改查操作,开始之前,可以运行如下命令安装这个依赖:
go get github.com/go-sql-driver/mysql
2)数据库连接
然后在 chitchat/models
目录下创建 db.go
,并编写数据库连接初始化方法以及生成 UUID、哈希加密方法:
package modelsimport ( "crypto/rand" "crypto/sha1" "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" "log")var Db *sql.DBfunc init() { var err error Db, err = sql.Open("mysql", "root:root@/chitchat?charset=utf8&parseTime=true") if err != nil { log.Fatal(err) } return}// create a random UUID with from RFC 4122// adapted from http://github.com/nu7hatch/gouuidfunc createUUID() (uuid string) { u := new([16]byte) _, err := rand.Read(u[:]) if err != nil { log.Fatalln("Cannot generate UUID", err) } // 0x40 is reserved variant from RFC 4122 u[8] = (u[8] | 0x40) & 0x7F // Set the four most significant bits (bits 12 through 15) of the // time_hi_and_version field to the 4-bit version number. u[6] = (u[6] & 0xF) | (0x4 << 4) uuid = fmt.Sprintf("%x-%x-%x-%x-%x", u[0:4], u[4:6], u[6:8], u[8:10], u[10:]) return}// hash plaintext with SHA-1func Encrypt(plaintext string) (cryptext string) { cryptext = fmt.Sprintf("%x", sha1.Sum([]byte(plaintext))) return}
其中,Db
变量代表数据库连接池,通过 init
方法在 Web 应用启动时自动初始化数据库连接,这样,我们就可以在应用中通过 Db
变量对数据库进行增删改查操作了,这也是该变量首字母大写的原因,方便在 models
包之外被引用,具体的操作实现我们放到独立的模型文件中处理。
注:这里通过 sql.Open 初始化数据库连接,我们写死了数据库连接配置,在实际生产环境,这块配置值应该从配置文件或系统环境变量获取。
3)用户相关模型类
有了代表数据库连接池的 Db
变量之后,就可以为每个数据表编写对应的模型类实现增删改查操作了,首先在 models
目录下创建 user.go
用于定义用户模型类 User
与 users
表进行交互,以及与 sessions
表进行关联:
package modelsimport "time"type User struct { Id int Uuid string Name string Email string Password string CreatedAt time.Time}// Create a new session for an existing userfunc (user *User) CreateSession() (session Session, err error) { statement := "insert into sessions (uuid, email, user_id, created_at) values (?, ?, ?, ?)" stmtin, err := Db.Prepare(statement) if err != nil { return } defer stmtin.Close() uuid := createUUID() stmtin.Exec(uuid, user.Email, user.Id, time.Now()) stmtout, err := Db.Prepare("select id, uuid, email, user_id, created_at from sessions where uuid = ?") if err != nil { return } defer stmtout.Close() // use QueryRow to return a row and scan the returned id into the Session struct err = stmtout.QueryRow(uuid).Scan(&session.Id, &session.Uuid, &session.Email, &session.UserId, &session.CreatedAt) return}// Get the session for an existing userfunc (user *User) Session() (session Session, err error) { session = Session{} err = Db.QueryRow("SELECT id, uuid, email, user_id, created_at FROM sessions WHERE user_id = ?", user.Id). Scan(&session.Id, &session.Uuid, &session.Email, &session.UserId, &session.CreatedAt) return}// Create a new user, save user info into the databasefunc (user *User) Create() (err error) { // Postgres does not automatically return the last insert id, because it would be wrong to assume // you're always using a sequence.You need to use the RETURNING keyword in your insert to get this // information from postgres. statement := "insert into users (uuid, name, email, password, created_at) values (?, ?, ?, ?, ?)" stmtin, err := Db.Prepare(statement) if err != nil { return } defer stmtin.Close() uuid := createUUID() stmtin.Exec(uuid, user.Name, user.Email, Encrypt(user.Password), time.Now()) stmtout, err := Db.Prepare("select id, uuid, created_at from users where uuid = ?") if err != nil { return } defer stmtout.Close() // use QueryRow to return a row and scan the returned id into the User struct err = stmtout.QueryRow(uuid).Scan(&user.Id, &user.Uuid, &user.CreatedAt) return}// Delete user from databasefunc (user *User) Delete() (err error) { statement := "delete from users where id = ?" stmt, err := Db.Prepare(statement) if err != nil { return } defer stmt.Close() _, err = stmt.Exec(user.Id) return}// Update user information in the databasefunc (user *User) Update() (err error) { statement := "update users set name = ?, email = ? where id = ?" stmt, err := Db.Prepare(statement) if err != nil { return } defer stmt.Close() _, err = stmt.Exec(user.Name, user.Email, user.Id) return}// Delete all users from databasefunc UserDeleteAll() (err error) { statement := "delete from users" _, err = Db.Exec(statement) return}// Get all users in the database and returns itfunc Users() (users []User, err error) { rows, err := Db.Query("SELECT id, uuid, name, email, password, created_at FROM users") if err != nil { return } for rows.Next() { user := User{} if err = rows.Scan(&user.Id, &user.Uuid, &user.Name, &user.Email, &user.Password, &user.CreatedAt); err != nil { return } users = append(users, user) } rows.Close() return}// Get a single user given the emailfunc UserByEmail(email string) (user User, err error) { user = User{} err = Db.QueryRow("SELECT id, uuid, name, email, password, created_at FROM users WHERE email = ?", email). Scan(&user.Id, &user.Uuid, &user.Name, &user.Email, &user.Password, &user.CreatedAt) return}// Get a single user given the UUIDfunc UserByUUID(uuid string) (user User, err error) { user = User{} err = Db.QueryRow("SELECT id, uuid, name, email, password, created_at FROM users WHERE uuid = ?", uuid). Scan(&user.Id, &user.Uuid, &user.Name, &user.Email, &user.Password, &user.CreatedAt) return}
创建 session.go
用于定义会话模型类 Session
:
package modelsimport "time"type Session struct { Id int Uuid string Email string UserId int CreatedAt time.Time}// Check if session is valid in the databasefunc (session *Session) Check() (valid bool, err error) { err = Db.QueryRow("SELECT id, uuid, email, user_id, created_at FROM sessions WHERE uuid = ?", session.Uuid). Scan(&session.Id, &session.Uuid, &session.Email, &session.UserId, &session.CreatedAt) if err != nil { valid = false return } if session.Id != 0 { valid = true } return}// Delete session from databasefunc (session *Session) DeleteByUUID() (err error) { statement := "delete from sessions where uuid = ?" stmt, err := Db.Prepare(statement) if err != nil { return } defer stmt.Close() _, err = stmt.Exec(session.Uuid) return}// Get the user from the sessionfunc (session *Session) User() (user User, err error) { user = User{} err = Db.QueryRow("SELECT id, uuid, name, email, created_at FROM users WHERE id = ?", session.UserId). Scan(&user.Id, &user.Uuid, &user.Name, &user.Email, &user.CreatedAt) return}// Delete all sessions from databasefunc SessionDeleteAll() (err error) { statement := "delete from sessions" _, err = Db.Exec(statement) return}
这里面定义了基于 Db
数据库连接实例实现用户模型和会话模型相关的增删改查操作,具体的语法可以参考 go-mysql-driver
的 官方文档,这里不详细展开,具体细节,我们留到后面专门介绍数据库模块时再详细说明。
4)主题相关模型类
编写好用户相关模型类后,接下来在同级目录下创建 thread.go
,定义群组模型类 Thread
与 threads
表进行交互:
package modelsimport "time"type Thread struct { Id int Uuid string Topic string UserId int CreatedAt time.Time}// format the CreatedAt date to display nicely on the screenfunc (thread *Thread) CreatedAtDate() string { return thread.CreatedAt.Format("Jan 2, 2006 at 3:04pm")}// get the number of posts in a threadfunc (thread *Thread) NumReplies() (count int) { rows, err := Db.Query("SELECT count(*) FROM posts where thread_id = ?", thread.Id) if err != nil { return } for rows.Next() { if err = rows.Scan(&count); err != nil { return } } rows.Close() return}// get posts to a threadfunc (thread *Thread) Posts() (posts []Post, err error) { rows, err := Db.Query("SELECT id, uuid, body, user_id, thread_id, created_at FROM posts where thread_id = ?", thread.Id) if err != nil { return } for rows.Next() { post := Post{} if err = rows.Scan(&post.Id, &post.Uuid, &post.Body, &post.UserId, &post.ThreadId, &post.CreatedAt); err != nil { return } posts = append(posts, post) } rows.Close() return}// Get all threads in the database and returns itfunc Threads() (threads []Thread, err error) { rows, err := Db.Query("SELECT id, uuid, topic, user_id, created_at FROM threads ORDER BY created_at DESC") if err != nil { return } for rows.Next() { conv := Thread{} if err = rows.Scan(&conv.Id, &conv.Uuid, &conv.Topic, &conv.UserId, &conv.CreatedAt); err != nil { return } threads = append(threads, conv) } rows.Close() return}// Get a thread by the UUIDfunc ThreadByUUID(uuid string) (conv Thread, err error) { conv = Thread{} err = Db.QueryRow("SELECT id, uuid, topic, user_id, created_at FROM threads WHERE uuid = ?", uuid). Scan(&conv.Id, &conv.Uuid, &conv.Topic, &conv.UserId, &conv.CreatedAt) return}// Get the user who started this threadfunc (thread *Thread) User() (user User) { user = User{} Db.QueryRow("SELECT id, uuid, name, email, created_at FROM users WHERE id = ?", thread.UserId). Scan(&user.Id, &user.Uuid, &user.Name, &user.Email, &user.CreatedAt) return}
以及 post.go
编写主题模型类与 posts
表进行交互:
package modelsimport "time"type Post struct { Id int Uuid string Body string UserId int ThreadId int CreatedAt time.Time}func (post *Post) CreatedAtDate() string { return post.CreatedAt.Format("Jan 2, 2006 at 3:04pm")}// Get the user who wrote the postfunc (post *Post) User() (user User) { user = User{} Db.QueryRow("SELECT id, uuid, name, email, created_at FROM users WHERE id = ?", post.UserId). Scan(&user.Id, &user.Uuid, &user.Name, &user.Email, &user.CreatedAt) return}
此外,我们到 user.go
中为 User
模型新增如下两个方法与 Thread
、Post
模型进行关联,用于创建新的群组和主题:
// Create a new threadfunc (user *User) CreateThread(topic string) (conv Thread, err error) { statement := "insert into threads (uuid, topic, user_id, created_at) values (?, ?, ?, ?)" stmtin, err := Db.Prepare(statement) if err != nil { return } defer stmtin.Close() uuid := createUUID() stmtin.Exec(uuid, topic, user.Id, time.Now()) stmtout, err := Db.Prepare("select id, uuid, topic, user_id, created_at from threads where uuid = ?") if err != nil { return } defer stmtout.Close() // use QueryRow to return a row and scan the returned id into the Session struct err = stmtout.QueryRow(uuid).Scan(&conv.Id, &conv.Uuid, &conv.Topic, &conv.UserId, &conv.CreatedAt) return}// Create a new post to a threadfunc (user *User) CreatePost(conv Thread, body string) (post Post, err error) { statement := "insert into posts (uuid, body, user_id, thread_id, created_at) values (?, ?, ?, ?, ?)" stmtin, err := Db.Prepare(statement) if err != nil { return } defer stmtin.Close() uuid := createUUID() stmtin.Exec(uuid, body, user.Id, conv.Id, time.Now()) stmtout, err := Db.Prepare("select id, uuid, body, user_id, thread_id, created_at from posts where uuid = ?") if err != nil { return } defer stmtout.Close() // use QueryRow to return a row and scan the returned id into the Session struct err = stmtout.QueryRow(uuid).Scan(&post.Id, &post.Uuid, &post.Body, &post.UserId, &post.ThreadId, &post.CreatedAt) return}
4、小结
在上述编写的模型类中,模型类与数据表是如何映射的呢?这个由 go-mysql-driver
底层实现,每次从数据库查询到结果之后,可以通过 Scan
方法将数据表字段值映射到对应的结构体模型类,而将模型类保存到数据库时,又可以基于字段映射关系将结构体属性值转化为对应的数据表字段值。对应的底层交互逻辑如下所示:
再次重申,本项目旨在帮助大家快速熟悉 Go Web 项目的完整开发流程和代码组织架构,具体的技术实现细节留到后面单独的数据库模块详细介绍,不过,如果你之前有过其他语言的 Web 开发经验,比如 PHP、Python、Java,基本上看一眼这些代码就能知道个大概了,因为他们的实现思路都是相通的,无非是语言的语法不同而已,所以这也是学院君反复强调新人应该花个三五年时间先精通一门语言,再学习其他语言的原因。
底层数据库交互逻辑定义好了之后,接下来,我们就可以编写上层实现代码了,下一篇学院君将给大家演示在线论坛项目上层路由和处理器方法的实现。
推荐阅读
基于 Go 语言编写在线论坛(一):整体设计与数据模型
喜欢本文的朋友,欢迎关注“Go语言中文网”:
Go语言中文网启用微信学习交流群,欢迎加微信:274768166,投稿亦欢迎
go 连接服务器 并存放图片_基于 Go 语言开发在线论坛(二):通过模型类与MySQL数据库交互...相关推荐
- go语言打印日期_基于 Go 语言开发在线论坛(八):消息、视图及日期时间本地化...
我们接着上篇在线论坛的进度,由于之前所有页面和消息文本都是英文的,而我们开发的应用基本都是面向中文用户的,所以需要对项目进行本地化,今天正好借着这个入门项目给大家介绍下如何在 Go Web 应用中进行 ...
- 与mysql数据库的交互实战_基于 Go 语言开发在线论坛(二):通过模型类与MySQL数据库交互...
在这篇教程中,我们将在 MySQL 中创建一个 chitchat 数据库作为论坛项目的数据库,然后在 Go 项目中编写模型类与之进行交互.你可以本地安装 MySQL 数据库,也可以基于 Docker ...
- java 计算移动平均线_基于Java语言开发的个性化股票分析技术:移动平均线(MA)...
基于Java语言开发的个性化股票分析技术:移动平均线(MA) 基于 Java 语言开发的个性化股票分析技术:移动平均线(MA)移动平均线(MA)是以道·琼斯的"平均成本概念"为理论 ...
- java写的股票技术分析_基于Java语言开发的个性化股票分析技术:量能突破模型(Energe-Break)...
基于Java语言开发的个性化股票分析技术: 量能突破模型(Energe-Break) 一个用量能指标作为判定依据的条件分析模型,根据最近5天内是否有量能平台的突破以及涨跌幅的大小给每只股票评分评价,给 ...
- c语言.jpg图片转成数组_基于 C 语言开发的 GUI 框架
一.介绍 AWTK全称Toolkit AnyWhere,是ZLG开发的开源GUI引擎,旨在为嵌入式系统.WEB.各种小程序.手机和PC打造的通用GUI引擎,为用户提供一个功能强大.高效可靠.简单易用. ...
- gui窗口遮挡算法_基于 C 语言开发的 GUI 框架
一.介绍 AWTK全称Toolkit AnyWhere,是ZLG开发的开源GUI引擎,旨在为嵌入式系统.WEB.各种小程序.手机和PC打造的通用GUI引擎,为用户提供一个功能强大.高效可靠.简单易用. ...
- go 连接服务器 并存放图片_Go 在马蜂窝即时通讯服务建设中的实践
即时通讯(IM)功能对于电商平台来说非常重要,特别是旅游电商. 从商品复杂性来看,一个旅游商品可能会包括用户在未来一段时间的衣.食.住.行等方方面面:从消费金额来看,往往单次消费额度较大:对目的地的陌 ...
- c语言编写订货系统,学位论文_基于c语言的仓库订货系统的仿真.doc
学位论文_基于c语言的仓库订货系统的仿真 本科毕业论文(设计.创作) 题目: 基于C语言的仓库订货系统的仿真 学生姓名: 学号: 所在系院: 信息与通信技术系 专业: 电子信息工程 入学时间: 201 ...
- Arduino开发(二)_基于Arduino UNO开发板的RGB灯光控制方法
Arduino开发(二)_基于Arduino UNO开发板的RGB灯光控制方法 首先,我们来看一下Arduino UNO开发板的具体引脚排列,如下图所示, 再了解一下三色RGB LED模块,如下图所示 ...
最新文章
- 剑指offer-丑数
- 基于Python的完全监督机器学习教程 Complete Supervised Machine Learning With Python
- spring boot 搭建 和 全局异常处理
- 正则表达式教程手册、正则一点通(Chinar出品)
- 同一肢体不同关节的运动想象过程中的多通道脑电图记录
- HighNewTech:重磅!来自深度学习的三位大牛Yoshua、Hinton、LeCun荣获2018年图灵奖
- string类的基本实现
- javascript通用验证
- DataGrid 功能实现收集(转)保留做参考
- Java笔记-EasyCaptcha在前后端分离项目的使用
- ThinkPHP V5.0 正式版发布
- Ctrl+F5为强制刷新
- 细胞分裂模拟(C++)
- 三.求导四则运算及三角函数导数
- 操作系统课设详细解答
- 新马華人的姓名大多用方言拼音,所以显得很混乱
- 在CentOs7上部署Gunicorn
- flashback全库和pdb
- linux pam 解锁_linux pam锁定用户
- Java打飞机小游戏
热门文章
- (转)Windows系统、Linux系统 和 Mac OS操作系统 历史由来 与 区别?
- equals null报错吗_轻轻松松教你搞定Java中的==和equals
- python装饰器用法_深入浅出分析Python装饰器用法
- hog函数的用法 python_Python常见内置函数用法(三)
- VS2013报错:错误:没有与这些操作匹配的《运算符
- python的print函数输出带颜色字体
- Socket编程应用——开发聊天软件
- Retrofit与RXJava整合
- 使用C与C++混合编程封装UDP协议
- Python搭建web服务器