脚本之家，脚本语言编程技术及教程分享平台！
分类导航

Python|VBS|Ruby|Lua|perl|VBA|Golang|PowerShell|Erlang|autoit|Dos|bat|

服务器之家 - 脚本之家 - Golang - golang MySQL实现对数据库表存储获取操作示例

golang MySQL实现对数据库表存储获取操作示例

2022-11-07 11:29小能正在往前冲 Golang

这篇文章主要为大家介绍了golang MySQL实现对数据库表存储获取操作示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪

新建数据库

 将部分数据存储至Mysql，使用axios通过golang搭建的http服务器获取数据。

sql

?
1
2
3
DROP DATABASE VUE;
create database if not exists vue;
use vue;

JSON to MySQL (transform.tools)

sql

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
DROP DATABASE VUE;
create database if not exists vue;
use vue;
CREATE TABLE gameblog (
  id INT PRIMARY KEY AUTO_INCREMENT,
  title VARCHAR(255),
  text VARCHAR(255),
  img VARCHAR(255)
);
insert into gameblog(title,text,img) values
("Games of the Month: surrealist solitaire puzzles","What's that? You need more games? I hear you, anonymous hapi fan.We've reached the part of the year when games start coming out fast","https://xiaonenglife.oss-cn-hangzhou.aliyuncs.com/static/pic/2022/11/20221102184434_1.jpg"),
("Games of the Month: Puzzles!","Sometimes you need a good puzzle game, just something to throw all of your attention at and ignore anything else going on. Well if that sometime for you is right now, then you're in luck because in this Games of the Month","https://xiaonenglife.oss-cn-hangzhou.aliyuncs.com/static/pic/2022/11/20221102184434_2.jpg"),
("The next hapi Creator Day is July 29th!","I don't think I'm allowed to make the entire body of this post “Thenext itch.io Creator Day is taking place on Friday July 29th.” I mean it's true, we are hosting the next itch.io Creator Day on Friday July 29th but I should probably write more here.","https://xiaonenglife.oss-cn-hangzhou.aliyuncs.com/static/pic/2022/11/20221102184434_3.jpg");
select * from gameblog;
CREATE TABLE game (
  id INT PRIMARY KEY AUTO_INCREMENT,
  title VARCHAR(255),
  text VARCHAR(255),
  img VARCHAR(255),
  price decimal(6,2) default 0,
  web boolean default 0
  # TODO 发布时间
  # TODO 浏览量
  # TODO 评论量
  # TODO 热度综合指标
);
CREATE TABLE tag (
  id INT PRIMARY KEY AUTO_INCREMENT,
  title VARCHAR(255)
);
CREATE TABLE gametag (
  gameid INT,
  tagid INT
);
# TODO 外键
insert into game(id,title,text,img,price,web) values
(1,"Late Night Mop","A haunted house cleaning simulator.","https://xiaonenglife.oss-cn-hangzhou.aliyuncs.com/static/pic/2022/11/20221102193135_1.png",0,0),
(2,"an average day at the cat cafe","A haunted house cleaning simulator.","https://xiaonenglife.oss-cn-hangzhou.aliyuncs.com/static/pic/2022/11/20221102193135_2.png",0,1),
(3,"Corebreaker","A fast-paced action-platform shooter game with roguelike elements.","https://xiaonenglife.oss-cn-hangzhou.aliyuncs.com/static/pic/2022/11/20221102193135_3.png",19.99,0),
(4,"Atuel","Traverse a surrealist landscape inspired by the Atuel River in Argentina.","https://xiaonenglife.oss-cn-hangzhou.aliyuncs.com/static/pic/2022/11/20221102193135_5.png",0,0);
insert into tag values
(1,"Difficult"),
(2,"Fast-Paced");
insert into gametag values
(3,1),
(3,2),
(4,1);
DELIMITER $$
CREATE PROCEDURE gamelist()
BEGIN
    # TODO
END $$
DELIMITER ;
select a.title,a.text,img,price,web,if(group_concat(c.title separator "#") is null ,"", group_concat(c.title separator "#")) as tag from game a left join gametag b on a.id = b.gameid left join tag c on b.tagid = c.id group by a.id;

本地图片上传OSS图床得到静态资源的持久地址，我使用的是PicGo图床工具。

golang MySQL实现对数据库表存储获取操作示例

SQL TO GOLANG STRUCT

在线sql转golang struct

config.go

为了方便mysql服务器的配置，写一个配置文件。

golang

?
1
2
3
4
5
6
7
8
9
10
package mysql_vue
import "database/sql"
func GetMySQLDB() (db *sql.DB, err error) {
    dbDriver := "mysql"
    dbUser := "root"
    dbPass := "sql2008"
    dbName := "vue"
    db, err = sql.Open(dbDriver, dbUser+":"+dbPass+"@/"+dbName)
    return
}

gameblog.go

id暂时不需要，后期路由跳转需要用到，可以先注释。

