Springフレーム下のJDBC

Spring JDBC
    SpringはJDBC技術規範をさらにパッケージ化しました.Spring JDBCTemplate(jdbcテンプレート技術)とも言います.
     純粋なJDBC:コードがはっきりしていて、最高効率で、コードが一番煩わしいです.    Spring JDBCTemplate:コードは相対的にそんなにはっきりしなくて、効率は少し低くて、コードは比較的に簡単です.
    Springとjdbcの集合はどうやって行いますか?(データベースの接続池)        (1)jarパッケージの導入:spring-jdbc.jar  ドライブクラス  接続池DruidUtil 2(フレームの原型)        (2)配置類:@Configration        (3)@Spring IOC+JDBC実現            JdbcConfig:a.配置属性  b.DataSource Beanの配置        (4)JdbcTemplate Beanを配置する  @ビーン
1.pom.xmlに必要なjarカバン

     
    
    <dependency>
        <groupId>org.springframeworkgroupId>
        <artifactId>spring-jdbcartifactId>
        <version>${spring.version}version>
    dependency>

        
        <dependency>
            <groupId>mysqlgroupId>
            <artifactId>mysql-connector-javaartifactId>
            <version>5.1.48version>
        dependency>

        
        
        <dependency>
            <groupId>com.alibabagroupId>
            <artifactId>druidartifactId>
            <version>1.1.20version>
        dependency>

 
2.実体類:Acceount.java

public class Account {
    private int id;
    private String name;
    private Double balance;
    public Account( String name, Double balance) {
        super();
        this.name = name;
        this.balance = balance;
    }
    public Account(int id, String name, Double balance) {
        super();
        this.id = id;
        this.name = name;
        this.balance = balance;
    }
    public Account() {
        super();
    }
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public Double getBalance() {
        return balance;
    }
    public void setBalance(Double balance) {
        this.balance = balance;
    }
    @Override
    public int hashCode() {
        final int prime = 31;
        int result = 1;
        result = prime * result + ((balance == null) ? 0 : balance.hashCode());
        result = prime * result + id;
        result = prime * result + ((name == null) ? 0 : name.hashCode());
        return result;
    }
    @Override
    public boolean equals(Object obj) {
        if (this == obj)
            return true;
        if (obj == null)
            return false;
        if (getClass() != obj.getClass())
            return false;
        Account other = (Account) obj;
        if (balance == null) {
            if (other.balance != null)
                return false;
        } else if (!balance.equals(other.balance))
            return false;
        if (id != other.id)
            return false;
        if (name == null) {
            if (other.name != null)
                return false;
        } else if (!name.equals(other.name))
            return false;
        return true;
    }
    @Override
    public String toString() {
        return "Account [id=" + id + ", name=" + name + ", balance=" + balance + "]";
    }
    
    
}

 
3.インターフェース:IAcceount.java

import java.util.List;

/**
 * AccountDao  
 * @author   
 */
public interface IAccountDao {
    List findAll();
    void delete(Account act);
    void saveOrUpdate(Account act);
}

 
4.1インターフェース実現類(JDBC):Acceount DaoJdbcImpl.java

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import javax.sql.DataSource;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
//@Component
@Repository("accountDaoJdbcImpl") //--   、  /       
public class AccountDaoJdbcImpl implements IAccountDao {
    @Autowired
    private DataSource ds;
    
    @Override
    public List findAll() {
        try {
            Connection con = ds.getConnection();
            String sql = "select * from account";
            Statement stmt = con.createStatement();
            ResultSet rs = stmt.executeQuery(sql);
            List acts = new ArrayList<>();
            while(rs.next()) {
                Account act = new Account(rs.getInt(1),rs.getString(2),rs.getDouble(3));
                acts.add(act);
            }
            return acts;
            
        } catch (Exception e) {e.printStackTrace();}
        
        return null;
    }

    
    @Override
    public void delete(Account act) {
        // TODO Auto-generated method stub
        
    }

