alembic并获取最后插入的值

在使用id作为Integer和主键添加表后，id列将成为自动增量列。我如何查询升级脚本中的数据，所以我确定我得到了正确的ID（我知道在这种情况下它是1）？

我知道我如何

#creating the table 
op.create_table(
    'srv_feed_return_type', 
    sa.Column('id', sa.Integer, primary_key=True), 
    sa.Column('name', sa.String(50), nullable=False), 
    sa.Column('created', sa.DateTime, server_default=func.now(), nullable=False), 
    sa.Column('created_by', sa.String(50), nullable=False), 
    sa.Column('last_updated', sa.DateTime, nullable=False), 
    sa.Column('last_updated_by', sa.String(50), nullable=False) 
) 

#table for operations 
srv_feed_return_type = table('srv_feed_return_type', 
          column('name'), 
          column('created'), 
          column('created_by'), 
          column('last_updated'), 
          column('last_updated_by')) 

#bulk insert 
op.bulk_insert(srv_feed_return_type, 
       [ 
        {'name': 'dataset', 
        'created': datetime.now(), 'created_by': 'Asken', 
        'last_updated': datetime.now(), 'last_updated_by': 'Asken'} 
       ])

知道我可以做更新，但我怎么做一个选择使用类似的东西象下面这样？

op.execute(
    srv_feed_return_type.update().\ 
     where(srv_feed_return_type.c.name==op.inline_literal('dataset')).\ 
     values({'name':op.inline_literal('somethingelse')}) 
     )

来源

2013-03-21 Asken

它是安全的假设，直到迁移完成后不会有任何其他进程修改您的新创建的表？ – vvladymyrov 2013-03-21 13:59:23

这个例子是的，但我知道它会在这里。在另一次迁移中，它不会再是1了。我需要知道特定返回类型的ID。 – Asken 2013-03-21 14:11:07

你的应用程序使用了哪些数据库，是否有可能让更多的数据库到另一个数据库 - 是否需要让应用程序成为数据库不可知的？ – vvladymyrov 2013-03-21 15:24:32

首先有自动递增列，您将需要修改表架构定义已序列传递给主键列：sa.Column('id', sa.Integer, Sequence('srv_feed_r_t_seq'),primary_key=True),

#creating the table 
op.create_table(
    'srv_feed_return_type', 
    sa.Column('id', sa.Integer, Sequence('srv_feed_r_t_seq'),primary_key=True), 
    sa.Column('name', sa.String(50), nullable=False), 
    sa.Column('created', sa.DateTime, server_default=func.now(), nullable=False), 
    sa.Column('created_by', sa.String(50), nullable=False), 
    sa.Column('last_updated', sa.DateTime, nullable=False), 
    sa.Column('last_updated_by', sa.String(50), nullable=False) 
)

现在关于如何获得PK ID：

op.execute和op.bulk_insert不会返回任何结果。但是您可以获得用于这些操作的相同连接。

做bulk_insert或execute(table.update ...)后，您可以在同一个环境中运行选择查询和检索PK ID为感兴趣的记录：

connection = op.get_bind() 
r = connection.execute(srv_feed_return_type.select().where(...)) 
for row in r: 
    pk_id = r['id'] 
    """or something more sophisticated"""

你需要指定where子句，以确保适当的过滤器您确定了您最近以独特方式更改的记录。

这里是some example of similar functionality，但它已硬编码选择查询

来源

2013-03-21 18:37:06 vvladymyrov

会尝试。谢谢！顺便说一句，通过定义Integer和primary_key = True，它将自动成为自动增量。 – Asken 2013-03-21 19:21:22

谢谢你有关自动自动增量的提示。当我使用Oracle时它不适用于我 - 所以我必须明确地使用序列 – vvladymyrov 2013-03-21 20:12:10

也许这对Oracle来说是不同的......也许我应该将它添加到我的代码中以确保安全。 – Asken 2013-03-22 07:12:00

alembic并获取最后插入的值

回答

相关问题