golang初始化数据库和redis的方法
这篇文章给大家分享的是有关golang初始化数据库和redis的方法。小编觉得挺实用的,因此分享给大家学习。如下资料是关于初始化数据库和redis的内容。
创新互联公司-专业网站定制、快速模板网站建设、高性价比垫江网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式垫江网站制作公司更省心,省钱,快速模板网站建设找我们,业务覆盖垫江地区。费用合理售后完善,十载实体公司更值得信赖。
初始化数据库
数据库orm我选用xorm。首先在config.json和config.go添加对应的数据库配置。
config.json:
"db_config": {
"db_host": "127.0.0.1",
"db_port": "3306",
"db_user": "root",
"db_password": "123456",
"db_name": "test"
}
config.go
type DBConfig struct {
DbHost string `json:"db_host"`
DbPort string `json:"db_port"`
DbUser string `json:"db_user"`
DbPassword string `json:"db_password"`
DbName string `json:"db_name"`
}
接着,初始化数据库:
package db
import (
"github.com/TomatoMr/awesomeframework/config"
_ "github.com/go-sql-driver/MySQL"
"github.com/go-xorm/xorm"
"github.com/pkg/errors"
)
var engine *xorm.Engine
func InitEngine() error {
var err error
conf := config.GetConfig()
engine, err = xorm.NewEngine("mysql", conf.DBConfig.DbUser+
":"+conf.DBConfig.DbPassword+"@tcp("+conf.DBConfig.DbHost+":"+conf.DBConfig.DbPort+")/"+conf.DBConfig.DbName+"?charset=utf8")
if err != nil {
err = errors.Wrap(err, "InitEngine1")
return err
}
err = engine.Ping()
if err != nil {
err = errors.Wrap(err, "InitEngine2")
return err
}
return nil
}
func GetEngine() *xorm.Engine {
return engine
}
我们再创建一个sql,等会测试连接用:
DROP DATABASE IF EXISTS `test`;
CREATE DATABASE `test`;
USE `test`;
DROP TABLE IF EXISTS `users`;
CREATE TABLE `users`
(
`id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'id',
`name` varchar(40) NOT NULL COMMENT '名字',
`age` int NOT NULL DEFAULT 0 COMMENT '年龄',
PRIMARY KEY (`id`)
) ENGINE = InnoDB COMMENT 'users';
初始化redis
同样先添加配置:
config.json:
"redis_config": {
"addr": "127.0.0.1:6379",
"password": "",
"db": 0
}
config.go:
type RedisConfig struct {
Addr string `json:"addr"`
Password string `json:"password"`
DB int `json:"db"`
}
初始化redis:
func InitRedis() error {
conf := config.GetConfig()
client = redis.NewClient(&redis.Options{
Addr: conf.RedisConfig.Addr,
Password: conf.RedisConfig.Password,
DB: conf.RedisConfig.DB,
})
pong, err := client.Ping().Result()
if err != nil {
err = errors.Wrap(err, "InitRedis")
return err
}
logger.GetLogger().Info("Redis ping:", zap.String("ping", pong))
return nil
}
调整入口文件
err = db.InitEngine()
if err != nil {
fmt.Printf("Init DB failed. Error is %v", err)
os.Exit(1)
}
err = redis.InitRedis()
if err != nil {
fmt.Printf("Init Redis failed. Error is %v", err)
os.Exit(1)
}
测试一下
使用上面的sql,创建一个数据库叫做test,然后搭建redis,接着我们测试一下:
编译:
go build
运行:
awesomeframework --config=./config/config.json
看下日志打印:
2020-01-20T20:09:26.798+0800 info Redis ping: {"ping": "PONG"}
2020-01-20T20:09:26.798+0800 info Init success.
关于golang初始化数据库和redis的方法就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
网站标题:golang初始化数据库和redis的方法
URL网址:http://pwwzsj.com/article/ippgsp.html