jdbctemplate.java

struts+spring+jdbc权限管理 菜单树实现

package com.hiiso.crm.common.jdbc;

import java.sql.*;

/*************************************************************************
* SYSTEM:       基金CRM系统
* SUBSYS:       CRM权限管理模块
* DESCRIPTION:  JDBC处理类
* AUTHOR:       yaoyi
* CREATE DATE:  2008/10/30
* COPYRIGHT:    (c)Copyright 2008 hisun Corporation. All rights reserved.
* VERSION:      V1.0G
* EDIT HISTORY:
*************************************************************************/

public class JdbcTemplate {
	
	public Connection conn;
	
	public JdbcTemplate(Connection conn){
		this.conn=conn;
	}

	//简单保存
	public int save(String sql){
		Statement stmt=null;
		try {
			stmt=conn.createStatement();
			return stmt.executeUpdate(sql);
		} catch (SQLException e) {
			throw new RuntimeException(e);
		}finally{
			close(null,stmt);
		}
	}
	
	//简单删除
	public int delete(String sql){
		return save(sql);
	}
	
	//根据条件删除
	public int delete(String sql,PreparedStatementSetter setter){
		return save(sql,setter);
	}
	
	//简单更新世界
	public int update(String sql){
		return save(sql);
	}
	
	//根据条件更新
	public int update(String sql,PreparedStatementSetter setter){
		return save(sql,setter);
	}
	
	//根据条件保存
	public int save(String sql,PreparedStatementSetter setter){
		PreparedStatement pstmt=null;
		try {
			pstmt=conn.prepareStatement(sql);
			if(setter!=null)
			    setter.setter(pstmt);
			return pstmt.executeUpdate();
		} catch (SQLException e) {
			throw new RuntimeException(e);
		}finally{
			close(null,pstmt);
		}
	}
	
	//简单查找返回结果集
	public void find(String sql,JdbcCallback callback){
		Statement stmt=null;
		ResultSet rs=null;
		try {
			stmt=conn.createStatement();
			rs=stmt.executeQuery(sql);
			if(callback!=null){
				callback.doExecute(rs);
			}
		} catch (SQLException e) {
			throw new RuntimeException(e);
		}finally{
			close(rs,stmt);
		}
	}
	
	//根据条件查找并返回结果集
	public void find(String sql,JdbcCallback callback,PreparedStatementSetter setter){
		PreparedStatement pstmt=null;
		ResultSet rs=null;
		try {
			pstmt=conn.prepareStatement(sql);
			if(setter!=null)
				setter.setter(pstmt);
			rs=pstmt.executeQuery();
			if(callback!=null){
				callback.doExecute(rs);
			}
		} catch (SQLException e) {
			throw new RuntimeException(e);
		}finally{
			close(rs,pstmt);
		}
	}
	//关闭ResultSet和Statement
	public void close(ResultSet rs, Statement stmt){
		try {
			if (rs != null)
				rs.close();
			if (stmt != null)
				stmt.close();
		} catch (SQLException e) {
			throw new RuntimeException(e);
		}
	}
}