JavaでPostgreSQLにJDBC接続してinsert/update/deleteするサンプルです。
(確認環境:Java 8,PostgreSQL 11.2,Eclipse 4.8,Windows 10)
目次
SQLの実行 | insertのサンプル |
updateのサンプル | |
deleteのサンプル | |
プレースホルダ | |
PreparedStatement | |
ドライバ | JDBCドライバを取得する |
JDBCドライバをクラスパス(ビルドパス)に追加する | |
環境 | 接続先のデータベースとテーブル |
insertのサンプル
PostgreSQLにJDBC接続してインサートを実行するサンプルです。
package test1;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class Test1 {
public static void main(String[] args) {
final String URL
= "jdbc:postgresql://127.0.0.1:5432/testdb10";
final String USER = "postgres";
final String PASS = "test1";
final String SQL = "insert into employee(id,name,romaji) VALUES(?,?,?)";
try(Connection conn =
DriverManager.getConnection(URL, USER, PASS)){
conn.setAutoCommit(false);
try(PreparedStatement ps = conn.prepareStatement(SQL)){
ps.setInt(1,4);
ps.setString(2,"竹田");
ps.setString(3,"takeda");
ps.executeUpdate();
conn.commit();
} catch (Exception e) {
conn.rollback();
System.out.println("rollback");
throw e;
}
} catch (Exception e) {
e.printStackTrace();
}finally {
System.out.println("処理が完了しました");
}
}
}
13行目は、プレースホルダを使用したSQLです。(?)の箇所はプレースホルダです。
15~16,20行目は、try-with-resources構文です。リソースを自動でクローズします。
18行目は、setAutoCommitメソッドで手動コミットするようにしています。デフォルトは自動コミットモードです。自動コミットモードは、SQLを実行する毎にコミットされます。
21~23行目は、プレースホルダに値をセットしています。1つめの引数はプレースホルダの位置です。2つめの引数は値です。
26行目は、SQL処理が成功した場合で、commitメソッドを実行します。
28行目は、SQL処理で例外が発生した場合で、rollbackメソッドを実行します。
updateのサンプル
PostgreSQLにJDBC接続してアップデートを実行するサンプルです。
package test1;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class Test1 {
public static void main(String[] args) {
final String URL
= "jdbc:postgresql://127.0.0.1:5432/testdb10";
final String USER = "postgres";
final String PASS = "test1";
final String SQL
= "update employee set name = ? ,romaji = ? where id = ?";
try(Connection conn =
DriverManager.getConnection(URL, USER, PASS)){
conn.setAutoCommit(false);
try(PreparedStatement ps = conn.prepareStatement(SQL)){
ps.setString(1,"山田");
ps.setString(2,"yamada");
ps.setInt(3,1);
ps.executeUpdate();
conn.commit();
} catch (Exception e) {
conn.rollback();
System.out.println("rollback");
throw e;
}
} catch (Exception e) {
e.printStackTrace();
}finally {
System.out.println("処理が完了しました");
}
}
}
14行目は、プレースホルダを使用したSQLです。(?)の箇所はプレースホルダです。
16~17,21行目は、try-with-resources構文です。リソースを自動でクローズします。
19行目は、setAutoCommitメソッドで手動コミットするようにしています。デフォルトは自動コミットモードです。自動コミットモードは、SQLを実行する毎にコミットされます。
22~24行目は、プレースホルダに値をセットしています。1つめの引数はプレースホルダの位置です。2つめの引数は値です。
24行目は、DBの項目(id)の型がint型のため、setIntメソッドを使用しています。
27行目は、SQL処理が成功した場合で、commitメソッドを実行します。
29行目は、SQL処理で例外が発生した場合で、rollbackメソッドを実行します。
deleteのサンプル
PostgreSQLにJDBC接続して削除を実行するサンプルです。
package test1;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class Test1 {
public static void main(String[] args) {
final String URL
= "jdbc:postgresql://127.0.0.1:5432/testdb10";
final String USER = "postgres";
final String PASS = "test1";
final String SQL = "delete from employee where id = ?";
try(Connection conn =
DriverManager.getConnection(URL, USER, PASS)){
conn.setAutoCommit(false);
try(PreparedStatement ps = conn.prepareStatement(SQL)){
ps.setInt(1,4);
ps.executeUpdate();
conn.commit();
} catch (Exception e) {
conn.rollback();
System.out.println("rollback");
throw e;
}
} catch (Exception e) {
e.printStackTrace();
}finally {
System.out.println("処理が完了しました");
}
}
}
13行目は、プレースホルダを使用したSQLです。(?)の箇所はプレースホルダです。
15~16,20行目は、try-with-resources構文です。リソースを自動でクローズします。
18行目は、setAutoCommitメソッドで手動コミットするようにしています。デフォルトは自動コミットモードです。自動コミットモードは、SQLを実行する毎にコミットされます。
21行目は、プレースホルダに値をセットしています。1つめの引数はプレースホルダの位置です。2つめの引数は値です。
24行目は、SQL処理が成功した場合で、commitメソッドを実行します。
26行目は、SQL処理で例外が発生した場合で、rollbackメソッドを実行します。
プレースホルダ
- SQL文中の(?)がプレースホルダです。動的に値をセットできます。
- 入力される不正な文字を抑止できるのでSQLインジェクション対策になります。
- 固定文字列のSQLの部分がプリコンパイルされるので実行速度が上がります。
- place=場所、holder=入れものです。
PreparedStatement
- PreparedStatementは、プリコンパイルされたSQL文を表すオブジェクトです。
- Prepared=準備された、Statement=文です。
- 以下はJava8 API仕様のPreparedStatementインターフェースのリンクです。https://docs.oracle.com/javase/jp/8/docs/api/java/sql/PreparedStatement.html
JDBCドライバを取得する
1.PostgreSQLのJDBC ドライバを取得します。
以下のPostgreSQLのサイトにアクセスします。
https://jdbc.postgresql.org/
2.JDBCの4.2バージョンのリンクをクリックするとダウンロードが始まります。
postgresql-42.2.5.jarを取得しました。任意の位置に配置します。
JDBCドライバをクラスパス(ビルドパス)に追加する
JDBCドライバ(postgresql-42.2.5.jar)をクラスパスに追加します。
クラスパスに追加する手順は、以下を参照願います。
Eclipse jarファイルをクラスパスに設定する方法
接続先のデータベースとテーブル
PostgreSQLのインストール方法と、データベースとテーブルを作成する方法は以下を参照願います。
PostgreSQLをインストールする手順(Windows)
PostgreSQL pgAdmin 4の使い方(起動からデータ参照)
関連の記事