Python sqlalchemy 模块,sql() 实例源码
我们从Python开源项目中,提取了以下5个代码示例,用于说明如何使用sqlalchemy.sql()。
def constrained(self):
from zeus.auth import get_current_tenant
if not self.current_constrained:
return self
mzero = self._mapper_zero()
if mzero is not None:
tenant = get_current_tenant()
if tenant.repository_ids:
return self.enable_assertions(False).filter(
mzero.class_.repository_id.in_(tenant.repository_ids)
)
else:
return self.enable_assertions(False).filter(sqlalchemy.sql.false())
return self
def run(self, connection):
print "Upgrading to schema version {0}".format(self.schema_version)
with connection.begin():
if self.schema_version != 1:
old_version = connection.execute("""SELECT value FROM config
WHERE key = 'schema_version'""").scalar()
if int(old_version) + 1 != self.schema_version:
raise DatabaseError("""Tried to update schema from
{0} to {1}""".format(old_version, self.schema_version))
if self.statements:
for s in self.statements:
connection.execute(s)
if self.callable:
self.callable(connection)
connection.execute(
sqlalchemy.sql.text(
"""UPDATE config SET value = :version
WHERE key = 'schema_version'"""),
version=self.schema_version)
def get_column_default_string(self, column):
if (isinstance(column.server_default, schema.DefaultClause) and
isinstance(column.server_default.arg, basestring)):
if isinstance(column.type, (sqltypes.Integer, sqltypes.Numeric)):
return self.sql_compiler.process(text(column.server_default.arg))
return super(InfoDDLCompiler, self).get_column_default_string(column)
### Informix wants the constraint name at the end,hence this ist c&p from sql/compiler.py
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。