Spring的數據庫開發

時間 2019-11-24

標籤 spring 數據庫開發欄目 Spring 简体版

原文原文鏈接

spring的jdbcTemplate操做（用在dao層）

spring框架是一個一站式框架，在每一層都提供瞭解決技術：在Dao層是使用了jdbcTemplate。mysql

spring針對不一樣的持久化技術都提供了不一樣的模板。程序員

Spring JDBC

　　Spring的JDBC模板負責提供數據庫資源的管理和錯誤處理，大大簡化了開發人員對數據庫操做，使得開發人員能夠從繁瑣的數據庫操做中解脫出來。spring

Spring jdbcTemplate的解析

　　針對數據庫的操做，Spring框架提供了jdbcTemplate類，該類是Spring框架數據層的基礎，其餘更高層次的抽象類是構建在JdbcTemplate類之上，能夠說，JdbcTemplate是Spring JDBC的核心類。sql

　　JdbcTemplata類的繼承關係十分簡單，它繼承了JdbcAccessor抽象類，同時實現了JdbcOperations接口。數據庫

　　JdbcAccessor的設計中，對DataSource數據源進行了管理和配置，JdbcOperation接口定義中，定義了經過JDBC操做數據庫的基本方法，而核心類JdbcTemplate提供了這些接口方法的實現。數組

Spring JDBC的配置

　　Spring JDBC模板主要是有四個包組成，分別是core(核心包)，dataSource（數據源包），object(對象包)，support(支持包),Spring對數據庫的操做都封裝在了這幾個包中，而想要使用JDBC，就須要對其進行配置，在Spring中，JDBC的配置是在Spring的配置文件applicationContext.xml中完成的，其配置模板以下所示。app

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd">


     <!-- 配置數據源 -->
     <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
         <!-- 數據庫驅動 -->
         <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
         <!-- 鏈接數據庫的Url -->
         <property name="url" value="jdbc:mysql://localhost:3306/數據庫名"/>
         <!-- 鏈接數據庫的用戶名 -->
         <property name="username" value="root"/>
         <!-- 鏈接數據庫的用戶名 -->
         <property name="password" value="abc"/>
     </bean>
     
     <!-- 配置JDBC模板 -->
     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
         <!-- 默認使用數據源 -->
         <property name="dataSource" ref="dataSource"/>
     </bean>
     
     <!-- 配置注入類 -->
     <bean id="" >
         <property name="jdbcTemplate" ref="jdbcTemplate"/>
     </bean>
     
 </beans>

　　dataSource的四個屬性：框架

屬性名	含義
driverClassName	所使用的驅動名稱，對應驅動JAR包中的Driver類
urlide	數據源所在的地址
username	訪問數據庫的用戶名
password	訪問數據庫的密碼

Spring JdbcTemplate的經常使用方法

1.execute()：execute(String sql)方法可以完成執行SQL語句的功能，單元測試

　　先建立數據庫spring

　　再在配置文件中配置jdbcTemplate

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
     http://www.springframework.org/schema/beans/spring-beans-4.3.xsd">
     <!-- 配置數據源 -->
     <bean id="dataSource" 
         class="org.springframework.jdbc.datasource.DriverManagerDataSource">
         <!-- 數據庫驅動 -->
         <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
         <!-- 鏈接數據庫的Url -->
         <property name="url" value="jdbc:mysql://localhost:3306/spring"/>
         <!-- 鏈接數據庫的用戶名 -->
         <property name="username" value="root"/>
         <!-- 鏈接數據庫的用戶名 -->
         <property name="password" value="abc"/>
     </bean>
     
     <!-- 配置JDBC模板 -->
     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
         <!-- 默認使用數據源 -->
         <property name="dataSource" ref="dataSource"/>
     </bean>
</beans>

　　在建立一個類用來測試是否成功

package com.itheima.jdbc;

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

/**
 * 使用execute()方法
 * @author 12428
 *
 */
public class JdbcTemplateTest {
    public static void main(String[] args) {
        //獲取配置文件
        ApplicationContext applicationContext=
                new ClassPathXmlApplicationContext("applicationContext.xml");
        //獲取JdbcTemplate模板
        JdbcTemplate jdbcTemplate=(JdbcTemplate) applicationContext.getBean("jdbcTemplate");
        //使用execute()方法執行SQL語句，建立用戶帳號管理表account
        jdbcTemplate.execute("create table account("+
                                "id int primary key auto_increment,"+
                                "username varchar(50),"+
                                "balance double)");
        System.out.println("帳戶表account建立成功！");
    }
}

　　測試結果

2.update():update()能完成插入，更新，刪除數據的操做。

　　（1）建立一個類Account類用來對應數據庫spring中的表account，以下：

package com.itheima.jdbc;
/**
 * 帳戶類：用來與數據庫spring的表account對應
 * @author 12428
 *
 */
