PostgreSQLのバックエンドサーバとの接続を作成するには、以下の関数を使用します。
アプリケーションプログラムは、バックエンドとの接続を一度に複数個開くことができます。(1つの理由として、複数のデータベースへのアクセスが挙げられます。)
個々の接続は、PQconnectdb
またはPQsetdbLogin
関数を呼び出すことで得られるPGconnオブジェクトによって表されます。
なお、これらの関数は、PGconnオブジェクトに割り当てるほんのわずかなメモリの余裕さえもない場合を除き、NULLではなく常にオブジェクトのポインタを返します。
また、この接続オブジェクトを通じて問い合わせを送る前に、PQstatus
関数を呼び出して、データベースとの接続に成功したかどうかをチェックすべきです。
PQconnectdb
新たにデータベースサーバへの接続を作成します。
PGconn *PQconnectdb(const char *conninfo);
この関数は、conninfo文字列から取得したパラメータを使用して、データベースとの接続を新たに1つ確立します。
後述のPQsetdbLogin
とは異なり、関数のプロトタイプを変更せずにパラメータを拡張できますので、アプリケーションプログラムを作成する際には、このルーチン(もしくは非ブロックモードでよく似た処理をするPQconnectStart
とPQconnectPoll
)を使用することをお勧めします。
空の文字列を渡すことで、全てのパラメータはデフォルトを使用できます。 また、空白文字で区切ることで1つ以上のパラメータを設定することができます。 それぞれのパラメータは、keyword = valueという形で設定します。 等号の前後の空白文字は、任意で付けられます。 空の値や空白文字を含む値を書く場合は、単一引用符で囲みます。 例えば、keyword = 'a value'といった具合です。 値中の単一引用符とバックスラッシュは\'や\\というように、バックスラッシュでエスケープしなければなりません。)
現時点で有効なパラメータのキーワードは以下に示す通りです。
接続するホストのIPアドレスを指定します。これは、172.28.40.9といった標準的なIPv4アドレス書式でなければなりません。 使用するマシンでIPv6をサポートする場合は、そのアドレスを使用することもできます。 このパラメータに非0長の文字列が指定されると、TCP/IP通信が常に使用されます。
hostの代わりにhostaddrを使用することで、アプリケーションがホスト名の検索をせずに済みます。 特に、時間に制約のあるアプリケーションでは、重要になるでしょう。 しかし、KerberosおよびGSSAPI認証を行うアプリケーションでは、ホスト名が必要になります。 結局、以下のようになります。 hostaddrを使わずにhostを指定した場合は、ホスト名の検索が発生します。 hostを使わず、hostaddrを指定した場合、hostaddrはリモートマシンのアドレスとなります。 この時、Kerberosを使用している場合は、IPアドレスからホスト名の逆引きが行われます。 hostとhostaddrの両方を指定した場合、hostaddrがリモートマシンのアドレスとなります。 この時、Kerberosが使用されていない場合はhostに与えられた値は無視され、使用されている場合はKerberos認証にhostの値が使用されます。(libpqに渡されたホスト名が、hostaddrに対応するマシンの名前と一致しない場合は、認証に失敗する可能性があるので、注意してください。) また、hostaddrではなくhostが~/.pgpass(項30.13を参照)での接続の識別に使用されます。
ホスト名もホストのアドレスも用いない場合、libpqはローカルのUnixドメインのソケットを使用して接続します。 ただし、Unixドメインソケットを持たないマシンでは、localhostへの接続を試みます。
サーバホストでの接続用のポート番号、または、Unixドメイン接続の場合は、ソケットファイルの拡張子を指定します。
データベース名を指定します。 デフォルトはユーザ名と同じです。
データベースへ接続するPostgreSQLユーザ名を 指定します。 デフォルトは、そのアプリケーションを実行しているユーザのオペレーティングシステム上の名前と同じです。
サーバがパスワードによる認証を必要とした場合に使用されるパスワードを指定します。
接続用の最大待機時間を秒単位で指定します。 (10進数整数で表した文字列として記述してください。) ゼロもしくは未設定は、無限時間の待機を意味します。 2秒未満の待機時間を使用することは勧めません。
サーバに送信するコマンドラインオプションを指定します。
無視されます。 (以前は、これはサーバデバッグ出力を送信する場所を指定するものでした。)
このオプションは、どのSSL TCP/IP接続の優先度でサーバと調停するかを決定します。 4つのモードがあります。 disableは暗号化しないSSL接続のみを試みます。 allowはまず非SSL接続を試み、失敗したらSSLで調停を行ないます。 prefer(デフォルトです)は、まずSSL接続を試み、失敗したら通常の非SSL接続で調停を行ないます。 requireはSSL接続でのみ調停を行ないます。 Unixドメインソケット通信ではsslmodeは無視されます。
SSLサポートなしでPostgreSQLがコンパイルされた場合に、requireを使用するとエラーになります。 一方、allowとpreferは使用できますが、実際にlibpqはSSL接続を受け付けません。
このオプションは、sslmode設定により廃れたものになりました。
1に設定することで、サーバへのSSL接続が必要になります。 (これはsslmodeのrequireと同じです。) サーバがSSL接続を受け付けない場合、Libpqは接続を拒絶します。 0(デフォルト)に設定することで、サーバと調停を行います。 (sslmodeのpreferと同じです。) SSLサポート付きでPostgreSQLをコンパイルした場合にのみ、このオプションが利用できます。
Kerberos5またはGSSAPIの認証時に使われるKerberosサービス名です。 これはサーバのKerberos認証設定のサービス名と一致していなければなりません。 (項21.2.5および項21.2.3も参照してください。)
GSSAPI認証で使用されるGSSライブラリです。 Windows上のみで使用されます。 libpqの認証がデフォルトのSSPIではなく、強制的にGSSAPIライブラリを使用するようにさせるにはgssapi を設定してください。
他のパラメータ用に使用されるサービス名です。 pg_service.conf内の追加的な接続パラメータを保持するサービス名を指定します。 これによりアプリケーションはサービス名だけを指定でき、接続パラメータを集中的に保守できるようになります。詳しくは 項30.14 を参照してください。
パラメータが指定されなかった場合には、対応する環境変数がチェックされます(項30.12を参照してください)。 環境変数も設定されていない場合は、指定された組み込みのデフォルト値が使用されます。
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内に=記号が含まれる場合、PQconnectdb
に渡された場合とまったく同じ扱いでconninfo文字列として扱われます。
その後残りのパラメータが上述の通りに適用されます。
PQsetdb
新たにデータベースサーバへの接続を作成します。
PGconn *PQsetdb(char *pghost, char *pgport, char *pgoptions, char *pgtty, char *dbName);
これは、loginとpwdにヌルポインタを設定するPQsetdbLogin
を呼び出すマクロです。
非常に古いプログラムへの後方互換性のために提供されています。
PQconnectStart
PQconnectPoll
ブロックしない方法で、データベースサーバへの接続を作成します。
PGconn *PQconnectStart(const char *conninfo);
PostgresPollingStatusType PQconnectPoll(PGconn *conn);
これら2つの関数を使用して、リモートI/Oの実行時にアプリケーションスレッドの実行がブロックされないように、データベースサーバへの接続を作成します。
このアプローチのポイントは、I/O の終了待ちがPQconnectdb
内部ではなく、アプリケーションプログラムのメインループで出来ることにあります。
これによって、アプリケーションは他の処理と並行してこの処理を管理することができます。
PQconnectStart
に渡されたconninfo文字列からパラメータを取得し、データベース接続が確立されます。
この文字列は、上述のPQconnectdb
の場合と同じ形式で記述されています。
PQconnectStart
とPQconnectPoll
は、以下の制限下ではブロックしません。
hostaddrとhostパラメータは、ホスト名からのIPアドレス検索やホスト名の逆引きが起こらないように適切に使用されなければいけません。
これらのパラメータについての詳細は、前述のPQconnectdb
の節を参照してください。
PQtrace
を呼び出す場合は、トレースに使用するストリームオブジェクトがブロックされないことが保証されていなくてはなりません。
プログラマ自身が、後に示すように、PQconnectPoll
を呼び出す前にソケットが適切な状態にあることを保証しなくてはいけません。
非ブロック接続を始めるにはまず、conn=PQconnectStart("connection_info_string")を呼び出します。
connがヌルの場合、libpqが新たにPGconn構造体を割り当てられなかったことを表します。
そうでない場合は、適切なPGconnへのポインタが返されます
(ただし、データベースに正しく接続されていることを表しているわけではありません)。
PQconnectStart
から値が返ってきた段階で、status=PQstatus(conn)を呼び出します。
もし、statusがCONNECTION_BADと等しい場合には、PQconnectStart
が失敗しています。
PQconnectStart
が成功したら、次は接続シーケンスを進めるために、libpqをポーリングします。
データベース接続の背後にあるソケットの記述子を取り出すには、PQsocket(conn)
を使用します。
以下の繰り返しです。
直前のPQconnectPoll(conn)
がPGRES_POLLING_READINGの場合、ソケットの読み込み準備が整うまで待機します。
(select()
やpoll()
などのシステム関数で示されます。)
そして、再度PQconnectPoll(conn)
を呼び出します。
反対に直前のPQconnectPoll(conn)
がPGRES_POLLING_WRITINGの場合、ソケットの書き込み準備が整うまで待機し、その後、PQconnectPoll(conn)
を再度呼び出します。
まだPQconnectPoll
を呼び出していない場合、つまり、PQconnectStart
の呼び出し直後では、直前がPGRES_POLLING_WRITINGであった場合と同様の処理を行ないます。
この繰り返しをPQconnectPoll(conn)
が、接続手続きの失敗を示すPGRES_POLLING_FAILED、もしくは、接続確立に成功したことを示すPGRES_POLLING_OKを返すまで継続します。
接続している間は、いつでもPQstatus
を呼び出すことで、接続の状態をチェックすることができます。
この関数がCONNECTION_BADを返す場合、接続手続きは失敗しており、CONNECTION_OKを返す場合、接続が確立しています。
上述のように、このいずれの状態も、PQconnectPoll
の戻り値から同様に検出できます。
これ以外の状態は、非同期の接続手続きの間(のみに)現れることがあります。
これらは、接続プロシージャの現在の段階を示すものであり、例えばユーザへのフィードバックを提供することに使用できます。
以下の状態があります。
接続の確立待ち状態です。
接続はOKです。 送信待ち状態です。
サーバからの応答待ち状態です。
認証済みです。 バックエンドの起動待ち状態です。
SSL暗号化の調停状態です。
環境が提供するパラメータ設定の調停状態です。
これらの定数は(互換性を保つため)なくなることはありませんが、アプリケーションは、これらが特定の順で出現したり、本書に書いてある値のどれかに必ずステータス値が該当するということを決して当てにしてはいけません。 アプリケーションは、以下に示すようにするべきです。
switch(PQstatus(conn)) { case CONNECTION_STARTED: feedback = "Connecting..."; break; case CONNECTION_MADE: feedback = "Connected to server..."; break; . . . default: feedback = "Connecting..."; }
PQconnectPoll
を使用する場合、connect_timeout接続パラメータは無視されます。
経過時間が長過ぎるかどうかの判定はアプリケーションの責任で行ないます。
さもないと、PQconnectStart
の後のPQconnectPoll
の繰り返しがPQconnectdb
と同じになります。
PQconnectStart
が非ヌルポインタを返した場合、処理を終了する際には、構造体や関連するメモリブロックを始末するために、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
が呼び出されるたびに少しずつメモリリークが発生します。
PQfinish
サーバとの接続を閉ざします。 また、PGconnオブジェクトが占めるメモリも解放します。
void PQfinish(PGconn *conn);
たとえサーバへの接続試行が失敗しても(PQstatus
で調べます)、アプリケーションはPQfinish
を呼び出しPGconnオブジェクトが占めるメモリを解放するべきです。
そしてPQfinish
を呼び出したら、もうPGconnへのポインタを使ってはいけません。
PQreset
サーバへの通信チャンネルをリセットします。
void PQreset(PGconn *conn);
この関数はサーバへの接続を閉じ、以前使用したパラメータを全て使用して、同一のサーバへ新しく接続を確立します。 これは、作業中の接続が失われた場合のエラーの修復に役立つでしょう。
PQresetStart
PQresetPoll
非ブロッキング方式で、サーバへの接続チャンネルをリセットします。
int PQresetStart(PGconn *conn);
PostgresPollingStatusType PQresetPoll(PGconn *conn);
これらの関数はサーバへの接続を閉じ、それから再度、以前使用したパラメータを全て使用して、同じサーバと新たな接続を確立しようとします。
これらは作業中の接続が失われた場合のエラー修復に役立つでしょう。
PQreset
(前述)との違いは、この2つの関数が非ブロック方式で動作することです。
また、これらの関数はPQconnectStart
やPQconnectPoll
と同じ制限を受けます。
接続リセットを始めるには、PQresetStart
を呼び出します。
この関数が0を返す場合、リセットに失敗しています。
戻り値が1ならば、PQconnectPoll
を使って接続を確立した時と同じように、PQresetPoll
を使用してリセットのポーリングを行います。