Удалить строки из таблицы postgresql, используя соединение JDB C из pyspark - PullRequest
0 голосов
/ 02 августа 2020

Я использовал mysql коннектор из скрипта pyspark для удаления строк и выполнения запросов из таблицы mariadb (mysql). Как показано ниже

import mysql.connector
connection = mysql.connector.connect(host='localhost',
                                         database='local_idp',
                                         user='root',
                                         password='root',
                                         port = '3306')
cursor = connection.cursor()
sql = "DELETE FROM local_table where Country = 'USA'"
cursor.execute(sql)
connection.commit()
cursor.close()

Теперь я использую базу данных postgresql и мне нужно использовать соединение JDB C. Как удалить строки из таблицы postgresql, используя соединение JDB C из скрипта pyspark. Пожалуйста, помогите

...