diff --git a/adapter/cockroachdb/helper_test.go b/adapter/cockroachdb/helper_test.go
index f8764597..13dedad5 100644
--- a/adapter/cockroachdb/helper_test.go
+++ b/adapter/cockroachdb/helper_test.go
@@ -99,7 +99,7 @@ func (h *Helper) TearDown() error {
 	return h.sess.Close()
 }
 
-func (h *Helper) TearUp() error {
+func (h *Helper) SetUp() error {
 	var err error
 
 	h.sess, err = Open(settings)
diff --git a/adapter/mongo/Makefile b/adapter/mongo/Makefile
index fe58bac0..ef0eb8b2 100644
--- a/adapter/mongo/Makefile
+++ b/adapter/mongo/Makefile
@@ -1,7 +1,7 @@
 SHELL					        ?= bash
 
-MONGO_VERSION         ?= 4
-MONGO_SUPPORTED       ?= $(MONGO_VERSION) 3
+MONGO_VERSION         ?= 8
+MONGO_SUPPORTED       ?= $(MONGO_VERSION) 7
 PROJECT               ?= $(subst .,_,"upper_mongo_$(MONGO_VERSION)")
 
 DB_HOST               ?= 127.0.0.1
diff --git a/adapter/mongo/collection.go b/adapter/mongo/collection.go
index e6caa3bc..19839c61 100644
--- a/adapter/mongo/collection.go
+++ b/adapter/mongo/collection.go
@@ -22,22 +22,22 @@
 package mongo
 
 import (
+	"context"
 	"fmt"
+	"reflect"
 	"strings"
 	"sync"
 
-	"reflect"
-
 	db "github.com/upper/db/v4"
 	"github.com/upper/db/v4/internal/adapter"
-	mgo "gopkg.in/mgo.v2"
-	"gopkg.in/mgo.v2/bson"
+	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/mongo"
 )
 
 // Collection represents a mongodb collection.
 type Collection struct {
 	parent     *Source
-	collection *mgo.Collection
+	collection *mongo.Collection
 }
 
 var (
@@ -108,9 +108,15 @@ func compare(field string, cmp *adapter.Comparison) (string, interface{}) {
 		}
 		return field, bson.M{"$ne": value}
 	case adapter.ComparisonOperatorRegExp, adapter.ComparisonOperatorLike:
-		return field, bson.RegEx{Pattern: value.(string), Options: ""}
+		return field, bson.M{
+			"$regex": value.(string),
+		}
 	case adapter.ComparisonOperatorNotRegExp, adapter.ComparisonOperatorNotLike:
-		return field, bson.M{"$not": bson.RegEx{Pattern: value.(string), Options: ""}}
+		return field, bson.M{
+			"$not": bson.M{
+				"$regex": value.(string),
+			},
+		}
 	}
 
 	if cmpOp, ok := comparisonOperators[op]; ok {
@@ -122,8 +128,8 @@ func compare(field string, cmp *adapter.Comparison) (string, interface{}) {
 	panic(fmt.Sprintf("Unsupported operator %v", op))
 }
 
-// compileStatement transforms conditions into something *mgo.Session can
-// understand.
+// compileStatement transforms upper-db conditions into something that the
+// adapter can understand.
 func compileStatement(cond db.Cond) bson.M {
 	conds := bson.M{}
 
@@ -170,10 +176,7 @@ func compileStatement(cond db.Cond) bson.M {
 	return conds
 }
 
-// compileConditions compiles terms into something *mgo.Session can
-// understand.
 func (col *Collection) compileConditions(term interface{}) interface{} {
-
 	switch t := term.(type) {
 	case []interface{}:
 		values := []interface{}{}
@@ -208,8 +211,6 @@ func (col *Collection) compileConditions(term interface{}) interface{} {
 	return nil
 }
 
-// compileQuery compiles terms into something that *mgo.Session can
-// understand.
 func (col *Collection) compileQuery(terms ...interface{}) interface{} {
 	compiled := col.compileConditions(terms)
 	if compiled == nil {
@@ -236,13 +237,12 @@ func (col *Collection) compileQuery(terms ...interface{}) interface{} {
 
 // Name returns the name of the table or tables that form the collection.
 func (col *Collection) Name() string {
-	return col.collection.Name
+	return col.collection.Name()
 }
 
 // Truncate deletes all rows from the table.
 func (col *Collection) Truncate() error {
-	err := col.collection.DropCollection()
-
+	err := col.collection.Drop(context.Background())
 	if err != nil {
 		return err
 	}
@@ -268,100 +268,33 @@ func (col *Collection) UpdateReturning(item interface{}) error {
 
 // Insert inserts a record (map or struct) into the collection.
 func (col *Collection) Insert(item interface{}) (db.InsertResult, error) {
-	var err error
+	ctx := context.Background()
 
-	id := getID(item)
-
-	if col.parent.versionAtLeast(2, 6, 0, 0) {
-		// this breaks MongoDb older than 2.6
-		if _, err = col.collection.Upsert(bson.M{"_id": id}, item); err != nil {
-			return nil, err
-		}
-	} else {
-		// Allocating a new ID.
-		if err = col.collection.Insert(bson.M{"_id": id}); err != nil {
-			return nil, err
-		}
-
-		// Now append data the user wants to append.
-		if err = col.collection.Update(bson.M{"_id": id}, item); err != nil {
-			// Cleanup allocated ID
-			if err := col.collection.Remove(bson.M{"_id": id}); err != nil {
-				return nil, err
-			}
-			return nil, err
-		}
+	res, err := col.collection.InsertOne(ctx, item)
+	if err != nil {
+		return nil, err
 	}
 
-	return db.NewInsertResult(id), nil
+	return db.NewInsertResult(res.InsertedID), nil
 }
 
 // Exists returns true if the collection exists.
 func (col *Collection) Exists() (bool, error) {
-	query := col.parent.database.C(`system.namespaces`).Find(map[string]string{`name`: fmt.Sprintf(`%s.%s`, col.parent.database.Name, col.collection.Name)})
-	count, err := query.Count()
-	return count > 0, err
-}
+	ctx := context.Background()
+	mcol := col.parent.database.Collection("system.namespaces")
 
-// Fetches object _id or generates a new one if object doesn't have one or the one it has is invalid
-func getID(item interface{}) interface{} {
-	v := reflect.ValueOf(item) // convert interface to Value
-	v = reflect.Indirect(v)    // convert pointers
-
-	switch v.Kind() {
-	case reflect.Map:
-		if inItem, ok := item.(map[string]interface{}); ok {
-			if id, ok := inItem["_id"]; ok {
-				bsonID, ok := id.(bson.ObjectId)
-				if ok {
-					return bsonID
-				}
-			}
-		}
-	case reflect.Struct:
-		t := v.Type()
-
-		idCacheMutex.RLock()
-		fieldName, found := idCache[t]
-		idCacheMutex.RUnlock()
-
-		if !found {
-			for n := 0; n < t.NumField(); n++ {
-				field := t.Field(n)
-				if field.PkgPath != "" {
-					continue // Private field
-				}
-
-				tag := field.Tag.Get("bson")
-				if tag == "" {
-					tag = field.Tag.Get("db")
-				}
-
-				if tag == "" {
-					continue
-				}
-
-				parts := strings.Split(tag, ",")
-
-				if parts[0] == "_id" {
-					fieldName = field.Name
-					idCacheMutex.RLock()
-					idCache[t] = fieldName
-					idCacheMutex.RUnlock()
-					break
-				}
-			}
-		}
-		if fieldName != "" {
-			if bsonID, ok := v.FieldByName(fieldName).Interface().(bson.ObjectId); ok {
-				if bsonID.Valid() {
-					return bsonID
-				}
-			} else {
-				return v.FieldByName(fieldName).Interface()
-			}
-		}
+	mcur, err := mcol.Find(ctx, bson.M{
+		"name": fmt.Sprintf("%s.%s", col.parent.database.Name(), col.collection.Name()),
+	})
+	if err != nil {
+		return false, err
+	}
+	defer mcur.Close(ctx)
+
+	hasNext := mcur.Next(ctx)
+	if err := mcur.Err(); err != nil {
+		return false, err
 	}
 
-	return bson.NewObjectId()
+	return hasNext, nil
 }
diff --git a/adapter/mongo/connection.go b/adapter/mongo/connection.go
index 98728078..6517e2aa 100644
--- a/adapter/mongo/connection.go
+++ b/adapter/mongo/connection.go
@@ -27,10 +27,14 @@ import (
 	"strings"
 )
 
-const connectionScheme = `mongodb`
+const (
+	defaultScheme = "mongodb"
+	srvScheme     = "mongodb+srv"
+)
 
 // ConnectionURL implements a MongoDB connection struct.
 type ConnectionURL struct {
+	Scheme   string
 	User     string
 	Password string
 	Host     string
@@ -39,13 +43,12 @@ type ConnectionURL struct {
 }
 
 func (c ConnectionURL) String() (s string) {
+	vv := url.Values{}
 
 	if c.Database == "" {
 		return ""
 	}
 
-	vv := url.Values{}
-
 	// Do we have any options?
 	if c.Options == nil {
 		c.Options = map[string]string{}
@@ -67,9 +70,13 @@ func (c ConnectionURL) String() (s string) {
 		}
 	}
 
+	if c.Scheme == "" {
+		c.Scheme = defaultScheme
+	}
+
 	// Building URL.
 	u := url.URL{
-		Scheme:   connectionScheme,
+		Scheme:   c.Scheme,
 		Path:     c.Database,
 		Host:     c.Host,
 		User:     userInfo,
@@ -80,17 +87,20 @@ func (c ConnectionURL) String() (s string) {
 }
 
 // ParseURL parses s into a ConnectionURL struct.
+// See https://www.mongodb.com/docs/manual/reference/connection-string/
 func ParseURL(s string) (conn ConnectionURL, err error) {
 	var u *url.URL
 
-	if !strings.HasPrefix(s, connectionScheme+"://") {
-		return conn, fmt.Errorf(`Expecting mongodb:// connection scheme.`)
+	hasPrefix := strings.HasPrefix(s, defaultScheme+"://") || strings.HasPrefix(s, srvScheme+"://")
+	if !hasPrefix {
+		return conn, fmt.Errorf("invalid scheme")
 	}
 
 	if u, err = url.Parse(s); err != nil {
-		return conn, err
+		return conn, fmt.Errorf("invalid URL: %v", err)
 	}
 
+	conn.Scheme = u.Scheme
 	conn.Host = u.Host
 
 	// Deleting / from start of the string.
@@ -108,12 +118,12 @@ func ParseURL(s string) (conn ConnectionURL, err error) {
 	var vv url.Values
 
 	if vv, err = url.ParseQuery(u.RawQuery); err != nil {
-		return conn, err
+		return conn, fmt.Errorf("invalid query: %v", err)
 	}
 
 	for k := range vv {
 		conn.Options[k] = vv.Get(k)
 	}
 
-	return conn, err
+	return conn, nil
 }
diff --git a/adapter/mongo/connection_test.go b/adapter/mongo/connection_test.go
index 8dba6512..3d2c5bca 100644
--- a/adapter/mongo/connection_test.go
+++ b/adapter/mongo/connection_test.go
@@ -70,30 +70,33 @@ func TestConnectionURL(t *testing.T) {
 }
 
 func TestParseConnectionURL(t *testing.T) {
-	var u ConnectionURL
-	var s string
-	var err error
+	{
+		const s = "mongodb:///mydatabase"
 
-	s = "mongodb:///mydatabase"
+		u, err := ParseURL(s)
+		require.NoError(t, err)
 
-	u, err = ParseURL(s)
-	require.NoError(t, err)
-
-	assert.Equal(t, "mydatabase", u.Database)
+		assert.Equal(t, "mydatabase", u.Database)
+	}
 
-	s = "mongodb://user:pass@localhost,1.2.3.4,example.org:1234/another_database?cache=foobar&mode=ro"
+	{
+		const s = "mongodb://user:pass@localhost,1.2.3.4,example.org:1234/another_database?cache=foobar&mode=ro"
 
-	u, err = ParseURL(s)
-	require.NoError(t, err)
+		u, err := ParseURL(s)
+		require.NoError(t, err)
 
-	assert.Equal(t, "another_database", u.Database)
-	assert.Equal(t, "foobar", u.Options["cache"])
-	assert.Equal(t, "ro", u.Options["mode"])
-	assert.Equal(t, "user", u.User)
-	assert.Equal(t, "pass", u.Password)
-	assert.Equal(t, "localhost,1.2.3.4,example.org:1234", u.Host)
+		assert.Equal(t, "another_database", u.Database)
+		assert.Equal(t, "foobar", u.Options["cache"])
+		assert.Equal(t, "ro", u.Options["mode"])
+		assert.Equal(t, "mongodb", u.Scheme)
+		assert.Equal(t, "user", u.User)
+		assert.Equal(t, "pass", u.Password)
+		assert.Equal(t, "localhost,1.2.3.4,example.org:1234", u.Host)
+	}
 
-	s = "http://example.org"
-	_, err = ParseURL(s)
-	require.Error(t, err)
+	{
+		const s = "http://example.org"
+		_, err := ParseURL(s)
+		require.Error(t, err)
+	}
 }
diff --git a/adapter/mongo/database.go b/adapter/mongo/database.go
index 64311927..ff5f5b96 100644
--- a/adapter/mongo/database.go
+++ b/adapter/mongo/database.go
@@ -19,20 +19,23 @@
 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 
-// Package mongo wraps the gopkg.in/mgo.v2 MongoDB driver. See
-// https://github.com/upper/db/adapter/mongo for documentation, particularities and usage
-// examples.
+// Package mongo wraps the official MongoDB driver. See
+// https://github.com/upper/db/adapter/mongo for documentation, particularities
+// and usage examples.
 package mongo
 
 import (
 	"context"
 	"database/sql"
+	"fmt"
 	"strings"
 	"sync"
 	"time"
 
 	db "github.com/upper/db/v4"
-	mgo "gopkg.in/mgo.v2"
+	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
 )
 
 // Adapter holds the name of the mongodb adapter.
@@ -48,8 +51,8 @@ type Source struct {
 
 	name          string
 	connURL       db.ConnectionURL
-	session       *mgo.Session
-	database      *mgo.Database
+	session       *mongo.Client // rename to client
+	database      *mongo.Database
 	version       []int
 	collections   map[string]*Collection
 	collectionsMu sync.Mutex
@@ -67,11 +70,18 @@ func init() {
 }
 
 // Open stablishes a new connection to a SQL server.
-func Open(settings db.ConnectionURL) (db.Session, error) {
-	d := &Source{Settings: db.NewSettings(), ctx: context.Background()}
-	if err := d.Open(settings); err != nil {
-		return nil, err
+func Open(connURL db.ConnectionURL) (db.Session, error) {
+	ctx := context.Background()
+	settings := db.NewSettings()
+
+	d := &Source{
+		Settings: settings,
+		ctx:      ctx,
+	}
+	if err := d.Open(connURL); err != nil {
+		return nil, fmt.Errorf("Open: %w", err)
 	}
+
 	return d, nil
 }
 
@@ -120,33 +130,35 @@ func (s *Source) Open(connURL db.ConnectionURL) error {
 
 // Clone returns a cloned db.Session session.
 func (s *Source) Clone() (db.Session, error) {
-	newSession := s.session.Copy()
 	clone := &Source{
 		Settings: db.NewSettings(),
 
 		name:        s.name,
 		connURL:     s.connURL,
-		session:     newSession,
-		database:    newSession.DB(s.database.Name),
 		version:     s.version,
 		collections: map[string]*Collection{},
 	}
+
+	if err := clone.open(); err != nil {
+		return nil, err
+	}
+
 	return clone, nil
 }
 
 // Ping checks whether a connection to the database is still alive by pinging
 // it, establishing a connection if necessary.
 func (s *Source) Ping() error {
-	return s.session.Ping()
+	return s.session.Ping(context.Background(), nil)
 }
 
 func (s *Source) Reset() {
 	s.collectionsMu.Lock()
 	defer s.collectionsMu.Unlock()
+
 	s.collections = make(map[string]*Collection)
 }
 
-// Driver returns the underlying *mgo.Session instance.
 func (s *Source) Driver() interface{} {
 	return s.session
 }
@@ -154,12 +166,24 @@ func (s *Source) Driver() interface{} {
 func (s *Source) open() error {
 	var err error
 
-	if s.session, err = mgo.DialWithTimeout(s.connURL.String(), connTimeout); err != nil {
-		return err
+	ctx, cancel := context.WithTimeout(context.Background(), connTimeout)
+	defer cancel()
+
+	opts := []*options.ClientOptions{
+		options.Client().ApplyURI(s.connURL.String()),
+	}
+
+	if s.session, err = mongo.Connect(ctx, opts...); err != nil {
+		return fmt.Errorf("mongo.Connect: %w", err)
 	}
 
 	s.collections = map[string]*Collection{}
-	s.database = s.session.DB("")
+	s.database = s.session.Database(settings.Database)
+
+	// ping
+	if err = s.Ping(); err != nil {
+		return fmt.Errorf("Ping: %w", err)
+	}
 
 	return nil
 }
@@ -167,23 +191,26 @@ func (s *Source) open() error {
 // Close terminates the current database session.
 func (s *Source) Close() error {
 	if s.session != nil {
-		s.session.Close()
+		s.session.Disconnect(context.Background())
 	}
+
 	return nil
 }
 
 // Collections returns a list of non-system tables from the database.
 func (s *Source) Collections() (cols []db.Collection, err error) {
-	var rawcols []string
+	ctx := context.Background()
+
+	var mgocols []string
 	var col string
 
-	if rawcols, err = s.database.CollectionNames(); err != nil {
-		return nil, err
+	if mgocols, err = s.database.ListCollectionNames(ctx, bson.D{}); err != nil {
+		return nil, fmt.Errorf("ListCollectionNames: %w", err)
 	}
 
-	cols = make([]db.Collection, 0, len(rawcols))
+	cols = make([]db.Collection, 0, len(mgocols))
 
-	for _, col = range rawcols {
+	for _, col = range mgocols {
 		if !strings.HasPrefix(col, "system.") {
 			cols = append(cols, s.Collection(col))
 		}
@@ -231,36 +258,10 @@ func (s *Source) Collection(name string) db.Collection {
 	if col, ok = s.collections[name]; !ok {
 		col = &Collection{
 			parent:     s,
-			collection: s.database.C(name),
+			collection: s.database.Collection(name),
 		}
 		s.collections[name] = col
 	}
 
 	return col
 }
-
-func (s *Source) versionAtLeast(version ...int) bool {
-	// only fetch this once - it makes a db call
-	if len(s.version) == 0 {
-		buildInfo, err := s.database.Session.BuildInfo()
-		if err != nil {
-			return false
-		}
-		s.version = buildInfo.VersionArray
-	}
-
-	// Check major version first
-	if s.version[0] > version[0] {
-		return true
-	}
-
-	for i := range version {
-		if i == len(s.version) {
-			return false
-		}
-		if s.version[i] < version[i] {
-			return false
-		}
-	}
-	return true
-}
diff --git a/adapter/mongo/docker-compose.yml b/adapter/mongo/docker-compose.yml
index af275258..4b34e183 100644
--- a/adapter/mongo/docker-compose.yml
+++ b/adapter/mongo/docker-compose.yml
@@ -1,5 +1,3 @@
-version: '3'
-
 services:
 
   server:
diff --git a/adapter/mongo/helper_test.go b/adapter/mongo/helper_test.go
index 15b3fdb9..266893c2 100644
--- a/adapter/mongo/helper_test.go
+++ b/adapter/mongo/helper_test.go
@@ -22,13 +22,15 @@
 package mongo
 
 import (
+	"context"
 	"fmt"
 	"os"
 
-	mgo "gopkg.in/mgo.v2"
-
 	db "github.com/upper/db/v4"
+
 	"github.com/upper/db/v4/internal/testsuite"
+
+	"go.mongodb.org/mongo-driver/mongo"
 )
 
 var settings = ConnectionURL{
@@ -54,7 +56,9 @@ func (h *Helper) TearDown() error {
 	return h.sess.Close()
 }
 
-func (h *Helper) TearUp() error {
+func (h *Helper) SetUp() error {
+	ctx := context.Background()
+
 	var err error
 
 	h.sess, err = Open(settings)
@@ -62,23 +66,23 @@ func (h *Helper) TearUp() error {
 		return err
 	}
 
-	mgod, ok := h.sess.Driver().(*mgo.Session)
+	mgdb, ok := h.sess.Driver().(*mongo.Client)
 	if !ok {
-		panic("expecting mgo.Session")
+		panic("expecting *mongo.Client")
 	}
 
-	var col *mgo.Collection
-	col = mgod.DB(settings.Database).C("birthdays")
-	_ = col.DropCollection()
+	var col *mongo.Collection
+	col = mgdb.Database(settings.Database).Collection("birthdays")
+	_ = col.Drop(ctx)
 
-	col = mgod.DB(settings.Database).C("fibonacci")
-	_ = col.DropCollection()
+	col = mgdb.Database(settings.Database).Collection("fibonacci")
+	_ = col.Drop(ctx)
 
-	col = mgod.DB(settings.Database).C("is_even")
-	_ = col.DropCollection()
+	col = mgdb.Database(settings.Database).Collection("is_even")
+	_ = col.Drop(ctx)
 
-	col = mgod.DB(settings.Database).C("CaSe_TesT")
-	_ = col.DropCollection()
+	col = mgdb.Database(settings.Database).Collection("CaSe_TesT")
+	_ = col.Drop(ctx)
 
 	// Getting a pointer to the "artist" collection.
 	artist := h.sess.Collection("artist")
@@ -89,7 +93,7 @@ func (h *Helper) TearUp() error {
 			Name: fmt.Sprintf("artist-%d", i),
 		})
 		if err != nil {
-			return err
+			return fmt.Errorf("insert: %w", err)
 		}
 	}
 
diff --git a/adapter/mongo/mongo_test.go b/adapter/mongo/mongo_test.go
index 65dd1e2a..e64b9f18 100644
--- a/adapter/mongo/mongo_test.go
+++ b/adapter/mongo/mongo_test.go
@@ -33,12 +33,13 @@ import (
 	"github.com/stretchr/testify/suite"
 	db "github.com/upper/db/v4"
 	"github.com/upper/db/v4/internal/testsuite"
-	"gopkg.in/mgo.v2/bson"
+	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/bson/primitive"
 )
 
 type artistType struct {
-	ID   bson.ObjectId `bson:"_id,omitempty"`
-	Name string        `bson:"name"`
+	ID   primitive.ObjectID `bson:"_id,omitempty"`
+	Name string             `bson:"name"`
 }
 
 // Structure for testing conversions and datatypes.
@@ -107,7 +108,7 @@ func (s *AdapterTests) TestOpenWithWrongData() {
 
 	// Attempt to open an empty database.
 	_, err = Open(rightSettings)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// Attempt to open with wrong password.
 	wrongSettings = ConnectionURL{
@@ -146,21 +147,21 @@ func (s *AdapterTests) TestOpenWithWrongData() {
 func (s *AdapterTests) TestTruncate() {
 	// Opening database.
 	sess, err := Open(settings)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// We should close the database when it's no longer in use.
 	defer sess.Close()
 
 	// Getting a list of all collections in this database.
 	collections, err := sess.Collections()
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	for _, col := range collections {
 		// The collection may ot may not exists.
 		if ok, _ := col.Exists(); ok {
 			// Truncating the structure, if exists.
 			err = col.Truncate()
-			s.NoError(err)
+			s.Require().NoError(err)
 		}
 	}
 }
@@ -168,7 +169,7 @@ func (s *AdapterTests) TestTruncate() {
 func (s *AdapterTests) TestInsert() {
 	// Opening database.
 	sess, err := Open(settings)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// We should close the database when it's no longer in use.
 	defer sess.Close()
@@ -181,15 +182,16 @@ func (s *AdapterTests) TestInsert() {
 	record, err := artist.Insert(map[string]string{
 		"name": "Ozzie",
 	})
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	id := record.ID()
 	s.NotZero(record.ID())
 
-	_, ok := id.(bson.ObjectId)
+	_, ok := id.(primitive.ObjectID)
 	s.True(ok)
 
-	s.True(id.(bson.ObjectId).Valid())
+	_, err = primitive.ObjectIDFromHex(id.(primitive.ObjectID).Hex())
+	s.Require().NoError(err)
 
 	// Inserting a struct.
 	record, err = artist.Insert(struct {
@@ -197,14 +199,16 @@ func (s *AdapterTests) TestInsert() {
 	}{
 		"Flea",
 	})
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	id = record.ID()
 	s.NotZero(id)
 
-	_, ok = id.(bson.ObjectId)
+	_, ok = id.(primitive.ObjectID)
 	s.True(ok)
-	s.True(id.(bson.ObjectId).Valid())
+
+	_, err = primitive.ObjectIDFromHex(id.(primitive.ObjectID).Hex())
+	s.Require().NoError(err)
 
 	// Inserting a struct (using tags to specify the field name).
 	record, err = artist.Insert(struct {
@@ -212,15 +216,17 @@ func (s *AdapterTests) TestInsert() {
 	}{
 		"Slash",
 	})
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	id = record.ID()
 	s.NotNil(id)
 
-	_, ok = id.(bson.ObjectId)
+	_, ok = id.(primitive.ObjectID)
 
 	s.True(ok)
-	s.True(id.(bson.ObjectId).Valid())
+
+	_, err = primitive.ObjectIDFromHex(id.(primitive.ObjectID).Hex())
+	s.Require().NoError(err)
 
 	// Inserting a pointer to a struct
 	record, err = artist.Insert(&struct {
@@ -228,40 +234,43 @@ func (s *AdapterTests) TestInsert() {
 	}{
 		"Metallica",
 	})
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	id = record.ID()
 	s.NotNil(id)
 
-	_, ok = id.(bson.ObjectId)
+	_, ok = id.(primitive.ObjectID)
 	s.True(ok)
-	s.True(id.(bson.ObjectId).Valid())
+
+	_, err = primitive.ObjectIDFromHex(id.(primitive.ObjectID).Hex())
+	s.Require().NoError(err)
 
 	// Inserting a pointer to a map
 	record, err = artist.Insert(&map[string]string{
 		"name": "Freddie",
 	})
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.NotZero(id)
 
-	_, ok = id.(bson.ObjectId)
+	_, ok = id.(primitive.ObjectID)
 	s.True(ok)
 
 	id = record.ID()
 	s.NotNil(id)
 
-	s.True(id.(bson.ObjectId).Valid())
+	_, err = primitive.ObjectIDFromHex(id.(primitive.ObjectID).Hex())
+	s.Require().NoError(err)
 
 	// Counting elements, must be exactly 6 elements.
 	total, err := artist.Find().Count()
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.Equal(uint64(5), total)
 }
 
 func (s *AdapterTests) TestGetNonExistentRow_Issue426() {
 	// Opening database.
 	sess, err := Open(settings)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	defer sess.Close()
 
@@ -276,7 +285,7 @@ func (s *AdapterTests) TestGetNonExistentRow_Issue426() {
 	var all []artistType
 	err = artist.Find(db.Cond{"name": "nothing"}).All(&all)
 
-	s.Zero(err, "All should not return mgo.ErrNotFound")
+	s.Zero(len(all), "All should return an empty slice")
 	s.Equal(0, len(all))
 }
 
@@ -286,7 +295,7 @@ func (s *AdapterTests) TestResultCount() {
 
 	// Opening database.
 	sess, err := Open(settings)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	defer sess.Close()
 
@@ -297,7 +306,7 @@ func (s *AdapterTests) TestResultCount() {
 
 	// Counting all the matching rows.
 	total, err := res.Count()
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.NotZero(total)
 }
 
@@ -305,7 +314,7 @@ func (s *AdapterTests) TestGroup() {
 	var stats db.Collection
 
 	sess, err := Open(settings)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	type statsT struct {
 		Numeric int `db:"numeric" bson:"numeric"`
@@ -323,7 +332,7 @@ func (s *AdapterTests) TestGroup() {
 	for i := 0; i < 1000; i++ {
 		numeric, value := rand.Intn(10), rand.Intn(100)
 		_, err = stats.Insert(statsT{numeric, value})
-		s.NoError(err)
+		s.Require().NoError(err)
 	}
 
 	// db.statsTest.group({key: {numeric: true}, initial: {sum: 0}, reduce: function(doc, prev) { prev.sum += 1}});
@@ -343,12 +352,12 @@ func (s *AdapterTests) TestGroup() {
 
 func (s *AdapterTests) TestResultNonExistentCount() {
 	sess, err := Open(settings)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	defer sess.Close()
 
 	total, err := sess.Collection("notartist").Find().Count()
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.Zero(total)
 }
 
@@ -356,7 +365,7 @@ func (s *AdapterTests) TestResultFetch() {
 
 	// Opening database.
 	sess, err := Open(settings)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// We should close the database when it's no longer in use.
 	defer sess.Close()
@@ -371,10 +380,11 @@ func (s *AdapterTests) TestResultFetch() {
 	for res.Next(&rowM) {
 		s.NotZero(rowM["_id"])
 
-		_, ok := rowM["_id"].(bson.ObjectId)
+		_, ok := rowM["_id"].(primitive.ObjectID)
 		s.True(ok)
 
-		s.True(rowM["_id"].(bson.ObjectId).Valid())
+		_, err := primitive.ObjectIDFromHex(rowM["_id"].(primitive.ObjectID).Hex())
+		s.Require().NoError(err)
 
 		name, ok := rowM["name"].(string)
 		s.True(ok)
@@ -382,46 +392,50 @@ func (s *AdapterTests) TestResultFetch() {
 	}
 
 	err = res.Close()
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// Testing struct
 	rowS := struct {
-		ID   bson.ObjectId `bson:"_id"`
-		Name string        `bson:"name"`
+		ID   primitive.ObjectID `bson:"_id"`
+		Name string             `bson:"name"`
 	}{}
 
 	res = artist.Find()
 
 	for res.Next(&rowS) {
-		s.True(rowS.ID.Valid())
+		_, err := primitive.ObjectIDFromHex(rowS.ID.Hex())
+		s.Require().NoError(err)
+
 		s.NotZero(rowS.Name)
 	}
 
 	err = res.Close()
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// Testing tagged struct
 	rowT := struct {
-		Value1 bson.ObjectId `bson:"_id"`
-		Value2 string        `bson:"name"`
+		Value1 primitive.ObjectID `bson:"_id"`
+		Value2 string             `bson:"name"`
 	}{}
 
 	res = artist.Find()
 
 	for res.Next(&rowT) {
-		s.True(rowT.Value1.Valid())
+		_, err := primitive.ObjectIDFromHex(rowT.Value1.Hex())
+		s.Require().NoError(err)
+
 		s.NotZero(rowT.Value2)
 	}
 
 	err = res.Close()
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// Testing Result.All() with a slice of maps.
 	res = artist.Find()
 
 	allRowsM := []map[string]interface{}{}
 	err = res.All(&allRowsM)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	for _, singleRowM := range allRowsM {
 		s.NotZero(singleRowM["_id"])
@@ -431,35 +445,37 @@ func (s *AdapterTests) TestResultFetch() {
 	res = artist.Find()
 
 	allRowsS := []struct {
-		ID   bson.ObjectId `bson:"_id"`
+		ID   primitive.ObjectID `bson:"_id"`
 		Name string
 	}{}
 	err = res.All(&allRowsS)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	for _, singleRowS := range allRowsS {
-		s.True(singleRowS.ID.Valid())
+		_, err := primitive.ObjectIDFromHex(singleRowS.ID.Hex())
+		s.Require().NoError(err)
 	}
 
 	// Testing Result.All() with a slice of tagged structs.
 	res = artist.Find()
 
 	allRowsT := []struct {
-		Value1 bson.ObjectId `bson:"_id"`
-		Value2 string        `bson:"name"`
+		Value1 primitive.ObjectID `bson:"_id"`
+		Value2 string             `bson:"name"`
 	}{}
 	err = res.All(&allRowsT)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	for _, singleRowT := range allRowsT {
-		s.True(singleRowT.Value1.Valid())
+		_, err := primitive.ObjectIDFromHex(singleRowT.Value1.Hex())
+		s.Require().NoError(err)
 	}
 }
 
 func (s *AdapterTests) TestUpdate() {
 	// Opening database.
 	sess, err := Open(settings)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// We should close the database when it's no longer in use.
 	defer sess.Close()
@@ -469,7 +485,7 @@ func (s *AdapterTests) TestUpdate() {
 
 	// Value
 	value := struct {
-		ID   bson.ObjectId `bson:"_id"`
+		ID   primitive.ObjectID `bson:"_id"`
 		Name string
 	}{}
 
@@ -477,7 +493,7 @@ func (s *AdapterTests) TestUpdate() {
 	res := artist.Find(db.Cond{"_id": db.NotEq(nil)}).Limit(1)
 
 	err = res.One(&value)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// Updating with a map
 	rowM := map[string]interface{}{
@@ -485,10 +501,10 @@ func (s *AdapterTests) TestUpdate() {
 	}
 
 	err = res.Update(rowM)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	err = res.One(&value)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	s.Equal(value.Name, rowM["name"])
 
@@ -498,10 +514,10 @@ func (s *AdapterTests) TestUpdate() {
 	}{strings.ToLower(value.Name)}
 
 	err = res.Update(rowS)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	err = res.One(&value)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	s.Equal(value.Name, rowS.Name)
 
@@ -511,10 +527,10 @@ func (s *AdapterTests) TestUpdate() {
 	}{strings.Replace(value.Name, "z", "Z", -1)}
 
 	err = res.Update(rowT)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	err = res.One(&value)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	s.Equal(value.Name, rowT.Value1)
 }
@@ -522,7 +538,7 @@ func (s *AdapterTests) TestUpdate() {
 func (s *AdapterTests) TestOperators() {
 	// Opening database.
 	sess, err := Open(settings)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// We should close the database when it's no longer in use.
 	defer sess.Close()
@@ -538,16 +554,16 @@ func (s *AdapterTests) TestOperators() {
 	res := artist.Find(db.Cond{"_id": db.NotIn(0, -1)})
 
 	err = res.One(&rowS)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	err = res.Close()
-	s.NoError(err)
+	s.Require().NoError(err)
 }
 
 func (s *AdapterTests) TestDelete() {
 	// Opening database.
 	sess, err := Open(settings)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// We should close the database when it's no longer in use.
 	defer sess.Close()
@@ -559,23 +575,23 @@ func (s *AdapterTests) TestDelete() {
 	res := artist.Find(db.Cond{"_id": db.NotEq(nil)}).Limit(1)
 
 	var first struct {
-		ID bson.ObjectId `bson:"_id"`
+		ID primitive.ObjectID `bson:"_id"`
 	}
 
 	err = res.One(&first)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	res = artist.Find(db.Cond{"_id": db.Eq(first.ID)})
 
 	// Trying to remove the row.
 	err = res.Delete()
-	s.NoError(err)
+	s.Require().NoError(err)
 }
 
 func (s *AdapterTests) TestDataTypes() {
 	// Opening database.
 	sess, err := Open(settings)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// We should close the database when it's no longer in use.
 	defer sess.Close()
@@ -585,7 +601,7 @@ func (s *AdapterTests) TestDataTypes() {
 
 	// Inserting our test subject.
 	record, err := dataTypes.Insert(testValues)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	id := record.ID()
 	s.NotZero(id)
@@ -594,13 +610,18 @@ func (s *AdapterTests) TestDataTypes() {
 	res := dataTypes.Find(db.Cond{"_id": db.Eq(id)})
 
 	exists, err := res.Count()
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.NotZero(exists)
 
 	// Trying to dump the subject into an empty structure of the same type.
 	var item testValuesStruct
 	err = res.One(&item)
-	s.NoError(err)
+	s.Require().NoError(err)
+
+	// Convert dates to local time for comparison.
+	testValues.Date = testValues.Date.Local()
+	item.Date = item.Date.Local()
+	*item.DateP = item.DateP.Local()
 
 	// The original value and the test subject must match.
 	s.Equal(testValues, item)
@@ -609,7 +630,7 @@ func (s *AdapterTests) TestDataTypes() {
 func (s *AdapterTests) TestPaginator() {
 	// Opening database.
 	sess, err := Open(settings)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// We should close the database when it's no longer in use.
 	defer sess.Close()
@@ -618,13 +639,13 @@ func (s *AdapterTests) TestPaginator() {
 	artist := sess.Collection("artist")
 
 	err = artist.Truncate()
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	for i := 0; i < 999; i++ {
 		_, err = artist.Insert(artistType{
 			Name: fmt.Sprintf("artist-%d", i),
 		})
-		s.NoError(err)
+		s.Require().NoError(err)
 	}
 
 	q := sess.Collection("artist").Find().Paginate(15)
@@ -632,37 +653,37 @@ func (s *AdapterTests) TestPaginator() {
 
 	var zerothPage []artistType
 	err = paginator.Page(0).All(&zerothPage)
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.Equal(13, len(zerothPage))
 
 	var secondPage []artistType
 	err = paginator.Page(2).All(&secondPage)
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.Equal(13, len(secondPage))
 
 	tp, err := paginator.TotalPages()
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.NotZero(tp)
 	s.Equal(uint(77), tp)
 
 	ti, err := paginator.TotalEntries()
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.NotZero(ti)
 	s.Equal(uint64(999), ti)
 
 	var seventySixthPage []artistType
 	err = paginator.Page(76).All(&seventySixthPage)
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.Equal(11, len(seventySixthPage))
 
 	var seventySeventhPage []artistType
 	err = paginator.Page(77).All(&seventySeventhPage)
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.Equal(0, len(seventySeventhPage))
 
 	var hundredthPage []artistType
 	err = paginator.Page(100).All(&hundredthPage)
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.Equal(0, len(hundredthPage))
 
 	for i := uint(0); i < tp; i++ {
@@ -670,7 +691,7 @@ func (s *AdapterTests) TestPaginator() {
 
 		var items []artistType
 		err := current.All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		if len(items) < 1 {
 			break
 		}
@@ -685,7 +706,7 @@ func (s *AdapterTests) TestPaginator() {
 		for i := 0; ; i++ {
 			var items []artistType
 			err := current.All(&items)
-			s.NoError(err)
+			s.Require().NoError(err)
 
 			if len(items) < 1 {
 				break
@@ -705,7 +726,7 @@ func (s *AdapterTests) TestPaginator() {
 			var items []artistType
 
 			err := current.All(&items)
-			s.NoError(err)
+			s.Require().NoError(err)
 
 			if len(items) < 1 {
 				s.Equal(0, len(items))
@@ -724,11 +745,11 @@ func (s *AdapterTests) TestPaginator() {
 
 		count, err := resultPaginator.TotalPages()
 		s.Equal(uint(67), count)
-		s.NoError(err)
+		s.Require().NoError(err)
 
 		var items []artistType
 		err = resultPaginator.Page(5).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 
 		for j := 0; j < len(items); j++ {
 			s.Equal(fmt.Sprintf("artist-%d", 15*5+j), items[j].Name)
@@ -739,7 +760,7 @@ func (s *AdapterTests) TestPaginator() {
 			var items []artistType
 
 			err = resultPaginator.All(&items)
-			s.NoError(err)
+			s.Require().NoError(err)
 
 			if len(items) < 1 {
 				break
@@ -756,7 +777,7 @@ func (s *AdapterTests) TestPaginator() {
 			var items []artistType
 
 			err = resultPaginator.All(&items)
-			s.NoError(err)
+			s.Require().NoError(err)
 
 			if len(items) < 1 {
 				break
diff --git a/adapter/mongo/result.go b/adapter/mongo/result.go
index 8c1982f2..c1b8ba4a 100644
--- a/adapter/mongo/result.go
+++ b/adapter/mongo/result.go
@@ -22,6 +22,7 @@
 package mongo
 
 import (
+	"context"
 	"errors"
 	"fmt"
 	"math"
@@ -32,8 +33,9 @@ import (
 	"encoding/json"
 
 	db "github.com/upper/db/v4"
-	mgo "gopkg.in/mgo.v2"
-	"gopkg.in/mgo.v2/bson"
+	"go.mongodb.org/mongo-driver/bson"
+	"go.mongodb.org/mongo-driver/mongo"
+	"go.mongodb.org/mongo-driver/mongo/options"
 
 	"github.com/upper/db/v4/internal/immutable"
 )
@@ -57,7 +59,8 @@ type resultQuery struct {
 }
 
 type result struct {
-	iter  *mgo.Iter
+	cur *mongo.Cursor
+
 	err   error
 	errMu sync.Mutex
 
@@ -237,10 +240,11 @@ func (res *result) All(dst interface{}) error {
 		})
 	}(time.Now())
 
-	err = q.All(dst)
-	if errors.Is(err, mgo.ErrNotFound) {
+	err = q.All(context.Background(), dst)
+	if errors.Is(err, mongo.ErrNoDocuments) {
 		return db.ErrNoMoreRows
 	}
+
 	return err
 }
 
@@ -255,6 +259,8 @@ func (res *result) GroupBy(fields ...interface{}) db.Result {
 
 // One fetches only one result from the resultset.
 func (res *result) One(dst interface{}) error {
+	ctx := context.Background()
+
 	rq, err := res.build()
 	if err != nil {
 		return err
@@ -274,10 +280,20 @@ func (res *result) One(dst interface{}) error {
 		})
 	}(time.Now())
 
-	err = q.One(dst)
-	if errors.Is(err, mgo.ErrNotFound) {
+	if !q.Next(ctx) {
+		if q.Err() != nil {
+			return q.Err()
+		}
 		return db.ErrNoMoreRows
 	}
+
+	defer q.Close(ctx)
+
+	err = q.Decode(dst)
+	if errors.Is(err, mongo.ErrNoDocuments) {
+		return db.ErrNoMoreRows
+	}
+
 	return err
 }
 
@@ -295,7 +311,9 @@ func (res *result) setErr(err error) {
 }
 
 func (res *result) Next(dst interface{}) bool {
-	if res.iter == nil {
+	ctx := context.Background()
+
+	if res.cur == nil {
 		rq, err := res.build()
 		if err != nil {
 			return false
@@ -315,11 +333,17 @@ func (res *result) Next(dst interface{}) bool {
 			})
 		}(time.Now())
 
-		res.iter = q.Iter()
+		res.cur = q
 	}
 
-	if !res.iter.Next(dst) {
-		res.setErr(res.iter.Err())
+	if !res.cur.Next(ctx) {
+		res.setErr(res.cur.Err())
+		return false
+	}
+
+	err := res.cur.Decode(dst)
+	if err != nil {
+		res.setErr(err)
 		return false
 	}
 
@@ -328,6 +352,8 @@ func (res *result) Next(dst interface{}) bool {
 
 // Delete remove the matching items from the collection.
 func (res *result) Delete() error {
+	ctx := context.Background()
+
 	rq, err := res.build()
 	if err != nil {
 		return err
@@ -342,7 +368,7 @@ func (res *result) Delete() error {
 		})
 	}(time.Now())
 
-	_, err = rq.c.collection.RemoveAll(rq.conditions)
+	_, err = rq.c.collection.DeleteMany(ctx, rq.conditions)
 	if err != nil {
 		return err
 	}
@@ -352,17 +378,22 @@ func (res *result) Delete() error {
 
 // Close closes the result set.
 func (r *result) Close() error {
+	ctx := context.Background()
 	var err error
-	if r.iter != nil {
-		err = r.iter.Close()
-		r.iter = nil
+
+	if r.cur != nil {
+		err = r.cur.Close(ctx)
+		r.cur = nil
 	}
+
 	return err
 }
 
 // Update modified matching items from the collection with values of the given
 // map or struct.
 func (res *result) Update(src interface{}) (err error) {
+	ctx := context.Background()
+
 	updateSet := map[string]interface{}{"$set": src}
 
 	rq, err := res.build()
@@ -379,7 +410,7 @@ func (res *result) Update(src interface{}) (err error) {
 		})
 	}(time.Now())
 
-	_, err = rq.c.collection.UpdateAll(rq.conditions, updateSet)
+	_, err = rq.c.collection.UpdateMany(ctx, rq.conditions, updateSet)
 	if err != nil {
 		return err
 	}
@@ -406,32 +437,47 @@ func (res *result) build() (*resultQuery, error) {
 			rq.sort = append(rq.sort, rq.cursorColumn)
 		}
 	}
+
+	if rq.conditions == nil {
+		rq.conditions = bson.D{}
+	}
+
 	return rq, nil
 }
 
-// query executes a mgo query.
-func (r *resultQuery) query() (*mgo.Query, error) {
+// query executes a mongo query.
+func (r *resultQuery) query() (*mongo.Cursor, error) {
+	ctx := context.Background()
+
+	opts := options.Find()
+
 	if len(r.groupBy) > 0 {
 		return nil, db.ErrUnsupported
 	}
 
-	q := r.c.collection.Find(r.conditions)
-
 	if r.pageSize > 0 {
 		r.offset = int(r.pageSize * r.pageNumber)
 		r.limit = int(r.pageSize)
 	}
 
 	if r.offset > 0 {
-		q.Skip(r.offset)
+		opts.SetSkip(int64(r.offset))
 	}
 
 	if r.limit > 0 {
-		q.Limit(r.limit)
+		opts.SetLimit(int64(r.limit))
 	}
 
 	if len(r.sort) > 0 {
-		q.Sort(r.sort...)
+		sort := bson.D{}
+		for _, field := range r.sort {
+			key, value := field, 1
+			if key[0] == '-' {
+				key, value = key[1:], -1
+			}
+			sort = append(sort, bson.E{Key: key, Value: value})
+		}
+		opts.SetSort(sort)
 	}
 
 	selectedFields := bson.M{}
@@ -445,26 +491,36 @@ func (r *resultQuery) query() (*mgo.Query, error) {
 	}
 
 	if r.cursorReverseOrder {
-		ids := make([]bson.ObjectId, 0, r.limit)
+		opts.SetSort(bson.D{{"_id", -1}})
+	}
 
-		iter := q.Select(bson.M{"_id": true}).Iter()
-		defer iter.Close()
+	if len(selectedFields) > 0 {
+		panic("not implemented")
+	}
 
-		var item map[string]bson.ObjectId
-		for iter.Next(&item) {
-			ids = append(ids, item["_id"])
-		}
+	q, err := r.c.collection.Find(ctx, r.conditions, opts)
+	if err != nil {
+		return nil, err
+	}
+
+	return q, nil
+}
+
+func (r *resultQuery) count() (int64, error) {
+	ctx := context.Background()
 
-		r.conditions = bson.M{"_id": bson.M{"$in": ids}}
+	opts := options.Count()
 
-		q = r.c.collection.Find(r.conditions)
+	if len(r.groupBy) > 0 {
+		return 0, db.ErrUnsupported
 	}
 
-	if len(selectedFields) > 0 {
-		q.Select(selectedFields)
+	n, err := r.c.collection.CountDocuments(ctx, r.conditions, opts)
+	if err != nil {
+		return 0, fmt.Errorf("CountDocuments: %w", err)
 	}
 
-	return q, nil
+	return n, nil
 }
 
 func (res *result) Exists() (bool, error) {
@@ -472,14 +528,20 @@ func (res *result) Exists() (bool, error) {
 	if err != nil {
 		return false, err
 	}
+
 	if total > 0 {
 		return true, nil
 	}
+
 	return false, nil
 }
 
 // Count counts matching elements.
 func (res *result) Count() (total uint64, err error) {
+	if res == nil {
+		return 0, nil
+	}
+
 	rq, err := res.build()
 	if err != nil {
 		return 0, err
@@ -487,19 +549,19 @@ func (res *result) Count() (total uint64, err error) {
 
 	defer func(start time.Time) {
 		queryLog(&db.QueryStatus{
-			RawQuery: rq.debugQuery("Find.Count"),
+			RawQuery: rq.debugQuery("Count"),
 			Err:      err,
 			Start:    start,
 			End:      time.Now(),
 		})
 	}(time.Now())
 
-	q := rq.c.collection.Find(rq.conditions)
-
-	var c int
-	c, err = q.Count()
+	count, err := rq.count()
+	if err != nil {
+		return 0, err
+	}
 
-	return uint64(c), err
+	return uint64(count), nil
 }
 
 func (res *result) Prev() immutable.Immutable {
@@ -521,7 +583,7 @@ func (res *result) Base() interface{} {
 }
 
 func (r *resultQuery) debugQuery(action string) string {
-	query := fmt.Sprintf("db.%s.%s", r.c.collection.Name, action)
+	query := fmt.Sprintf("db.%s.%s", r.c.collection.Name(), action)
 
 	if r.conditions != nil {
 		query = fmt.Sprintf("%s.conds(%v)", query, r.conditions)
diff --git a/adapter/mssql/helper_test.go b/adapter/mssql/helper_test.go
index b3016cad..83f20134 100644
--- a/adapter/mssql/helper_test.go
+++ b/adapter/mssql/helper_test.go
@@ -53,7 +53,7 @@ func (h *Helper) TearDown() error {
 	return h.sess.Close()
 }
 
-func (h *Helper) TearUp() error {
+func (h *Helper) SetUp() error {
 	var err error
 
 	h.sess, err = Open(settings)
diff --git a/adapter/mysql/helper_test.go b/adapter/mysql/helper_test.go
index 74f83ae8..671851bb 100644
--- a/adapter/mysql/helper_test.go
+++ b/adapter/mysql/helper_test.go
@@ -116,7 +116,7 @@ func (h *Helper) TearDown() error {
 	return h.sess.Close()
 }
 
-func (h *Helper) TearUp() error {
+func (h *Helper) SetUp() error {
 	var err error
 
 	h.sess, err = Open(settings)
diff --git a/adapter/postgresql/helper_test.go b/adapter/postgresql/helper_test.go
index 6f2dbfa6..a5a8da02 100644
--- a/adapter/postgresql/helper_test.go
+++ b/adapter/postgresql/helper_test.go
@@ -98,7 +98,7 @@ func (h *Helper) TearDown() error {
 	return h.sess.Close()
 }
 
-func (h *Helper) TearUp() error {
+func (h *Helper) SetUp() error {
 	var err error
 
 	h.sess, err = Open(settings)
diff --git a/adapter/ql/helper_test.go b/adapter/ql/helper_test.go
index a8b49c69..79de2a9e 100644
--- a/adapter/ql/helper_test.go
+++ b/adapter/ql/helper_test.go
@@ -53,7 +53,7 @@ func (h *Helper) TearDown() error {
 	return h.sess.Close()
 }
 
-func (h *Helper) TearUp() error {
+func (h *Helper) SetUp() error {
 	var err error
 
 	h.sess, err = Open(settings)
diff --git a/adapter/sqlite/helper_test.go b/adapter/sqlite/helper_test.go
index 7c3de1a7..052f7643 100644
--- a/adapter/sqlite/helper_test.go
+++ b/adapter/sqlite/helper_test.go
@@ -49,7 +49,7 @@ func (h *Helper) TearDown() error {
 	return h.sess.Close()
 }
 
-func (h *Helper) TearUp() error {
+func (h *Helper) SetUp() error {
 	var err error
 
 	h.sess, err = Open(settings)
diff --git a/go.mod b/go.mod
index 0621be26..d0b6755d 100644
--- a/go.mod
+++ b/go.mod
@@ -10,15 +10,15 @@ require (
 	github.com/ipfs/go-detect-race v0.0.1
 	github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 // indirect
 	github.com/jackc/pgtype v1.14.3
-	github.com/jackc/pgx/v4 v4.18.3
-	github.com/jackc/pgx/v5 v5.6.0 // indirect
+	github.com/jackc/pgx/v4 v4.18.3 // indirect
+	github.com/jackc/pgx/v5 v5.6.0
 	github.com/lib/pq v1.10.9
 	github.com/mattn/go-sqlite3 v1.14.22
 	github.com/segmentio/fasthash v1.0.3
 	github.com/sirupsen/logrus v1.9.3
 	github.com/stretchr/testify v1.9.0
+	go.mongodb.org/mongo-driver v1.16.1
 	golang.org/x/crypto v0.24.0 // indirect
-	gopkg.in/mgo.v2 v2.0.0-20190816093944-a6b53ec6cb22
 	modernc.org/b v1.1.0 // indirect
 	modernc.org/db v1.0.10 // indirect
 	modernc.org/file v1.0.8 // indirect
diff --git a/go.sum b/go.sum
index dbeef3e5..a343456a 100644
--- a/go.sum
+++ b/go.sum
@@ -22,8 +22,6 @@ github.com/edsrzf/mmap-go v1.1.0 h1:6EUwBLQ/Mcr1EYLE4Tn1VdW1A4ckqCQWZBw8Hr0kjpQ=
 github.com/edsrzf/mmap-go v1.1.0/go.mod h1:19H/e8pUPLicwkyNgOykDXkJ9F0MHE+Z52B8EIth78Q=
 github.com/go-kit/log v0.1.0/go.mod h1:zbhenjAZHb184qTLMA9ZjW7ThYL0H2mk7Q6pNt4vbaY=
 github.com/go-logfmt/logfmt v0.5.0/go.mod h1:wCYkCAKZfumFQihp8CzCvQ3paCTfi41vtzG1KdI/P7A=
-github.com/go-sql-driver/mysql v1.7.1 h1:lUIinVbN1DY0xBg0eMOzmmtGoHwWBbvnWubQUrtU8EI=
-github.com/go-sql-driver/mysql v1.7.1/go.mod h1:OXbVy3sEdcQ2Doequ6Z5BW6fXNQTmx+9S1MCJN5yJMI=
 github.com/go-sql-driver/mysql v1.8.1 h1:LedoTUt/eveggdHS9qUFC1EFSa8bU2+1pZjSRpvNJ1Y=
 github.com/go-sql-driver/mysql v1.8.1/go.mod h1:wEBSXgmK//2ZFJyE+qWnIsVGmvmEKlqwuVSjsCm7DZg=
 github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY=
@@ -34,8 +32,10 @@ github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 h1:au07oEsX2xN0kt
 github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
 github.com/golang-sql/sqlexp v0.1.0 h1:ZCD6MBpcuOVfGVqsEmY5/4FtYiKz6tSyUv9LPEDei6A=
 github.com/golang-sql/sqlexp v0.1.0/go.mod h1:J4ad9Vo8ZCWQ2GMrC4UCQy1JpCbwU9m3EOqtpKwwwHI=
-github.com/golang/snappy v0.0.3 h1:fHPg5GQYlCeLIPB9BZqMVR5nR9A+IM5zcgeTdjMYmLA=
 github.com/golang/snappy v0.0.3/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
+github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM=
+github.com/golang/snappy v0.0.4/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
+github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
 github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
 github.com/google/uuid v1.1.1 h1:Gkbcsh/GbpXz7lPftLA3P6TYMwjCLYm83jiFQZF/3gY=
@@ -53,9 +53,6 @@ github.com/jackc/pgconn v0.0.0-20190831204454-2fabfa3c18b7/go.mod h1:ZJKsE/KZfsU
 github.com/jackc/pgconn v1.8.0/go.mod h1:1C2Pb36bGIP9QHGBYCjnyhqu7Rv3sGshaQUvmfGIB/o=
 github.com/jackc/pgconn v1.9.0/go.mod h1:YctiPyvzfU11JFxoXokUOOKQXQmDMoJL9vJzHH8/2JY=
 github.com/jackc/pgconn v1.9.1-0.20210724152538-d89c8390a530/go.mod h1:4z2w8XhRbP1hYxkpTuBjTS3ne3J48K83+u0zoyvg2pI=
-github.com/jackc/pgconn v1.14.0/go.mod h1:9mBNlny0UvkgJdCDvdVHYSjI+8tD2rnKK69Wz8ti++E=
-github.com/jackc/pgconn v1.14.1 h1:smbxIaZA08n6YuxEX1sDyjV/qkbtUtkH20qLkR9MUR4=
-github.com/jackc/pgconn v1.14.1/go.mod h1:9mBNlny0UvkgJdCDvdVHYSjI+8tD2rnKK69Wz8ti++E=
 github.com/jackc/pgconn v1.14.3 h1:bVoTr12EGANZz66nZPkMInAV/KHD2TxH9npjXXgiB3w=
 github.com/jackc/pgconn v1.14.3/go.mod h1:RZbme4uasqzybK2RK5c65VsHxoyaml09lx3tXOcO/VM=
 github.com/jackc/pgio v1.0.0 h1:g12B9UwVnzGhueNavwioyEEpAmqMe1E/BN9ES+8ovkE=
@@ -74,12 +71,9 @@ github.com/jackc/pgproto3/v2 v2.0.0-rc3/go.mod h1:ryONWYqW6dqSg1Lw6vXNMXoBJhpzvW
 github.com/jackc/pgproto3/v2 v2.0.0-rc3.0.20190831210041-4c03ce451f29/go.mod h1:ryONWYqW6dqSg1Lw6vXNMXoBJhpzvWKnT95C46ckYeM=
 github.com/jackc/pgproto3/v2 v2.0.6/go.mod h1:WfJCnwN3HIg9Ish/j3sgWXnAfK8A9Y0bwXYU5xKaEdA=
 github.com/jackc/pgproto3/v2 v2.1.1/go.mod h1:WfJCnwN3HIg9Ish/j3sgWXnAfK8A9Y0bwXYU5xKaEdA=
-github.com/jackc/pgproto3/v2 v2.3.2 h1:7eY55bdBeCz1F2fTzSz69QC+pG46jYq9/jtSPiJ5nn0=
-github.com/jackc/pgproto3/v2 v2.3.2/go.mod h1:WfJCnwN3HIg9Ish/j3sgWXnAfK8A9Y0bwXYU5xKaEdA=
 github.com/jackc/pgproto3/v2 v2.3.3 h1:1HLSx5H+tXR9pW3in3zaztoEwQYRC9SQaYUHjTSUOag=
 github.com/jackc/pgproto3/v2 v2.3.3/go.mod h1:WfJCnwN3HIg9Ish/j3sgWXnAfK8A9Y0bwXYU5xKaEdA=
 github.com/jackc/pgservicefile v0.0.0-20200714003250-2b9c44734f2b/go.mod h1:vsD4gTJCa9TptPL8sPkXrLZ+hDuNrZCnj29CQpr4X1E=
-github.com/jackc/pgservicefile v0.0.0-20221227161230-091c0ba34f0a h1:bbPeKD0xmW/Y25WS6cokEszi5g+S0QxI/d45PkRi7Nk=
 github.com/jackc/pgservicefile v0.0.0-20221227161230-091c0ba34f0a/go.mod h1:5TJZWKEWniPve33vlWYSoGYefn3gLQRzjfDlhSJ9ZKM=
 github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 h1:iCEnooe7UlwOQYpKFhBabPMi4aNAfoODPEFNiAnClxo=
 github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761/go.mod h1:5TJZWKEWniPve33vlWYSoGYefn3gLQRzjfDlhSJ9ZKM=
@@ -87,7 +81,6 @@ github.com/jackc/pgtype v0.0.0-20190421001408-4ed0de4755e0/go.mod h1:hdSHsc1V01C
 github.com/jackc/pgtype v0.0.0-20190824184912-ab885b375b90/go.mod h1:KcahbBH1nCMSo2DXpzsoWOAfFkdEtEJpPbVLq8eE+mc=
 github.com/jackc/pgtype v0.0.0-20190828014616-a8802b16cc59/go.mod h1:MWlu30kVJrUS8lot6TQqcg7mtthZ9T0EoIBFiJcmcyw=
 github.com/jackc/pgtype v1.8.1-0.20210724151600-32e20a603178/go.mod h1:C516IlIV9NKqfsMCXTdChteoXmwgUceqaLfjg2e3NlM=
-github.com/jackc/pgtype v1.14.0 h1:y+xUdabmyMkJLyApYuPj38mW+aAIqCe5uuBB51rH3Vw=
 github.com/jackc/pgtype v1.14.0/go.mod h1:LUMuVrfsFfdKGLw+AFFVv6KtHOFMwRgDDzBt76IqCA4=
 github.com/jackc/pgtype v1.14.3 h1:h6W9cPuHsRWQFTWUZMAKMgG5jSwQI0Zurzdvlx3Plus=
 github.com/jackc/pgtype v1.14.3/go.mod h1:aKeozOde08iifGosdJpz9MBZonJOUJxqNpPBcMJTlVA=
@@ -95,8 +88,6 @@ github.com/jackc/pgx/v4 v4.0.0-20190420224344-cc3461e65d96/go.mod h1:mdxmSJJuR08
 github.com/jackc/pgx/v4 v4.0.0-20190421002000-1b8f0016e912/go.mod h1:no/Y67Jkk/9WuGR0JG/JseM9irFbnEPbuWV2EELPNuM=
 github.com/jackc/pgx/v4 v4.0.0-pre1.0.20190824185557-6972a5742186/go.mod h1:X+GQnOEnf1dqHGpw7JmHqHc1NxDoalibchSk9/RWuDc=
 github.com/jackc/pgx/v4 v4.12.1-0.20210724153913-640aa07df17c/go.mod h1:1QD0+tgSXP7iUjYm9C1NxKhny7lq6ee99u/z+IHFcgs=
-github.com/jackc/pgx/v4 v4.18.1 h1:YP7G1KABtKpB5IHrO9vYwSrCOhs7p3uqhvhhQBptya0=
-github.com/jackc/pgx/v4 v4.18.1/go.mod h1:FydWkUyadDmdNH/mHnGob881GawxeEm7TcMCzkb+qQE=
 github.com/jackc/pgx/v4 v4.18.2/go.mod h1:Ey4Oru5tH5sB6tV7hDmfWFahwF15Eb7DNXlRKx2CkVw=
 github.com/jackc/pgx/v4 v4.18.3 h1:dE2/TrEsGX3RBprb3qryqSV9Y60iZN1C6i8IrmW9/BA=
 github.com/jackc/pgx/v4 v4.18.3/go.mod h1:Ey4Oru5tH5sB6tV7hDmfWFahwF15Eb7DNXlRKx2CkVw=
@@ -110,16 +101,16 @@ github.com/jackc/puddle v1.3.0/go.mod h1:m4B5Dj62Y0fbyuIc15OsIqK0+JU8nkqQjsgx7dv
 github.com/jackc/puddle/v2 v2.2.1 h1:RhxXJtFG022u4ibrCSMSiu5aOq1i77R3OHKNJj77OAk=
 github.com/jackc/puddle/v2 v2.2.1/go.mod h1:vriiEXHvEE654aYKXXjOvZM39qJ0q+azkZFrfEOc3H4=
 github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
+github.com/klauspost/compress v1.13.6 h1:P76CopJELS0TiO2mebmnzgWaajssP/EszplttgQxcgc=
+github.com/klauspost/compress v1.13.6/go.mod h1:/3/Vjq9QcHkK5uEr5lBEmyoZ1iFhe47etQ6QUkpK6sk=
 github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
 github.com/konsorten/go-windows-terminal-sequences v1.0.2/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
-github.com/kr/pretty v0.1.0 h1:L/CwN0zerZDmRFUapSPitk6f+Q3+0za1rQkzVuMiMFI=
 github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
 github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
 github.com/kr/pretty v0.3.0 h1:WgNl7dwNpEZ6jJ9k1snq4pZsg7DOEN8hP9Xw0Tsjwk0=
 github.com/kr/pretty v0.3.0/go.mod h1:640gp4NfQd8pI5XOwp5fnNeVWj67G7CFk/SaSQn7NBk=
 github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
 github.com/kr/pty v1.1.8/go.mod h1:O1sed60cT9XZ5uDucP5qwvh+TE3NnUj51EiZO/lmSfw=
-github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
@@ -134,11 +125,11 @@ github.com/mattn/go-colorable v0.1.6/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope
 github.com/mattn/go-isatty v0.0.5/go.mod h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hdxcsrc5s=
 github.com/mattn/go-isatty v0.0.7/go.mod h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hdxcsrc5s=
 github.com/mattn/go-isatty v0.0.12/go.mod h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Kysco4FUpU=
-github.com/mattn/go-sqlite3 v1.14.18 h1:JL0eqdCOq6DJVNPSvArO/bIV9/P7fbGrV00LZHc+5aI=
-github.com/mattn/go-sqlite3 v1.14.18/go.mod h1:2eHXhiwb8IkHr+BDWZGa96P6+rkvnG63S2DGjv9HUNg=
 github.com/mattn/go-sqlite3 v1.14.22 h1:2gZY6PC6kBnID23Tichd1K+Z0oS6nE/XwU+Vz/5o4kU=
 github.com/mattn/go-sqlite3 v1.14.22/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=
 github.com/modocache/gover v0.0.0-20171022184752-b58185e213c5/go.mod h1:caMODM3PzxT8aQXRPkAt8xlV/e7d7w8GM5g0fa5F0D8=
+github.com/montanaflynn/stats v0.7.1 h1:etflOAAHORrCC44V+aR6Ftzort912ZU+YLiSTuV8eaE=
+github.com/montanaflynn/stats v0.7.1/go.mod h1:etXPPgVO6n31NxCd9KQUMvCM+ve0ruNzt6R8Bnaayow=
 github.com/pkg/browser v0.0.0-20180916011732-0a3d74bf9ce4/go.mod h1:4OwLy04Bl9Ef3GJJCoec+30X3LQs/0/m4HFRt/2LUSA=
 github.com/pkg/errors v0.8.1 h1:iURUrRGxPUNPdy5/HRSm+Yj6okJ6UtLINN0Q9M4+h3I=
 github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
@@ -149,6 +140,7 @@ github.com/remyoudompheng/bigfft v0.0.0-20200410134404-eec4a21b6bb0/go.mod h1:qq
 github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE=
 github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
 github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
+github.com/rogpeppe/go-internal v1.6.1 h1:/FiVV8dS/e+YqF2JvO3yXRFbBLTIuSDkuC7aBOAvL+k=
 github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTEfhy4qGm1nDQc=
 github.com/rs/xid v1.2.1/go.mod h1:+uKXf+4Djp6Md1KODXJxgGQPKngRmWyn10oCKFzNHOQ=
 github.com/rs/zerolog v1.13.0/go.mod h1:YbFCdg8HfsridGWAh22vktObvhZbQsZXe4/zB0OKkWU=
@@ -177,12 +169,21 @@ github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/
 github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
 github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
-github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk=
 github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
 github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
 github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
+github.com/xdg-go/pbkdf2 v1.0.0 h1:Su7DPu48wXMwC3bs7MCNG+z4FhcyEuz5dlvchbq0B0c=
+github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI=
+github.com/xdg-go/scram v1.1.2 h1:FHX5I5B4i4hKRVRBCFRxq1iQRej7WO3hhBuJf+UUySY=
+github.com/xdg-go/scram v1.1.2/go.mod h1:RT/sEzTbU5y00aCK8UOx6R7YryM0iF1N2MOmC3kKLN4=
+github.com/xdg-go/stringprep v1.0.4 h1:XLI/Ng3O1Atzq0oBs3TWm+5ZVgkq2aqdlvP9JtoZ6c8=
+github.com/xdg-go/stringprep v1.0.4/go.mod h1:mPGuuIYwz7CmR2bT9j4GbQqutWS1zV24gijq1dTyGkM=
+github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d h1:splanxYIlg+5LfHAM6xpdFEAYOk8iySO56hMFq6uLyA=
+github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA=
 github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
 github.com/zenazn/goji v0.9.0/go.mod h1:7S9M489iMyHBNxwZnk9/EHS098H4/F6TATF2mIxtB1Q=
+go.mongodb.org/mongo-driver v1.16.1 h1:rIVLL3q0IHM39dvE+z2ulZLp9ENZKThVfuvN/IiN4l8=
+go.mongodb.org/mongo-driver v1.16.1/go.mod h1:oB6AhJQvFQL4LEHyXi6aJzQJtBiTQHiAd83l0GdFaiw=
 go.uber.org/atomic v1.3.2/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
 go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
 go.uber.org/atomic v1.5.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=
@@ -206,13 +207,11 @@ golang.org/x/crypto v0.0.0-20210616213533-5ff15b29337e/go.mod h1:GvvjBRRGRdwPK5y
 golang.org/x/crypto v0.0.0-20210711020723-a769d52b0f97/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
 golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
 golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=
-golang.org/x/crypto v0.6.0/go.mod h1:OFC/31mSvZgRz0V1QTNCzfAI1aIRzbiufJtkMIlEp58=
 golang.org/x/crypto v0.13.0/go.mod h1:y6Z2r+Rw4iayiXXAIxJIDAJ1zMW4yaTpebo8fPOliYc=
-golang.org/x/crypto v0.14.0 h1:wBqGXzWJW6m1XrIKlAH0Hs1JJ7+9KBwnIO8v66Q9cHc=
-golang.org/x/crypto v0.14.0/go.mod h1:MVFd36DqK4CsrnJYDkBA3VC4m2GkXAM0PvzMCn4JQf4=
 golang.org/x/crypto v0.17.0/go.mod h1:gCAAfMLgwOJRpTjQ2zCCt2OcSfYMTeZVSRtQlPC7Nq4=
 golang.org/x/crypto v0.19.0/go.mod h1:Iy9bg/ha4yyC70EfRS8jz+B6ybOBKMaSxLj6P6oBDfU=
 golang.org/x/crypto v0.20.0/go.mod h1:Xwo95rrVNIoSMx9wa1JroENMToLWn3RNVrTBpLHgZPQ=
+golang.org/x/crypto v0.22.0/go.mod h1:vr6Su+7cTlO45qkww3VDJlzDn0ctJvRgYbC2NvXHt+M=
 golang.org/x/crypto v0.23.0/go.mod h1:CKFgDieR+mRhux2Lsu27y0fO304Db0wZe70UKqHu0v8=
 golang.org/x/crypto v0.24.0 h1:mnl8DM0o513X8fdIkmyFE/5hTYxbwYOjDS/+rK6qpRI=
 golang.org/x/crypto v0.24.0/go.mod h1:Z1PMYSOR5nyMcyAVAIQSKCDwalqy85Aqn1x3Ws4L5DM=
@@ -265,11 +264,9 @@ golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBc
 golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.8.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.13.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.14.0 h1:Vz7Qs629MkJkGyHxUlRHizWJRG2j8fbQKjELVSNhy7Q=
-golang.org/x/sys v0.14.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/sys v0.15.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/sys v0.17.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.19.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/sys v0.20.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/sys v0.21.0 h1:rF+pYz3DAGSQAxAu1CbC7catZg4ebC4UIeIhKxBZvws=
 golang.org/x/sys v0.21.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
@@ -280,9 +277,9 @@ golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuX
 golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k=
 golang.org/x/term v0.8.0/go.mod h1:xPskH00ivmX89bAKVGSKKtLOWNx2+17Eiy94tnKShWo=
 golang.org/x/term v0.12.0/go.mod h1:owVbMEjm3cBLCHdkQu9b1opXd4ETQWc3BhuQGKgXgvU=
-golang.org/x/term v0.13.0/go.mod h1:LTmsnFJwVN6bCy1rVCoS+qHT1HhALEFxKncY3WNNh4U=
 golang.org/x/term v0.15.0/go.mod h1:BDl952bC7+uMoWR75FIrCDx79TPU9oHkTZ9yRbYOrX0=
 golang.org/x/term v0.17.0/go.mod h1:lLRBjIVuehSbZlaOtGMbcMncT+aqLLLmKrsjNrUguwk=
+golang.org/x/term v0.19.0/go.mod h1:2CuTdWZ7KHSQwUzKva0cbMg6q2DMI3Mmxp+gKJbskEk=
 golang.org/x/term v0.20.0/go.mod h1:8UkIAJTvZgivsXaD6/pH6U9ecQzZ45awqEOzuCvwpFY=
 golang.org/x/term v0.21.0/go.mod h1:ooXLefLobQVslOqselCNF4SxFAaoS6KujMbsGzSDmX0=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
@@ -291,10 +288,10 @@ golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
 golang.org/x/text v0.3.4/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
 golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
 golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
+golang.org/x/text v0.3.8/go.mod h1:E6s5w1FMmriuDzIBO73fBruAKo1PCIq6d2Q6DHfQ8WQ=
 golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
 golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
 golang.org/x/text v0.13.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE=
-golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
 golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
 golang.org/x/text v0.15.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
 golang.org/x/text v0.16.0 h1:a94ExnEXNtEwYLGJSIUxnWoxoRz/ZcCsV63ROupILh4=
@@ -318,17 +315,13 @@ golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8T
 golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 h1:qIbj1fsPNlZgppZ+VLlY7N33q108Sa+fhmuc+sWQYwY=
 gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
 gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI=
 gopkg.in/inconshreveable/log15.v2 v2.0.0-20180818164646-67afb5ed74ec/go.mod h1:aPpfJ7XW+gOuirDoZ8gHhLh3kZ1B08FtV2bbmy7Jv3s=
-gopkg.in/mgo.v2 v2.0.0-20190816093944-a6b53ec6cb22 h1:VpOs+IwYnYBaFnrNAeB8UUWtL3vEUnzSCL1nVjPhqrw=
-gopkg.in/mgo.v2 v2.0.0-20190816093944-a6b53ec6cb22/go.mod h1:yeKp02qBN3iKW1OzL3MGk2IdtZzaj7SFntXj72NppTA=
 gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
-gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
 gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
@@ -348,7 +341,6 @@ modernc.org/file v1.0.8/go.mod h1:v0ae8/gLTK8QR+eyuV504kYZ/nsoe5JRDcHZFZecfxM=
 modernc.org/fileutil v1.0.0/go.mod h1:JHsWpkrk/CnVV1H/eGlFf85BEpfkrp56ro8nojIq9Q8=
 modernc.org/fileutil v1.1.1/go.mod h1:HdjlliqRHrMAI4nVOvvpYVzVgvRSK7WnoCiG0GUWJNo=
 modernc.org/fileutil v1.1.2/go.mod h1:HdjlliqRHrMAI4nVOvvpYVzVgvRSK7WnoCiG0GUWJNo=
-modernc.org/fileutil v1.2.0 h1:c7fsfzHf9WfUFXvv/RY9sStAr+VAKXYGKiAhBQQNoT4=
 modernc.org/fileutil v1.2.0/go.mod h1:0rLMFc17WSz6Bm/GtHeme7TOX8pNRhFN2NkfBlOZhrQ=
 modernc.org/fileutil v1.3.0 h1:gQ5SIzK3H9kdfai/5x41oQiKValumqNTDXMvKo62HvE=
 modernc.org/fileutil v1.3.0/go.mod h1:XatxS8fZi3pS8/hKG2GH/ArUogfxjpEKs3Ku3aK4JyQ=
diff --git a/internal/testsuite/generic_suite.go b/internal/testsuite/generic_suite.go
index 98832a61..92181d38 100644
--- a/internal/testsuite/generic_suite.go
+++ b/internal/testsuite/generic_suite.go
@@ -27,7 +27,6 @@ import (
 
 	"github.com/stretchr/testify/suite"
 	db "github.com/upper/db/v4"
-	"gopkg.in/mgo.v2/bson"
 )
 
 type birthday struct {
@@ -48,23 +47,22 @@ type oddEven struct {
 	// Test for JSON option.
 	Input int `json:"input" db:"input"`
 	// Test for JSON option.
-	// The "bson" tag is required by mgo.
 	IsEven bool `json:"is_even" db:"is_even,json" bson:"is_even"`
 	OmitMe bool `json:"omit_me" db:"-" bson:"-"`
 }
 
 // Struct that relies on explicit mapping.
 type mapE struct {
-	ID       uint          `db:"id,omitempty" bson:"-"`
-	MongoID  bson.ObjectId `db:"-" bson:"_id,omitempty"`
-	CaseTest string        `db:"case_test" bson:"case_test"`
+	ID       uint        `db:"id,omitempty" bson:"-"`
+	MongoID  interface{} `db:"-" bson:"_id,omitempty"`
+	CaseTest string      `db:"case_test" bson:"case_test"`
 }
 
 // Struct that will fallback to default mapping.
 type mapN struct {
-	ID        uint          `db:"id,omitempty"`
-	MongoID   bson.ObjectId `db:"-" bson:"_id,omitempty"`
-	Case_TEST string        `db:"case_test"`
+	ID        uint        `db:"id,omitempty"`
+	MongoID   interface{} `db:"-" bson:"_id,omitempty"`
+	Case_TEST string      `db:"case_test"`
 }
 
 // Struct for testing marshalling.
@@ -121,12 +119,12 @@ type GenericTestSuite struct {
 
 func (s *GenericTestSuite) AfterTest(suiteName, testName string) {
 	err := s.TearDown()
-	s.NoError(err)
+	s.Require().NoError(err)
 }
 
 func (s *GenericTestSuite) BeforeTest(suiteName, testName string) {
-	err := s.TearUp()
-	s.NoError(err)
+	err := s.SetUp()
+	s.Require().NoError(err)
 }
 
 func (s *GenericTestSuite) TestDatesAndUnicode() {
@@ -152,13 +150,13 @@ func (s *GenericTestSuite) TestDatesAndUnicode() {
 	col := sess.Collection(`birthdays`)
 
 	record, err := col.Insert(controlItem)
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.NotZero(record.ID())
 
 	var res db.Result
 	switch s.Adapter() {
 	case "mongo":
-		res = col.Find(db.Cond{"_id": record.ID().(bson.ObjectId)})
+		res = col.Find(db.Cond{"_id": record.ID()})
 	case "ql":
 		res = col.Find(db.Cond{"id()": record.ID()})
 	default:
@@ -167,7 +165,7 @@ func (s *GenericTestSuite) TestDatesAndUnicode() {
 
 	var total uint64
 	total, err = res.Count()
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.Equal(uint64(1), total)
 
 	switch s.Adapter() {
@@ -177,7 +175,7 @@ func (s *GenericTestSuite) TestDatesAndUnicode() {
 
 	var testItem birthday
 	err = res.One(&testItem)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	switch s.Adapter() {
 	case "sqlite", "ql", "mssql":
@@ -190,7 +188,7 @@ func (s *GenericTestSuite) TestDatesAndUnicode() {
 
 	var testItems []birthday
 	err = res.All(&testItems)
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.NotZero(len(testItems))
 
 	for _, testItem = range testItems {
@@ -203,10 +201,10 @@ func (s *GenericTestSuite) TestDatesAndUnicode() {
 
 	controlItem.Name = `宮崎駿`
 	err = res.Update(controlItem)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	err = res.One(&testItem)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	switch s.Adapter() {
 	case "sqlite", "ql", "mssql":
@@ -216,14 +214,14 @@ func (s *GenericTestSuite) TestDatesAndUnicode() {
 	s.Equal(controlItem, testItem)
 
 	err = res.Delete()
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	total, err = res.Count()
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.Zero(total)
 
 	err = res.Close()
-	s.NoError(err)
+	s.Require().NoError(err)
 }
 
 func (s *GenericTestSuite) TestFibonacci() {
@@ -240,7 +238,7 @@ func (s *GenericTestSuite) TestFibonacci() {
 	for i = 0; i < 10; i++ {
 		item := fibonacci{Input: i, Output: fib(i)}
 		_, err = col.Insert(item)
-		s.NoError(err)
+		s.Require().NoError(err)
 	}
 
 	// Testing sorting by function.
@@ -265,17 +263,19 @@ func (s *GenericTestSuite) TestFibonacci() {
 		res = res.OrderBy(db.Raw("RAND()"))
 	case "mssql":
 		res = res.OrderBy(db.Raw("NEWID()"))
+	case "mongo":
+		res = res.OrderBy(db.Raw(`{"$sample": {"size": 1}}`))
 	}
 
 	total, err = res.Count()
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.Equal(uint64(4), total)
 
 	// Find() with IN/$in
 	res = col.Find(db.Cond{"input IN": []int{3, 5, 6, 7}}).OrderBy("input")
 
 	total, err = res.Count()
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.Equal(uint64(4), total)
 
 	res = res.Offset(1).Limit(2)
@@ -287,10 +287,10 @@ func (s *GenericTestSuite) TestFibonacci() {
 		case 6:
 			s.Equal(fib(item.Input), item.Output)
 		default:
-			s.T().Errorf(`Unexpected item: %v.`, item)
+			s.T().Errorf(`unexpected item: %#v.`, item)
 		}
 	}
-	s.NoError(res.Err())
+	s.Require().NoError(res.Err())
 
 	// Find() with range
 	res = col.Find(
@@ -305,7 +305,7 @@ func (s *GenericTestSuite) TestFibonacci() {
 	).OrderBy("-input")
 
 	total, err = res.Count()
-	s.NoError(err)
+	s.Require().NoError(err)
 	s.Equal(uint64(4), total)
 
 	// Skipping.
@@ -318,26 +318,28 @@ func (s *GenericTestSuite) TestFibonacci() {
 		case 6:
 			s.Equal(fib(item2.Input), item2.Output)
 		default:
-			s.T().Errorf(`Unexpected item: %v.`, item2)
+			s.T().Errorf(`unexpected item: %#v.`, item2)
 		}
 	}
 	err = resWithLimit.Err()
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	err = res.Delete()
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	{
 		total, err := res.Count()
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Zero(total)
 	}
 
 	// Find() with no arguments.
 	res = col.Find()
+	s.Require().NotZero(res)
+
 	{
 		total, err := res.Count()
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Equal(uint64(6), total)
 	}
 
@@ -346,56 +348,56 @@ func (s *GenericTestSuite) TestFibonacci() {
 		// Find() with empty db.Cond.
 		{
 			total, err := col.Find(db.Cond{}).Count()
-			s.NoError(err)
+			s.Require().NoError(err)
 			s.Equal(uint64(6), total)
 		}
 
 		// Find() with empty expression
 		{
 			total, err := col.Find(db.Or(db.And(db.Cond{}, db.Cond{}), db.Or(db.Cond{}))).Count()
-			s.NoError(err)
+			s.Require().NoError(err)
 			s.Equal(uint64(6), total)
 		}
 
 		// Find() with explicit IS NULL
 		{
 			total, err := col.Find(db.Cond{"input IS": nil}).Count()
-			s.NoError(err)
+			s.Require().NoError(err)
 			s.Equal(uint64(0), total)
 		}
 
 		// Find() with implicit IS NULL
 		{
 			total, err := col.Find(db.Cond{"input": nil}).Count()
-			s.NoError(err)
+			s.Require().NoError(err)
 			s.Equal(uint64(0), total)
 		}
 
 		// Find() with explicit = NULL
 		{
 			total, err := col.Find(db.Cond{"input =": nil}).Count()
-			s.NoError(err)
+			s.Require().NoError(err)
 			s.Equal(uint64(0), total)
 		}
 
 		// Find() with implicit IN
 		{
 			total, err := col.Find(db.Cond{"input": []int{1, 2, 3, 4}}).Count()
-			s.NoError(err)
+			s.Require().NoError(err)
 			s.Equal(uint64(3), total)
 		}
 
 		// Find() with implicit NOT IN
 		{
 			total, err := col.Find(db.Cond{"input NOT IN": []int{1, 2, 3, 4}}).Count()
-			s.NoError(err)
+			s.Require().NoError(err)
 			s.Equal(uint64(3), total)
 		}
 	}
 
 	var items []fibonacci
 	err = res.All(&items)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	for _, item := range items {
 		switch item.Input {
@@ -412,7 +414,7 @@ func (s *GenericTestSuite) TestFibonacci() {
 	}
 
 	err = res.Close()
-	s.NoError(err)
+	s.Require().NoError(err)
 }
 
 func (s *GenericTestSuite) TestOddEven() {
@@ -425,7 +427,7 @@ func (s *GenericTestSuite) TestOddEven() {
 	for i = 1; i < 100; i++ {
 		item := oddEven{Input: i, IsEven: even(i)}
 		_, err := col.Insert(item)
-		s.NoError(err)
+		s.Require().NoError(err)
 	}
 
 	// Retrieving items
@@ -437,22 +439,22 @@ func (s *GenericTestSuite) TestOddEven() {
 	}
 
 	err := res.Err()
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	err = res.Delete()
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// Testing named inputs (using tags).
 	res = col.Find()
 
 	var item2 struct {
-		Value uint `db:"input" bson:"input"` // The "bson" tag is required by mgo.
+		Value uint `db:"input" bson:"input"`
 	}
 	for res.Next(&item2) {
 		s.NotZero(item2.Value % 2)
 	}
 	err = res.Err()
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// Testing inline tag.
 	res = col.Find()
@@ -465,7 +467,7 @@ func (s *GenericTestSuite) TestOddEven() {
 		s.NotZero(item3.OddEven.Input)
 	}
 	err = res.Err()
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	// Testing inline tag.
 	type OddEven oddEven
@@ -478,7 +480,7 @@ func (s *GenericTestSuite) TestOddEven() {
 		s.NotZero(item31.Input % 2)
 		s.NotZero(item31.Input)
 	}
-	s.NoError(res.Err())
+	s.Require().NoError(res.Err())
 
 	// Testing omision tag.
 	res = col.Find()
@@ -489,7 +491,7 @@ func (s *GenericTestSuite) TestOddEven() {
 	for res.Next(&item4) {
 		s.Zero(item4.Value)
 	}
-	s.NoError(res.Err())
+	s.Require().NoError(res.Err())
 }
 
 func (s *GenericTestSuite) TestExplicitAndDefaultMapping() {
@@ -505,7 +507,7 @@ func (s *GenericTestSuite) TestExplicitAndDefaultMapping() {
 
 	if err = col.Truncate(); err != nil {
 		if s.Adapter() != "mongo" {
-			s.NoError(err)
+			s.Require().NoError(err)
 		}
 	}
 
@@ -515,7 +517,7 @@ func (s *GenericTestSuite) TestExplicitAndDefaultMapping() {
 	}
 
 	_, err = col.Insert(testE)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	res = col.Find(db.Cond{"case_test": "Hello!"})
 	if s.Adapter() == "ql" {
@@ -523,10 +525,10 @@ func (s *GenericTestSuite) TestExplicitAndDefaultMapping() {
 	}
 
 	err = res.One(&testE)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	if s.Adapter() == "mongo" {
-		s.True(testE.MongoID.Valid())
+		//s.True(testE.MongoID.Valid())
 	} else {
 		s.NotZero(testE.ID)
 	}
@@ -537,7 +539,7 @@ func (s *GenericTestSuite) TestExplicitAndDefaultMapping() {
 	}
 
 	_, err = col.Insert(testN)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	if s.Adapter() == `mongo` {
 		res = col.Find(db.Cond{"case_test": "World!"})
@@ -550,10 +552,10 @@ func (s *GenericTestSuite) TestExplicitAndDefaultMapping() {
 	}
 
 	err = res.One(&testN)
-	s.NoError(err)
+	s.Require().NoError(err)
 
 	if s.Adapter() == `mongo` {
-		s.True(testN.MongoID.Valid())
+		//s.True(testN.MongoID.Valid())
 	} else {
 		s.NotZero(testN.ID)
 	}
@@ -566,7 +568,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 	err := birthdays.Truncate()
 	if err != nil {
 		if s.Adapter() != "mongo" {
-			s.NoError(err)
+			s.Require().NoError(err)
 		}
 	}
 
@@ -607,7 +609,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 	}
 	for _, birthday := range birthdaysDataset {
 		_, err := birthdays.Insert(birthday)
-		s.NoError(err)
+		s.Require().NoError(err)
 	}
 
 	// Test: equal
@@ -616,7 +618,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"name": db.Eq("Colin"),
 		}).One(&item)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.NotNil(item)
 
 		s.Equal("Colin", item.Name)
@@ -628,7 +630,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"name": db.NotEq("Colin"),
 		}).One(&item)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.NotNil(item)
 
 		s.NotEqual("Colin", item.Name)
@@ -641,7 +643,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"born": db.Gt(ref),
 		}).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.NotZero(len(items))
 		s.Equal(2, len(items))
 		for _, item := range items {
@@ -656,7 +658,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"born": db.Lt(ref),
 		}).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.NotZero(len(items))
 		s.Equal(5, len(items))
 		for _, item := range items {
@@ -671,7 +673,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"born": db.Gte(ref),
 		}).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.NotZero(len(items))
 		s.Equal(3, len(items))
 		for _, item := range items {
@@ -686,7 +688,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"born": db.Lte(ref),
 		}).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.NotZero(len(items))
 		s.Equal(6, len(items))
 		for _, item := range items {
@@ -702,7 +704,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"born": db.Between(dateA, dateB),
 		}).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Equal(6, len(items))
 		for _, item := range items {
 			s.True(item.Born.After(dateA) || item.Born.Equal(dateA))
@@ -718,7 +720,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"born": db.NotBetween(dateA, dateB),
 		}).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Equal(2, len(items))
 		for _, item := range items {
 			s.False(item.Born.Before(dateA) || item.Born.Equal(dateA))
@@ -733,7 +735,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"name": db.In(names...),
 		}).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Equal(4, len(items))
 		for _, item := range items {
 			inArray := false
@@ -753,7 +755,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"name": db.NotIn(names...),
 		}).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Equal(4, len(items))
 		for _, item := range items {
 			inArray := false
@@ -773,7 +775,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"name": db.NotIn(names...),
 		}).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Equal(4, len(items))
 		for _, item := range items {
 			inArray := false
@@ -793,7 +795,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 			db.Cond{"name": db.Is(nil)},
 			db.Cond{"name": db.IsNot(nil)},
 		)).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Equal(0, len(items))
 	}
 
@@ -803,7 +805,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.And(
 			db.Cond{"born_ut": db.IsNull()},
 		)).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Equal(8, len(items))
 	}
 
@@ -826,7 +828,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		}
 
 		err := q.All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Equal(1, len(items))
 
 		s.Equal("Daria López", items[0].Name)
@@ -839,7 +841,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 			err := birthdays.Find(db.And(
 				db.Cond{"name": db.RegExp("^[D|C|M]")},
 			)).OrderBy("name").All(&items)
-			s.NoError(err)
+			s.Require().NoError(err)
 			s.Equal(3, len(items))
 
 			s.Equal("Colin", items[0].Name)
@@ -854,7 +856,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 			err := birthdays.Find(db.And(
 				db.Cond{"name": db.NotRegExp("^[D|C|M]")},
 			)).OrderBy("name").All(&items)
-			s.NoError(err)
+			s.Require().NoError(err)
 			s.Equal(5, len(items))
 
 			for _, item := range items {
@@ -872,7 +874,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"born": db.After(ref),
 		}).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Equal(5, len(items))
 	}
 
@@ -883,7 +885,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"born": db.OnOrAfter(ref),
 		}).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Equal(6, len(items))
 	}
 
@@ -894,7 +896,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"born": db.Before(ref),
 		}).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Equal(2, len(items))
 	}
 
@@ -905,7 +907,7 @@ func (s *GenericTestSuite) TestComparisonOperators() {
 		err := birthdays.Find(db.Cond{
 			"born": db.OnOrBefore(ref),
 		}).All(&items)
-		s.NoError(err)
+		s.Require().NoError(err)
 		s.Equal(3, len(items))
 	}
 }
diff --git a/internal/testsuite/record_suite.go b/internal/testsuite/record_suite.go
index d1f644da..825d46d4 100644
--- a/internal/testsuite/record_suite.go
+++ b/internal/testsuite/record_suite.go
@@ -88,7 +88,7 @@ func (s *RecordTestSuite) AfterTest(suiteName, testName string) {
 }
 
 func (s *RecordTestSuite) BeforeTest(suiteName, testName string) {
-	err := s.TearUp()
+	err := s.SetUp()
 	s.NoError(err)
 
 	sess := s.Helper.Session()
diff --git a/internal/testsuite/sql_suite.go b/internal/testsuite/sql_suite.go
index 844e0dfa..4deecea9 100644
--- a/internal/testsuite/sql_suite.go
+++ b/internal/testsuite/sql_suite.go
@@ -71,7 +71,7 @@ func (s *SQLTestSuite) AfterTest(suiteName, testName string) {
 }
 
 func (s *SQLTestSuite) BeforeTest(suiteName, testName string) {
-	err := s.TearUp()
+	err := s.SetUp()
 	s.NoError(err)
 
 	sess := s.Session()
diff --git a/internal/testsuite/suite.go b/internal/testsuite/suite.go
index 7bbe91ed..5fabac9b 100644
--- a/internal/testsuite/suite.go
+++ b/internal/testsuite/suite.go
@@ -16,7 +16,7 @@ type Helper interface {
 
 	Adapter() string
 
-	TearUp() error
+	SetUp() error
 	TearDown() error
 }
 
@@ -32,6 +32,6 @@ func (s *Suite) AfterTest(suiteName, testName string) {
 }
 
 func (s *Suite) BeforeTest(suiteName, testName string) {
-	err := s.TearUp()
+	err := s.SetUp()
 	s.NoError(err)
 }