【发布时间】:2017-09-23 16:22:17
【问题描述】:
我是 python 和 postgresql 的新手
我一直在努力用 python 对每个 json 行进行硬编码,我认为这不是可扩展的方法。如果有人可以指出我可以处理从 python 插入 json 而无需硬编码的文献或文档。
我已经查看了 COPY。
【问题讨论】:
标签: python json postgresql psycopg2 jsonb
我是 python 和 postgresql 的新手
我一直在努力用 python 对每个 json 行进行硬编码,我认为这不是可扩展的方法。如果有人可以指出我可以处理从 python 插入 json 而无需硬编码的文献或文档。
我已经查看了 COPY。
【问题讨论】:
标签: python json postgresql psycopg2 jsonb
import json
data = [1, [2,3], {'a': [4,5]}]
my_json = json.dumps(data)
insert_query = "insert into t (j) values (%s) returning j"
cursor.execute(insert_query, (my_json,))
print (cursor.fetchone()[0])
输出:
[1, [2, 3], {'a': [4, 5]}]
【讨论】:
conn.autocommit = True 或conn.commit 在数据库中查看实际结果。
使用数据集 + psycopg2
import dataset
def construct_pg_url(postgres_user='postgres', postgres_password='', postgres_host='localhost', postgres_port='5432', postgres_database='postgres'):
PG_URL = "postgresql://" + postgres_user + ":" + postgres_password + '@' + postgres_host + ':' + postgres_port + '/' + postgres_database
return PG_URL
pgconn = dataset.Database(
url=construct_pg_url(),
schema='my_schema'
)
table = pgconn['my_table']
rows = [dict(foo='bar', baz='foo')] * 10000
table.insert_many(rows)
【讨论】: