[Spring Boot]Spring Data JDBCでDBにアクセスする

SpringDataJDBCでDBにアクセスする

Spring BootでMySQLの操作を行います。データベースアクセスには Spring Data JPA と Spring Data JDBC の2つあるようですが、SQLを書く練習をしたいのでJDBCを使っていきます。
今回はXAMPPのMySQLのデータベース（test）のテーブル（item）にしてみます。

---

1. Springで Spring Data JDBCを使うポイント

大事なポイントは以下の3点のみです。

• Spring Starterプロジェクトで 「Spring Data JDBC」 と 「MySQL Driver」 を追加する
• DB接続情報は src/main/resource/application.propeties に追加する
• JdbcTempalteのメソッドを実行する

---

2. DB接続情報を設定する

DB接続情報を src/main/resource/application.propeties に追加します。他にも方法があるようですが最も簡単な方法で実現します。

[src/main/resource/application.propeties]

spring.datasource.url=jdbc:mysql://127.0.0.1:3306/test
spring.datasource.username=（ユーザー名）
spring.datasource.password=（パスワード）
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

---

3. JdbcTemplateのメソッド

色々なメソッドがありますが、このメソッドを抑えておけば大丈夫そうです。

やりたいこと	メソッド
SELECT	query、queryForList、queryForObject
INSERT	update
UPDATE	update
DELETE	update

3.1. Queryの書き方（SELECT文）

【JdbcTemplate】Queryの書き方（SELECT文） を参考にします。

SELECTの方法は 3通り あります。

• BeanPropertyRowMapper
• RowMapper
• Map

Mapを使えば複雑なSQLを実行して結果を取得できそうです。
@lombok.Data アノテーションを付けたBeanなら BeanPropertyRowMapper を使う方法が簡単です。今回は、 BeanPropertyRowMapper + query メソッド を使ってSELECT文を作成します。

Item.java

@lombok.Data
public class Item {
	private Integer id;
	private String name;
}

ItemDao.java

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

//DBアクセスのコンポーネントには @Respository を付ける
@Repository
public class ItemDao {

  //@Autowiredを使ってインスタンスを注入すうｒ
	@Autowired
	private JdbcTemplate jdbcTemplate;

  //全件取得する場合は、queryか queryForList メソッドを利用します。
  public List<Item> selectAll() {
    //全件取得のSQLを作成
    String sql = "select * from item;";
    //SQLを実行
    return jdbcTemplate.query(sql, new BeanPropertyRowMapper<Item>(Item.class));
  }

  //1件だけ取得したい場合は queryForObject メソッドを利用します。
  public Item selectOne(Integer id) {
    //PKを使って1件のみ取得
    String sql = "select * from item where id=?;";
    //SQLを実行
    return jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<Item>(Item.class), id);
  }

	//DBを更新したい場合は update メソッドを利用します。
  public int insertOne(Item item) {

		//1件を新規追加するSQLを作成
    String sql = "insert into item (id, name) values (?, ?);";
		//SQLを実行
		return jdbcTemplate.update(sql, item.getId(), item.getName());
	}

	//DBを更新したい場合は update メソッドを利用します。
	public int updateOne(Item item) {
		//PKを使って1件のみ更新
		String sql = "update item set name=? where id=?;";
		//SQLを実行する
		return jdbcTemplate.update(sql, item.getName(), item.getId());
	}

	//DBを削除したい場合は update メソッドを利用します。
	public int deleteOne(Integer id) {
		//PKを使って1件のみ削除
		String sql = "delete from item where id=?;";
		//SQLを実行する
		return jdbcTemplate.update(sql, id);
	}