如何在SqlAlchemy中使用datetime进行原始查询

Question

所以我试图根据日期时间字段timeStamp从表messages查询，但我一直得到一个错误。也许我试图查询的方式是不正确的。

def get_test(self, start_date, end_date):

query = 'SELECT * from messages WHERE messages."timeStamp" > {start_date} and messages."timeStamp" < {end_date};'
res = self.session.execute(query)
self.session.commit()

return res.fetchall()

当我运行这段代码时，我得到以下错误:

sqlalchemy.exc.ProgrammingError: (psycopg2.errors.SyntaxError) syntax error at or near "00"
LINE 1: ... messages WHERE messages."timeStamp" > 2021-06-01 00:00:00 a...

我也试过使用datetime.strptime方法，但也不起作用。

def get_test(self, start_date, end_date):

query = f'''SELECT * from messages WHERE messages."timeStamp" > {datetime.strptime(start_date, "%Y-%m-%d %H:%M:%S")}   
and messages."timeStamp" < {datetime.strptime(end_date, "%Y-%m-%d %H:%M:%S")};'''
res = self.session.execute(query)
self.session.commit()

return res.fetchall()

我也尝试使用查询参数，但也没有工作。

def get_test(self, start_date, end_date):

query = f'SELECT * from messages WHERE messages."timeStamp" > %s and messages."timeStamp" < %s;'
res = self.session.execute(query, (datetime.strptime(start_date, "%Y-%m-%d %H:%M:%S"), 
datetime.strptime(end_date, "%Y-%m-%d %H:%M:%S")))
self.session.commit()

return res.fetchall()

如果有人能帮我一下，我将非常感激。

Answer 1

我认为这里有两件事。

我不认为你的f字符串是填充的，strptime是用来把字符串转换成日期的，而不是反过来。

我会这样写:

query = f'SELECT * from messages WHERE messages."timeStamp" > {start_date.isoformat()} and messages."timeStamp" < {end_date.isoformat()};'