從模板模式到JdbcTemplate

上一篇《模板方法模式》

原始的jdbc

 

關於原始的jdbc,以下:
 

import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.ResultSet;  
import java.sql.SQLException;  
import java.sql.Statement;  
  
public class JDBC_Test2 {  
  
    public static void main(String[] args) {  
          
        Connection conn=null;  
        Statement st=null;  
        ResultSet rs=null;  
        String url="jdbc:mysql://localhost:3306/webexample?useUnicode=true&characterEncoding=UTF-8";  
        String userName="root";  
        String passWord="";  
        try {  
            Class.forName("com.mysql.jdbc.Driver");  
            conn=DriverManager.getConnection(url,userName,passWord);  
            st=conn.createStatement();  
            rs=st.executeQuery("select * from admininfo");  
            while (rs.next()) {  
                System.out.println(rs.getString("Aname"));  
            }  
              
              
        } catch (ClassNotFoundException e) {  
            e.printStackTrace();           //log4j 具體記錄  
        }catch (SQLException e) {  
            e.printStackTrace();  
        }  
        finally{  
            try {  
                if (rs!=null) {  
                    rs.close();  
                    rs=null;  
                }  
                if (st!=null) {  
                    st.close();  
                    st=null;  
                }  
                if (conn!=null) {  
                    conn.close();  
                    conn=null;  
                }  
                  
            } catch (SQLException e) {  
                // TODO Auto-generated catch block  
                e.printStackTrace();  
            }  
        }  
    }  
}

我假定朋友們都有必定的編碼經驗,那麼你們再看了最基本的jdbc後,內心應該會有兩個想法
1 做爲jdbc hello world級別的示例程序,上面的代碼寫的仍是很不錯的,該try catch的地方都注意到了
2 若是要大規模使用的話,就比較麻煩了,操做數據庫的核心的代碼不多,可是核心以前以後的操做卻不少。
jdbc鏈接數據庫 獲取數據能夠分爲一下幾步:
1 加載驅動 Class.forName("com.mysql.jdbc.driver");
2 得到鏈接  Connection con=DriverManager.getConnection(url,userName,password);
3 得到Statement  Statement st=con.createStatement();
4 執行sql並得到ResultSet rs=st.executeQuery(sql);
5 處理rs中的數據
             while (rs.next()) {  
                System.out.println(rs.getString("Aname"));  
            }  
6 處理異常
7 關閉鏈接

仔細看看,其實只有第五步是真正核心的,以前以後的都是那種萬年不變的代碼

使用模板模式

 

咱們用模板模式來改裝一下。
 

package templatemethod1;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public abstract class JDBCTemplate  {

	public Object execute(String sql) {
		String  url="";
		String  userName="";
		String  password="";
		Connection con=null;
		Statement st=null;
		ResultSet rs=null;
		try{
			Class.forName("com.mysql.jdbc.driver");
			con=DriverManager.getConnection(url,userName,password);
			st=con.createStatement();
			rs=st.executeQuery(sql);
			//只把核心的第五步 抽象出來 交給子類處理
			Object object=doResultSet(rs); 
			return object;                 
			
		}
		catch (ClassNotFoundException e){
			e.printStackTrace();
		}
		catch(SQLException e){
			e.printStackTrace();
		}
		finally{
			try{
			if(rs!=null){
				rs.close();
				rs=null;
			}
			//...
			}catch(SQLException e){
				e.printStackTrace();

			}
		}
		return null;
	}
	//抽象出來 交給子類處理
	public abstract Object doResultSet(ResultSet rs);
	
}

package templatemethod1;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import model.Student;


public class JDBCTemplateStudentImpl extends JDBCTemplate {

    //doResultSet 就是關於獲取Student的真正核心的代碼
	@Override
	public Object doResultSet(ResultSet rs) {
		List<Student> userList = new ArrayList<Student>();  
        
        try {  
        	Student student = null;  
            while (rs.next()) {  
  
            	student = new Student();  
            	student.setId(rs.getInt("id"));  
            	student.setBirth(rs.getDate("birth"));  
                userList.add(student);  
            }  
            return userList;  
        } catch (SQLException e) {  
            e.printStackTrace();  
            return null;  
        }  
    }  
	
}

測試代碼

package templatemethod1;

import java.util.List;
import model.Student;

public class TemplateMethodTest {
	
	public static void main(String[] args) {
		String  sql="select * from user";
		JDBCTemplate template=new JDBCTemplateStudentImpl();
		List<Student> students=(List<Student>) template.execute(sql);
	}

}

model.Student的代碼我就不給出了,就是幾個字段,getset方法而已。

回調

上面的模板方法OK不?
好着呢。
問題是,若是JDBCTemplate中有不少個抽象方法,那麼咱們就得從新不少方法。太累。

那咱們可否只覆蓋咱們想要的呢?
這裏就牽扯到一個名詞,callback(回調)
所謂回調，就是方法參數中傳遞一個接口，父類在調用此方法時，必須調用方法中傳遞的接口的實現類。
咱們直接看代碼

package templatemethod2;


import java.sql.SQLException;
import java.sql.Statement;


public interface StatementCallback {  
    //這個doInStatement至關於上面的doResultSet
    Object doInStatement(Statement stmt) throws SQLException;  
}

package templatemethod2;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;


public  class JDBCTemplate  {

	public Object execute(StatementCallback action) {
		String  url="";
		String  userName="";
		String  password="";
		Connection con=null;
		Statement st=null;
		ResultSet rs=null;
		try{
			Class.forName("com.mysql.jdbc.driver");
			con=DriverManager.getConnection(url,userName,password);
			st=con.createStatement();
			Object object=action.doInStatement(st);
			return object;			
		}
		//省略try catch
	
		return null;
	}


	public  Object query(StatementCallback action){
		return execute(action);
	}
	
}
下面的測試方法,只要給定一個sql,就能傳回List<Student>
	@SuppressWarnings("unchecked")
	public List<Student> test2(final String sql) {


		JDBCTemplate jdbcTemplate = new JDBCTemplate();
		return (List<Student>) jdbcTemplate.execute(new StatementCallback() {
			@Override
			public Object doInStatement(Statement stmt) throws SQLException {
				ResultSet rs = stmt.executeQuery(sql);
				List<Student> userList = new ArrayList<Student>();

				Student user = null;
				while (rs.next()) {
					user = new Student();
					user.setId(rs.getInt("id"));
					user.setBirth(rs.getDate("birth"));
					userList.add(user);
				}
				return userList;
			}
		});

	}