使用asyncpg插入多行的最佳方式
使用asyncpg插入多行的最佳方式
提问于 2017-05-02 21:27:10
我想用asyncpg插入多行并获取i，我找到了两种方法: 1:像这样生成sql
INSERT INTO films (code, title, did, date_prod, kind) VALUES
('B6717', 'Tampopo', 110, '1985-02-10', 'Comedy'),
('HG120', 'The Dinner Game', 140, DEFAULT, 'Comedy')
RETURNING id;2:在for循环中使用预准备语句
values =(('B6717', 'Tampopo', 110, '1985-02-10', 'Comedy'),
('HG120', 'The Dinner Game', 140, DEFAULT, 'Comedy'))
stmnt = connection.prepare("INSERT INTO films (code, title, did, date_prod, kind) VALUES $1, $2, $3, $4, $5 RETURNING id")
for val in values:
stmnt.fetchval(*val)在100x倍的情况下，我必须选择哪种方法来处理70万行数据，或者有一些方法可以组合这些方法？我完全是菜鸟，所以给我扔点西红柿
回答 2
Stack Overflow用户
发布于 2017-05-04 18:15:19
asyncpg提供了executemany方法来插入许多行。
statement = """INSERT INTO films (code,
title,
did,
date_prod,
kind) VALUES($1, $2, $3, $4, $5);"""
await connection.executemany(statement, values)如果需要使用稍后提到的RETURNING来返回插入的ids，则可以使用此answer。
Stack Overflow用户
发布于 2019-04-19 03:00:36
一次插入多行的另一种方法(假设不需要插入的is )是使用copy_records_to_table方法。
data = [
("row", 1, "some data"),
("row", 2, "more data"),
]
await conn.copy_records_to_table('mytable', records=data)页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/43739123
复制相关文章
相似问题