一、數(shù)據(jù)庫連接池
數(shù)據(jù)庫連接池是一個容器焕梅,用于存儲多個連接對象伯诬,這樣java程序就不用向系統(tǒng)申請創(chuàng)建新的連接對象,提高了性能企软。
從連接池中獲取的Connection連接對象,使用close方法不是釋放掉饭望,而是返回連接池仗哨。
標準連接池接口:DataSource
方法:
- 獲取連接:getConnection()
- 歸還連接:Connection.close()形庭。
常用的連接池技術:
C3P0技術
Druid:阿里巴巴提供的苇倡。
C3P0的使用:
- 1富纸、導包 c3p0-0.9.5.2.jar、mchange-commons-java-0.2.12.jar
- 2旨椒、定義配置文件:
- 名稱: c3p0.properties 或者 c3p0-config.xml
- 路徑:直接將文件放在src目錄下即可晓褪。會自動讀取配置文件。
- 3综慎、創(chuàng)建連接池涣仿,獲取連接對象,歸還連接對象
public static void main(String[] args) {
Connection conn = null;
PreparedStatement psttm = null;
try {
DataSource ds = new ComboPooledDataSource();
conn = ds.getConnection();
String sql = "INSERT INTO USER VALUE (null,?,?)";
psttm = conn.prepareStatement(sql);
psttm.setString(1,"やちよ");
psttm.setString(2,"111");
int count = psttm.executeUpdate();
System.out.println(count);
} catch (SQLException e) {
e.printStackTrace();
}finally {
if (psttm != null){
try {
psttm.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn != null){
try {
conn.close(); //歸還到連接池
psttm.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
Druid的使用示惊,與C3P0不同好港,Druid需要自己寫讀配置文件的代碼
- 1.導包 druid-1.0.9.jar
- 2.寫配置文件
- 3.讀取配置文件,創(chuàng)建連接池對象米罚,獲取連接钧汹,歸還連接
我們這里也把這些步驟封裝成一個JDBCUtils工具類
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.io.IOException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
//封裝Druid的創(chuàng)建,獲取連接對象录择,釋放連接對象拔莱,以及配置文件的讀取的功能
public class JDBCUtils {
//讀取配置文件
static DataSource ds = null;
static {
try {
Properties prop = new Properties();
prop.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
ds = DruidDataSourceFactory.createDataSource(prop);
} catch (IOException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 獲取Druid連接池的連接對象
* @return
* @throws SQLException
*/
public static Connection getConnnection() throws SQLException {
return ds.getConnection();
}
/**
* 釋放資源
* @param conn
* @param sttm
* @param rs
*/
public static void close(Connection conn, Statement sttm, ResultSet rs){
if (rs != null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (sttm!=null){
try {
sttm.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn != null){
try {
conn.close(); //歸還連接
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* 釋放資源
* @param conn
* @param sttm
*/
public static void close(Connection conn, Statement sttm){
close(conn,sttm,null);
}
}
DruidDemo,看代碼變少了好多隘竭!
public class Demo {
public static void main(String[] args) {
Connection conn = null;
PreparedStatement psttm = null;
try {
conn = JDBCUtils.getConnnection();
String sql = "DELETE FROM USER WHERE uid = ?;";
psttm = conn.prepareStatement(sql);
psttm.setInt(1,2);
int count = psttm.executeUpdate();
System.out.println(count);
} catch (SQLException e) {
e.printStackTrace();
}finally {
JDBCUtils.close(conn,psttm);
}
}
}
但是查詢操作的結果處理也很麻煩塘秦,于是我們使用Spring JDBC來封裝查詢起來的結果。
Spring JDBC
Spring框架中提供了JDBCTemplate類來簡化JDBC的開發(fā)货裹。
JDBCTemplate的使用方法
- 1.導入jar包
- 2.創(chuàng)建jdbctemplate對象嗤形,構造方法的參數(shù)是DataSource對象
- 3.方法:
update():執(zhí)行DML語句。增弧圆、刪赋兵、改語句
-
queryForMap():查詢結果將結果集封裝為map集合,將列名作為key搔预,將值作為value 將這條記錄封裝為一個map集合
- 注意:這個方法查詢的結果集長度只能是1
-
queryForList():查詢結果將結果集封裝為list集合
- 注意:將每一條記錄封裝為一個Map集合霹期,再將Map集合裝載到List集合中
-
query():查詢結果,將結果封裝為JavaBean對象
- query的參數(shù):RowMapper
- 一般我們使用BeanPropertyRowMapper實現(xiàn)類拯田±欤可以完成數(shù)據(jù)到JavaBean的自動封裝
- new BeanPropertyRowMapper<類型>(類型.class)
queryForObject:查詢結果,將結果封裝為對象
* 一般用于聚合函數(shù)的查詢
使用實例:
import org.junit.Test;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import utils.JDBCUtils;
import java.util.List;
import java.util.Map;
import java.util.Set;
/**
* 需求:
1. 修改1號數(shù)據(jù)的 salary 為 10000
2. 添加一條記錄
3. 刪除剛才添加的記錄
4. 查詢id為1的記錄,將其封裝為Map集合
5. 查詢所有記錄吭产,將其封裝為List
6. 查詢所有記錄侣监,將其封裝為Emp對象的List集合
7. 查詢總記錄數(shù)
*/
public class TestDemo {
JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());
@Test// 1. 修改1號數(shù)據(jù)的 salary 為 10000
public void test1(){
String sql = "UPDATE person SET salary = ? WHERE id = ? ";
template.update(sql,1000,1);
}
@Test // 2. 添加一條記錄
public void test2(){
String sql = "INSERT INTO person VALUE (NULL,?,?)";
template.update(sql,"八千代",6000);
}
@Test // 3. 刪除記錄
public void test3(){
String sql = "DELETE FROM person WHERE id = ?";
template.update(sql,3);
}
@Test // 4. 查詢id為4的記錄,將其封裝為Map集合
public void test4(){
String sql = "SELECT * FROM person WHERE id = ?";
Map<String, Object> map = template.queryForMap(sql, 4);
System.out.println(map); //重寫了toString方法
}
// 5. 查詢所有記錄臣淤,將其封裝為List
@Test
public void test5(){
String sql = "SELECT * FROM person;";
List<Map<String, Object>> maps = template.queryForList(sql);
for (Map<String, Object> map : maps) {
System.out.println(map.toString());
}
}
@Test
// 6. 查詢所有記錄橄霉,將其封裝為Emp對象的List集合 ps:emp表在db1數(shù)據(jù)庫,記得改配置文件
public void test6(){
String sql = "SELECT * FROM emp";
List<EMP> emps = template.query(sql, new BeanPropertyRowMapper<EMP>(EMP.class));
for (EMP emp : emps) {
System.out.println(emp);
}
}
@Test
// 7. 查詢總記錄數(shù)
public void test7(){
String sql = "SELECT COUNT(id) FROM person";
Long total = template.queryForObject(sql, Long.class);
System.out.println("一共條"+total+"記錄");
}
}