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

  • 时间:
  • 浏览:413
  • 来源:区块链技术网

一、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.User
password := config.Conf.Mysql.Password
host := config.Conf.Mysql.Host
port := config.Conf.Mysql.Port
database := config.Conf.Mysql.Database
DB, 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/gorm
go 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 Banner
db.Table("banner").First(&banner, 1)
fmt.Println(banner)
  • 获取所有数据
var array []Banner
db.Table("banner").Find(&array)
fmt.Println(array)

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

  • 获取一条数据
var array []Banner
db.Table("banner").Limit(1).Find(&array)
fmt.Println(array)
  • 获取多个条件的并集
var array []Banner
db.Table("banner").Where("id = ?""1").Or(db.Where("id = ?""2"),).Find(&array)
fmt.Println(array)
  • 模糊查询
var array []Banner
db.Table("banner").Where("image_url like ?""%lijie%").Find(&array)
fmt.Println( array)
  • 多条件查询
var array []Banner
db.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

猜你喜欢

比特币提现会被银行查吗?

比特币提现会被银行查吗? 首先,根据《中华人民共和国反洗钱法》、《金融机构大额交易和可疑交易报告管理办法》、《金融机构报告涉嫌恐怖融资的可疑交易管理办法》等法律法规的相关规定,银行会对大额资金的流动做监控,主要是审查来源是否合法,是否涉嫌洗钱。

2022-05-21

比特币暴跌50%!30岁老公玩比特币输了好多钱

比特币暴跌50%!30岁老公玩比特币输了好多钱 过去的一周里,作为一个游曳在币圈边缘的键盘侠,见识了币圈度日如年的跌宕后,仍可以笑看潮起潮落。

2022-05-21

UST爆雷之后,USDT也要爆雷了?

这几天的行情,证明了良心哥的推测非常准确。 首先是5月10日分析luna背后是被人开了黑枪,并且持续看空luna。 次日消息实锤,luna再次跌了个99%。 昨天分析说,luna的死亡螺旋会带崩大盘。

2022-05-21

Luna币7天蒸发2000亿,但更怕的是熊市即将到来!

心哥昨天虽然不知道这里边的细节,但依然非常确定的告诉大家,这是一场狙击战,找的就是这个空档,打出来的子弹是要人命的。 另外排队枪毙这个场景,估计今天很多人也领教了。

2022-05-21

一天蒸发400亿人民币,Luna是如何被狙击的?

你们也都知道良心哥炒币是个渣渣,但良心哥的判断大体还是准确的。 可能这就是从业时间久了的盘感吧。 有人说luna的暴跌,ust抛锚,都他吗赖孙宇晨。 从5月5号孙宇晨宣布进军算法稳定币之后,大盘就崩了

2022-05-21