Skip to content

Commit 294bc65

Browse files
committed
Working on escaping inside quotes
Signed-off-by: Jason Myers <[email protected]>
1 parent 99259ec commit 294bc65

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

redshift_sqlalchemy/dialect.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -75,15 +75,17 @@ def __init__(self, select, bucket, access_key, secret_key):
7575
self.access_key = access_key
7676
self.secret_key = secret_key
7777

78+
7879
@compiles(UnloadFromSelect)
7980
def visit_unload_from_select(element, compiler, **kw):
8081
''' Returns the actual sql query for the UnloadFromSelect class
8182
'''
83+
query = compiler.process(element.select)
84+
import pdb; pdb.set_trace()
85+
query_str = str(query).replace("'", "\'")
8286
return "unload ('%(query)s') to '%(bucket)s' credentials 'aws_access_key_id=%(access_key)s;aws_secret_access_key=%(secret_key)s' delimiter ',' addquotes" % {
83-
'query': compiler.process(element.select),
87+
'query': query_str,
8488
'bucket': element.bucket,
8589
'access_key': element.access_key,
8690
'secret_key': element.secret_key,
8791
}
88-
89-

0 commit comments

Comments
 (0)