From a8f2a375a984272f405b10a34cedf68019f52d65 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Jos=C3=A9=20Carlos=20Nieto?= <jose.carlos@menteslibres.net>
Date: Tue, 9 Aug 2016 23:22:24 -0500
Subject: [PATCH] Reinitialize database on Clone(). Closes #214
---
mongo/database.go | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/mongo/database.go b/mongo/database.go
index c8f14e70..f9647232 100644
--- a/mongo/database.go
+++ b/mongo/database.go
@@ -78,11 +78,12 @@ func (s *Source) Open(connURL db.ConnectionURL) error {
// Clone returns a cloned db.Database session.
func (s *Source) Clone() (db.Database, error) {
+ newSession := s.session.Copy()
clone := &Source{
name: s.name,
connURL: s.connURL,
- session: s.session.Copy(),
- database: s.database,
+ session: newSession,
+ database: newSession.DB(s.database.Name),
version: s.version,
collections: map[string]*Collection{},
}
--
GitLab