使用模板模式封装数据库连接

模板模式
模板模式与策略模式都是对于算法进行相关处理的设计模式,属于形为形模式。模板模式是使用继承来复写或者修改算法，具有定制性。策略模式是对算法进行抽调，或者说是对算法进行分类封装处理，使算法具有灵活性。
模板模式是定义一个算法骨架，然后让子类对实现算法的细节。使算法细节不改变主算法的结构。
它的结构为：
1、
AbstractClass:通常使用抽象类，定义一系列抽象方法，具体子类可以重定义它，以实现各算法的具体步骤。
2、
ConcteteClass:实现抽象方法，以完成算法中与特定子类相关的步骤。

使用模板模式封装数据库连接类：

package com.hejianjiao.database;

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

public class JdbcAbstractTemplate extends DabaseInfo {

	/**
	 * 这就是模板模式中的模板,用于处理数据库连接的相关操作
	 */

	/**
	 * 注册JDBC驱动
	 */
	public void registerDriver() {
		try {
			Class.forName(driverClass);
		} catch (ClassNotFoundException e) {
			System.out.println("注册驱动失败!");
			e.printStackTrace();
		}
	}

	/**
	 * 取得连接
	 */
	public Connection getConnection() {
		try {
			return DriverManager.getConnection(url, username, password);
		} catch (SQLException e) {
			System.out.println("数据库连接失败!");
			e.printStackTrace();
		}
		return null;
	}

	/**
	 * 关闭连接
	 */
	public void closeConnection(Connection conn) {
		if (conn != null)
			try {
				conn.close();
			} catch (SQLException e) {
				System.out.println("数据库关闭失败!");
				e.printStackTrace();
			}
	}

	/**
	 * 关闭语句
	 */
	public void closeStatement(Statement statement) {
		if (statement != null)
			try {
				statement.close();
			} catch (SQLException e) {
				System.out.println("语句关闭失败!");
				e.printStackTrace();
			}
	}

	/**
	 * 模板方法----操作数据
	 */
	public void save(String sql) {
		PreparedStatement pstmt = null;
		Connection conn = null;

		try {
			registerDriver();
			conn = getConnection();
			pstmt = conn.prepareStatement(sql);
			pstmt.executeUpdate();
		} catch (SQLException e) {
			System.out.println("数据操作失败!");
			e.printStackTrace();
		} finally {
			closeStatement(pstmt);
			closeConnection(conn);
		}
	}

	/**
	 * 模板方法----获取数据
	 */
	public ResultSet get(String sql) {
		PreparedStatement pstmt = null;
		Connection conn = null;
		ResultSet rs = null;

		try {
			registerDriver();
			conn = getConnection();
			pstmt = conn.prepareStatement(sql);
			rs = pstmt.executeQuery();

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			closeStatement(pstmt);
			closeConnection(conn);
		}
		return rs;
	}

}

2、数据连接信息封装

package com.hejianjiao.database;

public class DatabaseInfo {

	protected final String url = "jdbc:mysql://localhost:3306/test";
	protected final String username = "root";
	protected final String password = "";
	protected final String driverClass = "org.gjt.mm.mysql.Driver";

}

3、使用User对象进行再一次封装操作

package com.hejianjiao.database;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Vector;

public class UserTemplate extends JdbcAbstractTemplate {

	/**
	 * 对于User表的另外封装操作类
	 */

	/**
	 * 保存User对象数据
	 */
	public void saveUser(User user) {
		String sql = "insert into user (username,password) values('"
				+ user.getName() + "','" + user.getPassword() + "')";
		super.save(sql);
	}

