模板模式初探
关于模板模式,大家可以参阅 模板方法模式深度解析(一)
原始的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; } }); }
参考资料
http://blog.****.net/lovelion/article/details/8299794
http://www.bubuko.com/infodetail-666886.html