次のような辞書がありますd = {'table': 'db_schema.foo', 'column': 'bar'}
。すべての値から引用符を削除した後、この辞書を渡したいです。{'table': db_schema.foo, 'column': bar}
だから私は動的に取得したい。
詳細:
接続後に動的クエリの実行を exasol に渡そうとしています。ここでpyexasolを使用して試していexecute()
ます。次のような単純なクエリを実行しようとしています:
SELECT *
FROM db_schema.foo
WHERE bar >= 0
辞書を提供するd
と、実行されるクエリは次のようになります。
SELECT *
FROM 'db_schema.foo'
WHERE 'bar' >= 0
となり、エラーになります。したがって、すべての値から引用符を削除したいと思います。などを試し{k:v.strip("\'") for k, v in d.items()}
ましたが、まだ成功していません。
要求されたコード:
foo_query = '''select *
from {app_table}
where {col} >= '2020-01-01'
limit 10;'''
foo_param={'app_table': 'src.application',
'col': 'createdat'}
foo_results = exasol.runQueryExaParams(query=foo_query, query_param=foo_param)
foo_results1 = exasol.runQueryExaParams(query=foo_query, query_param={k:v.strip("\'") for k, v in foo_param.items()})
ここで、exasol は、接続パラメーターのみを使用して pyexasol で構築されたクラスです。そこにあるクラスからの関連メソッド:
def runQueryExaParams(self, query, query_param):
self.conn = pyexasol.connect(
dsn=self.__dsn, user=self.__user, password=self.__password, encryption=True)
res = self.conn.export_to_pandas(query, query_param)
self.conn.close()
res.columns = res.columns.str.lower()
return res
どちらの場合も、同じエラーが発生します:
pyexasol.exceptions.ExaQueryError:
(
message => syntax error, unexpected simple_string_literal [line 3, column 22] (Session: )
dsn =>
user =>
schema =>
code => 42000
session_id =>
query => EXPORT (
select *
from 'src.application'
where 'createdat' >= '2020-01-01'
limit 10
) INTO CSV
AT 'https://1.2.3.4' FILE '000.csv'
WITH COLUMN NAMES
)