Skip to content

Instantly share code, notes, and snippets.

@johnoscott

johnoscott/pg8000_upsert.py

Forked from karol-blaszczyk/pg8000_upsert.py
Created November 23, 2020 10:43
Show Gist options
  • Save johnoscott/bcdd51cd0bd4a6800d956b33208d5fe4 to your computer and use it in GitHub Desktop.
Save johnoscott/bcdd51cd0bd4a6800d956b33208d5fe4 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
pg8000_upsert.py
## Connect PG8000 to database
conn = pg8000.connect(database=args['db_name'],user=args['db_user'],password=args['db_password'],host=args['db_host'],port=5432)
cur = conn.cursor()
# ...
# Example upsert query
cur.execute("INSERT INTO {} SELECT * FROM {} ON CONFLICT (id) DO UPDATE SET name = EXCLUDED.name".format('campaigns', 'tmp_staging_campaings'))
# ...
conn.commit()
cur.close()
conn.close()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment