从零开发区块链应用 (三)--mysql 初始化及 gorm 框架使用

2022 年 1 月 18 日
本文字数：2339 字
阅读完需：约 8 分钟

一、mysql 初始化

1.1 导入依赖包

import (  "database/sql"  _ "github.com/go-sql-driver/mysql"  "github.com/moba/moba/config"  "github.com/moba/moba/pkg/go-logger"  "time")

复制代码

1.2 连接数据库

var err error// 创建连接池//DB, err = sql.Open("mysql", config.Conf.Mysql.SourceName)user := config.Conf.Mysql.Userpassword := config.Conf.Mysql.Passwordhost := config.Conf.Mysql.Hostport := config.Conf.Mysql.Portdatabase := config.Conf.Mysql.DatabaseDB, err = sql.Open("mysql", user+":"+password+"@tcp("+host+":"+port+")/"+database+"?parseTime=true&charset=utf8&loc=Local")if err != nil {  logger.Error(err.Error())}

复制代码

1.3 设置连接数

DB.SetMaxIdleConns(20)DB.SetMaxOpenConns(20)DB.SetConnMaxLifetime(time.Minute * 10)

复制代码

1.4 测试数据库是否可以连接成功

err = DB.Ping()if err != nil {  logger.Error("MySQL connection failed.", "err", err.Error())} else {  logger.Info("MySQL connection successful!")}

复制代码

二、gorm 框架使用

Gorm 是 golang 的一个 orm 框架，它提供了对数据库操作的封装，使用起来相当便利。所以如果对 mysql 使用操作不熟悉，建议也可以使用 gorm 框架操作 mysql 数据库。

2.1 gorm 库安装

go get -u gorm.io/gormgo get -u gorm.io/driver/sqlite

复制代码

2.2 数据库连接

//数据库连接var err error
dsn := "root:AXCyDF5jV4FWcAJyV4FN@tcp(IP地址:port)/nft?charset=utf8&parseTime=True&loc=Local"db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{  NamingStrategy: schema.NamingStrategy{    SingularTable: true,  //使用单数表名，启用该选项后，`User` 表将是`user`  },  //Logger: logger.Default.LogMode(logger.Silent), //打印详细日志，可在代码测试时关闭，打开后为静默输出})

复制代码

连接比较简单，直接调用 gorm.Open 传入数据库地址即可。gorm 支持基本上所有主流的关系数据库，只是连接方式上略有不同，这里使用 mysql 为例

2.3 表数据插入

表结构体定义

type Banner struct {  ID         int       `gorm:"primary_key"`  ImageUrl   string    `gorm:"type:varchar(255);"`  JumpUrl    string    `gorm:"type:varchar(255);"`  Order      int       `gorm:"int(10)"`  Status     int       `gorm:"type:tinyint(1);"`  CreateTime time.Time `gorm:"type:datetime;"`  UpdateTime time.Time `gorm:"type:datetime;"`}

复制代码

表数据插入

  banner := Banner{    ImageUrl:   "http://imageurl.lijie.com",    JumpUrl:    "http://jumpurl.lijie.com",    Order:      1,    Status:     1,    CreateTime: time.Now(),    UpdateTime: time.Now(),  }  db.Table("banner").Create(&banner) // 通过数据的指针来创建

复制代码

构造已给对象，直接调用 db.Create() 就可以插入一条记录。不用拼接 sql 语句，可以说非常方便了。

2.4 表数据查询

根据主键 ID 进行查询

var banner Bannerdb.Table("banner").First(&banner, 1)fmt.Println(banner)

复制代码

获取所有数据

var array []Bannerdb.Table("banner").Find(&array)fmt.Println(array)

复制代码

注：Find 查询结果是列表，First 查询的是单条数据。Find 方法与 First 的逻辑很像，First 增加了一个 Limit(1)，而 Find 没有

获取一条数据

var array []Bannerdb.Table("banner").Limit(1).Find(&array)fmt.Println(array)

复制代码

获取多个条件的并集

var array []Bannerdb.Table("banner").Where("id = ?", "1").Or(db.Where("id = ?", "2"),).Find(&array)fmt.Println(array)

复制代码

模糊查询

var array []Bannerdb.Table("banner").Where("image_url like ?", "%lijie%").Find(&array)fmt.Println( array)

复制代码

多条件查询

var array []Bannerdb.Table("banner").Where("id = ?", "1").Where("image_url like ?", "%lijie%").Find(&array)fmt.Println(array)

复制代码

2.5 表数据更新

根据条件进行更新单个字段

db.Table("banner").Where("id = ?", 1).Update("image_url", "http://baidu.com")

复制代码

或

db.Model(&Banner{}).Where("id = ?", 1).Update("image_url", "http://JD.com")

复制代码

根据条件更新多个字段

db.Table("banner").Where("id = ?", 2).Updates(Banner{ImageUrl: "http://baidu.com", JumpUrl: "http://qq.com"})

复制代码

或

db.Model(&Banner{}).Where("id = ?", 1).Updates(Banner{ImageUrl: "http://baidu.com", JumpUrl: "http://qq.com"})

复制代码

选定某些字段更新

db.Table("banner").Where("id = ?", "3").Select("ImageUrl").Updates(Banner{ImageUrl: "http://badui.com", JumpUrl: "http://badui.com", Status: 1})

复制代码

或

db.Model(&Banner{}).Where("id = ?", "3").Select("ImageUrl").Updates(Banner{ImageUrl: "http://badui.com", JumpUrl: "http://badui.com", Status: 1})

复制代码

忽略某些字段更新

db.Table("banner").Where("id = ?", "3").Omit("ImageUrl").Updates(Banner{ImageUrl: "http://badui.com", JumpUrl: "http://badui.com", Status: 1})

复制代码

对应 sql 语句：UPDATE banner SET jump_url='http://badui.com',status=1 WHERE id = '3'

或

db.Model(&Banner{}).Where("id = ?", "3").Omit("JumpUrl", "Status").Updates(Banner{ImageUrl: "http://badui.com", JumpUrl: "http://badui.com", Status: 1}

复制代码

对应 sql 语句：UPDATE banner SET image_url='http://badui.com' WHERE id = '3'

2.6 表数据删除

删除符合条件的数据

Delete 中必须传参一个对象

db.Table("banner").Where("status = ?", "0").Delete(&Banner{})

复制代码

对应 sql 语句：DELETE FROM banner WHERE status = '0'

根据表中主键删除数据

db.Table("banner").Delete(&Banner{}, 2)

复制代码

对应 sql 语句：DELETE FROM banner WHERE banner.id = 2

发布于: 刚刚阅读数: 2

原文链接:【http://xie.infoq.cn/article/fd7dec9184050570ef99641ac】。文章转载请联系作者。

看见月亮的人

关注

还未添加个人签名 2020.11.21 加入

还未添加个人简介

发布

暂无评论

创作场景

从零开发区块链应用 (三)--mysql 初始化及 gorm 框架使用

一、mysql 初始化

1.1 导入依赖包

1.2 连接数据库

1.3 设置连接数

1.4 测试数据库是否可以连接成功

二、gorm 框架使用

2.1 gorm 库安装

2.2 数据库连接

2.3 表数据插入

2.4 表数据查询

2.5 表数据更新

2.6 表数据删除

看见月亮的人

评论