从模板模式到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;
			}
		});

	}