PostgreSQLで作るLinuxデータベース（3）
PostgreSQLをプログラムで操作する

前回までにPostgreSQLの歴史やインストール方法について説明してきた。今回は、実際にPostgreSQLとPerlやC言語を使ったアプリケーションを開発する方法について解説する。

宗近龍一郎（ハンドル名：まいパパ）
株式会社デジタルデザイン
Project BLUE
2000/11/21

今回のおもな内容 サンプルデータベースの作成 PerlによるPostgreSQLの操作 C言語によるPostgreSQLの操作 PHP3によるPostgreSQLの操作 PostgreSQLの開発環境

　PostgreSQLはいろいろな言語とのインターフェイスを持っていますが、今回は代表的なところとして、PerlとC言語でのインターフェイスや、PostgreSQLと一番組み合わせて使われることが多いと思われるApacheおよびPHP3を使ってのアプリケーション開発についても説明したいと思います。

1．サンプルデータベースの作成

　何をするにしても、データベースがなければ話になりません。そこで、今回紹介するプログラムで使うためのサンプルデータベースを作成しましょう。とりあえず、氏名と電話番号および電子メールアドレスを管理する簡易アドレス帳ということにします。

　まず、PostgreSQLのプロンプトでcreate table文を発行して、テーブルを定義します。

postgres=> create table addrbook (name varchar(50),telno varchar(50), email varchar(50));

＃折り返していますが、実際には1行で入力します

　テーブルが作成できたらテストデータを入力するのですが、一から作成するのは大変なので、先に用意しておいたデータからコピーすることにします。

　以下の内容のテキストファイルを用意し、addrbook.txtというファイル名で保存します。スペースの部分はTABにしてください。

R.Munechika     070-6682-****   munetika@myhome.niji-net.com H.Nishida       090-****-****   nishida@hoge.co.jp T.Miyahara      090-9999-9999   tmiyahar@red.gr.jp

　このファイルをcopyコマンドを使ってインポートします。

postgres=> \copy addrbook from addrbook.txt Successfully copied.

　コピーされた内容を確認します。

postgres=> select * from addrbook; name       |telno        |email -----------+-------------+---------------------------- R.Munechika|070-6682-****|munetika@myhome.niji-net.com H.Nishida  |090-****-****|nishida@hoge.co.jp T.Miyahara |090-9999-9999|tmiyahar@red.gr.jp (3 rows)

　以上でサンプルデータベースの用意ができました。

2．PerlによるPostgreSQLの操作

■Perlインターフェイスの導入

　PostgreSQLにPerlからアクセスするには、インターフェイスを導入しなければなりません。

　PostgreSQLのソースを展開したディレクトリにあるsrc/interfaces/perl5ディレクトリに移動します（ここでは、/usr/local/src/postgresql-6.5.3とします）。

$ cd /usr/local/src/postgresql-6.5.3/src/interfaces/perl5

　ここで、Makefile.PLをPerlから実行します。

$ perl Makefile.PL

　コンパイルを実行します。

$ make

　rootになってインストールを行います。

$ su # make install

■Perlのプログラム(表示用)

　PerlでPostgreSQLに作成したデータベーステーブルの表示を行うプログラムを作成してみます。以下は、先ほど作成したテーブルの内容を表示する簡単なプログラムのリストです。

#!/usr/bin/perl use Pg; $dbname = "postgres"; $conn = Pg::connectdb("dbname=$dbname"); $res = $conn-> exec("select * from addrbook"); print "name telno email\n"; print "--------------------------------------\n"; while(@item = $res-> fetchrow) {   print "@item[0] @item[1] @item[2]";   print ("\n"); }

リスト1　サンプルプログラムtest1.pl

　1行目はPerlの実行ファイルの絶対パスを指定します。whichなどのコマンドで調べて、各自の環境に合わせてください。3行目がデータベース名の指定で、6行目がデータベースに対して実際にSQL文を発行する部分です。

　8〜13行目までが表示を行う部分になります。まず10〜13行目でループを行い、1行ずつfetchを行ってレコードを取得し、printで出力します。

■Perlのプログラム(追加用)

　次にレコード追加を行うサンプルプログラムtest2.plについて説明します。

#!/usr/bin/perl use Pg; $dbname = "postgres"; $conn = Pg::connectdb("dbname=$dbname"); $res = $conn-> exec("insert into addrbook values('K,Hamano','070-8888-8888','hamano\@email.net')"); if ( $res -> resultStatus == PGRES_COMMAND_OK ) {   print "OK\n" } else {   print "NG\n" }

リスト2　サンプルプログラムtest2.pl

　5行目まではtest1.plと同じですが、6行目のSQL文の発行部分が異なる点に注目してください。また、“@”を入力するような場合は、“\”を使ってエスケープすることに注意してください（実際のデータに“\”は登録されません）。

