summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/dialects/mysql/dml.py
diff options
context:
space:
mode:
Diffstat (limited to 'lib/sqlalchemy/dialects/mysql/dml.py')
-rw-r--r--lib/sqlalchemy/dialects/mysql/dml.py23
1 files changed, 13 insertions, 10 deletions
diff --git a/lib/sqlalchemy/dialects/mysql/dml.py b/lib/sqlalchemy/dialects/mysql/dml.py
index 130ef2347..5d59b2073 100644
--- a/lib/sqlalchemy/dialects/mysql/dml.py
+++ b/lib/sqlalchemy/dialects/mysql/dml.py
@@ -6,7 +6,7 @@ from ...sql.base import _generative
from ... import exc
from ... import util
-__all__ = ('Insert', 'insert')
+__all__ = ("Insert", "insert")
class Insert(StandardInsert):
@@ -39,7 +39,7 @@ class Insert(StandardInsert):
@util.memoized_property
def inserted_alias(self):
- return alias(self.table, name='inserted')
+ return alias(self.table, name="inserted")
@_generative
def on_duplicate_key_update(self, *args, **kw):
@@ -87,27 +87,29 @@ class Insert(StandardInsert):
"""
if args and kw:
raise exc.ArgumentError(
- "Can't pass kwargs and positional arguments simultaneously")
+ "Can't pass kwargs and positional arguments simultaneously"
+ )
if args:
if len(args) > 1:
raise exc.ArgumentError(
"Only a single dictionary or list of tuples "
- "is accepted positionally.")
+ "is accepted positionally."
+ )
values = args[0]
else:
values = kw
- inserted_alias = getattr(self, 'inserted_alias', None)
+ inserted_alias = getattr(self, "inserted_alias", None)
self._post_values_clause = OnDuplicateClause(inserted_alias, values)
return self
-insert = public_factory(Insert, '.dialects.mysql.insert')
+insert = public_factory(Insert, ".dialects.mysql.insert")
class OnDuplicateClause(ClauseElement):
- __visit_name__ = 'on_duplicate_key_update'
+ __visit_name__ = "on_duplicate_key_update"
_parameter_ordering = None
@@ -118,11 +120,12 @@ class OnDuplicateClause(ClauseElement):
# Update._proces_colparams(), however we don't look for a special flag
# in this case since we are not disambiguating from other use cases as
# we are in Update.values().
- if isinstance(update, list) and \
- (update and isinstance(update[0], tuple)):
+ if isinstance(update, list) and (
+ update and isinstance(update[0], tuple)
+ ):
self._parameter_ordering = [key for key, value in update]
update = dict(update)
if not update or not isinstance(update, dict):
- raise ValueError('update parameter must be a non-empty dictionary')
+ raise ValueError("update parameter must be a non-empty dictionary")
self.update = update