mongodb/mongo-python-driver
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use createIndexes command when available PYTHON-622

Browse Source
This commit is contained in:
Bernie Hackett 2014-01-28 11:46:30 -08:00
parent 36b86007e5
commit af08da3bcb
1 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
pymongo/collection.py
View File

@ -24,7 +24,7 @@ from pymongo import (bulk,
helpers,
message)
from pymongo.cursor import Cursor
from pymongo.errors import InvalidName
from pymongo.errors import InvalidName, OperationFailure
from pymongo.helpers import _check_write_command_response
from pymongo.message import _INSERT, _UPDATE, _DELETE
@ -949,10 +949,8 @@ class Collection(common.BaseObject):
keys = helpers._index_list(key_or_list)
index_doc = helpers._index_document(keys)
index = {"key": index_doc, "ns": self.__full_name}
name = "name" in kwargs and kwargs["name"] or _gen_index_name(keys)
index["name"] = name
index = {"key": index_doc, "name": name}
if "drop_dups" in kwargs:
kwargs["dropDups"] = kwargs.pop("drop_dups")
@ -962,9 +960,16 @@ class Collection(common.BaseObject):
index.update(kwargs)
self.__database.system.indexes.insert(index, manipulate=False,
check_keys=False,
**self._get_wc_override())
try:
self.__database.command('createIndexes', self.name, indexes=[index])
except OperationFailure, exc:
if exc.code in (59, None):
index["ns"] = self.__full_name
self.__database.system.indexes.insert(index, manipulate=False,
check_keys=False,
**self._get_wc_override())
else:
raise
self.__database.connection._cache_index(self.__database.name,
self.__name, name, cache_for)