如何将 JSON 文件也加载到 PSQL 数据库中

Question

我有一个 JSON 文件。现在我需要将 JSON 数据加载到我的 PSQL 数据库中。

目前我试过这个

import psycopg2
import json
with open('new.json') as f:
    data = f.read()
    dd = json.loads(data)
    conn = psycopg2.connect(database="newdb", user = "postgres",  password = "postgres",host = "127.0.0.1", port = "5432")

    print "Opened database successfully"

    cur = conn.cursor()

    cur.execute(''' CREATE TABLE jsontable(SUM INT NOT NULL,
                                      APP  CHAR[30] NOT NULL,
                                      ID INT NOT NULL,
                                      DOMAINNAME TEXT NOT NULL,
                                      DOMAINID INT NOT NULL);''')
    print "Table Created successfully"


    cur.execute('''INSERT INTO jsontable(data)
                   VALUES(%s)
                ''',
                     (data, str(dd['sum'],str(dd['app'],str(dd['id'],str(dd['Domain_name'],str(dd['Domain_Id'])))

print ("Data Entered successfully")
conn.commit()
conn.close()

请提供一些例子，如何将JSON文件数据传递到数据库

Answer 1

我个人喜欢asyncpg，因为它是完全异步的，特别是如果您使用的是 Python 3.x 并且基本上您需要做的就是将 await 放在同步命令的前面。

import asyncpg
import json
with open('new.json') as f:
    data = f.read()
    dd = json.loads(data)
    conn = await asyncpg.connect(database="newdb", user = "postgres",  password = "postgres",host = "127.0.0.1", port = "5432")    
    print "Opened database successfully"
    await con.execute(''' CREATE TABLE jsontable(SUM INT NOT NULL,
                                      APP  CHAR[30] NOT NULL,
                                      ID INT NOT NULL,
                                      DOMAINNAME TEXT NOT NULL,
                                      DOMAINID INT NOT NULL);''')
    print "Table Created successfully"


    await con.execute('''INSERT INTO jsontable(SUM, APP, ID, DOMAINNAME, DOMAINID)
                   VALUES($1, $2, $3, $4, $5)
                ''',(str(dd['sum'],str(dd['app'],str(dd['id'],str(dd['Domain_name'],str(dd['Domain_Id'])))

print ("Data Entered successfully")
await conn.commit()
await conn.close()