summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/mapper.py
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2005-11-27 05:32:13 +0000
committerMike Bayer <mike_mp@zzzcomputing.com>2005-11-27 05:32:13 +0000
commit2452cebc23c527ec9361468bb698e279e739d71d (patch)
treeaed1b9b7da3063cf3e6b292cd2d8b7cc2f9793ac /lib/sqlalchemy/mapper.py
parentcdcd74cb390507fc4e04bd61f77a2a2d2baa9614 (diff)
downloadsqlalchemy-2452cebc23c527ec9361468bb698e279e739d71d.tar.gz
rowcount doesnt work on MySQL, so disabled concurrency check with mysql
Diffstat (limited to 'lib/sqlalchemy/mapper.py')
-rw-r--r--lib/sqlalchemy/mapper.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/sqlalchemy/mapper.py b/lib/sqlalchemy/mapper.py
index 520319942..ce3cb0566 100644
--- a/lib/sqlalchemy/mapper.py
+++ b/lib/sqlalchemy/mapper.py
@@ -506,7 +506,7 @@ class Mapper(object):
clause.clauses.append(col == sql.bindparam(col.table.name + "_" + col.key))
statement = table.update(clause)
c = statement.execute(*update)
- if c.rowcount != len(update):
+ if table.engine.supports_sane_rowcount() and c.rowcount != len(update):
raise "ConcurrencyError - updated rowcount %d does not match number of objects updated %d" % (c.cursor.rowcount, len(update))
if len(insert):
import sys
@@ -545,7 +545,7 @@ class Mapper(object):
clause.clauses.append(col == sql.bindparam(col.key))
statement = table.delete(clause)
c = statement.execute(*delete)
- if c.rowcount != len(delete):
+ if table.engine.supports_sane_rowcount() and c.rowcount != len(delete):
raise "ConcurrencyError - updated rowcount %d does not match number of objects updated %d" % (c.cursor.rowcount, len(delete))
def register_dependencies(self, *args, **kwargs):