Spring4（JDBC）

<!-- XML形式のBean定義ファイル -->

<?xml version="1.0" encoding="UTF-8"?>
<!-- スキーマの使用はbeansタグ内でスキーマを定義する必要がある -->
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:jdbc="http://www.springframework.org/schema/jdbc"
    xmlns:jee="http://www.springframework.org/schema/jee"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
		http://www.springframework.org/schema/beans/spring-beans.xsd
		http://www.springframework.org/schema/context
		http://www.springframework.org/schema/context/spring-context.xsd
		http://www.springframework.org/schema/jee
		http://www.springframework.org/schema/jee/spring-jee.xsd
		http://www.springframework.org/schema/jdbc
		http://www.springframework.org/schema/jdbc/spring-jdbc.xsd
		http://www.springframework.org/schema/tx
		http://www.springframework.org/schema/tx/spring-tx.xsd
		http://www.springframework.org/schema/aop
		http://www.springframework.org/schema/aop/spring-aop.xsd">


<!-- location属性にプロパティファイルのパスを指定する -->
	<context:property-placeholder location="application.properties"/>

<!-- DBCPのデータソース定義箇所 -->
	<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
        <property name="driverClassName" value="${jdbc.driverClassName}" />
        <property name="url" value="${jdbc.url}" />
        <property name="username" value="${jdbc.username}" />
        <property name="password" value="${jdbc.password}" />
	</bean>

<!-- XML形式のBean定義ファイルにおけるBean定義 -->
<!-- JdbcTemplateクラスのBean定義 -->
	<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
		<constructor-arg ref="dataSource"/>
	</bean>
<!-- NamedParameterJdbcTemplateクラスのBean定義 -->
	<bean class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate">
		<constructor-arg ref="dataSource"/>
	</bean>
</beans>

#データベースに接続するための必要な情報を記述したプロパティファイル

jdbc.driverClassName = com.mysql.cj.jdbc.Driver
jdbc.url = jdbc:mysql://localhost:3306/db_ex?useUnicode=true&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC
jdbc.username = root
jdbc.password = forStudy

//プレゼンテーション層パッケージ
package sample;

import java.sql.ResultSet;
import java.sql.SQLException;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.ResultSetExtractor;

import sample.springjdbc.bujiness.domain.Book;

//コントローラの代わとしてmain()メソッドを実行する
public class SampleRun {

	public static void main(String[] args) {
		//SpringコンテナをBean定義ファイルにより生成
		String classPath = "sample/config/spring-db.xml";
		ApplicationContext ctx = new ClassPathXmlApplicationContext(classPath);

		//JdbcTemplateオブジェクトを取得
		JdbcTemplate jdbcTemplate = ctx.getBean(JdbcTemplate.class);

		//SELECT文
		//queryForObjectメソッド
		String sql = "SELECT COUNT(*) FROM 商品一覧";
		int count = jdbcTemplate.queryForObject(sql, Integer.class);
		System.out.println("レコード数：" + count + "件"+ "¥n");

		//SELECT文
		//queryメソッド
		sql = "SELECT * FROM 商品一覧";
		Book book = jdbcTemplate.query(sql
				, new ResultSetExtractor<Book>() {
					public Book extractData(ResultSet rs) throws SQLException ,DataAccessException {
					if (!rs.next()) { return null; }
					Book book = new Book();
					while (rs.next()) {
						System.out.println("id ： " + rs.getInt("ID"));
						System.out.println("name ： " + rs.getString("NAME"));
						System.out.println("price ： " + rs.getInt("PRICE") + "¥n");
					}
					return book;
				 }}
				);


		// INSERT/UPDATE/DELETE 文
		//INSERT文
		book = new Book();
		book.setId(6);
		book.setBookName("123書籍");
		book.setPrice(2700);
		//INSERT文
		sql = "INSERT INTO 商品一覧 (ID , NAME , PRICE)"
					+ "VALUES(? , ? , ?)";
		jdbcTemplate.update(sql , book.getId() , book.getBookName() , book.getPrice());

		//UPDATE文
		sql = "UPDATE 商品一覧 SET PRICE = 9999 WHERE ID = ?";
		jdbcTemplate.update(sql , book.getId());

		System.out.println("INSERT/UPDATE後");
		sql = "SELECT * FROM 商品一覧";
		book = jdbcTemplate.query(sql
				, new ResultSetExtractor<Book>() {
					public Book extractData(ResultSet rs) throws SQLException ,DataAccessException {
					if (!rs.next()) { return null; }
					Book book = new Book();
					while (rs.next()) {
						System.out.println("id ： " + rs.getInt("ID"));
						System.out.println("name ： " + rs.getString("NAME"));
						System.out.println("price ： " + rs.getInt("PRICE") + "¥n");
					}
					return book;
				 }}
				);

		//DELETE文
		sql = "DELETE FROM 商品一覧 WHERE ID = 6";
		jdbcTemplate.update(sql);
	}
}

//ビジネスロジック層(ドメイン)パッケージ
package sample.springjdbc.bujiness.domain;

public class Book {
	private Integer id;
	private String bookName;
	private Integer price;

	public Integer getId() { return id; }
	public void setId(Integer id) { this.id = id; }

	public String getBookName() { return bookName; }
	public void setBookName(String bookName) { this.bookName = bookName; }

	public Integer getPrice() { return price; }
	public void setPrice(Integer price) { this.price = price; }
}