summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/engine/default.py
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2008-03-06 16:54:55 +0000
committerMike Bayer <mike_mp@zzzcomputing.com>2008-03-06 16:54:55 +0000
commit63b904881b02ac765ff2665eae57f51de5ce67b9 (patch)
tree06a76edca3027b7563d563641ceb86815af59d9d /lib/sqlalchemy/engine/default.py
parentd8e258410e224b5910e656539c9e15d3135d8eb7 (diff)
downloadsqlalchemy-63b904881b02ac765ff2665eae57f51de5ce67b9.tar.gz
check the isinsert/isupdate flags before calling __process_defaults
Diffstat (limited to 'lib/sqlalchemy/engine/default.py')
-rw-r--r--lib/sqlalchemy/engine/default.py68
1 files changed, 34 insertions, 34 deletions
diff --git a/lib/sqlalchemy/engine/default.py b/lib/sqlalchemy/engine/default.py
index cc4eb60d2..dfeefa337 100644
--- a/lib/sqlalchemy/engine/default.py
+++ b/lib/sqlalchemy/engine/default.py
@@ -176,7 +176,8 @@ class DefaultExecutionContext(base.ExecutionContext):
self.executemany = len(parameters) > 1
self.cursor = self.create_cursor()
- self.__process_defaults()
+ if self.isinsert or self.isupdate:
+ self.__process_defaults()
self.parameters = self.__convert_compiled_params(self.compiled_parameters)
elif statement is not None:
@@ -355,42 +356,41 @@ class DefaultExecutionContext(base.ExecutionContext):
"""generate default values for compiled insert/update statements,
and generate last_inserted_ids() collection."""
- if self.isinsert or self.isupdate:
- if self.executemany:
- if len(self.compiled.prefetch):
- drunner = self.dialect.defaultrunner(self)
- params = self.compiled_parameters
- for param in params:
- # assign each dict of params to self.compiled_parameters;
- # this allows user-defined default generators to access the full
- # set of bind params for the row
- self.compiled_parameters = param
- for c in self.compiled.prefetch:
- if self.isinsert:
- val = drunner.get_column_default(c)
- else:
- val = drunner.get_column_onupdate(c)
- if val is not None:
- param[c.key] = val
- self.compiled_parameters = params
-
- else:
- compiled_parameters = self.compiled_parameters[0]
+ if self.executemany:
+ if len(self.compiled.prefetch):
drunner = self.dialect.defaultrunner(self)
+ params = self.compiled_parameters
+ for param in params:
+ # assign each dict of params to self.compiled_parameters;
+ # this allows user-defined default generators to access the full
+ # set of bind params for the row
+ self.compiled_parameters = param
+ for c in self.compiled.prefetch:
+ if self.isinsert:
+ val = drunner.get_column_default(c)
+ else:
+ val = drunner.get_column_onupdate(c)
+ if val is not None:
+ param[c.key] = val
+ self.compiled_parameters = params
- for c in self.compiled.prefetch:
- if self.isinsert:
- val = drunner.get_column_default(c)
- else:
- val = drunner.get_column_onupdate(c)
-
- if val is not None:
- compiled_parameters[c.key] = val
+ else:
+ compiled_parameters = self.compiled_parameters[0]
+ drunner = self.dialect.defaultrunner(self)
+ for c in self.compiled.prefetch:
if self.isinsert:
- self._last_inserted_ids = [compiled_parameters.get(c.key, None) for c in self.compiled.statement.table.primary_key]
- self._last_inserted_params = compiled_parameters
+ val = drunner.get_column_default(c)
else:
- self._last_updated_params = compiled_parameters
+ val = drunner.get_column_onupdate(c)
+
+ if val is not None:
+ compiled_parameters[c.key] = val
+
+ if self.isinsert:
+ self._last_inserted_ids = [compiled_parameters.get(c.key, None) for c in self.compiled.statement.table.primary_key]
+ self._last_inserted_params = compiled_parameters
+ else:
+ self._last_updated_params = compiled_parameters
- self.postfetch_cols = self.compiled.postfetch
+ self.postfetch_cols = self.compiled.postfetch