在 sqlalchemy 中使用 DATEADD答案

【问题标题】：Using DATEADD in sqlalchemy在 sqlalchemy 中使用 DATEADD
【发布时间】：2013-03-12 10:11:37
【问题描述】：

如何在 python 中使用 sqlalchemy 重写以下 sql 语句。我一直在寻找 30 分钟，但仍然找不到任何解决方案。

DATEADD(NOW(), INTERVAL 1 DAY)

或

INSERT INTO dates (expire)
VALUES(DATEADD(NOW(), INTERVAL 1 DAY))

提前致谢

【问题讨论】：

标签： python sql sqlalchemy flask flask-sqlalchemy

【解决方案1】：

为了完整起见，以下是使用 sqlalchemy.sql.func 生成准确 SQL 的方法：

from sqlalchemy.sql import func
from sqlalchemy.sql.expression import bindparam
from sqlalchemy import Interval

tomorrow = func.dateadd(func.now(), bindparam('tomorrow', timedelta(days=1), Interval()))

导致：

>>> from sqlalchemy.sql import func
>>> func.dateadd(func.now(), bindparam('tomorrow', timedelta(days=1), Interval(native=True)))
<sqlalchemy.sql.expression.Function at 0x100f559d0; dateadd>
>>> str(func.dateadd(func.now(), bindparam('tomorrow', timedelta(days=1), Interval(native=True))))
'dateadd(now(), :tomorrow)'

您也可以使用text() 对象来指定间隔：

from sqlalchemy.sql import func
from sqlalchemy.sql.expression import text

tomorrow = func.dateadd(func.now(), text('interval 1 day'))

【讨论】：

值得注意的是，the docs state that Interval 仅适用于某些 DB，并且可能需要 text 版本。
@wbyoung：由于 OP 说明了他们想在问题中使用的确切 SQL 表达式，因此可以安全地假设他们正在使用支持该语法的数据库。
其他数据库支持DATEADD(NOW(), INTERVAL 1 DAY)，即MySQL，但SQLAlchemy不支持，因为适配器存在类型问题。

【解决方案2】：

SQLAlchemy 日期自动映射到 Python 日期时间对象，因此您应该能够做到：

from sqlalchemy import Table, Column, MetaData, DateTime
from datetime import datetime, timedelta

metadata = MetaData()
example = Table('users', metadata,
   Column('expire', DateTime)
)

tomorrow = datetime.now() + timedelta(days=1)

ins = example.insert().values(expire=tomorrow)

【讨论】：

不幸的是，SQLAlchemy 的日期系统现在不会自动强制转换为特定于平台的函数，例如 DATEADD()。只有在带有 psycopg2（也可能是 mysql）的 Postgresql 上，上面的简单日期算术才会转换为数据库的预期。

【解决方案3】：

Doobeh 在我打字的时候打败了我，这是我要发布的烧瓶 sqlalchemy 示例（以补充简单的 sqlalchemy 示例）：

from flask.ext.sqlalchemy import SQLAlchemy
from datetime import datetime, timedelta

db = SQLAlchemy()

class Thing(db.Model):
    id = db.Column(db.Integer, primary_key=True)
    created = db.Column(db.DateTime)

c = Thing(created = datetime.utcnow() + timedelta(days=1))
print repr(c.created)
# datetime.datetime(2013, 3, 23, 15, 5, 48, 136583)

您也可以将默认值作为可调用对象传递：

from flask.ext.sqlalchemy import SQLAlchemy
from datetime import datetime, timedelta

db = SQLAlchemy()

def tomorrow():
    return datetime.utcnow() + timedelta(days=1)

class Thing(db.Model):
    id = db.Column(db.Integer, primary_key=True)
    publish_date = db.Column(db.DateTime, default=tomorrow)

【讨论】：

【解决方案4】：

您可以使用 MySQL timestampadd insted dateadd。

【讨论】：

【解决方案5】：

from datetime import datetime, timedelta
from dateutil import tz

new_date = datetime.now(tz=tz.tzlocal()) + timedelta(days=1)
new_item = Expire(expire=new_date)
session.save(new_item)
session.commit()

【讨论】：