From 1d22b44dd43314ce984858cbed3567033c32c89c Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Wed, 24 May 2023 12:26:59 +0800 Subject: [PATCH] Test_BatchInsertChat2DB --- pkg/common/db/controller/msg_test.go | 27 ++++++++++++--------------- 1 file changed, 12 insertions(+), 15 deletions(-) diff --git a/pkg/common/db/controller/msg_test.go b/pkg/common/db/controller/msg_test.go index 3bfd4aeec..597f95842 100644 --- a/pkg/common/db/controller/msg_test.go +++ b/pkg/common/db/controller/msg_test.go @@ -2,10 +2,8 @@ package controller import ( "context" - "fmt" "github.com/OpenIMSDK/Open-IM-Server/pkg/common/config" "github.com/OpenIMSDK/Open-IM-Server/pkg/common/db/unrelation" - "github.com/OpenIMSDK/Open-IM-Server/pkg/proto/sdkws" "go.mongodb.org/mongo-driver/bson" "strconv" "sync" @@ -36,19 +34,18 @@ func Test_BatchInsertChat2DB(t *testing.T) { db := &commonMsgDatabase{ msgDocDatabase: unrelation.NewMsgMongoDriver(mongo.GetDatabase()), } - ctx := context.Background() - - msgs := make([]*sdkws.MsgData, 0, 1) - for i := 0; i < cap(msgs); i++ { - msgs = append(msgs, &sdkws.MsgData{ - Content: []byte(fmt.Sprintf("test-%d", i)), - SendTime: time.Now().UnixMilli(), - }) - } - err = db.BatchInsertChat2DB(ctx, "test", msgs, 0) - if err != nil { - panic(err) - } + //ctx := context.Background() + //msgs := make([]*sdkws.MsgData, 0, 1) + //for i := 0; i < cap(msgs); i++ { + // msgs = append(msgs, &sdkws.MsgData{ + // Content: []byte(fmt.Sprintf("test-%d", i)), + // SendTime: time.Now().UnixMilli(), + // }) + //} + //err = db.BatchInsertChat2DB(ctx, "test", msgs, 0) + //if err != nil { + // panic(err) + //} _ = db.BatchInsertChat2DB c := mongo.GetDatabase().Collection("msg")