|
|
@@ -2,13 +2,9 @@ package mgodb
|
|
|
|
|
|
import (
|
|
|
"context"
|
|
|
- "eta/eta_forum_task/utils"
|
|
|
"github.com/qiniu/qmgo"
|
|
|
"github.com/qiniu/qmgo/options"
|
|
|
- "go.mongodb.org/mongo-driver/bson"
|
|
|
- "go.mongodb.org/mongo-driver/event"
|
|
|
mgoptions "go.mongodb.org/mongo-driver/mongo/options"
|
|
|
- "sync"
|
|
|
)
|
|
|
|
|
|
var (
|
|
|
@@ -41,9 +37,9 @@ type MgoConfig struct {
|
|
|
func MgoNewClient(mgoConfig MgoConfig) *qmgo.Client {
|
|
|
// 创建cmdMonitor，用于打印SQL
|
|
|
//startedCommands := make(map[int64]bson.Raw)
|
|
|
- startedCommands := sync.Map{} // map[int64]bson.Raw
|
|
|
+ /*startedCommands := sync.Map{} // map[int64]bson.Raw
|
|
|
|
|
|
- _ = &event.CommandMonitor{
|
|
|
+ cmdMonitor := &event.CommandMonitor{
|
|
|
Started: func(_ context.Context, evt *event.CommandStartedEvent) {
|
|
|
startedCommands.Store(evt.RequestID, evt.Command)
|
|
|
//startedCommands[evt.RequestID] = evt.Command
|
|
|
@@ -72,7 +68,7 @@ func MgoNewClient(mgoConfig MgoConfig) *qmgo.Client {
|
|
|
}
|
|
|
utils.MongoLog.Info("\n【MongoDB】[%.3fms] [%v] \n %v \n", float64(evt.Duration)/1e6, commands, evt.Failure)
|
|
|
},
|
|
|
- }
|
|
|
+ }*/
|
|
|
|
|
|
// 创建options
|
|
|
ops := options.ClientOptions{ClientOptions: &mgoptions.ClientOptions{}}
|
