加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 编程开发 > Python > 正文

python – 使用SQLAlchemy在两秒内过滤对象

发布时间:2020-12-16 22:21:02 所属栏目:Python 来源:网络整理
导读:我有两个表date列.一个持有(名称,日期),另一个持有(日期,p1,p2).给定一个名称,我想使用表1中的日期来查询表2中的p1和p2;如果表1中的日期在表2中的日期的两秒内,则匹配应该发生. 你如何使用SQLAlchemy实现这一目标? 我试过(不成功)使用between运算符和一个子

我有两个表’date’列.一个持有(名称,日期),另一个持有(日期,p1,p2).给定一个名称,我想使用表1中的日期来查询表2中的p1和p2;如果表1中的日期在表2中的日期的两秒内,则匹配应该发生.

你如何使用SQLAlchemy实现这一目标?

我试过(不成功)使用between运算符和一个子句,如:

td = datetime.timedelta(seconds=2)
q = session.query(table1,table2).filter(table1.name=='my_name').
    filter(between(table1.date,table2.date - td,table2.date + td))

有什么想法吗?

编辑:
我已设法使用以下方法解决问题:

from sqlalchemy.sql import between
import datetime
# [all other relevant imports]

td = datetime.timedelta(seconds=2)
t1_entry = session.query(table_1).filter(table_1.name == 'the_name').first()
if t1_entry is not None:
 tmin = t1_entry.date - td
 tmax = t1_entry.date + td
 t2_entry = session.query(table_2).filter(between(table_2.date,tmin,tmax)).first()
 return (t1_entry,t2_entry)
return None

所以可以进行比较,但我不确定这种方法是否有效.

最佳答案
让我先解释一下你为什么尝试不起作用. SQLAlchemy只是编写SQL查询的一种便捷方式,但所有查询都发生在远程端. SQLAlchemy列是特殊对象,其__eq __,__ gt__等方法被覆盖以返回非True或False,但是其他特殊对象,它们记住它们被比较的对象是什么,并且可以在以后生成适当的SQL语句.同样是添加等:自定义__add __,_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _您可以将它们与字符串,整数等,其他列,select语句,mysql函数调用等进行比较/添加,但不能将它们添加到像timedeltas这样的特殊python对象中. (简化,技术上可能不是100%正确;))

所以你能做的是:

>使数据库中的值为整数,例如unix时间戳.那样你的查询之间就可以了(用2而不是delta)
>使用数据库端函数将日期时间格式日期转换为unix时间戳,然后进行比较.

更新:我已经玩了一点,并且它确实有效,甚至有一个Interval数据类型.但至少在这里它不能正常工作:

MySQL的:

>>> db.session.execute(db.select([User.date_joined,User.date_joined + timedelta(seconds=2)],limit=1)).fetchall()
[(datetime.datetime(2009,7,10,20,47,33),20090710204733.0)]
>>> db.session.execute(db.select([User.date_joined,User.date_joined + 2],20090710204735.0)]
>>> db.session.execute(db.select([User.date_joined+0,limit=1)).fetchall()
[(20090710204733.0,20090710204735.0)]

SQLite的:

>>> db.session.execute(db.select([User.date_joined,limit=1)).fetchall()
TypeError: expected string or buffer
>>> db.session.execute(db.select([User.date_joined,limit=1)).fetchall()
[(datetime.datetime(2010,5,28,23,8,22,476708),2012)]
>>> db.session.execute(db.select([User.date_joined+0,limit=1)).fetchall()
[(2010,2012)]

我不知道为什么第一个在MySQL上失败以及为什么它返回浮点数. SQLite错误似乎发生,因为SQLite does not have a DATETIME data type and SQLAlchemy stores it as a string.

你将不得不玩一点,也许你会找到一种方法 – 但我认为保持真正的dbms独立整数方法将是唯一可行的方法.

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读