　8〜13行目はエラー処理を記述しています。処理がうまく実行できなかった場合は、resultStatusに“PGRES_COMMAND_OK”以外のステータスを戻してきます。

　test2.plを実行してから表示用のプログラムtest1.plを実行すると、レコードの追加が行われているのが分かります。

[postgres@micky postgres]$ ./test2.pl OK [postgres@micky postgres]$ ./test1.pl name            telno           email -------------------------------------- R.Munechika     070-6682-****   munetika@myhome.niji-net.com H.Nishida       090-****-****   nishida@hoge.co.jp T.Miyahara      090-9999-9999   tmiyahar@red.gr.jp K,Hamano        070-8888-8888   hamano@email.net

3．C言語によるPostgreSQLの操作

■C言語のプログラム(表示用)

　次に、C言語を使ってPostgreSQLのデータベーステーブルの中身を表示してみることとします。

/* ヘッダファイル取り込み */ #include <stdio.h> #include <stdlib.h> #include <string.h> #include <errno.h> #include "postgres.h" #include "libpq-fe.h" /* main処理 */ int main(int argc,char **argv) {     /* 変数定義 */     char dbName[255] = "postgres"; /* データベース名はハードコーディング */     char sql[255];     int i;     PGconn *con;     PGresult *res;     char *kou1,*kou2,*kou3;     /* DBとの接続 */     con = PQsetdb("","",NULL,NULL,dbName);     if ( PQstatus(con) == CONNECTION_BAD ) { /* 接続が失敗したときのエラー処理 */         fprintf(stderr,"Connection to database '%s' failed.\n",dbName);         fprintf(stderr,"%s",PQerrorMessage(con));         exit(1);     }     /* select文の発行 */     sprintf(sql,"select * from addrbook");     res = PQexec(con,sql);     if (PQresultStatus(res) != PGRES_TUPLES_OK) { /* SQLの実行に失敗したときのエラー処理 */         fprintf(stderr,"%s",PQerrorMessage(con));         exit(1);     }     printf("name telno email\n");     printf("--------------------------------------\n");     for(i = 0; i < 3 ;i++) {         kou1 = PQgetvalue(res,i,0);         kou2 = PQgetvalue(res,i,1);         kou3 = PQgetvalue(res,i,2);         printf("%s %s %s\n",kou1,kou2,kou3);     }     PQclear(res); }

リスト3　サンプルプログラムtest1.c

　C言語で記述する際は、postgres.hとlibpq-fe.hのインクルードをお忘れなく。また、PQexec()関数は以下のように第2引数にSQL文を代入して実行します。

/* select文の発行 */ sprintf(sql,"select * from addrbook"); res = PQexec(con,sql);

　PQgetvalue()関数はデータベースから値を取り出すもので、第2引数に「行」、第3引数に「列」を指定します。そして、PQgetvalue()関数の戻り値をprintf()関数で整形して出力します。

kou1 = PQgetvalue(res,i,0); kou2 = PQgetvalue(res,i,1); kou3 = PQgetvalue(res,i,2); printf("%s %s %s\n",kou1,kou2,kou3);

　コンパイル時は、PostgreSQLのヘッダファイルとライブラリファイルが存在するディレクトリに明示的にパスが通るようにします。

cc -o test1 test1.c -I$POSTGRES_HOME/include -L$POSTGRES_HOME/lib -lpq -lnsl -lcrypt

■C言語のプログラム(追加用)

/* ヘッダファイル取り込み */ #include <stdio.h> #include <stdlib.h> #include <string.h> #include <errno.h> #include "postgres.h" #include "libpq-fe.h" /* main処理 */ int main(int argc,char **argv) {     /* 変数定義 */     char dbName[255] = "postgres"; /* データベース名はハードコーディング */     char sql[255];     int i;     PGconn *con;     PGresult *res; /* DBとの接続 */     con = PQsetdb("","",NULL,NULL,dbName);     if ( PQstatus(con) == CONNECTION_BAD ) { /* 接続が失敗したときのエラー処理 */         fprintf(stderr,"Connection to database '%s' failed.\n",dbName);         fprintf(stderr,"%s",PQerrorMessage(con));         exit(1);     }     /* insert文の発行 */     sprintf(sql,"insert into addrbook values ('K,Hamano','070-8888-8888','hamano@email.net')");     res = PQexec(con,sql);     if (PQresultStatus(res) != PGRES_COMMAND_OK) { /* SQLの実行に失敗したときのエラー処理 */         fprintf(stderr,"%s",PQerrorMessage(con));         exit(1);     }     PQclear(res); }

リスト4　サンプルプログラムtest2.c

　表示するプログラムの変更個所はPerlのプログラムのときと同様、SQL文を発行するところとSQL文からの戻り値を判断するところです。C言語でもPerlと同じような処理を行えばよいということが理解できるでしょう。

