我正在使用下面的一组参数来创建动态 sql 查询并从 python 运行它。
target_column = 'connect_status'
table_name = 'public.main_table'
query_params = {'month_date' : '201801',
'churn_date' : ['201802','201803','201804'],
'disco_target' : '1-3 Month Disco'
}
for churn in query_params['churn_date']:
sql_data_sample = str("""select * from {1}
where dt = %(month_date)s
and churn_date = %(churn)s
and {0} IN (%(disco_target)s,'No Disco') order by random() limit 5000
;""").format(target_column,table_name)
print (sql_data_sample)
df_data_sample = pd.read_sql(sql_data_sample,con = cnxn,params = query_params)
但是这会产生数据库错误:
Execution failed on sql 'select * from public.main_table
where dt = %(month_date)s
and churn_date = %(churn)s
and connect_status IN (%(disco_target)s,'No Disco') order by random() limit 5000
;': 'churn'
有人可以帮我改正吗?
最佳答案
问题是因为 churn
在 query_params
中不可用。将您的代码修改为
for churn in query_params['churn_date']:
try:
sql_data_sample = str("""select * from {1}
where dt = %(month_date)s
and churn_date = %(churn)s
and {0} IN (%(disco_target)s,'No Disco') order by random() limit 5000
;""").format(target_column,table_name)
print (sql_data_sample)
query_params['churn'] = churn
df_data_sample = pd.read_sql(sql_data_sample,con = cnxn,params = query_params)
except (Exception, psycopg2.DatabaseError) as error:
print(error)
关于python - 从 Python 创建动态 SQL 查询,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53256723/