-
Notifications
You must be signed in to change notification settings - Fork 0
/
mysql.go
52 lines (44 loc) · 961 Bytes
/
mysql.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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
package db
import (
"time"
"github.com/Sirlanri/distiot-master/server/config"
"github.com/Sirlanri/distiot-master/server/log"
"gorm.io/driver/mysql"
"gorm.io/gorm"
)
var (
//MySQL数据库指针
Mdb *gorm.DB
)
func init() {
connectMysqlByGorm()
connectRedis()
}
func connectMysqlByGorm() {
var err error
dsn := config.Config.MysqlUrl
Mdb, err = gorm.Open(mysql.Open(dsn))
if err != nil {
log.Log.Errorln("server-db MySQL连接失败", err.Error())
return
}
err = Mdb.Error
if err != nil {
log.Log.Errorln("server-db MySQL ping失败", err.Error())
return
}
log.Log.Infoln("server-db MySQL连接成功")
}
//MySQL内的数据模型
//Node节点表
type Node struct {
ID int `gorm:"primary_key"`
Addr string `grom:"type:varchar(511)"`
Port int `grom:"type:int(0)"`
}
//设备表
type Device struct {
ID int `gorm:"int(0)"`
Nodeid int `gorm:"int(0)"`
Itime time.Time `gorm:"autoCreateTime:milli"`
}