diff options
author | Mike Bayer <mike_mp@zzzcomputing.com> | 2005-11-27 05:32:13 +0000 |
---|---|---|
committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2005-11-27 05:32:13 +0000 |
commit | 2452cebc23c527ec9361468bb698e279e739d71d (patch) | |
tree | aed1b9b7da3063cf3e6b292cd2d8b7cc2f9793ac /lib/sqlalchemy/mapper.py | |
parent | cdcd74cb390507fc4e04bd61f77a2a2d2baa9614 (diff) | |
download | sqlalchemy-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.py | 4 |
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): |