From fc11b3c463d64268b933f116ec3e6cfce56785d7 Mon Sep 17 00:00:00 2001
From: wangchuxiao <wangchuxiao97@outlook.com>
Date: Wed, 23 Feb 2022 12:30:18 +0800
Subject: [PATCH] test mongo driver

---
 pkg/common/db/model.go | 58 +++++++++++++++++++++---------------------
 1 file changed, 29 insertions(+), 29 deletions(-)

diff --git a/pkg/common/db/model.go b/pkg/common/db/model.go
index 29ebf8c24..c85c948fa 100644
--- a/pkg/common/db/model.go
+++ b/pkg/common/db/model.go
@@ -58,37 +58,37 @@ func init() {
 		}
 	}
 	log.NewInfo("0", utils.GetSelfFuncName(), "mongo driver client init success")
-
-
-	mgoDailInfo := &mgo.DialInfo{
-		Addrs:     config.Config.Mongo.DBAddress,
-		Direct:    config.Config.Mongo.DBDirect,
-		Timeout:   time.Second * time.Duration(config.Config.Mongo.DBTimeout),
-		Database:  config.Config.Mongo.DBDatabase,
-		Source:    config.Config.Mongo.DBSource,
-		Username:  config.Config.Mongo.DBUserName,
-		Password:  config.Config.Mongo.DBPassword,
-		PoolLimit: config.Config.Mongo.DBMaxPoolSize,
-	}
-	mgoSession, err := mgo.DialWithInfo(mgoDailInfo)
-
-	if err != nil {
-
-		mgoSession, err1 = mgo.DialWithInfo(mgoDailInfo)
-		if err1 != nil {
-			log.NewError(" mongo.Connect  failed, panic", err.Error())
-			panic(err1.Error())
-		}
-	}
 	DB.mongoClient = mongoClient
-	DB.mgoSession = mgoSession
-	DB.mgoSession.SetMode(mgo.Monotonic, true)
-	c := DB.mgoSession.DB(config.Config.Mongo.DBDatabase).C(cChat)
-	err = c.EnsureIndexKey("uid")
-	if err != nil {
-		panic(err.Error())
-	}
 
+	//mgoDailInfo := &mgo.DialInfo{
+	//	Addrs:     config.Config.Mongo.DBAddress,
+	//	Direct:    config.Config.Mongo.DBDirect,
+	//	Timeout:   time.Second * time.Duration(config.Config.Mongo.DBTimeout),
+	//	Database:  config.Config.Mongo.DBDatabase,
+	//	Source:    config.Config.Mongo.DBSource,
+	//	Username:  config.Config.Mongo.DBUserName,
+	//	Password:  config.Config.Mongo.DBPassword,
+	//	PoolLimit: config.Config.Mongo.DBMaxPoolSize,
+	//}
+	//mgoSession, err = mgo.DialWithInfo(mgoDailInfo)
+	//
+	//if err != nil {
+	//
+	//	mgoSession, err1 = mgo.DialWithInfo(mgoDailInfo)
+	//	if err1 != nil {
+	//		log.NewError(" mongo.Connect  failed, panic", err.Error())
+	//		panic(err1.Error())
+	//	}
+	//}
+
+	//DB.mgoSession = mgoSession
+	//DB.mgoSession.SetMode(mgo.Monotonic, true)
+	//c := DB.mgoSession.DB(config.Config.Mongo.DBDatabase).C(cChat)
+	//err = c.EnsureIndexKey("uid")
+	//if err != nil {
+	//	panic(err.Error())
+	//}
+	//
 
 	// redis pool init
 	DB.redisPool = &redis.Pool{