diff options
| author | Stefan Urbanek <stefan@agentfarms.net> | 2015-10-24 13:33:27 -0700 |
|---|---|---|
| committer | Stefan Urbanek <stefan@agentfarms.net> | 2015-10-24 13:33:27 -0700 |
| commit | a2dc8d9ce1a5c9069c2cc7124c513bad5991e0f4 (patch) | |
| tree | b22479161ffec3b08f0a2cb4874edf86da29238c /lib/sqlalchemy/dialects | |
| parent | c2c4fc14d592a022e192e5e63e015c0f0c00c893 (diff) | |
| download | sqlalchemy-pr/209.tar.gz | |
Added FULL OUTER JOIN through Join(full=True)pr/209
Diffstat (limited to 'lib/sqlalchemy/dialects')
| -rw-r--r-- | lib/sqlalchemy/dialects/mysql/base.py | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/lib/sqlalchemy/dialects/mysql/base.py b/lib/sqlalchemy/dialects/mysql/base.py index 2c78de2fc..dc6340d32 100644 --- a/lib/sqlalchemy/dialects/mysql/base.py +++ b/lib/sqlalchemy/dialects/mysql/base.py @@ -1850,9 +1850,16 @@ class MySQLCompiler(compiler.SQLCompiler): return "" def visit_join(self, join, asfrom=False, **kwargs): + if join.full: + join_type = " FULL OUTER JOIN " + elif join.isouter: + join_type = " LEFT OUTER JOIN " + else: + join_type = " INNER JOIN " + return ''.join( (self.process(join.left, asfrom=True, **kwargs), - (join.isouter and " LEFT OUTER JOIN " or " INNER JOIN "), + join_type, self.process(join.right, asfrom=True, **kwargs), " ON ", self.process(join.onclause, **kwargs))) |