summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/orm/shard.py
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2008-11-05 20:50:48 +0000
committerMike Bayer <mike_mp@zzzcomputing.com>2008-11-05 20:50:48 +0000
commit9f894d2f265bb5fd03ab0b3aa3fd164108c99259 (patch)
tree5886dd1b46b1e1865de2a278ada95f168ed1915b /lib/sqlalchemy/orm/shard.py
parent89b86f41bbdb15d024bc716fdb484b1b6f57ddb9 (diff)
downloadsqlalchemy-9f894d2f265bb5fd03ab0b3aa3fd164108c99259.tar.gz
- Dialects can now generate label names of adjustable length.
Pass in the argument "label_length=<value>" to create_engine() to adjust how many characters max will be present in dynamically generated column labels, i.e. "somecolumn AS somelabel". Any value less than 6 will result in a label of minimal size, consiting of an underscore and a numeric counter. The compiler uses the value of dialect.max_identifier_length as a default. [ticket:1211] - removed ANON_NAME regular expression, using string patterns now - _generated_label() unicode subclass is used to indicate generated names which are subject to truncation
Diffstat (limited to 'lib/sqlalchemy/orm/shard.py')
-rw-r--r--lib/sqlalchemy/orm/shard.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/sqlalchemy/orm/shard.py b/lib/sqlalchemy/orm/shard.py
index b4525d8fb..395d87dbf 100644
--- a/lib/sqlalchemy/orm/shard.py
+++ b/lib/sqlalchemy/orm/shard.py
@@ -93,7 +93,7 @@ class ShardedQuery(Query):
def _execute_and_instances(self, context):
if self._shard_id is not None:
- result = self.session.connection(mapper=self._mapper_zero(), shard_id=self._shard_id).execute(context.statement, **self._params)
+ result = self.session.connection(mapper=self._mapper_zero(), shard_id=self._shard_id).execute(context.statement, self._params)
try:
return iter(self.instances(result, context))
finally:
@@ -101,7 +101,7 @@ class ShardedQuery(Query):
else:
partial = []
for shard_id in self.query_chooser(self):
- result = self.session.connection(mapper=self._mapper_zero(), shard_id=shard_id).execute(context.statement, **self._params)
+ result = self.session.connection(mapper=self._mapper_zero(), shard_id=shard_id).execute(context.statement, self._params)
try:
partial = partial + list(self.instances(result, context))
finally: