从零开发区块链应用(三)–mysql初始化及gorm框架使用
一、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
SETjump_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
SETimage_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
WHEREbanner
.id
= 2
猜你喜欢
比特币价格今日行情,比特币暴跌7%其它加密货币也跳水
比特币价格今日行情,比特币暴跌7%其它加密货币也跳水 比特币价格大幅下跌,而以太币价格也下跌。
2022-01-22
09年上大学买了5000个比特币,不惜卖掉婚房的唐宇,现今咋样了
09年上大学买了5000个比特币,不惜卖掉婚房的唐宇,现今咋样了 2013年,那个为买118个比特币,不惜卖掉婚房的唐宇,现今咋样了
2022-01-22
中国全面禁止比特币挖矿的原因
中国全面禁止比特币挖矿的原因 近期因为国内碳排放问题和国内电力不够用的情况,先是把比特币挖矿关停,进而把虚拟货币的整个交易市场也几乎关停了。很多区块链的企业开始转向了海外,或者直接清算结束运行了。
2022-01-22
交易所出海后,比特币中国禁止后怎么提现
交易所出海后,比特币中国禁止后怎么提现 为什么要清退虚拟货币呢?
2022-01-22
李晨比特币5个亿爆仓怎么翻身
李晨比特币5个亿爆仓怎么翻身 李晨有多少比特币 李晨比特币爆仓 李晨炒比特币 比特币大涨李晨 李晨的比特币 Q1:李晨比特币5个亿爆仓怎么翻身
2022-01-22
上一篇
从零开发区块链应用(四)--自定义业务错误信息
下一篇
从零开发区块链应用(二)--mysql安装及数据库表的安装创建
评论