4．PHP3によるPostgreSQLの操作

　PHP3からPostgreSQLにアクセスするには、PHP3を導入します。ここではDSO版のApacheを使うものとして説明します。以後の操作はrootで作業します。

■Apacheのインストール

# cd /usr/local/src # tar xfz apache_1.3.12.tar.gz # cd apache_1.3.12 # ./configure --enable-module=so # make # make install

■PHPのインストール

# cd /usr/local/src # tar xfz php-3.0.15-i18n-ja.tar.gz # cd php-3.0.15-i18n-ja # ./configure --with-pgsql --with-apache=../apache_1.3.12 --enable-track-vars --with-apxs=/usr/local/apache/bin/apxs --enable-i18n --enable-mbregex # make # make install

■httpd.confの編集

　Apacheの標準の設定ではPHP3が実行できないようになっていますので、設定ファイル（httpd.conf）を編集します。

#AddType application/x-httpd-php3 .php3 #AddType application/x-httpd-php3-source .phps

という個所のコメント行の「#」を削除して、設定を有効化します。httpd.confを編集したら、必ずApacheを再起動してください。

■PHP3のプログラム(表示用)

　PHP3のプログラムとPerlやC言語でのプログラムとの相違点は、PHP3はサーバサイドで実行し、クライアント（Webブラウザ）で表示するというところにあります。

<HTML> <HEAD> <META HTTP-EQUIV="Content-type" CONTENT="text/html; charset=EUC-JP"> <title> 簡易アドレス帳 </title> </HEAD> <BODY BGCOLOR="#FFFFFF"> <h1>簡易アドレス帳</h1> <br> <hr> <br> <? /* Global variables. */ $dbname = "postgres";           /* DB name of PostgreSQL. */ $tbname = "addrbook";           /* table name of PostgreSQL. */         /* データベースとの接続 */     $conn = pg_Connect("localhost", "5432", "", "", $dbname);     if (!$conn){         echo "データベースの接続でエラーが発生しました<BR>\n";         exit;     }         /* SQL文の発行 */     $sql = "select * from $tbname";     $result = pg_Exec($conn, $sql);     if (!$result) {         echo "検索でエラーが発生しました<BR>\n";         exit;     }     $num = pg_numrows($result);     echo "<TABLE BORDER=\"1\">\n";     echo "<TR><TD>名前</TD><TD>電話番号</TD><TD>メール</TD></TR>\n";     for ($i = 0; $i < $num; $i++) {         $row = pg_fetch_row($result, $i);                 echo "<TR><TD>" . $row[0] . "</TD><TD>" . $row[1] . "</TD><TD>" . $row[2] . "</TD></TR>\n";     }     echo "</TABLE>\n"; ?> </BODY> </HTML>

リスト5　サンプルプログラムtest1.php3。プログラムの文字コードセットはEUCにしてください

　PHP3の文法はC言語によく似ているので、HTMLタグを除けば先ほどのC言語のサンプルプログラムとほとんど変わらないことにお気付きになるでしょう。

■PHP3のプログラム(追加用)

　次にPHP3でのレコード追加プログラムの例を示します。HTMLフォームでデータを入力し、そのHTMLフォームからPHP3プログラムを実行することにより登録を行います。リスト6はPHP3プログラムを呼び出すHTML、リスト7がPHP3プログラムです。

<html> <head> <META HTTP-EQUIV="Content-Type" CONTENT="text/html; charset=EUC-JP"> <title> 簡易アドレス帳（追加） </title> </head> <body bgcolor="FFFFFF"> <TABLE align="center" BORDER="0"> <TR><TD WIDTH="600"> <table align="center" border="5"> <TR> <TD align="center"> <FONT SIZE="5"><B>簡易アドレス帳（追加）<BR> </B></FONT> </TD> </table> <br> 登録してください <BR><BR> </TD></TR> </TABLE> <BR> <P align="right"> <hr> <form method="post" action="./test2.php3" NAME="myForm"> <TABLE ALIGN="CENTER" BORDER="1" WIDTH="600"> <input type="hidden" name="ename"> ※(*)がついている項目は、必ず入力してください。<BR> <TR> <TD WIDTH="100" BGCOLOR="#CCCCFF">名前 (*)</TD><TD><input type="text" name="name" size="60" maxlength="80"></TD> </TR> <TR> <TD WIDTH="100" BGCOLOR="#CCCCFF">電話番号 (*)</TD><TD><input type="text" name="telno" size="60" maxlength="80"></TD> </TR> <TR> <TD WIDTH="100" BGCOLOR="#CCCCFF">メール (*)</TD><TD><input type="text" name="email" size="60" maxlength="120"></TD> </TR> </TABLE> <center> <input type="submit" value="登録"><input type="reset" value="リセット"> </CENTER> </form> </body> </html>

リスト6　サンプルプログラム用HTML（test2.html）。HTMLフォームに入力したデータは、環境変数としてPHP3に引き継がれてレコードの追加が行われます

<HTML> <HEAD> <META HTTP-EQUIV="Content-type" CONTENT="text/html; charset=EUC-JP"> <title> 簡易アドレス帳（追加） </title> </HEAD> <BODY BGCOLOR="#FFFFFF"> <FORM ACTION="test2.php3" METHOD=POST> <H2> 簡易アドレス帳（追加）<BR> </H2> <? /* Global variables. */ $dbname = "postgres";           /* DB name of PostgreSQL. */ $tbname = "addrbook";           /* table name of PostgreSQL. */         /* データベースとの接続 */     $conn = pg_Connect("localhost", "5432", "", "", $dbname);     if (!$conn){         echo "データベースの接続でエラーが発生しました\n";         exit;     }     $sql = "insert into $tbname values ('$name','$telno','$email')";     $result = pg_Exec($conn, $sql);     if (!$result) {         echo "データベースへの登録でエラーが発生しました<BR>\n";         exit;     }     echo "登録しました<BR>\n"; ?> </BODY> </HTML>

リスト7　サンプルプログラムtest2.php3

　これもC言語の例と同じく、あまり変わりがないことがお分かりになるでしょう。

5．PostgreSQLの開発環境

　第1回の原稿に書いたとおり、PostgreSQLにはレプリケーションが実装されていないために、つい最近まではPostgreSQLを使用してシステムインテグレーションを行うのはいろいろと苦労がつきまとっていました。

　ところが、レプリケーションを実装するための仕組みが最近になって現れてきました。1つが、筆者の所属する株式会社デジタルデザインが2000年11月より出荷を開始する「FCR for PostgreSQL」です。このソフトは2つのサーバ間にFast Connector Serverを置いて、insert文などの発行を受けてもう1つのサーバにトリガを使ってレプリケーションを行う仕組みになっています。評価版がダウンロードできますので、一度お試しになられてはいかがでしょう。

http://www.fastconnector.com/

　また、導入方法などについては下記のURLが参考になります。

http://www.asahi-net.or.jp/~pq6a-tsmt/poco/fcs4pgsql/fcs4pgsql

　もう1つの実装は、株式会社グッデイの細川さんがGPL2で公開されている「Usogres」です。

http://usogres.good-day.net/

　UsogresはPostgreSQLのプロキシとして機能するサーバソフトです。Usogresで実行されたSQLの処理が複数のPostgreSQLサーバーに送られるので、結果的にリアルタイムでバックアップされるというものです。しかし、厳密的な意味でのレプリケーションはまだ実現されていません。作者の細川氏によると、今後本格的なレプリケーション機能を実装するとのことなので大いに期待が持てるソフトです。

　今回まで3回にわたりPostgreSQLの説明を行ってきました。PostgreSQLの概要や導入方法、アプリケーション開発について、おおよそ理解できたと思います。この連載が皆さんのお仕事に生かされることを願ってやみません。

連載 PostgreSQLで作るLinuxデータベース

---

Linux Squareフォーラム データベース関連記事

	連載：快速MySQLでデータベースアプリ！（全11回） 軽快な動作で知られるRDBMS、MySQLでDBアプリの構築を行う。MySQLのインストールに始まり、PerlやRubyなどのスクリプトでデータベースを操作する方法までを完全解説
	連載：今から始める MySQL入門（連載中） 定番のLAMP（Linux＋Apache＋MySQL＋PHP）構成でWebアプリケーション開発に挑戦！ サンプルアプリの構築を進めながら、基礎知識や操作方法について詳しく解説する
	連載：Oracleマイスター養成講座（全6回） 本連載では、Oracleの管理・チューニング方法を紹介していく。これからOracleを始める人、そしてOracleをより深く理解したい人のための、一歩踏み込んだ実用講座
	連載：DB2マイスター養成講座（全7回） 本連載では、DB2 UDBの実践的な運用・管理方法を紹介していく。DB2を利用するうえで必要な知識を、実運用を前提にDB2のプロが解説
	特集：エンタープライズ市場に向かうMySQL 5.0［前編］ MySQL 5.0の新機能をアルファ版でチェック 1月に公開された5.0アルファ版は大幅に拡張されており、エンタープライズ市場への進出を予感させる
	特集：Linuxで動くリレーショナルデータベース・カタログ データベースサーバのOSとしてLinuxを採用するケースが増えている。Linuxで動作する7つの主なリレーショナルデータベースを紹介する。製品導入の際の参考にしてほしい
	more

MONOist組み込み開発フォーラムの中から、Linux関連記事を紹介します

＠ITメールマガジン　新着情報やスタッフのコラムがメールで届きます（無料）