spring中的JdbcTemplate如何使用？

時間 2021-01-09

標籤 java spring sql 數據庫 apache app ide 工具翻譯欄目 Spring 简体版

原文原文鏈接

前言

JdbcTemplate前世此生，好久好久之前，當咱們剛剛要踏入程序猿的行列，仍是一隻菜鳥的時候，咱們天真的覺得踏踏實實才是真。因此，咱們堅守着最初的誓言，每次在作持久層技術選型的時候，咱們老是選擇最原始的JDBC，快樂的coding。

直到有一天，Java界的武林盟主-Spring，爲了進一步鞏固本身在Java開發領域的地位，無情的搶走了它，隨即對它作了一系列的封裝改造，今後咱們再也見不到它了，可是總能依稀感受到它的存在，今後就誕生了JdbcTemplate，這就是JdbcTemplate的由來。

Spring官方有一句很是經典的宣言"Don't Reinvent theWheel"，翻譯過來就是"不要重複發明輪子"。java

因此咱們能夠看到不少Spring出品的技術都是在原有的技術基礎之上進一步封裝、重構、改造，也所以成就了Spring這樣一個偉大的技術生態，在Java開發領域作出了很是大的貢獻。JdbcTemplate的存在無疑也是最好的見證。spring

Tips:凡是咱們看到xxxTemplate的類，都是Spring對xxx的封裝的模板類。sql

什麼是JdbcTemplate

咱們都知道使用原始的JDBC在操做數據庫是比較麻煩的，因此Spring爲了提升開發的效率，順帶着就把JDBC封裝、改造了一番，而JdbcTemplate就是Spring對原始JDBC封裝以後提供的一個操做數據庫的工具類。數據庫

咱們能夠藉助JdbcTemplate來完成全部數據庫操做，好比：增刪改查等。改造以後的JdbcTemplate主要提供如下三種類型的方法apache

executeXxx() : 執行任何SQL語句，對數據庫、表進行新建、修改、刪除操做
updateXxx() : 執行新增、修改、刪除等語句
queryXxx() : 執行查詢相關的語句

JdbcTemplate配置鏈接池

org.springframework.jdbc.core.JdbcTemplate類方便執行SQL語句app

public JdbcTemplate(DataSource dataSource)
建立JdbcTemplate對象，方便執行SQL語句

public void execute(final String sql)
execute能夠執行全部SQL語句，由於沒有返回值，通常用於執行DDL語句。

JdbcTemplate使用步驟

準備DruidDataSource鏈接池
導入依賴的jar包
- spring-beans-4.1.2.RELEASE.jar
- spring-core-4.1.2.RELEASE.jar
- spring-jdbc-4.1.2.RELEASE.jar
- spring-tx-4.1.2.RELEASE.jar
- com.springsource.org.apache.commons.logging-1.1.1.jar
建立JdbcTemplate對象，傳入Druid鏈接池
調用execute、update、queryXxx等方法

案例代碼

public class Demo04 {
    public static void main(String[] args) {
        // 建立表的SQL語句
        String sql = "CREATE TABLE product("
                + "pid INT PRIMARY KEY AUTO_INCREMENT,"
                + "pname VARCHAR(20),"
                + "price DOUBLE"
                + ");";

        JdbcTemplate jdbcTemplate = new JdbcTemplate(DataSourceUtils.getDataSource());
        jdbcTemplate.execute(sql);
    }
}

JdbcTemplate實現增刪改

API介紹

org.springframework.jdbc.core.JdbcTemplate類方便執行SQL語句ide

public int update(final String sql)
用於執行`INSERT`、`UPDATE`、`DELETE`等DML語句。

使用步驟

1.建立JdbcTemplate對象
2.編寫SQL語句
3.使用JdbcTemplate對象的update方法進行增刪改工具

案例代碼

public class Demo05 {
    public static void main(String[] args) throws Exception {
//      test01();
//      test02();
//      test03();
    }

    // JDBCTemplate添加數據
    public static void test01() throws Exception {
        JdbcTemplate jdbcTemplate = new JdbcTemplate(DataSourceUtils.getDataSource());

        String sql = "INSERT INTO product VALUES (NULL, ?, ?);";

        jdbcTemplate.update(sql, "iPhone3GS", 3333);
        jdbcTemplate.update(sql, "iPhone4", 5000);
        jdbcTemplate.update(sql, "iPhone4S", 5001);
        jdbcTemplate.update(sql, "iPhone5", 5555);
        jdbcTemplate.update(sql, "iPhone5C", 3888);
        jdbcTemplate.update(sql, "iPhone5S", 5666);
        jdbcTemplate.update(sql, "iPhone6", 6666);
        jdbcTemplate.update(sql, "iPhone6S", 7000);
        jdbcTemplate.update(sql, "iPhone6SP", 7777);
        jdbcTemplate.update(sql, "iPhoneX", 8888);
    }

    // JDBCTemplate修改數據
    public static void test02() throws Exception {
        JdbcTemplate jdbcTemplate = new JdbcTemplate(DataSourceUtils.getDataSource());

        String sql = "UPDATE product SET pname=?, price=? WHERE pid=?;";

        int i = jdbcTemplate.update(sql, "XVIII", 18888, 10);
        System.out.println("影響的行數: " + i);
    }

    // JDBCTemplate刪除數據
    public static void test03() throws Exception {
        JdbcTemplate jdbcTemplate = new JdbcTemplate(DataSourceUtils.getDataSource());
        String sql = "DELETE FROM product WHERE pid=?;";
        int i = jdbcTemplate.update(sql, 7);
        System.out.println("影響的行數: " + i);
    }
}

JdbcTemplate查詢-queryForInt返回一個int整數

org.springframework.jdbc.core.JdbcTemplate類方便執行SQL語句ui

API介紹

public int queryForInt(String sql)
執行查詢語句，返回一個int類型的值。

使用步驟

建立JdbcTemplate對象
編寫查詢的SQL語句
使用JdbcTemplate對象的queryForInt方法
輸出結果

案例代碼

// queryForInt返回一個整數
public static void test01() throws Exception {
   // String sql = "SELECT COUNT(*) FROM product;";
   String sql = "SELECT pid FROM product WHERE price=18888;";
   JdbcTemplate jdbcTemplate = new JdbcTemplate(DataSourceUtils.getDataSource());
   int forInt = jdbcTemplate.queryForInt(sql);
   System.out.println(forInt);
}

JdbcTemplate查詢-queryForLong返回一個long整數

講解

org.springframework.jdbc.core.JdbcTemplate類方便執行SQL語句翻譯

API介紹

public long queryForLong(String sql)
執行查詢語句，返回一個long類型的數據。

使用步驟

建立JdbcTemplate對象
編寫查詢的SQL語句
使用JdbcTemplate對象的queryForLong方法
輸出結果

案例代碼

// queryForLong  返回一個long類型整數
public static void test02() throws Exception {
   String sql = "SELECT COUNT(*) FROM product;";
   // String sql = "SELECT pid FROM product WHERE price=18888;";
   JdbcTemplate jdbcTemplate = new JdbcTemplate(DataSourceUtils.getDataSource());
   long forLong = jdbcTemplate.queryForLong(sql);
   System.out.println(forLong);
}

JdbcTemplate查詢-queryForObject返回String

講解

org.springframework.jdbc.core.JdbcTemplate類方便執行SQL語句

API介紹

public <T> T queryForObject(String sql, Class<T> requiredType)
執行查詢語句，返回一個指定類型的數據。

使用步驟

建立JdbcTemplate對象
編寫查詢的SQL語句
使用JdbcTemplate對象的queryForObject方法，並傳入須要返回的數據的類型
輸出結果

案例代碼

public static void test03() throws Exception {
   String sql = "SELECT pname FROM product WHERE price=7777;";
   JdbcTemplate jdbcTemplate = new JdbcTemplate(DataSourceUtils.getDataSource());
   String str = jdbcTemplate.queryForObject(sql, String.class);
   System.out.println(str);
}

JdbcTemplate查詢-queryForMap返回一個Map集合

API介紹

public Map<String, Object> queryForMap(String sql)
執行查詢語句，將一條記錄放到一個Map中。

使用步驟

建立JdbcTemplate對象
編寫查詢的SQL語句
使用JdbcTemplate對象的queryForMap方法
處理結果

public static void test04() throws Exception {
   String sql = "SELECT * FROM product WHERE pid=?;";
   JdbcTemplate jdbcTemplate = new JdbcTemplate(DataSourceUtils.getDataSource());
   Map<String, Object> map = jdbcTemplate.queryForMap(sql, 6);
   System.out.println(map);
}

JdbcTemplate查詢-queryForList返回一個List集合

目標

可以掌握JdbcTemplate中queryForList方法的使用

講解

org.springframework.jdbc.core.JdbcTemplate類方便執行SQL語句

API介紹

public List<Map<String, Object>> queryForList(String sql)
執行查詢語句，返回一個List集合，List中存放的是Map類型的數據。

使用步驟

建立JdbcTemplate對象
編寫查詢的SQL語句
使用JdbcTemplate對象的queryForList方法
處理結果

public static void test05() throws Exception {
   String sql = "SELECT * FROM product WHERE pid<?;";
   JdbcTemplate jdbcTemplate = new JdbcTemplate(DataSourceUtils.getDataSource());
   List<Map<String, Object>> list = jdbcTemplate.queryForList(sql, 8);
   for (Map<String, Object> map : list) {
      System.out.println(map);
   }
}

queryForList方法的做用？將返回的一條記錄保存在Map集合中，多條記錄對應多個Map，多個Map存儲到List集合中

JdbcTemplate查詢-RowMapper返回自定義對象

org.springframework.jdbc.core.JdbcTemplate類方便執行SQL語句

API介紹

public <T> List<T> query(String sql, RowMapper<T> rowMapper)
執行查詢語句，返回一個List集合，List中存放的是RowMapper指定類型的數據。

使用步驟

定義Product類
建立JdbcTemplate對象
編寫查詢的SQL語句
使用JdbcTemplate對象的query方法，並傳入RowMapper匿名內部類
在匿名內部類中將結果集中的一行記錄轉成一個Product對象

案例代碼

// query使用rowMap作映射返回一個對象
public static void test06() throws Exception {
    JdbcTemplate jdbcTemplate = new JdbcTemplate(DataSourceUtils.getDataSource());

   // 查詢數據的SQL語句
   String sql = "SELECT * FROM product;";

   List<Product> query = jdbcTemplate.query(sql, new RowMapper<Product>() {
      @Override
      public Product mapRow(ResultSet arg0, int arg1) throws SQLException {
         Product p = new Product();
         p.setPid(arg0.getInt("pid"));
         p.setPname(arg0.getString("pname"));
         p.setPrice(arg0.getDouble("price"));
         return p;
      }
   });

   for (Product product : query) {
      System.out.println(product);
   }
}

使用JdbcTemplate對象的query方法，並傳入RowMapper匿名內部類
在匿名內部類中將結果集中的一行記錄轉成一個Product對象

JdbcTemplate查詢-BeanPropertyRowMapper返回自定義對象

org.springframework.jdbc.core.JdbcTemplate類方便執行SQL語句

API介紹

public <T> List<T> query(String sql, RowMapper<T> rowMapper)
執行查詢語句，返回一個List集合，List中存放的是RowMapper指定類型的數據。
public class BeanPropertyRowMapper<T> implements RowMapper<T>
BeanPropertyRowMapper類實現了RowMapper接口

使用步驟

定義Product類
建立JdbcTemplate對象
編寫查詢的SQL語句
使用JdbcTemplate對象的query方法，並傳入BeanPropertyRowMapper對象

// query使用BeanPropertyRowMapper作映射返回對象
public static void test07() throws Exception {
    JdbcTemplate jdbcTemplate = new JdbcTemplate(DataSourceUtils.getDataSource());

    // 查詢數據的SQL語句
    String sql = "SELECT * FROM product;";
    List<Product> list = jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(Product.class));

    for (Product product : list) {
        System.out.println(product);
    }
}