python - psycopg2 实际上没有插入数据

Question

我需要将 JSON 数据从龙卷风插入到 postgres，所以这里的测试是这样的：

from psycopg2 import connect

conn = connect("user='pguser' host='localhost' dbname='pgdb' password='pgpass'")
cursor = conn.cursor()

data = '[{"id":"sdf","name":"wqe","author":"vb"}]'

for row in eval(data):
  print row
  cursor.execute("""INSERT INTO books(id,name,author) VALUES('%s','%s','%s')""" % \
        (row['id'], row['name'], row['author'])
  )

>>> cursor.execute("SELECT * FROM books")
>>> cursor.fetchall()
[('sdf', 'wqe', 'vb')]
>>> 
$> psql -d pgdb -U pguser -W
Password for user pguser: 
psql (9.1.6)
Type "help" for help.

pgdb=> select * from books;
 id | name | author 
----+------+--------
(0 rows)

正如你select在python shell中看到的，有一些数据，但在psql中有0行！我可能做错了什么？

Python 2.7.2+

Answer 1

你没有提交交易。

Psycopg2 自动打开一个事务，您必须告诉它提交以使数据对其他会话可见。

请参阅psycopg2 常见问题解答和connection.commit()方法。

Answer 2

刚刚遇到同样令人困惑的问题。将选项放在一起：

正如@Craig Ringer 在 cursor.execute 之后所写，您可以运行 connection.commit

cursor.execute('INSERT INTO table VALUES(DEFAULT, %s)', email)
...
connection.commit()

或连接后设置自动提交

connection = connect("user='pguser' host='localhost' dbname='pgdb' password='pgpass'")
connection.autocommit = True

或使用 set_session 设置自动提交

connection = connect("user='pguser' host='localhost' dbname='pgdb' password='pgpass'") 
connection.set_session(autocommit=True)

一切都为我工作。