summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/mapper.py
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2005-10-22 05:51:05 +0000
committerMike Bayer <mike_mp@zzzcomputing.com>2005-10-22 05:51:05 +0000
commit65811386b0526e1f7a775c29e97344c201845eab (patch)
treebdfe9c7ba96a6717b7a30d628da51dcb9386ced3 /lib/sqlalchemy/mapper.py
parent77d4a6d2ef04c1032fca3f60e415b46b91298a16 (diff)
downloadsqlalchemy-65811386b0526e1f7a775c29e97344c201845eab.tar.gz
Diffstat (limited to 'lib/sqlalchemy/mapper.py')
-rw-r--r--lib/sqlalchemy/mapper.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/lib/sqlalchemy/mapper.py b/lib/sqlalchemy/mapper.py
index 3cee340d4..42e0945bb 100644
--- a/lib/sqlalchemy/mapper.py
+++ b/lib/sqlalchemy/mapper.py
@@ -423,8 +423,8 @@ class Mapper(object):
clause.clauses.append(col == sql.bindparam(col.table.name + "_" + col.key))
statement = table.update(clause)
c = statement.execute(*update)
- if c.cursor.rowcount != len(update):
- raise "ConcurrencyError - updated rowcount does not match number of objects updated"
+ if 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):
statement = table.insert()
for rec in insert:
@@ -458,8 +458,8 @@ class Mapper(object):
clause.clauses.append(col == sql.bindparam(col.key))
statement = table.delete(clause)
c = statement.execute(*delete)
- if c.cursor.rowcount != len(delete):
- raise "ConcurrencyError - updated rowcount does not match number of objects updated"
+ if 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):
"""called by an instance of objectstore.UOWTransaction to register