def prepare(query, connection=None, external=None):
connection = merge(_default, connection or {})
database = escape(connection['database'])
query = query.format(db=database)
params = {'query': query,
'user': connection['user'],
'password': connection['password']}
params = valfilter(lambda x: x, params)
files = {}
external = external or {}
for name, (structure, serialized) in external.items():
params['{}_format'.format(name)] = 'CSV'
params['{}_structure'.format(name)] = structure
files[name] = serialized
host = connection['host']
return host, params, files
评论列表
文章目录