python - 使用 SQLAlchemy 将行从一个表批量移动到另一个表

Question

我有两个相同的表 post 和 old_post。我有一个检查旧帖子的查询。我想将查询返回的行移动到表 old_post 中，并从表 post 中删除这些行。

我可以通过遍历初始查询返回的结果并以这种方式更新我的结果来解决这个问题，但是我担心这是非常低效的，并且当我有 1,000 多行时会开始给我带来问题。如何有效地将行从一个表“批量移动”到另一个表？

Answer 1

查询旧的帖子。使用旧的 Posts 数据批量插入 OldPosts。批量删除旧的帖子。

keys = db.inspect(Post).columns.keys()
get_columns = lambda post: {key: getattr(post, key) for key in keys}

posts = Post.query.filter(Post.expiry > ts)
db.session.bulk_insert_mappings(OldPost, (get_columns(post) for post in posts))
posts.delete()
db.session.commit()

get_columns 函数接受一个 Post 实例并根据列键和值创建一个字典。阅读有关使用批量的文档和警告 insert和 delete操作。