try:
b = self.binds[key]
except KeyError:
- raise "No such bind param in statement '%s': %s" % (str(self), key)
+ continue
d[b.key] = value
for b in self.binds.values():
clearly, this approach only goes so far, such as if database A commits, then database B commits
and fails, A is already committed. Any failure conditions have to be raised before anyone
commits for this to be useful."""
- engines = util.Set()
+ engines = util.HashSet()
for table in tables:
engines.append(table.engine)
for engine in engines:
object.__getattribute__(self, 'tdict')["%d_%s" % (thread.get_ident(), key)] = value
-class Set(object):
+class HashSet(object):
def __init__(self, iter = None):
self.map = {}
if iter is not None:
def __getitem__(self, key):
return self.map[key]
+class HistoryAwareArraySet(object):
+ def __init__(self):
+ self.elements = []
class ScopedRegistry(object):
def __init__(self, createfunc):