Как правильно передать параметр в вызове процедуры с MySQL, Pandas и SQLAlchemy?
В Python 2.7, когда я использую sqlalchemy и pandas для выполнения вызова proc из MySQL, я получаю эту ошибку:
sqlalchemy.exc.ProgrammingError: (pymysql.err.ProgrammingError) (1064, u'You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near \'2018-03-10\'","end_date":"\'2018-03-16\'"
start_date = datetime.date(2018, 3, 10)
end_date = datetime.date(2018, 3, 16)
proc_call = text('''call schema.proc_call('{"start_date"\\:":start_date","end_date"\\:":end_date","foo":"1", "foo2":2}')''')
results = pd.read_sql_query(proc_call, con=connection, params = {"start_date": start_date, "end_date": end_date})
Это работает, когда даты жестко запрограммированы, но мне нужно, чтобы они были параметрами.
Ответы 1
Похоже, вы пытаетесь передать строку JSON в proc_call, так что сделайте это. Создайте подходящую конструкцию Python, закодируйте как JSON и передайте ее в качестве аргумента:
import json
start_date = datetime.date(2018, 3, 10)
end_date = datetime.date(2018, 3, 16)
arg0 = {"start_date": start_date, "end_date": end_date, "foo": "1", "foo2": 2}
proc_call = text('call schema.proc_call(:arg0)')
results = pd.read_sql_query(proc_call, con=connection,
params = {"arg0": json.dumps(arg0)})
Ошибка является результатом попытки использовать заполнители внутри строкового литерала. Конечный результат - что-то вроде
'{"start_date":"'2018-03-10'", ...}'
это строковый литерал '{"start_date":"', за которым следует 2018-03-10 и т. д., что не является допустимым синтаксисом.
Вы также можете использовать связанные параметры еще дальше и указать их тип явно:
from sqlalchemy import bindparam, JSON
start_date = datetime.date(2018, 3, 10)
end_date = datetime.date(2018, 3, 16)
arg0 = {"start_date": start_date, "end_date": end_date, "foo": "1", "foo2": 2}
proc_call = text('call schema.proc_call(:arg0)')
proc_call = proc_call.bindparams(bindparam('arg0', type_=JSON))
results = pd.read_sql_query(proc_call, con=connection, params = {"arg0": arg0})