|
2 | 2 | from sqlalchemy.engine import reflection
|
3 | 3 | from sqlalchemy import util, exc
|
4 | 4 | from sqlalchemy.types import VARCHAR, NullType
|
| 5 | +from sqlalchemy.ext.compiler import compiles |
| 6 | +from sqlalchemy.sql.expression import Executable, ClauseElement |
| 7 | + |
5 | 8 |
|
6 | 9 | class RedshiftDialect(PGDialect_psycopg2):
|
7 | 10 | @reflection.cache
|
@@ -51,3 +54,20 @@ def _get_column_info(self, name, format_type, default,
|
51 | 54 | if isinstance(column_info['type'], VARCHAR) and column_info['type'].length is None:
|
52 | 55 | column_info['type'] = NullType()
|
53 | 56 | return column_info
|
| 57 | + |
| 58 | + |
| 59 | +class UnloadFromSelect(Executable, ClauseElement): |
| 60 | + def __init__(self, select, bucket, access_key, secret_key): |
| 61 | + self.select = select |
| 62 | + self.bucket = bucket |
| 63 | + self.access_key = access_key |
| 64 | + self.secret_key = secret_key |
| 65 | + |
| 66 | +@compiles(UnloadFromSelect) |
| 67 | +def visit_unload_from_select(element, compiler, **kw): |
| 68 | + return "unload ('%(query)s') to '%(bucket)s' credentials 'aws_access_key_id=%(access_key)s;aws_secret_access_key=%(secret_key)s'" % { |
| 69 | + 'query': element.select, |
| 70 | + 'bucket': element.bucket, |
| 71 | + 'access_key': element.access_key, |
| 72 | + 'secret_key': element.secret_key, |
| 73 | + } |
0 commit comments