Added DefineSchema method

pip-services3-go · Apr 3, 2021 · 45a1a5a · 45a1a5a
1 parent 82a0739
commit 45a1a5a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/persistence/IdentifiableMongoDbPersistence.go b/persistence/IdentifiableMongoDbPersistence.go
@@ -135,7 +135,6 @@ type IdentifiableMongoDbPersistence struct {
 func InheritIdentifiableMongoDbPersistence(overrides IMongoDbPersistenceOverrides, proto reflect.Type, collection string) *IdentifiableMongoDbPersistence {
 	if collection == "" {
 		panic("Collection name could not be nil")
-		return nil
 	}
 	c := IdentifiableMongoDbPersistence{}
 	c.MongoDbPersistence = *InheritMongoDbPersistence(overrides, proto, collection)

diff --git a/persistence/MongoDbPersistence.go b/persistence/MongoDbPersistence.go
@@ -406,6 +406,9 @@ func (c *MongoDbPersistence) Open(correlationId string) error {
 	//ctx, cancel := context.WithTimeout(context.Background(), 15*time.Second)
 	//defer cancel()
 
+	// Define database schema
+	c.Overrides.DefineSchema()
+
 	// Recreate indexes
 	if len(c.indexes) > 0 {
 		keys, errIndexes := c.Collection.Indexes().CreateMany(c.Connection.Ctx, c.indexes, mongoopt.CreateIndexes())