animeic 1 жил өмнө
parent
commit
c17a704d1a
1 өөрчлөгдсөн 2 нэмэгдсэн , 2 устгасан
  1. 2 2
      baishuihu/db/db.go

+ 2 - 2
baishuihu/db/db.go

@@ -38,11 +38,11 @@ func (db *MongoDB) GetOrCreateDatabase(name string) *mongo.Database {
 func NewConfigMongoDB(bus *comm.NatsBus, config *conf.AppConf) *MongoDB {
 
 	fmt.Println("db-config=>", config.Configer.Mongo)
-	MongoInst, err := bus.NewMongoDBFromConfigDev(config.Configer.Mongo)
+	MongoInst, err := bus.NewMongoDBFromConfig(config.Configer.Mongo)
 	if err != nil {
 		panic(err)
 	}
-	GMongoDb = &MongoDB{Client: MongoInst.Client, Database: MongoInst.Database}
+	GMongoDb = &MongoDB{Client: MongoInst.Client, Database: MongoInst.Database, Databases: map[string]*mongo.Database{}}
 
 	return GMongoDb
 }