DAO模式
Data Access Object：數(shù)據(jù)訪問對象
首先尸变，你的應(yīng)用程序，肯定會有業(yè)務(wù)邏輯的代碼寸宵。在三層架構(gòu)的web系統(tǒng)中患久，業(yè)務(wù)邏輯的代碼，就是在你的Service組件里面示启；在我們的spark作業(yè)中兢哭，業(yè)務(wù)邏輯代碼就是在我們的spark作業(yè)里面。
如果說丑搔，你不用DAO模式的話厦瓢，那么所有的數(shù)據(jù)庫訪問的代碼和邏輯會全部耦合在業(yè)務(wù)邏輯代碼里面。比如啤月，你的業(yè)務(wù)邏輯代碼中煮仇，可能會充斥著JDBCHelper，定義SQL語句谎仲，處理查詢返回結(jié)果等等代碼浙垫。會導(dǎo)致業(yè)務(wù)邏輯和數(shù)據(jù)訪問嚴(yán)重耦合。導(dǎo)致以后如果你只是想修改數(shù)據(jù)訪問的代碼郑诺，那么還得在一大堆業(yè)務(wù)邏輯的代碼中去找夹姥，找到這段代碼，然后去做對應(yīng)的修改辙诞。
因為我們要將數(shù)據(jù)庫訪問的代碼辙售，封裝在DAO中，然后呢飞涂，業(yè)務(wù)邏輯的代碼旦部，就可以直接去調(diào)用DAO組件，實現(xiàn)數(shù)據(jù)庫操作的邏輯较店。如果這樣做了以后士八，那么在業(yè)務(wù)邏輯的代碼中，就不可能出現(xiàn)SQL語句梁呈、查詢結(jié)果處理等等這些東西婚度。當(dāng)后面對系統(tǒng)進行維護的時候，如果你只是要優(yōu)化一條SQL語句官卡，那么你肯定不用跑到業(yè)務(wù)邏輯的代碼里面去找到這條SQL語句蝗茁，然后去修改它。寻咒。评甜。
只需要到業(yè)務(wù)邏輯代碼調(diào)用的DAO組件里面去，找到對應(yīng)的SQL語句仔涩，修改忍坷，即可。
引入了DAO模式以后，就大大降低了業(yè)務(wù)邏輯層和數(shù)據(jù)訪問層的耦合佩研，大大提升了后期的系統(tǒng)維護的效率柑肴，并降低了時間成本。
我們自己在實現(xiàn)DAO模式的時候旬薯，通常來說晰骑，會將其分為兩部分，一個是DAO接口绊序；一個是DAO實現(xiàn)類硕舆。我們的業(yè)務(wù)的代碼，通常就是面向接口進行編程骤公；那么當(dāng)接口的實現(xiàn)需要改變的時候抚官，直接定義一個新的實現(xiàn)即可。但是對于我們的業(yè)務(wù)代碼來說阶捆，只要面向接口開發(fā)就可以了凌节。DAO的改動對業(yè)務(wù)代碼應(yīng)該沒有任何的影響。
ITaskDAO.java
/**
* 任務(wù)管理DAO接口
* @author Administrator
*
*/
public interface ITaskDAO {
/**
* 根據(jù)主鍵查詢?nèi)蝿?wù)
* @param taskid 主鍵
* @return 任務(wù)
*/
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;
/**
* 任務(wù)管理DAO實現(xiàn)類
* @author Administrator
*
*/
public class TaskDAOImpl implements ITaskDAO {
/**
* 根據(jù)主鍵查詢?nèi)蝿?wù)
* @param taskid 主鍵
* @return 任務(wù)
*/
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ù)的設(shè)置
* 造成大量很冗余的代碼
*
* 所以說畔裕，之前就是說，不建議用Scala來開發(fā)大型復(fù)雜的Spark的工程項目
* 因為大型復(fù)雜的工程項目碉碉，必定是要涉及很多第三方的東西的，MySQL只是最基礎(chǔ)的淮韭，要進行數(shù)據(jù)庫操作
* 可能還會有其他的redis垢粮、zookeeper等等
*
* 如果你就用Scala，那么勢必會造成與調(diào)用第三方組件的代碼用java靠粪，那么就會變成scala+java混編
* 大大降低我們的開發(fā)和維護的效率
*
* 此外蜡吧，即使，你是用了scala+java混編
* 但是占键，真正最方便的昔善，還是使用一些j2ee的開源框架，來進行第三方
* 技術(shù)的整合和操作畔乙，比如MySQL君仆，那么可以用MyBatis/Hibernate，大大減少我們的冗余的代碼
* 大大提升我們的開發(fā)速度和效率
*
* 但是如果用了scala，那么用j2ee開源框架返咱，進來钥庇，造成scala+java+j2ee開源框架混編
* 簡直會造成你的spark工程的代碼上的極度混亂和慘不忍睹
* 后期非常難以維護和交接
*
*/
return task;
}
}
