Как выполнить этот SQL-запрос с помощью Python - PullRequest
Новая
       9

Как выполнить этот SQL-запрос с помощью Python

0 голосов
/ 07 января 2019

Traceback (последний вызов был последним):

Файл "testtrans.py", строка 26, в модуле

cursor1.execute (sql_query) psycopg2.ProgrammingError:

синтаксическая ошибка в конце ввода LINE 1:

... катион, где созданный_датчик <= ДАТА (NOW () - интервал '1 месяц' </p> 

import time
import pandas as pd
import sqlalchemy
from sqlalchemy import create_engine
import psycopg2
from sqlalchemy.types import TIMESTAMP as typeTIMESTAMP

connection1 = psycopg2.connect("host='localhost1' dbname='prod' user='root' password='pass1'")
 cursor1 = connection1.cursor()

engine1 =   create_engine('postgresql://root:localhost1:5432/prod')
engine2 = create_engine('postgresql://root:localhost1:5432/prod_archive')

df = pd.read_sql_query("""
select id,text,created_date,is_read,to_user_id,is_new,url,text_ar,text_en from notifications_notification where created_date <= NOW() - interval '1 month'
""",engine1)
df= df.rename(columns={
'id':'original_id','text':'text','created_date':'created_date','is_read':'is_read','to_user_id':'to_user_id','is_new':'is_new','url':'url','text_ar':'text_ar','text_en':'text_en'  
})

df['created_date'] = pd.to_datetime(df['created_date'])
df['created_date'] = df['created_date'].astype('datetime64[us]')
df.set_index('created_date', inplace=True)
#df.to_sql(name='notifications_notification_archive',con=engine2,if_exists='append')
sql_query = "delete from notifications_notification where id in (select id from notifications_notification where created_date <= "DATE(NOW() - interval '1 month'""
cursor1.execute(sql_query)
connection1.commit()

Я пробовал много сценариев, чтобы сделать эту строку исполняемой, но она не сработала.

Ответы [ 2 ]

0 голосов
/ 07 января 2019

удалить из notification_notification, где id в (выберите id из notifications_notification, в котором create_date <= NOW () - интервал '1 месяц') </p>

0 голосов
/ 07 января 2019

Я не уверен насчёт этого, но команда DATE в вашем коде должна быть функцией sql и, как она есть, выглядит как переменная / функция python. Даже если я ошибаюсь, круглые скобки не закрыты, и в конце есть лишние ". Попробуйте: 

sql_query = "delete from notifications_notification where id in (select id from notifications_notification where created_date <= DATE(NOW())" - interval '1 month'"
...