DAO模式
Data Access Object：數(shù)據(jù)訪問對象
首先，你的應用程序，肯定會有業(yè)務邏輯的代碼。在三層架構的web系統(tǒng)中，業(yè)務邏輯的代碼，就是在你的Service組件里面；在我們的spark作業(yè)中，業(yè)務邏輯代碼就是在我們的spark作業(yè)里面。
如果說，你不用DAO模式的話，那么所有的數(shù)據(jù)庫訪問的代碼和邏輯會全部耦合在業(yè)務邏輯代碼里面。比如，你的業(yè)務邏輯代碼中，可能會充斥著JDBCHelper，定義SQL語句，處理查詢返回結果等等代碼。會導致業(yè)務邏輯和數(shù)據(jù)訪問嚴重耦合。導致以后如果你只是想修改數(shù)據(jù)訪問的代碼，那么還得在一大堆業(yè)務邏輯的代碼中去找，找到這段代碼，然后去做對應的修改。
因為我們要將數(shù)據(jù)庫訪問的代碼，封裝在DAO中，然后呢，業(yè)務邏輯的代碼，就可以直接去調(diào)用DAO組件，實現(xiàn)數(shù)據(jù)庫操作的邏輯。如果這樣做了以后，那么在業(yè)務邏輯的代碼中，就不可能出現(xiàn)SQL語句、查詢結果處理等等這些東西。當后面對系統(tǒng)進行維護的時候，如果你只是要優(yōu)化一條SQL語句，那么你肯定不用跑到業(yè)務邏輯的代碼里面去找到這條SQL語句，然后去修改它。。。
只需要到業(yè)務邏輯代碼調(diào)用的DAO組件里面去，找到對應的SQL語句，修改，即可。
引入了DAO模式以后，就大大降低了業(yè)務邏輯層和數(shù)據(jù)訪問層的耦合，大大提升了后期的系統(tǒng)維護的效率，并降低了時間成本。
我們自己在實現(xiàn)DAO模式的時候，通常來說，會將其分為兩部分，一個是DAO接口；一個是DAO實現(xiàn)類。我們的業(yè)務的代碼，通常就是面向接口進行編程；那么當接口的實現(xiàn)需要改變的時候，直接定義一個新的實現(xiàn)即可。但是對于我們的業(yè)務代碼來說，只要面向接口開發(fā)就可以了。DAO的改動對業(yè)務代碼應該沒有任何的影響。
ITaskDAO.java
/**
* 任務管理DAO接口
* @author Administrator
*
*/
public interface ITaskDAO {
/**
* 根據(jù)主鍵查詢?nèi)蝿? * @param taskid 主鍵
* @return 任務
*/
Task findById(long taskid);
}
TaskDAOImpl.java
import java.sql.ResultSet;
import com.ibeifeng.sparkproject.dao.ITaskDAO;
import com.ibeifeng.sparkproject.domain.Task;
import com.ibeifeng.sparkproject.jdbc.JDBCHelper;
/**
* 任務管理DAO實現(xiàn)類
* @author Administrator
*
*/
public class TaskDAOImpl implements ITaskDAO {
/**
* 根據(jù)主鍵查詢?nèi)蝿? * @param taskid 主鍵
* @return 任務
*/
public Task findById(long taskid) {
final Task task = new Task();
String sql = "select * from task where task_id=?";
Object[] params = new Object[]{taskid};
JDBCHelper jdbcHelper = JDBCHelper.getInstance();
jdbcHelper.executeQuery(sql, params, new JDBCHelper.QueryCallback() {
@Override
public void process(ResultSet rs) throws Exception {
if(rs.next()) {
long taskid = rs.getLong(1);
String taskName = rs.getString(2);
String createTime = rs.getString(3);
String startTime = rs.getString(4);
String finishTime = rs.getString(5);
String taskType = rs.getString(6);
String taskStatus = rs.getString(7);
String taskParam = rs.getString(8);
task.setTaskid(taskid);
task.setTaskName(taskName);
task.setCreateTime(createTime);
task.setStartTime(startTime);
task.setFinishTime(finishTime);
task.setTaskType(taskType);
task.setTaskStatus(taskStatus);
task.setTaskParam(taskParam);
}
}
});
/**
* 說在后面的話：
*
* 大家看到這個代碼，包括后面的其他的DAO，就會發(fā)現(xiàn)，用JDBC進行數(shù)據(jù)庫操作，最大的問題就是麻煩
* 你為了查詢某些數(shù)據(jù)，需要自己編寫大量的Domain對象的封裝，數(shù)據(jù)的獲取，數(shù)據(jù)的設置
* 造成大量很冗余的代碼
*
* 所以說，之前就是說，不建議用Scala來開發(fā)大型復雜的Spark的工程項目
* 因為大型復雜的工程項目，必定是要涉及很多第三方的東西的，MySQL只是最基礎的，要進行數(shù)據(jù)庫操作
* 可能還會有其他的redis、zookeeper等等
*
* 如果你就用Scala，那么勢必會造成與調(diào)用第三方組件的代碼用java，那么就會變成scala+java混編
* 大大降低我們的開發(fā)和維護的效率
*
* 此外，即使，你是用了scala+java混編
* 但是，真正最方便的，還是使用一些j2ee的開源框架，來進行第三方
* 技術的整合和操作，比如MySQL，那么可以用MyBatis/Hibernate，大大減少我們的冗余的代碼
* 大大提升我們的開發(fā)速度和效率
*
* 但是如果用了scala，那么用j2ee開源框架，進來，造成scala+java+j2ee開源框架混編
* 簡直會造成你的spark工程的代碼上的極度混亂和慘不忍睹
* 后期非常難以維護和交接
*
*/
return task;
}
}
