From 7cf712daff2171b7b69ad5e08e51bc1835a4d7db Mon Sep 17 00:00:00 2001
From: wenxu12345 <44203734@qq.com>
Date: Mon, 21 Feb 2022 15:20:39 +0800
Subject: [PATCH] replace mongo driver

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

diff --git a/pkg/common/db/model.go b/pkg/common/db/model.go
index f6f074c48..c61416dd4 100644
--- a/pkg/common/db/model.go
+++ b/pkg/common/db/model.go
@@ -37,21 +37,21 @@ func init() {
 	// mongo init
 	// "mongodb://sysop:moon@localhost/records"
 	// uri := "mongodb://user:pass@sample.host:27017/?maxPoolSize=20&w=majority"
-	uri := fmt.Sprintf("mongodb://%s:%s@%s/%s/?maxPoolSize=%d",
-		config.Config.Mongo.DBUserName, config.Config.Mongo.DBPassword,
-		config.Config.Mongo.DBAddress[0],config.Config.Mongo.DBDatabase,
-		config.Config.Mongo.DBMaxPoolSize)
-
-	mongoClient, err := mongo.Connect(context.TODO(), options.Client().ApplyURI(uri))
-	if err != nil{
-		log.NewError(" mongo.Connect  failed, try ", err.Error(), uri)
-		time.Sleep(time.Duration(30) * time.Second)
-		mongoClient, err1 = mongo.Connect(context.TODO(), options.Client().ApplyURI(uri))
-		if err1 != nil {
-			log.NewError(" mongo.Connect  failed, panic", err.Error(), uri)
-			panic(err1.Error())
-		}
-	}
+	//uri := fmt.Sprintf("mongodb://%s:%s@%s/%s/?maxPoolSize=%d",
+	//	config.Config.Mongo.DBUserName, config.Config.Mongo.DBPassword,
+	//	config.Config.Mongo.DBAddress[0],config.Config.Mongo.DBDatabase,
+	//	config.Config.Mongo.DBMaxPoolSize)
+	//
+	//mongoClient, err := mongo.Connect(context.TODO(), options.Client().ApplyURI(uri))
+	//if err != nil{
+	//	log.NewError(" mongo.Connect  failed, try ", err.Error(), uri)
+	//	time.Sleep(time.Duration(30) * time.Second)
+	//	mongoClient, err1 = mongo.Connect(context.TODO(), options.Client().ApplyURI(uri))
+	//	if err1 != nil {
+	//		log.NewError(" mongo.Connect  failed, panic", err.Error(), uri)
+	//		panic(err1.Error())
+	//	}
+	//}