public class Account {
    private Integer id; //帳戶Id
    private String username; //用戶名
    private Double balance; //用戶餘額
    public Integer getId() {
        return id;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public String getUsername() {
        return username;
    }
    public void setUsername(String username) {
        this.username = username;
    }
    public Double getBalance() {
        return balance;
    }
    public void setBalance(Double balance) {
        this.balance = balance;
    }
    @Override
    public String toString() {
        return "Account [id=" + id + ", username=" + username + ", balance=" + balance + "]";
    }        
}

　　（2）建立一個接口類AccountDao，接口中含有幾個抽象方法，以下：

package com.itheima.jdbc;

public interface AccountDao {
    
    //添加
    public int addAccount(Account account);
    
    //更新
    public int updateAccount(Account account);
    
    //刪除
    public int deleteAccount(int id);
}

　　（3）建立一個類AccountDaoImpl，該類實現了AccountDao接口,以下：

package com.itheima.jdbc;

import org.springframework.jdbc.core.JdbcTemplate;

public class AccountDaoImpl implements AccountDao {

    // 聲明JdbcTemplate屬性及其setter方法，使用setter注入屬性
    private JdbcTemplate jdbcTemplate;

    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    /**
     * 添加帳戶 返回一個修改的行數
     */
    @Override
    public int addAccount(Account account) {
        // 定義sql語句
        String sql = "insert into account(username,balance) value(?,?)";
        // 定義數組來存儲sql語句中的參數
        Object[] objects = new Object[] { account.getUsername(), account.getBalance() };
        // 執行添加操做，返回的是受SQL影響的記錄數
        int num = this.jdbcTemplate.update(sql, objects);
        return num;
    }

    /**
     * 更新帳戶
     */
    @Override
    public int updateAccount(Account account) {
        // 定義SQL
        String sql = "update account set username=?,balance=? where id=?";
        // 定義數組來存儲sql語句中的參數
        Object[] objects = new Object[] { account.getUsername(), account.getBalance(), account.getId() };
        // 執行更新操做，返回的是受SQL語句影響的記錄條數
        int num = this.jdbcTemplate.update(sql, objects);
        return num;
    }

    /**
     * 刪除用戶
     */
    @Override
    public int deleteAccount(int id) {
        // 定義sql
        String sql = "delete from account where id=?";
        // 執行刪除操做，返回的是受sql語句影響的記錄條數
        int num = this.jdbcTemplate.update(sql, id);
        return num;
    }
}

　　（4）設置配置文件applicationContext.xml,以下

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
     http://www.springframework.org/schema/beans/spring-beans-4.3.xsd">
     <!-- 配置數據源 -->
     <bean id="dataSource" 
         class="org.springframework.jdbc.datasource.DriverManagerDataSource">
         <!-- 數據庫驅動 -->
         <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
         <!-- 鏈接數據庫的Url -->
         <property name="url" value="jdbc:mysql://localhost:3306/spring"/>
         <!-- 鏈接數據庫的用戶名 -->
         <property name="username" value="root"/>
         <!-- 鏈接數據庫的用戶名 -->
         <property name="password" value="abc"/>
     </bean>
     
     <!-- 配置JDBC模板 -->
     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
         <!-- 默認使用數據源 -->
         <property name="dataSource" ref="dataSource"/>
     </bean>
     
     <!-- 配置一個AccountDao的Bean，把jdbcTemplate注入到accountDao裏面 -->
     <bean id="accountDao" class="com.itheima.jdbc.AccountDaoImpl">
         <property name="jdbcTemplate" ref="jdbcTemplate"/>
     </bean>
</beans>

　　（5）建立一個測試類JdbcTemplateTest，使用單元測試，以下：

package com.itheima.jdbc;

import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;

public class JdbcTemplateTest {
    /*
     * public static void main(String[] args) { //獲取配置文件 ApplicationContext
     * applicationContext= new
     * ClassPathXmlApplicationContext("applicationContext.xml"); //獲取JdbcTemplate模板
     * JdbcTemplate jdbcTemplate=(JdbcTemplate)
     * applicationContext.getBean("jdbcTemplate");
     * //使用execute()方法執行SQL語句，建立用戶帳號管理表account
     * jdbcTemplate.execute("create table account("+
     * "id int primary key auto_increment,"+ "username varchar(50),"+
     * "balance double)"); System.out.println("帳戶表account建立成功！"); }
     */

    /**
     * 添加一個用戶
     */
    @Test
    public void addAccount() {
        // 加載配置文件
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
        // 獲取bean
        AccountDao accountDao = (AccountDao) applicationContext.getBean("accountDao");

        // 建立一個用戶
        Account account = new Account();
        account.setUsername("張三");
        account.setBalance(2000.0);
        // 調用方法
        int num = accountDao.addAccount(account);
        // 返回一個結果
        if (num > 0) {
            System.out.println("你已成功添加了" + num + "條數據");
        } else {
            System.out.println("添加數據失敗！");
        }
    }

    /**
     * 更新一個用戶
     */
    @Test
    public void updateAccount() {
        // 加載配置文件
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
        // 獲取bean
        AccountDao accountDao = (AccountDao) applicationContext.getBean("accountDao");

        // 建立一個用戶
        Account account = new Account();
        account.setId(1);
        account.setUsername("李四");
        account.setBalance(2000.0);

        // 執行更新方法
        int num = accountDao.updateAccount(account);

        // 返回一個結果
        if (num > 0) {
            System.out.println("你已成功修改了" + num + "條數據");
        } else {
            System.out.println("添加數據失敗！");
        }
    }

    /**
     * 刪除一個用戶
     */
    @Test
    public void deleteAccount() {
        // 加載配置文件
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
        // 獲取bean
        AccountDao accountDao = (AccountDao) applicationContext.getBean("accountDao");

        // 執行刪除方法
        int num = accountDao.deleteAccount(1);

        // 輸出結果
        if (num > 0) {
            System.out.println("你成功刪除了" + num + "條數據");
        } else {
            System.out.println("刪除數據失敗！");
        }
    }
}

　　(6)運行添加方法的結果以下：

　　（7）運行了更新方法的結果以下：

　　（8）運行了刪除方法後的結果以下：

3.query()：query()方法能夠執行查詢操做

　　jdbcTemplate中提供了大量的查詢方法，以下是幾個經常使用的查詢方法：

方法名	說明
List query(String sql,RowMapper rowMapper)	執行string類型參數提供的的sql語句，並經過RowMapper返回一個List類型的結果
List query(String sql,PreparedStatementSetter pss,RowMapper rowMapper)	根據String類型的參數提供的Sql語句建立的PreparedStatements對象經過RowMapper將結果返回到List中。
List query(String sql,Object[] args,RowMapper rowMapper)	使用Object[]的值來設置sql語句中的參數值，採用RowMapper回調方法直接返回List類型的數據
queryForObject(String sql,RowMapper rowMapper,Object...args)	將args參數綁定到SQL語句中，並經過RowMapper返回一個Object類型的單行記錄
queryForList（String sql，Object[] args,class<T> elementType）	該方法能夠返回多行數據的結果，但必須是返回列表，elementsType參數返回的是List元素類型

　（1）先給數據庫中添加幾條數據，以下：

　（2）在AccountDao接口中添加兩個查詢方法：

　　//經過id查詢
    public Account queryAccountById(int id);
    
    //查詢全部的用戶
    public List<Account> queryAllAcount();

（3）在AccounDaoImpl中實現兩個查詢方法

/**
     * 根據id來查詢帳戶
     */
    @Override
    public Account queryAccountById(int id) {
        //聲明sql語句
        String sql="select * from account where id=?";
        
        //建立一個新的BeanPropertyRowMapper對象,返回一個須要返回的對象類型，不用再手動轉換類型
        RowMapper<Account> rowMapper=new BeanPropertyRowMapper<Account>(Account.class);
        //執行查詢語句
        return this.jdbcTemplate.queryForObject(sql, rowMapper, id);
        
    }

    /**
     * 查詢全部的帳戶
     */
    @Override
    public List<Account> queryAllAcount() {
        
        //聲明sql語句
        String sql="select * from account";
        
        //建立一個新的BeanPropertyRowMapper對象,返回一個須要返回的對象類型，不用再
        //手動轉換類型
        RowMapper<Account> rowMapper=new BeanPropertyRowMapper<Account>(Account.class);
        
        //執行方法
        return this.jdbcTemplate.query(sql, rowMapper);
    }

（4）在jdbcTemplateTest中添加兩個測試方法，以下：

/**
     * 根據id來查詢用戶
     */
    @Test
    public void queryAccountById() {
        // 加載配置文件
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
        // 獲取bean
        AccountDao accountDao = (AccountDao) applicationContext.getBean("accountDao");
        
        //執行方法
        Account account=accountDao.queryAccountById(1);
    
        System.out.println(account);
    }
    
    /**
     * 查詢全部的帳戶
     */
    @Test
    public void queryAllAccount() {
        //獲取容器對象
        ApplicationContext applicationContext=new ClassPathXmlApplicationContext("applicationContext.xml");
        //獲取對象AccountDao
        AccountDao accountDao=(AccountDao) applicationContext.getBean("accountDao");
        
        //執行方法
        List<Account> accounts=accountDao.queryAllAcount();
        //輸出結果
        for(Account account:accounts) {
            System.out.println(account);}
        }

（5）執行第一個查詢方法：根據Id來進行查詢，結果以下：

（6）執行第二個插敘方法：查詢全部的帳戶，結果以下：

注意：在執行jdbcTemplate查詢操做時，若是查詢的結果爲空，則會拋出一個錯誤emptyResultDataAccessException異常，這樣作的目的是爲了防止程序員不對空值進行判斷，保證了查程序的健壯性，若是想要查詢結果爲空時返回一個null而不是異常，則能夠在jdbcTemplate返回查詢結果的時候捕獲異常，然爾返回null,例：

　　try{

　　　　Object obj=jdbcTemplate.queryForObject();

}catch(EmptyResultDataAccessException e){

　　return null;

　　}