go

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
package mysql_vue
import (
    "encoding/json"
    _ "github.com/go-sql-driver/mysql"
)
type Gameblog struct {
    // ID int64 `db:"id" json:"id"`
    Title string `db:"title" json:"title"`
    Text  string `db:"text" json:"text"`
    Img   string `db:"img" json:"img"`
}
func (Gameblog) TableName() string {
    return "gameblog"
}
func (Gameblog) QueryGameblog() (json_ []byte, err error) {
    // db, err := sql.Open("mysql", "root:sql2008@tcp(127.0.0.1:3306)/vue")
    db, err := GetMySQLDB()
    checkError(err)
    defer db.Close()
    // ^ 必须按照顺序选取,下面的Scan需要一一对应,如果多了或少了字段会导致Scan错误.
    results, err := db.Query("SELECT title,text,img FROM gameblog order by id desc")
    checkError(err)
    var gameBlogs []Gameblog
    for results.Next() {
        var gameBlog Gameblog
        err = results.Scan(&gameBlog.Title, &gameBlog.Text, &gameBlog.Img)
        checkError(err)
        gameBlogs = append(gameBlogs, gameBlog)
    }
    json_, err = json.Marshal(gameBlogs)
    checkError(err)
    return json_, nil
}

http

Simplify server.go

前面我们把评论相关的请求处理代码写在了 server.go，移出到 comment.go，并在init初始化中绑定各个请求路径处理函数。

comment.go

go

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
package server
import (
    "fmt"
    "net/http"
    "strconv"
)
type Comment interface {
    QueryComment(pid int64) (json_ []byte, err error)
    InsertComment(uid, pid int64, text string) (json_ []byte, err error)
    DeleteComment(id int64) error
}
func init() {
    http.HandleFunc("/insertComment", insertComment)
    http.HandleFunc("/deleteComment", deleteComment)
    http.HandleFunc("/queryComment", queryComment)
}
func insertComment(w http.ResponseWriter, r *http.Request) {
    ....
}
func deleteComment(w http.ResponseWriter, r *http.Request) {
    ....
}
func queryComment(w http.ResponseWriter, r *http.Request) {
    ....
}

gameblog.go

接口用于确保某个数据库对象实现了处理函数，否则编译不通过。

go

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
package server
import (
    "fmt"
    "net/http"
)
type Gameblog interface {
    QueryGameblog() (json_ []byte, err error)
}
func init() {
    http.HandleFunc("/queryGameblog", QueryGameblog)
}
func QueryGameblog(w http.ResponseWriter, r *http.Request) {
    if r.Method != "GET" {
        fmt.Fprintf(w, "Only GET Method")
        return
    }
    json, err := gameblog.QueryGameblog()
    if err != nil {
        fmt.Fprintf(w, "Error Delete")
        return
    }
    fmt.Fprint(w, string(json))
}

server.go

go

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
package server
import (
    "log"
    "net/http"
    mysql_vue "wolflong.com/vue_http/lib/mysql"
    sq3_vue "wolflong.com/vue_http/lib/sqlite"
)
var comment Comment = sq3_vue.Comment{}
var gameblog Gameblog = mysql_vue.Gameblog{}
func StartServer() {
    err := http.ListenAndServe(":1314", nil)
    if err != nil {
        log.Fatal("ListenAndServe: ", err)
    }
}

postman test api

使用 postman 测试当前接口。

golang MySQL实现对数据库表存储获取操作示例

Axios

修改 HomeView.vue 的选项卡api，在 created 钩子函数添加axios请求访问。

js

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
created() {
    this.axios
      .get("queryGameblog")
      .then((response) => {
        if (!response.data) {
          this.gameBlog = [];
          return;
        }
        this.gameBlog = response.data;
      })
      .catch((err) => {
        console.log(err);
      });
  },

golang MySQL实现对数据库表存储获取操作示例

gamelist.go

查询语句使用两次左连接，并用 group_concat 聚合函数，聚合 tag，分解tag的过程可以从服务端迁移到客户端进行降低性能消耗。

go

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
package mysql_vue
import (
    "encoding/json"
    "strings"
)
type Gamelist struct {
    // ID    int64    `db:"id" json:"id"`
    Title string   `db:"title" json:"title"`
    Text  string   `db:"text" json:"text"`
    Img   string   `db:"img" json:"img"`
    Price float64  `db:"price" json:"price"`
    Tag   []string `db:"tag" json:"tag"` // 新添加
    Web   bool     `db:"Web" json:"web"`
}
// type Tag struct {
//  ID    int64  `db:"id" json:"id"`
//  Title string `db:"title" json:"title"`
// }
func (Gamelist) QueryGamelist() (json_ []byte, err error) {
    db, err := GetMySQLDB()
    checkError(err)
    defer db.Close()
    results, err := db.Query(`select a.title,a.text,img,price,web,if(group_concat(c.title separator "#") is null ,"", group_concat(c.title separator "#")) as tag from game a left join gametag b on a.id = b.gameid left join tag c on b.tagid = c.id group by a.id;`)
    checkError(err)
    var GameList []Gamelist
    for results.Next() {
        var g Gamelist
        var tag string
        err = results.Scan(&g.Title, &g.Text, &g.Img, &g.Price, &g.Web, &tag)
        g.Tag = strings.Split(tag, "#") // 这里暂且由服务端完成分解
        checkError(err)
        GameList = append(GameList, g)
    }
    json_, err = json.Marshal(GameList)
    checkError(err)
    return json_, nil
}

