我在cassandra中有数据,我正在尝试从数据库中获取日期时间范围内的数据。
下面是代码。
fromdate = datetime.combine(dt, datetime.min.time())
todate = datetime.combine(datetime.now().date(), time(23, 59, 59))
print(fromdate)
print(todate)
batch = BatchStatement()
batch.add(SimpleStatement("SELECT * FROM datadump WHERE 'pickup_time' >= '%s' AND 'pickup_time' <= '%s' ALLOW FILTERING;"),
(fromdate, todate,))
data = session.execute(batch)
当我尝试在日期时间范围内提取数据时,上面的代码不起作用,但如果我尝试从数据转储中提取所有数据(如"SELECT*"(,它就会起作用。
有人能告诉我上面的方法出了什么问题吗?
提前感谢!
您不能在批处理语句中使用SELECT
,它只适用于INSERT
/UPDATE
/DELETE
。。。
此外,请注意,CQL中的BATCH与SQL中的不同,您需要知道何时使用它,何时不使用它——请参阅有关如何使用的文档;何时使用。