在項目中，我們要不斷的和資料庫打交道，為了提高資料庫操作的執行效率和增加代碼的複用性，将重新封裝一個Dao層，也就是資料通路層 ，用來通路資料庫實作資料的持久化。
雖然現在有不少資料持久化層的架構，但其配置檔案還是比較麻煩的。
Dao層設計
Dao層操作通用的步驟：
- 1.寫SQL語句
- 2.擷取連接配接
- 3.建立stmt
- 4.執行sql
a)更新
String sql = “delete from temp where id=?””;
String sql = “insert into temp(id,name) values (?,?)”
public void update(String sql, Object[] paramValues);
b)查詢
String sql = “select * from temp”;
String sql = “select * from temp where id=?”;
// 傳入的什麼類型的對象，就封裝為什麼類型
// 要求： 列的名稱，要與指定類型的對象的屬性名稱一樣
Public List query (String sql , Object[] paramValues , Class clazz);
T t; // 對象指派
- 5.關閉/異常
為便于連接配接資料庫，先編寫一個工具類
具體請參考:http://http://www.cnblogs.com/DanielJing/p/6384615.html
編寫BaseDao，自己寫的所有的Dao都繼承此類
package testDao2;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.util.ArrayList;
import java.util.List;
import org.apache.commons.beanutils.BeanUtils;
import com.jdbc.util.JDBCUtil;;
/**
* 通用的dao，自己寫的所有的dao都繼承此類;
* 此類定義了2個通用的方法：
* 1. 更新
* 2. 查詢
*/
public class BaseDao {
// 初始化參數
private Connection con;
private PreparedStatement pstmt;
private ResultSet rs;
/**
* 查詢的通用方法
* @param sql
* @param paramsValue
*/
public <T> List<T> query(String sql, Object[] paramsValue,Class<T> clazz){
try {
// 傳回的集合
List<T> list = new ArrayList<T>();
// 對象
T t = null;
// 1. 擷取連接配接
con = JDBCUtil.getConnection();
// 2. 建立stmt對象
pstmt = con.prepareStatement(sql);
// 3. 擷取占位符參數的個數， 并設定每個參數的值
int count = pstmt.getParameterMetaData().getParameterCount();
if (paramsValue != null && paramsValue.length > 0) {
for (int i=0; i<paramsValue.length; i++) {
pstmt.setObject(i+1, paramsValue[i]);
}
}
// 4. 執行查詢
rs = pstmt.executeQuery();
System.out.println(sql);
// 5. 擷取結果集中繼資料
ResultSetMetaData rsmd = rs.getMetaData();
// ---> 擷取列的個數
int columnCount = rsmd.getColumnCount();
// 6. 周遊rs
while (rs.next()) {
// 要封裝的對象
t = clazz.newInstance();
// 7. 周遊每一行的每一列, 封裝資料
for (int i=0; i<columnCount; i++) {
// 擷取每一列的列名稱
String columnName = rsmd.getColumnName(i + 1);
// 擷取每一列的列名稱, 對應的值
Object value = rs.getObject(columnName);
// 封裝： 設定到t對象的屬性中 【BeanUtils元件】,需要beanutils jar包支援
BeanUtils.copyProperty(t, columnName, value);
}
// 把封裝完畢的對象，添加到list集合中
list.add(t);
}
return list;
} catch (Exception e) {
throw new RuntimeException(e);
} finally {
JDBCUtil.close(con, pstmt, rs);
}
}
/**
* 更新的通用方法
* @param sql 更新的sql語句(update/insert/delete)
* @param paramsValue sql語句中占位符對應的值(如果沒有占位符，傳入null)
*/
public void update(String sql,Object[] paramsValue){
try {
// 擷取連接配接
con = JDBCUtil.getConnection();
// 建立執行指令的stmt對象
pstmt = con.prepareStatement(sql);
// 參數中繼資料： 得到占位符參數的個數
int count = pstmt.getParameterMetaData().getParameterCount();
// 設定占位符參數的值
if (paramsValue != null && paramsValue.length > 0) {
// 循環給參數指派
for(int i=0;i<count;i++) {
pstmt.setObject(i+1, paramsValue[i]);
}
}
// 執行更新
pstmt.executeUpdate();
System.out.println(sql);
} catch (Exception e) {
throw new RuntimeException(e);
} finally {
JDBCUtil.close(con, pstmt, null);
}
}
}
編寫實際操作的Dao類繼承自BaseDao
package testDao2;
import java.util.List;
public class StudentDao extends BaseDao {
// 删除
public void delete(int id) {
String sql = "delete from temp where id=?";
Object[] paramsValue = {id};
super.update(sql, paramsValue);
}
// 插入
public void insert(Student student) {
String sql = "insert into temp (id,name) values (?,?)";
Object[] paramsValue = {student.getId(),student.getName()};
super.update(sql, paramsValue);
}
// 查詢全部
public List<Student> getAll(){
String sql = "select * from temp";
List<Student> list = super.query(sql, null, Student.class);
return list;
}
// 根據條件查詢(主鍵)
public Student findById(int id){
String sql = "select * from temp where id=?";
List<Student> list = super.query(sql, new Object[]{id}, Student.class);
return (list!=null&&list.size()>0) ? list.get(0) : null;
}
// 修改
public void update(Student student) {
String sql = "update temp set name=? where id=?";
Object[] paramsValue = {student.getName(),student.getId()};
super.update(sql, paramsValue);
}
}
實體類
package testDao2;
public class Student {
private int id;
private String name;
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;
}
@Override
public String toString() {
return "Student [id=" + id + ", name=" + name + "]";
}
public Student(int id, String name) {
super();
this.id = id;
this.name = name;
}
public Student() {//必不可少的無參構造器
// TODO Auto-generated constructor stub
}
}
測試
package testDao2;
import java.util.List;
public class Test {
public static void main(String[] args) {
// TODO Auto-generated method stub
StudentDao studentDao = new StudentDao();
Student student = studentDao.findById(1);
System.out.println(student);
List<Student> list = studentDao.getAll();
System.out.println(list);
studentDao.delete(1);
list = studentDao.getAll();
System.out.println(list);
studentDao.insert(new Student(1,"yang"));
list = studentDao.getAll();
System.out.println(list);
studentDao.update(new Student(1,"ffffff"));
list = studentDao.getAll();
System.out.println(list);
}
}