Запуск SQL UDF в Python для цикла по CSV-файлу - PullRequest
0 голосов
/ 12 апреля 2019

У меня есть таблица UDF в SQL, которая возвращает имена основных столбцов таблицы.Я хочу запустить этот UDF для сотен таблиц.У меня плоский файл с именами всех таблиц.Я хочу передать имя таблицы в качестве аргумента из этого файла в UDF и сохранить результаты в плоский файл.Моя таблица UDF выглядит следующим образом:

 create or replace function get_pk(tab_name varchar)
  returns table (primary_key_column varchar)
  as
  $$
  SELECT fieldname FROM audit_table WHERE table_name=tab_name
  $$
  ;

Может кто-нибудь помочь мне в реализации этого в Python 3?Я могу подключиться к своей БД, но мне нужно знать только логику, чтобы перебрать CSV-файл, в котором есть только один столбец с именем таблицы.

...