    @Override
    public void saveOrUpdate(Account act) {
        // TODO Auto-generated method stub
        
    }

}

 
4.2インターフェース実現類(Spring JDBCTempplte):AcceountDao TemplateImpl.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;

@Repository("accountDaoTemplateImpl")
public class AccountDaoTemplateImpl implements IAccountDao {
    @Autowired
    private JdbcTemplate jdbcTemplate;
    
    @Override
    public List findAll() {
        System.out.println("accountDaoTemplateImpl");
        return jdbcTemplate.query(
                "select * from account",
                new BeanPropertyRowMapper(Account.class)
                );
    }
    
    @Override
    public void saveOrUpdate(Account act) {
        
        if(act.getId()==0) {
            jdbcTemplate.update(
                    "insert into account(name,balance) values(?,?)",
                    new Object[] {act.getName(),act.getBalance()}
                    );
        }else {
            jdbcTemplate.update(
                    "update account set name=?,balance=? where id=?",
                    new Object[] {act.getName(),act.getBalance(),act.getId()}
                    );
        }
        
    }

    @Override
    public void delete(Account act) {
        jdbcTemplate.update(
                "delete from account where id=?",
                new Object[] {act.getId()}
                );
    }
    
}

 
5.1 JDBC配置資源:jdbc.properties

jdbc.driverClass=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/demo
jdbc.username=root
jdbc.password=root

pool.maxActive=10

 
5.2 JDBC配置類:JdbcConfig.java

import javax.sql.DataSource;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.jdbc.core.JdbcTemplate;

import com.alibaba.druid.pool.DruidDataSource;

/**
 * JdbcConfig 
 * @author   
 *
 */
@Configuration
@PropertySource("classpath:jdbc.properties") 
                //--         
public class JdbcConfig {
    //-- 1.       
    @Value("${jdbc.driverClass}")
    private String driver;
    @Value("${jdbc.url}")
    private String url;
    @Value("${jdbc.username}")
    private String username;
    @Value("${jdbc.password}")
    private String password;
    
    @Value("${pool.maxActive}")
    private int maxActive;
    
    //-- 2.         
    @Bean(name="dataSource")
    public DataSource createDataSource() {
        DruidDataSource ds = new DruidDataSource();    
        ds.setDriverClassName(driver);
        ds.setUrl(url);
        ds.setUsername(username);
        ds.setPassword(password);
        ds.setMaxActive(maxActive);
        
        return ds;
    }
    
    //-- 3.   JdbcTemplate
    @Bean(name="jdbcTemplate")
    public JdbcTemplate createJdbcTemplate(DataSource ds) {
        return new JdbcTemplate(ds);//--        JdbcTemplate
    }
    
}

 
6.Spring配置類:SpringConfig.java

/**
 * Spring    
 *         
 */
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;

@Configuration
@ComponentScan("day")//--    
@Import(JdbcConfig.class)  //--           
public class SpringConfig {

}

 
7.メイン関数の入り口:Invoker.java

import javax.sql.DataSource;

import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

public class Invoker {
    public static void main(String[] args) {
        ApplicationContext ctx=
                new AnnotationConfigApplicationContext(SpringConfig.class);
        DataSource ds = (DataSource)ctx.getBean("dataSource");
        System.out.println(ds);
    }
}

 
8.テストクラス:TestAcceountDao.java

import java.util.List;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;


@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(classes= {SpringConfig.class})
public class TestAccountDao {
    @Autowired
    @Qualifier("accountDaoTemplateImpl")//--             
    private IAccountDao actDao;
    
    @Test
    public void testFind() {
        List acts = actDao.findAll();
        for (Account account : acts) {
            System.out.println(account);
        }
    }
    
    @Test
    public void testSave() {
        actDao.saveOrUpdate(new Account("xx",12.0));    
    }
    
    @Test
    public void testUpdate() {
        actDao.saveOrUpdate(new Account(8,"xx",22.0));    
    }
    
    @Test
    public void testDelete() {
        actDao.delete(new Account(8,"xx",22.0));    
    }
    
}