Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import sys, csv, sqlite3, codecs, unicodedata, string, glob, os
- conn = psycopg2.connect(database="xxx", user="xxxx", password="xxxx", host="localhost", port="5432")
- cur = conn.cursor()
- print("done")
- def runSQL(query):
- cur = conn.cursor()
- cur.execute(query)
- conn.commit()
- with open("*.txt", "r") as ins:
- for line in ins:
- words = line.split('|')
- print(words)
- query = words[0]
- pmicode = words[1]
- print(query)
- conn.close()
- import sys, csv, sqlite3, codecs, unicodedata, string, glob, os
- postgres_url = 'jdbc:postgresql://localhost:5432/database'
- properties = {"user": "xxxx", "password": "xxxx"}
- print("done")
- def runSQL(query):
- return sqlContext.read.jdbc(
- url=postgres_url,
- table="( {0} ) TEMPDB_SPARK_DELINQ".format(query)
- with open("*.txt", "r") as ins:
- for line in ins:
- words = line.split('|')
- print(words)
- query = words[0]
- pmicode = words[1]
- print(query)
- runSQL(query)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement