Servlet／JSP＋MySQLでアプリケーションサーバ その1：快速MySQLでデータベースアプリ！（8）（2/3 ページ）
いよいよWebアプリケーションサーバの大本命Java Servlet／JSPの登場だ。Javaを使えばさまざまな方法でMySQLを操作できるようになる。今回はServlet／JSPの基本となるJavaアプリケーションを作成してみよう。
Javaアプリケーションのコーディング
JDBCドライバのロードとMySQLサーバへの接続
では、JDBCドライバをロードしてMySQLサーバへ接続するサンプルを見てみましょう（リスト1）。
1、2行目でJDBC APIを使用するためにjava.net.*とjava.sql.*をインポートし、
import java.net.*; import java.sql.*;
7〜11行目で必要な値の宣言を行います。
String server = "localhost"; //MySQLサーバ String db = "ATMARKIT"; // String user = "test"; //ユーザー名 String pass = "test2001"; //パスワード String url = "jdbc:mysql://" + server + "/" + db;
11行目の、サーバの単純なURLは下記のように定義されます。
jdbc:<サブプロトコル名>://<サブネーム>
一般的にホームページのアドレスは「http://www.mysql.gr.jp」のように「プロトコル名://サーバのアドレス」で構成されるのに対し、JDBC APIを使ってデータベースに接続するにはサブプロトコルが必要になります。このサブプロトコルはJavaSoftから一意に与えられており、MM.MySQL JDBCドライバの場合は「mysql」がサブプロトコルになります。
次にMM.MySQL JDBCドライバをロードします（15行目）。
Class.forName("org.gjt.mm.mysql.Driver");
準備が整ったところでDriverManagerのConnectionメソッドに、URL、ユーザー名、パスワードを引数として渡し、MySQLサーバと接続します（18行目）。
con = DriverManager.getConnection(url,user,pass);
MySQLサーバに対するすべての操作が終わったところで接続を解除します（23行目）。
con.close();
ではサンプルをコンパイル、実行してみましょう。Sample1.java（リスト1）を保存したディレクトリで下記のようにします。
$ $JAVA_HOME/bin/javac Sample1.java
コンパイルが成功した後、Sample1.classファイルができていることを確認したら、上のディレクトリに先ほど展開してできたmysql.jarをコピーして実行します。
$ cp mm.mysql-2.0.4/mysql.jar . $ $JAVA_HOME/bin/java -classpath mysql.jar:. Sample1
MM.MySQL JDBCドライバを参照するため、javaコマンドに-classpathオプションを使ってmysql.jarファイルをclasspathに追加しています。ここで重要なのは、-classpathオプションを指定することです。暗黙的なclasspathである“.”（カレントディレクトリ）がclasspathから外れてしまうのを防ぐことです。そのため、
-classpath mysql.jar:.
とすることで、mysql.jarとカレントディレクトリを明示的にclasspathに追加します。成功していれば「接続成功です！」と表示されます。
レコードの挿入
では次に、実際にMySQLサーバに対し「INSERT」を行ってみましょう（リスト2）。
JDBCを使ってクエリーを作成するには、まずStatementオブジェクトを作成する必要があります（21行目）。
Statement stmt = con.createStatement();
StatmentクラスのexecuteUpdate()メソッドにSQL文を渡すことでINSERT、UPDATE、DELETEEなど、SELECT以外のクエリーを実行できます（23行目）。
stmt.executeUpdate(sql_str);
注：SQL文中に「'」「"」「\」を含ませる場合はエスケープ文字を用いて「\'」「\"」「\\」とします。
ではコンパイルと実行です。Sample2.java（リスト2）を保存したディレクトリで下記のようにします。
$ $JAVA_HOME/bin/javac Sample2.java $ $JAVA_HOME/bin/java -classpath mysql.jar:. Sample2
「レコードの挿入成功です！」と表示されれば成功です。また本当にデータが挿入されているか下記の手順で確かめてみましょう。
$ mysql ATMARKIT mysql> select * from list; +----+-------+--------------------------+ | id | name | memo | +----+-------+--------------------------+ | 1 | 1st | memo 1st | | 2 | 2nd | 2nd trial | +----+-------+--------------------------+ 2 rows in set (0.01 sec)
漢字の対応
MySQLは多くの方の努力により、EUCやシフトJISなどのマルチバイト文字に対応しています。一方、Java内部ではUnicodeとして文字を扱い、入出力は実行環境のfile.encodingに左右されます。そのため、Windows 95／98／2000／NTではマルチバイトを含んだSQL文はシフトJISとして実行され、LANGがja_JP.eucJPにセットされているLinuxではEUCとして実行されます。Javaアプリケーションを実行する際に「java -Dfile.encoding=EUC_JP」などとして明示的に指定することも可能ですが、MM.MySQL JDBCドライバはURLにcharacterEncodingパラメータを指定することで、文字列を任意のコードとして扱えます（リスト3）。
リスト2とリスト3では、11行目が異なっていることが分かるかと思います。
String url = "jdbc:mysql://" + server + "/" + db;
String url = "jdbc:mysql://" + server + "/" + db + "?useUnicode=true&characterEncoding=EUC_JP";
jdbc:mysql://<MySQLサーバ名>:<ポート番号>/<データベース名>?useUnicode=true&characterEncoding=<サーバの文字コード>
注：MySQLサーバがデフォルトの3306ポートで起動しているなら:＜ポート番号＞は省略できます。
●characterEncodingの例
［MySQLサーバがEUCで起動している場合］
jdbc:mysql://<MySQLサーバ名>:<ポート番号>/<データベース名>?useUnicode=true&characterEncoding=EUC_JP
［MySQLサーバがシフトJISで起動している場合］
jdbc:mysql://<MySQLサーバ名>:<ポート番号>/<データベース名>?useUnicode=true&characterEncoding=SJIS
注：characterEncodingパラメータは同時に「useUnicode=true」の指定が必要です。
MM.MySQL JDBCでは、上記以外にもURLにパラメータを加えることでさまざまな値を調整できます。
| 変数 | 用途 | デフォルト値 |
|---|---|---|
| user | 接続時のユーザー名 | なし |
| password | 接続時のパスワード | なし |
| autoReconnects | データベースとの接続が失われた場合、再接続を試みるかどうか（true／false） | false |
| maxReconnects | autoReconnectsが選択されている場合、再接続を何回まで行うか | 3 |
| initialTimeout | autoReconnectsが選択されている場合、再接続までの待ち受け時間（秒数） | 2 |
| maxRows | データベースサーバから受け取る最大レコード数（すべて受け取る場合は0） | 0 |
| useUnicode | 文字列を扱う際、Unicode変換を行うかどうか（true／false） | false |
| characterEncoding | 文字コード変換を何で扱うか（useUnicodeが選択されている必要あり） | なし |
| 表 MM.MySQL JDBCのURLパラメータ | ||
URLの指定は、下記の要領になります。
jdbc:mysql://<MySQLサーバ名>:<ポート番号>/<データベース名>?<変数1=値1>&<変数2=値2>&...
では、漢字を含んだINSERTクエリーを実行してみましょう。Sample3.java（リスト3）を保存したディレクトリで下記のようにします。
$ $JAVA_HOME/bin/javac Sample3.java $ $JAVA_HOME/bin/java -classpath mysql.jar:. Sample3
「漢字を含んだレコードの挿入成功です！」と表示されれば成功です。
レコードの抽出
次はSELECTクエリーをJavaアプリケーションで実行してみましょう（リスト4）。
リスト2と同様にStatementオブジェクトを作成します（21行目）。SELECTクエリーを実行するには、先ほどのexecuteUpdate()メソッドではなく、executeQuery()メソッドを呼び出し、戻り値にResultSetオブジェクトを受け取ります（25行目）。
ResultSet rs = stmt.executeQuery(sql_str);
ResultSetオブジェクトのnext()メソッドの戻り値がfalseになるまでgetXX()メソッドに該当カラムのカラム番号を引数に渡し、処理を行います（28〜36行目）。
while(rs.next()){
int id = rs.getInt("id");
String name = rs.getString("name");
String memo = rs.getString("memo");
System.out.println("-------" + id + "---------");
System.out.println("name:" + name);
System.out.println("memo:" + memo);
}
注：カラム番号ではなく、カラム名を引数に渡すこともできます。
ResultSetオブジェクトには、各レコードの型に対応して下記のようなデータの取得方法が用意されています。
| get系メソッド | 得られるJavaの型 |
|---|---|
| getAsciiStream | InputStream |
| getBigDecimal | BigDecimal |
| getBinaryStream | InputStream |
| getBoolean | boolean |
| getByte | byte |
| getBytes | byte[] |
| getDate | sava.sql.Date |
| getDouble | double |
| getFloat | float |
| getInt | int |
| getLong | long |
| getObject | java.lang.Object |
| getShort | short |
| getString | String |
| getTime | java.sql.Time |
| getTimestamp | java.sql.timestamp |
| getUnicodeStream | InputStream |
では、実行してみましょう。Sample4.java（リスト4）を保存したディレクトリで下記のようにします。
$ $JAVA_HOME/bin/javac Sample4.java $ $JAVA_HOME/bin/java -classpath mysql.jar:. Sample4
先ほど登録したレコードも含めて結果が表示されると思います。
-------1--------- name:1st memo:memo 1st -------2--------- name:2nd memo:2nd trial -------3--------- name:3番目 memo:3番目のテスト
次回は、今回作成したプログラムをServlet化してWebブラウザから使えるようにしたいと思います。また、Servletを実行するにはApacheに加えてTomcatというJava実行環境が必要になります。そこでTomcatの設定についても紹介します。
Copyright © ITmedia, Inc. All Rights Reserved.