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

PYTHON-857 - Simplify _Bulk.execute_no_results.

Browse Source
This commit is contained in:
A. Jesse Jiryu Davis 2015-03-18 14:28:01 -04:00
parent 1af1fd27db
commit 98922562cf
1 changed files with 18 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
pymongo/bulk.py
View File

@ -307,30 +307,25 @@ class _Bulk(object):
run.ops,
self.ordered,
write_concern=write_concern)
elif run.op_type == _UPDATE:
for operation in run.ops:
doc = operation['u']
check_keys = True
if doc and next(iter(doc)).startswith('$'):
check_keys = False
coll._update(sock_info,
operation['q'],
doc,
operation['upsert'],
check_keys,
operation['multi'],
write_concern=write_concern)
else:
try:
if run.op_type == _UPDATE:
for operation in run.ops:
doc = operation['u']
check_keys = True
if doc and next(iter(doc)).startswith('$'):
check_keys = False
coll._update(sock_info,
operation['q'],
doc,
operation['upsert'],
check_keys,
operation['multi'],
write_concern=write_concern)
else:
for operation in run.ops:
coll._delete(sock_info,
operation['q'],
not operation['limit'],
write_concern)
except OperationFailure:
if self.ordered:
return
for operation in run.ops:
coll._delete(sock_info,
operation['q'],
not operation['limit'],
write_concern)
except OperationFailure:
if self.ordered:
break