HTTP

gamelist.go

go

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
package server
import (
    "fmt"
    "net/http"
)
type Gamelist interface {
    QueryGamelist() (json_ []byte, err error)
}
func init() {
    http.HandleFunc("/queryGamelist", QueryGamelist)
}
func QueryGamelist(w http.ResponseWriter, r *http.Request) {
    if r.Method != "GET" {
        fmt.Fprintf(w, "Only GET Method")
        return
    }
    json, err := gamelist.QueryGamelist()
    if err != nil {
        fmt.Fprintf(w, "Error Delete")
        return
    }
    fmt.Fprint(w, string(json))
}

server.go

添加语句 var gamelist Gamelist = mysql_vue.Gamelist{}

golang MySQL实现对数据库表存储获取操作示例

Axios

js

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
this.axios
  .get("queryGamelist")
  .then((response) => {
    if (!response.data) {
      this.latestGames.games = [];
      this.mostFeatureGames.games = [];
      return;
    }
    this.latestGames.games = response.data;
    this.mostFeatureGames.games = response.data;
  })
  .catch((err) => {
    console.log(err);
  });

golang MySQL实现对数据库表存储获取操作示例

以上就是golang MySQL实现对数据库表存储获取操作示例的详细内容，更多关于golang MySQL表存储获取的资料请关注服务器之家其它相关文章！

原文链接：https://www.cnblogs.com/linxiaoxu/p/16852367.html

  • mysql
  • 存储
  • golang
  • 数据库表

    • 延伸 · 阅读

    精彩推荐
    • GolangGo语言实现简单留言板的方法

      Go语言实现简单留言板的方法

      这篇文章主要介绍了Go语言实现简单留言板的方法,涉及数据库、模板页面元素等留言板相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下 ...

      不吃皮蛋6162020-04-15
    • Golang解决vscode中golang插件依赖安装失败问题

      解决vscode中golang插件依赖安装失败问题

      这篇文章主要介绍了解决vscode中golang插件依赖安装失败问题,本文给大家介绍的非常详细，具有一定的参考借鉴价值，需要的朋友可以参考下 ...

      feiquan13452020-05-27
    • Golang通过Golang编写一个AES加密解密工具

      通过Golang编写一个AES加密解密工具

      这篇文章主要为大家详细介绍了如何利用Golang制作一个AES加密解密工具，文中的示例代码讲解详细，感兴趣的小伙伴可以跟随小编一起学习一下...

      iqsing8112022-10-07
    • Golanggolang中命令行库cobra的使用方法示例

      golang中命令行库cobra的使用方法示例

      这篇文章主要给大家介绍了关于golang中命令行库cobra的使用方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需...

      wangbin5182020-05-18
    • GolangGolang项目搭配nginx部署反向代理负载均衡讲解

      Golang项目搭配nginx部署反向代理负载均衡讲解

      这篇文章主要为大家介绍了Golang项目搭配nginx部署正反向代理负载均衡讲解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步早日升职...

      Jeff的技术栈3562022-09-22
    • Golang浅析goland等待锁问题

      浅析goland等待锁问题

      这篇文章主要介绍了goland等待锁问题，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友参考下吧...

      Skyego9582021-02-01
    • GolangGolang记录、计算函数执行耗时、运行时间的一个简单方法

      Golang记录、计算函数执行耗时、运行时间的一个简单方法

      这篇文章主要介绍了Golang记录、计算函数执行耗时、运行时间的一个简单方法,本文直接给出代码实例,需要的朋友可以参考下 ...

      脚本之家11852020-04-26
    • Golanggolang实现数组分割的示例代码

      golang实现数组分割的示例代码

      本文主要介绍了golang实现数组分割的示例代码，要求把数组分割成多个正整数大小的数组，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴...

      _little_stone10892022-01-26
    最近更新
    编辑推荐
    阅读排行
    热门标签
    tidy 　 指针类型 　 new() 　 make() 　 并发模型 　 切片 　 静态WEB服务器 　 端口扫描器 　 Go语言入门教程 　 基础语 　 Slices 　 Maps 　 Golang编程 　 panic 　 接受者类型 　 嵌入类型 　 Slice 　 Golang教程 　 Golang项目 　 内存模型 　 开发环境搭建 　 大小端判断 　 代码组织结构 　 复合类型 　 GOPATH 　 工作目录 　 实例 　 struct类型 　 并发技术 　 buffered 　
    © 2019-2022 脚本之家 | 服务器之家(www.tuohang.net)旗下站点 版权所有关于我们联系我们版权申明网站地图