Я использовал 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. Пожалуйста, помогите