func (d *DB) Create() {
ns := viper.GetString("db.sessionNamespace")
- d.session = sdl.Create(ns)
+ d.session = sdl.NewSdlInstance(ns, sdl.NewDatabase())
// Test DB connection, and wait until ready!
for {
if _, err := d.session.GetAll(); err == nil {
return
}
- mdclog(MdclogErr, "Database connection not ready, waiting ...")
+ Logger.Error("Database connection not ready, waiting ...")
time.Sleep(time.Duration(5 * time.Second))
}
}
data, err := json.Marshal(s.req)
if err != nil {
- mdclog(MdclogErr, "json.marshal failed: "+err.Error())
+ Logger.Error("json.marshal failed: %v ", err.Error())
return
}
if err := d.session.Set(s.req.Id, data); err != nil {
- mdclog(MdclogErr, "DB.session.Set failed: "+err.Error())
+ Logger.Error("DB.session.Set failed: %v ", err.Error())
}
}
}
keys, err := d.session.GetAll()
if err != nil {
- mdclog(MdclogErr, "DB.session.GetAll failed: "+err.Error())
+ Logger.Error("DB.session.GetAll failed: %v ", err.Error())
return
}
for _, key := range keys {
value, err := d.session.Get([]string{key})
if err != nil {
- mdclog(MdclogErr, "DB.session.Get failed: "+err.Error())
+ Logger.Error("DB.session.Get failed: %v ", err.Error())
return
}
var item SubscriptionReq
if err = json.Unmarshal([]byte(value[key].(string)), &item); err != nil {
- mdclog(MdclogErr, "json.Unmarshal failed: "+err.Error())
+ Logger.Error("json.Unmarshal failed: %v ", err.Error())
return
}