Statementオブジェクト

Statementインタフェースは、SQL文などを使ってデータベースに問い合わせをするためのクラスです。Connectionオブジェクトのメソッドから取得して利用します。

■ 主なメソッド

メソッド名 概要
close データベースの接続を閉じる
execute 複数の結果を返す可能性のあるSQL文を実行する
executeQuery SELECT文の実行結果を表すResultSetオブジェクトを返す
executeUpdate INSERT、UPDATE、DELETE文を実行する
isClose このオブジェクトがクローズされているかどうかを取得する
Statementの主なメソッド

○　ファイル

ConnectionTest.javaファイルをコピーして、次のファイルを作成してください。

ファイル名 StatementTest.java

サンプルダウンロード

○　プログラム

次のようにプログラムを入力してください。

StatementTest.java

  1. import java.io.BufferedReader;
  2. import java.io.InputStreamReader;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.Statement;
  7. public class StatementTest{
  8.     public static void main(String[] args){
  9.         try{
  10.             //JDBCドライバークラスを指定する
  11.             String drivername = "com.mysql.cj.jdbc.Driver";
  13.             //データベースを指定する
  14.             String url = "jdbc:mysql://localhost:3306/books? characterEncoding=utf8";
  16.             //ユーザー名を指定する
  17.             String username = "root";
  19.             //パスワードを指定する
  20.             String password = "";
  22.             //指定したドライバークラスを読み込む
  23.             Class.forName(drivername);
  25.             //データベースに接続する
  26.             Connection con = DriverManager.getConnection(url, username, password);
  28.             //追加する情報を入力する
  29.             BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
  30.             System.out.println("登録するユーザー情報を入力してください。");
  31.             System.out.print("ID：");
  32.             int id = Integer.parseInt(br.readLine());
  33.             System.out.print("ユーザー名：");
  34.             String uname = br.readLine();
  35.             System.out.print("パスワード：");
  36.             String passwd = br.readLine();
  37.             System.out.print("氏名：");
  38.             String name = br.readLine();
  40.             //入力した情報をもとにSQL文を作成する
  41.             String sql = "INSERT INTO Users VALUES(" + id + ", '" + uname + "', '" + passwd + "', '" + name + "')";
  43.             //Statementオブジェクトを取得する
  44.             Statement st = con.createStatement();
  45.             
  46.             //SQL文を実行する
  47.             int ret = st.executeUpdate(sql);
  48.             
  49.             //変更のあった行数を表示する
  50.             System.out.println("変更のあった件数：" + ret);
  52.             //データベースを切断する
  53.             st.close();
  54.             con.close();
  55.         }catch(Exception e){
  56.             //例外の状態を出力する
  57.             e.printStackTrace();
  58.         }
  59.     }
  60. }

○　コンパイルと実行

C:¥work>javac　StatementTest.java
C:¥work>java　-cp　mysql-connector-java-8.0.22.jar;.　StatementTest
登録するユーザー情報を入力してください。
ID：4
ユーザー名：takana
パスワード：tpass
氏名：田中
変更のあった件数：1

C:¥work>

○　解説

今回はusersテーブルにデータを追加するプログラムです。31~38行目では、追加するデータを入力しています。入力したデータをもとに41行目でSQL文を作成しています。今回はレコードを追加するのでINSERT文を作成します。このようにJavaプログラムの中でSQL文は文字列として扱います。

44行目でStatementオブジェクトを取得しています。ConnectionオブジェクトのcreateStatementメソッドを使って取得します。

47行目では、SQL文を実行しています。excecuteUpdateメソッドは影響のあった行数を返すので、それをret変数に格納し、50行目で表示しています。一連の処理が終わったら53、54行目にもあるようにStatementオブジェクトのcloseメソッドと、Connectionオブジェクトのcloseメソッドを使ってデータベースへの接続を閉じます。

データベースとStatementオブジェクトの関係
データベースとStatementオブジェクトの関係

○　データベースの確認

phpMyAdminでuserテーブルのデータを確認してください。レコードが追加されていることを確認できます。

データベースに追加された
データベースに追加された

前へ   次へ