diff options
author | Mike Bayer <mike_mp@zzzcomputing.com> | 2005-10-22 05:51:05 +0000 |
---|---|---|
committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2005-10-22 05:51:05 +0000 |
commit | 65811386b0526e1f7a775c29e97344c201845eab (patch) | |
tree | bdfe9c7ba96a6717b7a30d628da51dcb9386ced3 /lib/sqlalchemy/mapper.py | |
parent | 77d4a6d2ef04c1032fca3f60e415b46b91298a16 (diff) | |
download | sqlalchemy-65811386b0526e1f7a775c29e97344c201845eab.tar.gz |
Diffstat (limited to 'lib/sqlalchemy/mapper.py')
-rw-r--r-- | lib/sqlalchemy/mapper.py | 8 |
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 |