前回までのプログラムでは、データベースを開いた後に何らかの例外が発生し、catch文に処理が移るとデータベースが閉じられないことがあります。
try {
SampleDb030 db = new SampleDb030();
db.open();
int num = db.executeUpdate(mySql); ←ここで例外が発生すると
db.close(); ←実行されない
prefAll();
} catch (SQLException e) {
}
そこで finally文を使い以下のようにすると、必ずデータベースを閉じることができます。変数 db はfinally文でも使うので、try文の外で宣言しインスタンス化している点がポイントです。変数 db の有効範囲はメソッドの中だけです。
SampleDb030 db = new SampleDb030();
try {
db.open();
int num = db.executeUpdate(mySql); ←ここで例外発生しても
prefAll();
} catch (SQLException e) {
} finally {
db.close(); ←実行される
}
しかしここで問題が発生します。よく見ると finally文でデータベースを閉じる前に、リストを再表示する prefAll() メソッドが実行されてしまいます。この時点ではデータベースのデータは古いままです。
前回述べた通り、追加、修正、削除などのSQL文を実行したときは、データベースを閉じるか、コミット(Commit)しないとデータが反映されません。コミットするには Connection クラスのメソッドを利用する必要があります。
con.commit();
したがって SampleDb030 クラスのメソッドを少し修正する必要があります。また commit()は例外 SQLException を発生する可能性があるので、try-catch文で囲む必要があります。すると SQLException を再スローすることは出来なくなるため、独自の例外を作り再スローするように工夫が必要です。
上記の点をふまえて修正したプログラムを掲載します。
【1】sample216 フォルダをフォルダごとコピーして、sample217 フォルダを作ります。
【2】今回は以下のようなファイル構成になりますので、コピーした余計なものは削除してください。
＊データベースに接続する部分を変更しますので、「SampleDb030.class」ではなく、「SampleDb030.java」を使います。SampleDb030.javaは以下に掲載します。
【3】SampleDb030.java と PrefTest.java を以下のように変更します。
＊「\」はWindowsではエンマークのことです。
保存先 C:\java\sample217
ファイル名 SampleDb030.java
import java.sql.*;
class SampleDb030{
private Connection con = null;
private Statement stmt = null;
private ResultSet rs = null;
public void open() {
String url = "jdbc:odbc:SampleDB030";
String user = "";
String pass = "";
try {
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
con = DriverManager.getConnection(url,user,pass);
stmt = con.createStatement();
} catch (Exception e) {
e.printStackTrace();
}
}
public void close() {
try {
if (rs != null){
rs.close();
}
if (stmt != null){
stmt.close();
}
if (con != null){
con.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
public ResultSet executeQuery(String sql) {
if (stmt != null){
try {
rs = stmt.executeQuery(sql);
} catch (SQLException e) {
e.printStackTrace();
}
}
return rs;
}
public int executeUpdate(String sql) throws BadSqlException {
int num = 0;
if(stmt != null){
try {
con.setAutoCommit(false);
num = stmt.executeUpdate(sql);
con.commit();
} catch (SQLException e) {
try {
con.rollback();
e.printStackTrace();
throw new BadSqlException();
} catch (SQLException e1) {
e1.printStackTrace();
}
}
}
return num;
}
}
class BadSqlException extends Exception {
}
保存先 C:\java\sample217
ファイル名 PrefTest.java
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import javax.swing.event.*;
import java.sql.*;
import java.util.*;
class PrefFrame extends JFrame implements ActionListener, ListSelectionListener {
Container cp;
JLabel lb1;
JList lt;
JButton btn1, btn2, btn3, btn4;
JMenuItem mi1, mi2, mi3, mi4, mi5, mi6;
String[] tkn;
public PrefFrame(String title) {
//フレームのタイトル
setTitle(title);
//コンテンツペイン取得
cp = getContentPane();
//ウィンドウを閉じる時
setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);
addWindowListener(new WindowAdapter() {
public void windowClosing(WindowEvent e) {
showExitDialog();
}
});
//Look&Feelの設定
/*
String type = "com.sun.java.swing.plaf.windows.WindowsLookAndFeel";
try {
UIManager.setLookAndFeel(type);
} catch ( Exception e ) {
System.out.println("例外発生：" + e );
}
*/
//メニューバーの生成
JMenuBar mb = new JMenuBar();
//メニューの生成
JMenu mn1 = new JMenu("ファイル");
JMenu mn2 = new JMenu("編集");
JMenu mn3 = new JMenu("検索");
//メニュー項目の生成
mi1 = new JMenuItem("追加");
mi2 = new JMenuItem("更新");
mi3 = new JMenuItem("削除");
mi4 = new JMenuItem("終了");
mi5 = new JMenuItem("検索");
mi6 = new JMenuItem("全件表示");
//イベントリスナーの登録
mi1.addActionListener(this);
mi2.addActionListener(this);
mi3.addActionListener(this);
mi4.addActionListener(this);
mi5.addActionListener(this);
mi6.addActionListener(this);
//メニューへの追加
mn1.addSeparator(); //セパレーター
mn1.add(mi4);
mn2.add(mi1);
mn2.add(mi2);
mn2.add(mi3);
mn3.add(mi5);
mn3.add(mi6);
//メニューバーへの追加
mb.add(mn1);
mb.add(mn2);
mb.add(mn3);
//メニューバーをフレームへ追加
setJMenuBar(mb);
//ラベル
lb1 = new JLabel();
lb1.setHorizontalAlignment(SwingConstants.CENTER);
lb1.setOpaque(true);
lb1.setFont(new Font("Dialog", Font.PLAIN, 12));
lb1.setBackground(Color.WHITE);
cp.add(lb1, BorderLayout.NORTH);
//リスト
lt = new JList();
lt.setFont(new Font("Dialog", Font.PLAIN, 14));
lt.setForeground(new Color(64, 64, 64));
lt.setSelectionMode(ListSelectionModel.SINGLE_SELECTION);
lt.addListSelectionListener(this);
JScrollPane sp = new JScrollPane(lt);
cp.add(sp, BorderLayout.CENTER);
//パネル
JPanel pn1 = new JPanel();
pn1.setLayout(new GridLayout(1, 4));
//ボタンの設定
btn1 = new JButton("追加");
btn2 = new JButton("更新");
btn3 = new JButton("削除");
btn4 = new JButton("終了");
btn4.setForeground(new Color(255, 0, 0));
btn1.addActionListener(this);
btn2.addActionListener(this);
btn3.addActionListener(this);
btn4.addActionListener(this);
pn1.add(btn1);
pn1.add(btn2);
pn1.add(btn3);
pn1.add(btn4);
//パネルを追加
cp.add(pn1, BorderLayout.SOUTH);
//データ表示
prefAll();
}
public void actionPerformed (ActionEvent e) {
Object obj = e.getSource();
if (obj == btn1 || obj == mi1) {
prefInsert();
}else if (obj == btn2 || obj == mi2) {
prefUpdate();
}else if (obj == btn3 || obj == mi3) {
prefDelete();
}else if (obj == btn4 || obj == mi4) {
showExitDialog();
}else if (obj == mi5) {
prefSearch();
}else if (obj == mi6) {
prefAll();
}
}
public void valueChanged (ListSelectionEvent e) {
try {
String str = (String)lt.getSelectedValue();
if(str != null){
StringTokenizer st = new StringTokenizer(str, ",");
int arraySize = st.countTokens();
tkn = new String[arraySize];
int i = 0;
while(st.hasMoreTokens()) {
tkn[i] = st.nextToken();
i++;
}
lb1.setText("PREF_CD:" + tkn[0] + " PREF_NAME:" + tkn[1]);
lb1.setForeground(Color.BLUE);
}
} catch (Exception e1) {
e1.printStackTrace();
}
}
private void prefDisplay (ResultSet rs) {
tkn = null;
ArrayList<String> listData = new ArrayList<String>();
try {
//結果セットからデータを取り出す next()で次の行に移動
int count = 0;
while(rs.next()) {
int prefCd = rs.getInt("PREF_CD");
String prefName = rs.getString("PREF_NAME");
listData.add(prefCd + "," + prefName);
count++;
}
lt.setListData(listData.toArray());
lb1.setForeground(Color.BLUE);
if(count == 0) {
lb1.setText("該当するレコードがありません。");
}else{
lb1.setText(count + "件表示しました。");
}
} catch (Exception e) {
e.printStackTrace();
}
}
private void showExitDialog () {
//終了ダイアログボックスの表示
int ret = JOptionPane.showConfirmDialog (cp, "プログラムを終了しますか？", "確認", JOptionPane.YES_NO_OPTION);
if(ret == JOptionPane.YES_OPTION) {
System.exit(0);
}
}
private void prefInsert () {
//追加
SampleDb030 db = new SampleDb030();
String message = "PREF_CD を入力してください。";
String title = "追加";
try {
String prefCd = JOptionPane.showInputDialog (cp, message, title,JOptionPane.QUESTION_MESSAGE);
if(prefCd != null && !prefCd.equals("")) {
String message2 = "PREF_NAME を入力してください。";
String prefName = JOptionPane.showInputDialog (cp, message2, title,JOptionPane.QUESTION_MESSAGE);
if(prefName != null && !prefName.equals("")) {
String mySql = "insert into T01Prefecture values(" + prefCd + ", '" + prefName + "')";
System.out.println(mySql);
db.open();
int num = db.executeUpdate(mySql);
prefAll();
lb1.setText("登録しました。");
}
}
} catch (BadSqlException e) {
lb1.setText("登録できませんでした。");
lb1.setForeground(Color.RED);
} catch (Exception e) {
e.printStackTrace();
} finally {
db.close();
}
}
private void prefUpdate () {
//更新
SampleDb030 db = new SampleDb030();
String prefCd = (tkn != null) ? tkn[0] : null;
String prefName = (tkn != null) ? tkn[1] : null;
Object nameObj = null;
try {
if(prefCd != null) {
String message = "「" + prefCd + " " + prefName + "」の\n新しい PREF_NAME を入力してください。";
String title = "更新";
nameObj = JOptionPane.showInputDialog (cp, message, title,JOptionPane.QUESTION_MESSAGE, null, null, prefName);
}else{
JOptionPane.showMessageDialog(cp, "先に都道府県を選択してください。");
}
if(nameObj != null) {
prefName = (String)nameObj;
String mySql = "update T01Prefecture set PREF_NAME = '" + prefName + "' where PREF_CD = " + prefCd;
System.out.println(mySql);
db.open();
int num = db.executeUpdate(mySql);
prefAll();
lb1.setText(num + "件更新しました。");
}
} catch (Exception e) {
e.printStackTrace();
} finally {
db.close();
}
}
private void prefDelete () {
//削除
SampleDb030 db = new SampleDb030();
String prefCd = (tkn != null) ? tkn[0] : null;
String prefName = (tkn != null) ? tkn[1] : null;
int ret = -9;
try {
if(prefCd != null) {
String message = "「" + prefCd + " " + prefName + "」を削除しますか？";
String title = "削除";
ret = JOptionPane.showConfirmDialog (cp, message, title, JOptionPane.OK_CANCEL_OPTION, JOptionPane.WARNING_MESSAGE);
}else{
JOptionPane.showMessageDialog(cp, "先に都道府県を選択してください。");
}
if(ret == JOptionPane.OK_OPTION) {
String mySql = "delete from T01Prefecture where PREF_CD = " + prefCd;
System.out.println(mySql);
db.open();
int num = db.executeUpdate(mySql);
prefAll();
lb1.setText(num + "件削除しました。");
}
} catch (Exception e) {
e.printStackTrace();
} finally {
db.close();
}
}
private void prefSearch () {
//検索
SampleDb030 db = new SampleDb030();
String message = "PREF_NAME の一部を入力してください。";
String title = "検索";
try {
String prefName = JOptionPane.showInputDialog (cp, message, title, JOptionPane.QUESTION_MESSAGE);
if(prefName != null && !prefName.equals("")) {
String mySql = "select * from T01Prefecture where PREF_NAME like '%" + prefName + "%'";
System.out.println(mySql);
db.open();
ResultSet rs = db.executeQuery(mySql);
prefDisplay(rs);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
db.close();
}
}
private void prefAll () {
//全件表示
//SampleDb030をインスタンス化
SampleDb030 db = new SampleDb030();
try {
String mySql = "select * from T01Prefecture order by PREF_CD";
System.out.println(mySql);
//データベースに接続
db.open();
//検索するSQL実行
ResultSet rs = db.executeQuery(mySql);
//データ表示
prefDisplay(rs);
} catch (Exception e) {
e.printStackTrace();
} finally {
//オブジェクトを解放
db.close();
}
}
}
public class PrefTest {
public static void main(String args[]) {
PrefFrame frm = new PrefFrame("都道府県マスター");
//フレームの設定
frm.setLocation(300, 200);
frm.setSize(250, 350);
frm.cp.setBackground(Color.LIGHT_GRAY);
frm.setVisible(true);
}
}
【4】以下の図を参考に、コマンドプロンプトを起動、カレントディレクトリの切り替え、コンパイル、プログラムの実行を行います。
【5】都道府県マスターが表示されたら、これまでと同じように動作するか確認してください。
【解説】
■SampleDb030.java側
(1)Exceptionを継承した独自の例外クラスを作りました。このクラスは最小限で何も書いていません。例外をスローするために使います。
class BadSqlException extends Exception {
}
(2)executeUpdate()メソッドについて
・BadSqlExceptionクラスの例外が発生した時には、このメソッドの呼び出し元に処理を委ねています。
public int executeUpdate(String sql) throws BadSqlException {
・オートコミットを無効にしてトランザクションを開始します。SQL文を実行し何も問題なければ、コミット（確定）しています。コミットは tyr-catch文で囲む必要があります。
con.setAutoCommit(false);
num = stmt.executeUpdate(sql);
con.commit();
・SQL文が適切でない場合は例外が発生し、catch文に処理が移りますので、ロールバック（取り消し）して、エラーの詳細を出力し、例外BadSqlExceptionをスローしています。
con.rollback();
e.printStackTrace();
throw new BadSqlException();
catch文で SQLException を指定し、メソッドの呼び出し元にスローする例外も SQLException だとつじつまが合いません。そこで独自の例外クラスを作り、 SQLException が発生したときには、BadSqlExceptionをスローするようにしています。
・con.rollback()自体が例外を発生する可能性があるので、catch文の中でさらにtyr-catch文で囲んでいます。前のtry文ではcatch文の中まで補足できないからです。少し複雑ですね。
■PrefTest.java側
(1)prefInsert()メソッドについて
例外BadSqlExceptionを受け取るように変更しました。
} catch (BadSqlException e) {
lb1.setText("登録できませんでした。");
lb1.setForeground(Color.RED);
}
【ワンポイント】
トランザクション処理とは必ず同時に行わなければならない複数の処理を、一つの処理として扱うためのものです。処理がすべて成功した場合はコミット（確定）し、一つでも失敗した場合は、ロールバック（取消し）でデータベースを処理前の状態に戻すことができます。
例 銀行の振込みにおける、出金処理と入金処理
