3592dfd3
zhangqijia
重构models, 索引唯一索引
|
1
2
3
|
package models
import (
|
3592dfd3
zhangqijia
重构models, 索引唯一索引
|
4
|
"pro2d/protos/pb"
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
5
6
7
|
"pro2d/src/components/db"
"pro2d/src/components/logger"
"pro2d/src/utils"
|
3592dfd3
zhangqijia
重构models, 索引唯一索引
|
8
9
10
11
|
)
func InitDoc(schema ...interface{}) {
for _, s := range schema {
|
1584eb4b
zhangqijia
修复创建唯一索引的bug
|
12
13
14
|
coll, keys := utils.FindIndex(s)
for _, index := range keys {
db.CreateCollection(coll)
|
3592dfd3
zhangqijia
重构models, 索引唯一索引
|
15
|
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
16
|
logger.Debug("InitDoc collect: %v, createIndex: %s", coll, index)
|
1584eb4b
zhangqijia
修复创建唯一索引的bug
|
17
|
res, err := db.SetUnique(coll, index)
|
3592dfd3
zhangqijia
重构models, 索引唯一索引
|
18
|
if err != nil {
|
cad2b7f3
zhangqijia
reactor: 重构目录, 重构...
|
19
|
logger.Error("InitDoc unique: %s, err: %v", res, err)
|
3592dfd3
zhangqijia
重构models, 索引唯一索引
|
20
21
22
23
24
25
26
27
|
continue
}
}
}
}
func InitAccountServerModels() {
var schema []interface{} = []interface{}{
|
563acaf7
zhangqijia
在拦截器中认证jwt
|
28
|
pb.Account{},
|
3592dfd3
zhangqijia
重构models, 索引唯一索引
|
29
30
31
32
33
34
35
36
37
38
39
40
|
}
InitDoc(schema...)
}
func InitGameServerModels() {
var schema []interface{} = []interface{}{
pb.Hero{},
pb.Role{},
pb.Team{},
}
InitDoc(schema...)
}
|