remove autoIndexId when autoIndexId and idIndex co-exists in create c…

…ollection oplog. #400
alibaba · Aug 13, 2020 · bddf6db · bddf6db
1 parent 5a1c74d
commit bddf6db
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/mongoshake/executor/db_writer.go b/src/mongoshake/executor/db_writer.go
@@ -125,6 +125,11 @@ func RunCommand(database, operation string, log *oplog.PartialLog, session *mgo.
 	case "dropDatabase":
 		err = dbHandler.DropDatabase()
 	case "create":
+		if oplog.GetKey(log.Object, "autoIndexId") != nil &&
+			oplog.GetKey(log.Object, "idIndex") != nil {
+			// exits "autoIndexId" and "idIndex", remove "autoIndexId"
+			log.Object = oplog.RemoveFiled(log.Object, "autoIndexId")
+		}
 		fallthrough
 	case "collMod":
 		fallthrough

diff --git a/src/mongoshake/oplog/oplog.go b/src/mongoshake/oplog/oplog.go
@@ -5,7 +5,6 @@ import (
 	"fmt"
 	"encoding/json"
 
-	"github.com/gugemichael/nimo4go"
 	"github.com/vinllen/mgo/bson"
 
 )
@@ -122,7 +121,6 @@ func GetKeyWithIndex(log bson.D, wanted string) (interface{}, int) {
 		}
 	}
 
-	nimo.Assert("you can't see me")
 	return nil, 0
 }