Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import psycopg2
- import io
- import json
- from psycopg2.extras import Json
- from psycopg2.extensions import register_adapter
- try:
- connection = psycopg2.connect(user = "parking",password = "pg2019",host = "172.17.0.2",port = "5432",database = "parkingdb")
- cursor = connection.cursor()
- gravar = []
- with open('/dados_json2/arq.json') as f:
- for line in f:
- gravar.append(json.loads(line))
- for item in gravar:
- #my_data = item
- my_data = json.dumps(item)
- cursor.execute("INSERT INTO parking VALUES (%s)", (my_data, ))
- connection.commit()
- print("Ok, sucesso !")
- except (Exception, psycopg2.Error) as error :
- print ("Error while connecting to PostgreSQL", error)
- finally:
- #closing database connection.
- if(connection):
- cursor.close()
- connection.close()
- print("PostgreSQL connection is closed")
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement