1. 程式人生 > >Java學習筆記43(Spring的jdbc模板)

Java學習筆記43(Spring的jdbc模板)

釋放 ack frame from 麻煩 exc tmg demo pack

在之前的學習中,我們執行sql語句,需要頻繁的開流,關流比較麻煩,為了更加的簡化代碼,我們使用Spring 的jdbc模板jdbcTemplate來簡化我們的代碼量;需要導入的包有:技術分享圖片

我們在之前的druid連接池的基礎上來使用該模板:

在這裏先介紹一個Spring 的Test類;我們可以用它來完成代碼的測試,不需要建立main方法來調用方法,直接測試;具體如下:

技術分享圖片註意:導入junit.Test包,輸入@Test報紅字,然後alt+enter鍵導入Jutil包;

可以發現在方法左邊有運行圖標,可以直接運行方法,不需要通過main方法;在jdbc模板中我們的不需要關其他的流,所以之前的連接池工具類我們需要做一下修改,添加一個獲得連接池對象的方法;

package JDBCUtils;

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;
/*Druid連接池工具類
*/ public class JDBCUtils { private static DataSource ds; // 靜態代碼塊獲取配置文件內容 static{ Properties p = new Properties(); InputStream in = JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"); try { p.load(in); ds = DruidDataSourceFactory.createDataSource(p); }
catch (Exception e) { e.printStackTrace(); } } // 創建獲得連接對象方法 public static Connection getConnection() throws SQLException { return ds.getConnection(); } // 創建關閉方法 關閉方法中的conn.close()是歸還連接對象給連接池,並不是釋放資源 public static void close(Connection conn, PreparedStatement pre){ if (pre!=null) { try { pre.close(); } catch (SQLException e) { e.printStackTrace(); } } if (conn!=null) { try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } // 重載關閉方法 public static void close(Connection conn, PreparedStatement pre, ResultSet rs) { if (rs != null) { try { rs.close(); } catch (SQLException e) { e.printStackTrace(); } } if (pre != null) { try { pre.close(); } catch (SQLException e) { e.printStackTrace(); } } if (conn != null) { try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } // 重載關閉方法 public static void close(Connection conn){ if (conn != null) { try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } // 創建獲得連接池方法 public static DataSource getDateSource(){ return ds; } }

jdbc模板使用:

package com.zs.JdbcTemplate;


import JDBCUtils.JDBCUtils;
import org.junit.Test;
import org.springframework.jdbc.core.JdbcTemplate;

import java.util.List;
import java.util.Map;

/*JdbcTemplate用法;*/
public class TemplateDemo {
    JdbcTemplate jt=new JdbcTemplate(JDBCUtils.getDateSource());
//    Junit單元測試可以讓方法獨立運行

//    插入數據方法
    @Test
    public void insert(){
        String sql="insert into login value(?,?,?);";
        int i = jt.update(sql, 3, "泰羅", "12345");
        System.out.println(i);
    }
//    修改數據方法
    @Test
    public void update(){
        String sql="update login set sname = ? where id = ? ;";
        int i = jt.update(sql, "賽文", 1);
        System.out.println(i);
    }
//    查詢方法
    @Test
    public void select(){
        String sql = "select * from login;";
//        執行查詢語句將結果放入集合中,默認每一個結果用map集合來保存,用列名來做鍵
        List<Map<String, Object>> maps = jt.queryForList(sql);
        for (Map<String, Object> map : maps) {
            System.out.println(map);
        }
    }
}

在之前我們將結果集封裝到對象中,結果賦值語句需要先rs.getObject(),再將結果通過set方法賦值給對象,比較繁瑣,在這裏也有講結果集賦值給對象的,我們先建對象類:

package com.zs.JdbcTemplate;

import java.util.Date;

public class Emp {
//    在創建對象的類中,為了防止賦值時出現數據不匹配的情況,盡量都使用引用類型,要註意與表數據類型一致
    private Integer id;
    private String ename;
    private Integer job_id;
    private Integer mgr;
    private Date joindate;
    private Double salary;
    private Double bonus;
    private Integer dept_id;

    public Integer getId() {
        return id;
    }

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

    public String getEname() {
        return ename;
    }

    public void setEname(String ename) {
        this.ename = ename;
    }

    public Integer getJob_id() {
        return job_id;
    }

    public void setJob_id(Integer job_id) {
        this.job_id = job_id;
    }

    public Integer getMgr() {
        return mgr;
    }

    public void setMgr(Integer mgr) {
        this.mgr = mgr;
    }

    public Date getJoindate() {
        return joindate;
    }

    public void setJoindate(Date joindate) {
        this.joindate = joindate;
    }

    public Double getSalary() {
        return salary;
    }

    public void setSalary(Double salary) {
        this.salary = salary;
    }

    public Double getBonus() {
        return bonus;
    }

    public void setBonus(Double bonus) {
        this.bonus = bonus;
    }

    public Integer getDept_id() {
        return dept_id;
    }

    public void setDept_id(Integer dept_id) {
        this.dept_id = dept_id;
    }

    @Override
    public String toString() {
        return "Emp{" +
                "id=" + id +
                ", ename=‘" + ename + ‘\‘‘ +
                ", job_id=" + job_id +
                ", mgr=" + mgr +
                ", joindate=" + joindate +
                ", salary=" + salary +
                ", bonus=" + bonus +
                ", dept_id=" + dept_id +
                ‘}‘;
    }
}

將查詢結果放入對象,再將對象放入集合:

package com.zs.JdbcTemplate;


import JDBCUtils.JDBCUtils;
import org.junit.Test;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;

import java.util.List;
import java.util.Map;

/*JdbcTemplate用法;*/
public class TemplateDemo {
    JdbcTemplate jt=new JdbcTemplate(JDBCUtils.getDateSource());//    將結果放入對象中,將對象放入集合中
    @Test
    public void select1(){
        String sql = "select * from emp;";
        List<Emp> rs = jt.query(sql, new BeanPropertyRowMapper<Emp>(Emp.class));
        for (Emp r : rs) {
            System.out.println(r);
        }
    }
}

可以發現,不僅代碼量少了,而且也不需要頻繁開關流了

Java學習筆記43(Spring的jdbc模板)