	/**
	 * 获取User对象信息
	 */
	public User getUserById(String id) {
		Vector<User> vector = null;
		String sql = "select * from user where id='" + id + "'";
		ResultSet rs = super.get(sql);
		User user = null;
		if (rs != null) {
			try {
				while (rs.next()) {
					user = new User();
					user.setId(rs.getString(1));
					user.setName(rs.getString(2));
					user.setPassword(rs.getString(3));
					vector.add(user);

					if (vector != null) {
						for (int i = 0; i < vector.size(); i++) {
							user = (User) vector.elementAt(i);
						}
					}
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return user;
	}

	/**
	 * 获取所有User信息列表
	 */
	public Vector getAllUser() {
		String sql = "select * from user";
		Vector vector = null;
		User user = null;
		ResultSet rs = super.get(sql);
		if (rs != null) {
			try {
				user = new User();
				user.setId(rs.getString(1));
				user.setName(rs.getString(2));
				user.setPassword(rs.getString(3));
			} catch (SQLException e) {
				e.printStackTrace();
			}
			vector.add(user);
		}
		return vector;
	}
}

4、User对象

package com.hejianjiao.database;

public class User {

	private String id;
	private String name;
	private String password;

	public String getId() {
		return id;
	}

	public void setId(String id) {
		this.id = id;
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public String getPassword() {
		return password;
	}

	public void setPassword(String password) {
		this.password = password;
	}

}

上面这个例子,JdbcAbstractTemplate类,用一个可以重用的形式,处理了数据库初使化、关闭等操作，然后在具体到一个对象时，就可以使用模板模式来重用模板类中的方法，以达到快捷开发的效果。
在上面这个例子来看,模板模式展示了一种经典的重用形式.

评论

3 楼 mabusyao 2009-02-10  

多谢楼主的回答，对于你第一个问题的解释，我还是不太能理解

举get这个方法的例子：
#     /**
#      * 模板方法----获取数据
#      */ 
#     public ResultSet get(String sql) { 
#         PreparedStatement pstmt = null; 
#         Connection conn = null; 
#         ResultSet rs = null; 
#  
#         try { 
#             registerDriver(); 
#             conn = getConnection(); 
#             pstmt = conn.prepareStatement(sql); 
#             rs = pstmt.executeQuery(); 
#  
#         } catch (SQLException e) { 
#             e.printStackTrace(); 
#         } finally { 
#             closeStatement(pstmt); 
#             closeConnection(conn); 
#         } 
#         return rs; 
#     }

在finally里面，你不是已经把statement和connection给close掉了么？ 而在此之后，你reture了一个rs。

那么我在UserTemplate中调用的“ResultSet rs = super.get(sql);  ”这句话得到的rs，岂不是已经无效了？

今天看到你的头像，突然发现你居然是我的同事... 我在公司发的邮件中貌似看到过你。你是IBM的同仁么？

2 楼 anysky131 2009-02-02  

首先感谢兄台的指教!
呵呵,兄台可能看错了,我的ResultSet,Connection的关闭操作都单独封装在了一个单独的方法中去了.所以你的第一个问题,不是问题.

对于第二个问题,我想说两点:
1、这个文章的名字是，使用模板模式对数据库操作进行封装。就是封装了数据库的增、删、查、改。重点不是想说明数据库操作的封装。只是想说明模板模式的使用。对于数据库的封装，可以有很多种方法的。
2、对于数据库连接，关闭，已经封装了出来，可以单独进行操作了。而对于你说，一个事务处理，可以放在一个connection中去，是的，我这里也是可以的，只是看你怎样使用这里的方法了，这里只是写了一个小小的例子罢了。

对于最后一句，文章是原创的，数据库封装，网上可以有很多资料的，而且都是高手们写的，我这种菜人，就不出来说了吧。呵呵

多多交流。。。。。

1 楼 mabusyao 2009-01-20  

提两个问题：

1. 你的public ResultSet get(String sql) 函数返回一个ResultSet， 但是在函数内部已经把connection给close掉了，那在外部得到的ResultSet还有什么用处呢？要知道ResultSet只是数据的的一个索引而已，如果connection都已经关掉了，再去操作ResultSet会报错的。

2. 你的每次数据库操作都会进行数据库连接以及关闭，为什么不把这块内容抽出来，在一个更大的事务处理过程中进行？ 要知道，一个事务处理可能包含多次数据库读写，完全可以在同一个connection中。

想请问下你的文章是原创的么？ 我最近在写一个数据库的封装，不知道你有没有什么好的东东可以推荐的？