36.1. Функции управления подключением к базе данных
Следующие функции имеют дело с созданием подключения к серверу Postgres Pro. Прикладная программа может иметь несколько подключений к серверу, открытых одновременно. (Одна из причин этого заключается в необходимости доступа к более чем одной базе данных.) Каждое соединение представляется объектом PGconn, который можно получить от функции PQconnectdb, PQconnectdbParams или PQsetdbLogin. Обратите внимание, что эти функции всегда возвращают ненулевой указатель на объект, кроме случая, когда не остаётся свободной памяти даже для объекта PGconn. Прежде чем передавать запросы через объект подключения, следует вызвать функцию PQstatus для проверки возвращаемого значения в случае успешного подключения.
Предупреждение
Если к базе данных, которая не приведена в соответствие шаблону безопасного использования схем, имеют доступ недоверенные пользователи, начинайте сеанс с удаления доступных им для записи схем из пути поиска (search_path). Для этого можно присвоить параметру с ключом options значение -csearch_path=. Также можно выполнить PQexec( после подключения. Это касается не только psql, но и любых других интерфейсов для выполнения произвольных SQL-команд.соединение, "SELECT pg_catalog.set_config('search_path', '', false)")
Предупреждение
В системе Unix создание дочернего процесса на основе процесса, уже имеющего открытые подключения с помощью libpq, может привести к непредсказуемым результатам, потому что родительский и дочерний процессы совместно используют одни и те же сокеты и ресурсы операционной системы. По этой причине подобный подход не рекомендуется. Однако использование системного вызова exec из дочернего процесса для загрузки нового исполняемого файла является безопасным.
PQconnectdbParamsСоздаёт новое подключение к серверу баз данных.
PGconn *PQconnectdbParams(const char * const *keywords, const char * const *values, int expand_dbname);Эта функция открывает новое соединение с базой данных, используя параметры, содержащиеся в двух массивах, завершающихся символом
NULL. Первый из них,keywords, определяется как массив строк, каждая из которых представляет собой ключевое слово. Второй,values, даёт значение для каждого ключевого слова. В отличие от функцииPQsetdbLogin, описываемой ниже, её набор параметров может быть расширен без изменения сигнатуры функции, поэтому при разработке новых приложений предпочтительнее использовать данную функцию (или её неблокирующие аналогиPQconnectStartParamsиPQconnectPoll).Ключевые слова-параметры, распознаваемые в настоящее время, приведены в Подразделе 36.1.2.
Передаваемые массивы могут быть пустыми (в этом случае будут использоваться все параметры по умолчанию) или содержать одно или несколько имён/значений параметров. При этом они должны быть одинаковой длины. Просмотр массивов завершается, как только в массиве
keywordsвстречаетсяNULL. Если элемент массиваvalues, соответствующий отличному отNULLэлементуkeywords, содержит пустую строку или NULL, такой параметр пропускается и просматривается следующая пара элементов массива.Когда
expand_dbnameимеет ненулевое значение, первый параметрdbnameможет содержать строку подключения. В этом случае она «разворачивается» в отдельные параметры подключения, извлечённые из этой строки. Значение считается строкой подключения, а не просто именем базы данных, если оно содержит знак равно (=) или начинается с обозначения схемы URI. (Подробнее форматы строк подключения описаны в Подразделе 36.1.1.) Таким способом обрабатывается только первое вхождениеdbname, следующие параметрыdbnameбудут восприниматься как просто имя базы данных.Как правило, массивы параметров обрабатываются от начала к концу. Если какой-либо параметр указывается неоднократно, использоваться будет последнее значение (отличное от
NULLи непустое). Это справедливо, в частности, и тогда, когда ключевое слово, заданное в строке подключения, конфликтует с заданным в массивеkeywords. Таким образом, программист может по своему усмотрению решить, будут ли значения в массиве переопределять значения, заданными в строке подключения, или переопределяться ими. Элементы массива, предшествующие развёрнутому значениюdbname, могут быть переопределены значениями в строке подключения, которые в свою очередь переопределяются элементами массива, следующими послеdbname(и в этом случае речь идёт о непустых значениях).После разбора всех элементов массива и развёрнутой строки подключения (если она задана), параметры подключения, которые остались незаданными, получают значения по умолчанию. Если незаданному параметру соответствует установленная переменная окружения (см. Раздел 36.14), будет использоваться её значение. Если такая переменная не задана, для параметра будет использоваться встроенное значение по умолчанию.
PQconnectdbСоздаёт новое подключение к серверу баз данных.
PGconn *PQconnectdb(const char *conninfo);
Эта функция открывает новое соединение с базой данных, используя параметры, полученные из строки
conninfo.Передаваемая строка может быть пустой. В этом случае используются все параметры по умолчанию. Она также может содержать одно или более значений параметров, разделённых пробелами, или URI. За подробностями обратитесь к Подразделу 36.1.1.
PQsetdbLoginСоздаёт новое подключение к серверу баз данных.
PGconn *PQsetdbLogin(const char *pghost, const char *pgport, const char *pgoptions, const char *pgtty, const char *dbName, const char *login, const char *pwd);Это предшественница функции
PQconnectdbс фиксированным набором параметров. Она имеет такую же функциональность, за исключением того, что отсутствующие параметры всегда принимают значения по умолчанию. ПодставьтеNULLили пустую строку в качестве любого из фиксированных параметров, которые должны принять значения по умолчанию.Если параметр
dbNameсодержит знак=или имеет допустимый префикс URI для подключения, то он воспринимается в качестве строкиconninfoточно таким же образом, как если бы он был передан функцииPQconnectdb, а оставшиеся параметры применяются, как указано дляPQconnectdbParams.PQsetdbСоздаёт новое подключение к серверу баз данных.
PGconn *PQsetdb(char *pghost, char *pgport, char *pgoptions, char *pgtty, char *dbName);Это макрос, который вызывает
PQsetdbLoginс нулевыми указателями в качестве значений параметровloginиpwd. Обеспечивает обратную совместимость с очень старыми программами.PQconnectStartParamsPQconnectStartPQconnectPollСоздают подключение к серверу баз данных неблокирующим способом.
PGconn *PQconnectStartParams(const char * const *keywords, const char * const *values, int expand_dbname); PGconn *PQconnectStart(const char *conninfo); PostgresPollingStatusType PQconnectPoll(PGconn *conn);Три эти функции используются для того, чтобы открыть подключение к серверу баз данных таким образом, чтобы поток исполнения вашего приложения не был заблокирован при выполнении удалённой операции ввода-вывода в процессе подключения. Суть этого подхода в том, чтобы ожидание завершения операций ввода-вывода могло происходить в главном цикле приложения, а не внутри функций
PQconnectdbParamsилиPQconnectdb, с тем, чтобы приложение могло управлять этой операцией параллельно с другой работой.С помощью функции
PQconnectStartParamsподключение к базе данных выполняется, используя параметры, взятые из массивовkeywordsиvalues, а управление осуществляется с помощьюexpand_dbname, как описано выше дляPQconnectdbParams.С помощью функции
PQconnectStartподключение к базе данных выполняется, используя параметры, взятые из строкиconninfo, как описано выше дляPQconnectdb.Ни
PQconnectStartParams, ниPQconnectStart, ниPQconnectPollне заблокируются до тех пор, пока выполняется ряд ограничений:Параметр
hostaddrдолжен использоваться так, чтобы для разрешения заданного имени не требовалось выполнять запросы DNS. Подробнее этот параметр описан в Подразделе 36.1.2.Если вы вызываете
PQtrace, сделайте так, чтобы поток, в который выводится трассировочная информация, не заблокировался.Перед вызовом
PQconnectPollвы должны перевести сокет в соответствующее состояние, как описано ниже.
Чтобы начать неблокирующий запрос на подключение, вызовите
PQconnectStartилиPQconnectStartParams. Если результатом будет null, значит libpq не смогла выделить память для новой структурыPGconn. В противном случае возвращается действительный указательPGconn(хотя он ещё не представляет установленное подключение к базе данных). Затем вызовитеPQstatus(conn). Если результатом будетCONNECTION_BAD, значит попытка подключения уже не будет успешной, возможно, из-за неверных параметров.Если вызов
PQconnectStartилиPQconnectStartParamsоказался успешным, теперь нужно опросить libpq для продолжения процедуры подключения. ВызовитеPQsocket(conn)для получения дескриптора нижележащего сокета, через который устанавливается соединение. (Внимание: этот сокет может меняться от вызова к вызовуPQconnectPoll.) Организуйте цикл таким образом: еслиPQconnectPoll(conn)при последнем вызове возвращаетPGRES_POLLING_READING, ожидайте, пока сокет не окажется готовым для чтения (это покажет функцияselect(),poll()или подобная системная функция). Затем снова вызовитеPQconnectPoll(conn). Если жеPQconnectPoll(conn)при последнем вызове возвратилаPGRES_POLLING_WRITING, дождитесь готовности сокета к записи, а затем снова вызовитеPQconnectPoll(conn). На первой итерации, то есть когда вы ещё не вызывалиPQconnectPoll, реализуйте то же поведение, что и после полученияPGRES_POLLING_WRITING. Продолжайте этот цикл, покаPQconnectPoll(conn)не выдаст значениеPGRES_POLLING_FAILED, сигнализирующее об ошибке при установлении соединения, илиPGRES_POLLING_OK, показывающее, что соединение установлено успешно.В любое время в процессе подключения его состояние можно проверить, вызвав
PQstatus. Если этот вызов возвратитCONNECTION_BAD, значит, процедура подключения завершилась сбоем; если вызов возвратитCONNECTION_OK, значит, соединение готово. Оба эти состояния можно определить на основе возвращаемого значения функцииPQconnectPoll, описанной выше. Другие состояния могут также иметь место в течение (и только в течение) асинхронной процедуры подключения. Они показывают текущую стадию процедуры подключения и могут быть полезны, например, для предоставления обратной связи пользователю. Вот эти состояния:CONNECTION_STARTEDОжидание, пока соединение будет установлено.
CONNECTION_MADEСоединение установлено; ожидание отправки.
CONNECTION_AWAITING_RESPONSEОжидание ответа от сервера.
CONNECTION_AUTH_OKАутентификация получена; ожидание завершения запуска серверной части.
CONNECTION_SSL_STARTUPСогласование SSL-шифрования.
CONNECTION_SETENVСогласование значений параметров, зависящих от программной среды.
CONNECTION_CHECK_WRITABLEПроверка, можно ли через подключение выполнять пишущие транзакции.
CONNECTION_CONSUMEПрочтение всех оставшихся ответных сообщений через подключение.
Заметьте, что, хотя эти константы и сохранятся (для поддержания совместимости), приложение никогда не должно полагаться на то, что они появятся в каком-то конкретном порядке или вообще появятся, а также на то, что состояние всегда примет одно из этих документированных значений. Приложение может сделать что-то наподобие:
switch(PQstatus(conn)) { case CONNECTION_STARTED: feedback = "Подключение..."; break; case CONNECTION_MADE: feedback = "Подключён к серверу..."; break; . . . default: feedback = "Подключение..."; }Параметр подключения
connect_timeoutигнорируется, когда используетсяPQconnectPoll; именно приложение отвечает за принятие решения о том, является ли истекшее время чрезмерным. В противном случае вызовPQconnectStartс последующим вызовомPQconnectPollв цикле будут эквивалентны вызовуPQconnectdb.Заметьте, что когда функция
PQconnectStartилиPQconnectStartParamsвозвращает ненулевой указатель, вы должны вызватьPQfinish, закончив его использование, чтобы освободить полученную структуру и все связанные с ней блоки памяти. Это нужно сделать, даже если попытка подключения оказалась неудачной или подключение не потребовалось.PQconndefaultsВозвращает значения по умолчанию для параметров подключения.
PQconninfoOption *PQconndefaults(void); typedef struct { char *keyword; /* Ключевое слово для данного параметра */ char *envvar; /* Имя альтернативной переменной окружения */ char *compiled; /* Альтернативное значение по умолчанию, назначенное при компиляции */ char *val; /* Текущее значение параметра или NULL */ char *label; /* Обозначение этого поля в диалоге подключения */ char *dispchar; /* Показывает, как отображать это поле в диалоге подключения. Значения следующие: "" Отображать введённое значение "как есть" "*" Поле пароля — скрывать значение "D" Параметр отладки — не показывать по умолчанию */ int dispsize; /* Размер поля в символах для диалога */ } PQconninfoOption;Возвращает массив параметров подключения. Он может использоваться для определения всех возможных параметров
PQconnectdbи их текущих значений по умолчанию. Возвращаемое значение указывает на массив структурPQconninfoOption, который завершается элементом, имеющим нулевой указательkeyword. Если выделить память не удалось, то возвращается нулевой указатель. Обратите внимание, что текущие значения по умолчанию (поляval) будут зависеть от переменных среды и другого контекста. Отсутствующий или неверный файл служб будет просто проигнорирован. Вызывающие функции должны рассматривать данные параметров подключения как данные только для чтения.После обработки массива параметров освободите память, передав его функции
PQconninfoFree. Если этого не делать, то при каждом вызове функцииPQconndefaultsбудет теряться небольшой объём памяти.PQconninfoВозвращает параметры подключения, используемые действующим соединением.
PQconninfoOption *PQconninfo(PGconn *conn);
Возвращает массив параметров подключения. Он может использоваться для определения всех возможных параметров
PQconnectdbи значений, которые были использованы для подключения к серверу. Возвращаемое значение указывает на массив структурPQconninfoOption, который завершается элементом, имеющим нулевой указательkeyword. Все замечания, приведённые выше дляPQconndefaults, также справедливы и для результатаPQconninfo.PQconninfoParseВозвращает разобранные параметры подключения, переданные в строке подключения.
PQconninfoOption *PQconninfoParse(const char *conninfo, char **errmsg);
Разбирает строку подключения и возвращает результирующие параметры в виде массива; возвращает
NULL, если возникают проблемы при разборе строки подключения. Эту функцию можно использовать для извлечения параметров функцииPQconnectdbиз предоставленной строки подключения. Возвращаемое значение указывает на массив структурPQconninfoOption, который завершается элементом, имеющим нулевой указательkeyword.Все разрешённые параметры будут присутствовать в результирующем массиве, но
PQconninfoOptionдля любого параметра, не присутствующего в строке подключения, будет иметь значениеNULLв полеval; значения по умолчанию не подставляются.Если
errmsgне равноNULL, тогда в случае успеха*errmsgприсваиваетсяNULL, а в противном случае -- адрес строки сообщения об ошибке, объясняющего проблему. Память для этой строки выделяет функцияmalloc. (Также возможна ситуация, когда*errmsgбудет установлено вNULL, и при этом функция возвращаетNULL. Это указывает на нехватку памяти.)После обработки массива параметров освободите память, передав его функции
PQconninfoFree. Если этого не делать, некоторое количество памяти будет теряться при каждом вызовеPQconninfoParse. Если же произошла ошибка иerrmsg, указывающий на строку сообщения об ошибке, не равенNULL, не забудьте освободить память с этой строкой, вызвавPQfreemem.PQfinishЗакрывает соединение с сервером. Также освобождает память, используемую объектом
PGconn.void PQfinish(PGconn *conn);
Обратите внимание, что даже если попытка подключения к серверу потерпела неудачу (как показывает
PQstatus), приложение все равно должно вызватьPQfinish, чтобы освободить память, используемую объектомPGconn. УказательPGconnне должен использоваться повторно после того, как была вызвана функцияPQfinish.PQresetПереустанавливает канал связи с сервером.
void PQreset(PGconn *conn);
Эта функция закроет подключение к серверу, а потом попытается установить новое подключение, используя все те же параметры, которые использовались прежде. Это может быть полезным для восстановления после ошибки, если работающее соединение было разорвано.
PQresetStartPQresetPollПереустанавливает канал связи с сервером неблокирующим способом.
int PQresetStart(PGconn *conn); PostgresPollingStatusType PQresetPoll(PGconn *conn);
Эти функции закроют подключение к серверу, а потом попытаются установить новое подключение, используя все те же параметры, которые использовались прежде. Это может быть полезным для восстановления после ошибки, если работающее соединение оказалось потерянным. Они отличаются от
PQreset(см. выше) тем, что действуют неблокирующим способом. На эти функции налагаются те же ограничения, что и наPQconnectStartParams,PQconnectStartиPQconnectPoll.Чтобы произвести переподключение, вызовите
PQresetStart. Если она возвратит 0, значит при переподключении произошла ошибка. Если она возвратит 1, опросите результат операции, используяPQresetPoll, таким же образом, как это делается с помощьюPQconnectPollпри обычном установления соединения.PQpingParamsPQpingParamsсообщает состояние сервера. Она принимает параметры подключения, идентичные тем, что получает функцияPQconnectdbParams, описанная выше. Нет необходимости предоставлять корректные имя пользователя, пароль или имя базы данных, чтобы получить состояние сервера. Но если будут предоставлены некорректные значения, сервер зафиксирует в журнале неудачную попытку подключения.PGPing PQpingParams(const char * const *keywords, const char * const *values, int expand_dbname);Функция возвращает одно из следующих значений:
PQPING_OKСервер работает и, по-видимому, принимает подключения.
PQPING_REJECTСервер работает, но находится в состоянии, которое запрещает подключения (запуск, завершение работы или восстановление после аварийного отказа).
PQPING_NO_RESPONSEКонтакт с сервером не удался. Это может указывать на то, что сервер не запущен или что-то не в порядке с параметрами данного подключения (например, неверный номер порта), или имеет место проблема с возможностью соединения по сети (например, брандмауэр блокирует запрос на подключение).
PQPING_NO_ATTEMPTНикакой попытки установить контакт с сервером сделано не было, поскольку предоставленные параметры были явно некорректными, или имела место какая-то проблема на стороне клиента (например, нехватка памяти).
PQpingPQpingсообщает состояние сервера. Она принимает параметры подключения, идентичные тем, что получает функцияPQconnectdb, описанная выше. Нет необходимости предоставлять корректные имя пользователя, пароль или имя базы данных, чтобы получить состояние сервера. Но если будут предоставлены некорректные значения, сервер зафиксирует в журнале неудачную попытку подключения.PGPing PQping(const char *conninfo);
Возвращаемые значения такие же, как и для
PQpingParams.PQsetSSLKeyPassHook_OpenSSLPQsetSSLKeyPassHook_OpenSSLпозволяет приложению переопределить реализованный вlibpqстандартный вариант обработки файлов с зашифрованными ключами клиентских сертификатов, используя sslpassword или интерактивное приглашение.void PQsetSSLKeyPassHook_OpenSSL(PQsslKeyPassHook_OpenSSL_type hook);
Приложение передаёт указатель на функцию-обработчик со следующей сигнатурой:
int callback_fn(char *buf, int size, PGconn *conn);
Эту функцию
libpqбудет вызывать вместо своего стандартного обработчикаPQdefaultSSLKeyPassHook_OpenSSL. Данная функция должна получить пароль для ключа и скопировать его в результирующий буферbufразмераsize. Строка вbufдолжна завершаться нулём. В результате эта функция должна выдать длину пароля, сохранённого вbuf, не считая завершающего нуля. В случае ошибки она должна установитьbuf[0] = '\0'и выдать 0.Если пользователь задал размещение ключа явно, заданный путь будет передан при вызове этого обработчика в
conn->sslkey. Это поле будет пустым, если используется путь к ключу по умолчанию. Что касается ключей, специфичных для модулей OpenSSL, для них модули могут по своему усмотрению получать пароль через стандартный обработчик OpenSSL или через свой собственный.Пользовательский обработчик может полностью переопределить функцию
PQdefaultSSLKeyPassHook_OpenSSL, либо делегировать ей необрабатываемые им случаи, либо сначала вызывать её и предпринимать какие-то другие действия, если она возвратит 0.Этот обработчик не должен нарушать обычный ход выполнения, выбрасывая исключения, вызывая
longjmp(...)и т. п. Он должен завершиться нормально.PQgetSSLKeyPassHook_OpenSSLPQgetSSLKeyPassHook_OpenSSLвозвращает текущий обработчик пароля для ключа клиентского сертификата либоNULL, если такой обработчик не установлен.PQsslKeyPassHook_OpenSSL_type PQgetSSLKeyPassHook_OpenSSL(void);