在SQLite中读取（从另一个表中）时插入行

  • Z时代
  • 2024-01-10
  • 分类：问答

无论使用python还是sqlite，我都会收到此错误。在SQLite中读取（从另一个表中）时插入行

File "addbooks.py", line 77, in saveBook 
    conn.commit() 
    sqlite3.OperationalError: cannot commit transaction - SQL statements in progress

的代码看起来是这样的：

conn = sqlite3.connect(fname) 
cread = conn.cursor() 
cread.execute('''select book_text from table''') 
while True: 
    row = cread.fetchone() 
    if row is None: 
     break 
    .... 
    for entry in getEntries(doc): 
     saveBook(entry, conn)

不能做一个使用fetchall（），因为表和列的尺寸是大的，而内存不足。

没有诉诸肮脏的技巧可以做什么（如获取内存中的rowid，这可能适合，然后逐一选择行）？

回答：

不知道这样算不算“搞鬼”太;-)

我对这个问题的解决方案是使用SELECT... LIMIT clause，以为你有主键整数字段id

current_id = 0 
while True:  
    cread.execute('''select book_text from table where id > %s limit 2''' % current_id) 
    results = cread.fetchall() 
    if results is None: 
     break; 
    for row in results: 
     ... (save book) ... 
     current_id = row.id

回答：

的问题在于您已将连接保留为自动提交模式。在整个过程中包装单个事务，以便在完成所有更新后才会发生提交，并且它应该都可以正常工作。

回答：

问题是连接中应该只有一个活动游标。

解决方案是使用新的连接进行更新。

不幸的是我不记得在我看过的文档中的确切位置，所以我不能证明它。

UPD：

下面的代码工作在我的Windows XP：

results: 
---------- 
0 updated 
1 updated 
2 updated 
3 updated 
4 updated

如果我移动conn2.commit()到了：

import sqlite3 
import os 
conn1 = sqlite3.connect('test.db') 
cursor1 = conn1.cursor() 
conn2 = sqlite3.connect('test.db') 
cursor2 = conn2.cursor() 
cursor1.execute("CREATE TABLE my_table (a INT, b TEXT)") 
cursor1.executemany("INSERT INTO my_table (a, b) VALUES (?, NULL);", zip(range(5))) 
conn1.commit() 
cursor1.execute("SELECT * FROM my_table") 
for a, b in cursor1: 
    cursor2.execute("UPDATE my_table SET b='updated' WHERE a = ?", (a,)) 
conn2.commit() 
print "results:" 
print 10 * '-' 
cursor1.execute("SELECT * FROM my_table") 
for a, b in cursor1: 
    print a, b 
cursor1.close() 
conn1.close() 
cursor2.close() 
conn2.close() 
os.unlink('test.db')

，并返回预期以下循环，我得到了你提到的同样的错误：

Traceback (most recent call last): 
    File "concurent.py", line 16, in <module> 
    conn2.commit() 
sqlite3.OperationalError: database is locked

因此，解决方案是在末尾提交一次，而不是在每行之后提交。

以上是 在SQLite中读取（从另一个表中）时插入行 的全部内容， 来源链接： utcz.com/qa/265792.html

回到顶部