?

暮然回首，看看jDBC的操作，原来很多的东西都忘记了，数据库的的语句也忘得差不多了，还的捡起来以前的东西，自己粗糙的写了一个封装JDBC的CURD的方法，回顾回顾以前的东西。

类名：BasedDaoSupport。主要功能为Dao提供一次分装的接口。

注：有几个类是工具类，获得JDBC的链接和独缺配置文件的。

package cn.edu.lzcc.orderdishes.utils;

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

import cn.edu.lzcc.orderdishes.exception.ObejectIdException;
/**
 * 
 * Project: orderdishes
 * Package: cn.edu.lzcc.orderdishes.utils
 * @author  bestupon
 * Email:   bestupon@foxmail.com
 * DateTime:Oct 15, 2009 2:06:59 AM
 * JDBC的数据封装类
 * 实现了增删改查的基本操作。
 */

public class BaseDaoSupport {
	private boolean result=false;
	Connection conn = DataBaseConnection.getConnection();
	Statement stmt = DataBaseConnection.createStatement(conn);
	ResultSet rs = null;
	/**
	 * 插入增加的方法
	 * @param entityTable 要操作的表的名称
	 * @param propertys 操作的表的属性名称
	 * @param params 增加的值
	 * @return 成功与否
	 * @throws SQLException
	 */
	public  boolean  addObject(String entityTable,String []propertys,Object[]params) throws SQLException {
		StringBuffer insertSql =new StringBuffer("");
		if(null !=entityTable &&!entityTable.equals("")) {
			insertSql.append("INSERT INTO  ");
		}else {
			return result;
		}
		if(null !=propertys && propertys.length >=1) {
			insertSql.append(entityTable.toLowerCase());
			insertSql.append("  (");
			 for(int i= 0 ; i<propertys.length;i++) {
				 insertSql.append(propertys[i]);
				 insertSql.append(",");
				 if(propertys[i].trim().toLowerCase().equals(entityTable.toLowerCase()+"id") && propertys[i]!=null) {
					 ObejectIdException oie =  new ObejectIdException("增加方法中的ObjectId的值必须是‘null’值causeby：（主键不能有重复值）");
					 throw oie;
				 }
			 }
			 insertSql = new StringBuffer(insertSql.substring(0, insertSql.length()-1));
			 insertSql.append(" )");
		}
		if(null !=params) {
			insertSql.append(" VALUES (");
			 for(int i= 0 ; i<propertys.length;i++) {
				 if(params[i] != null) {
					 insertSql.append("'").append(params[i]).append("',");
				 }else {
					 insertSql.append(params[i]).append(",");
				 }
			 }
			 insertSql = new StringBuffer(insertSql.substring(0, insertSql.length()-1));
			 insertSql.append(" ) ;");
		}
		System.out.println(insertSql.toString());
		result =DataBaseConnection.executeUpdate(conn, insertSql.toString())>0 ? true :false;
		return result;
	}
	/**
	 * 删除操作
	 * @param entityTable
	 * @param objectId
	 * @return
	 * @throws SQLException
	 */
	public  boolean  delObject(String entityTable,String sqlWhere) throws SQLException {
		StringBuffer deleteSql = new StringBuffer(""); 
		deleteSql.append("DELETE FROM  ");
		deleteSql.append(entityTable.toLowerCase());
		if(null != sqlWhere && !sqlWhere.equals("") &&sqlWhere.length()>1) {
			if(sqlWhere.trim().split(" ")[0].toLowerCase().equals("where")){
				deleteSql.append(sqlWhere);
			}else {
				deleteSql.append(" WHERE " ).append(sqlWhere);
			}
		}
		System.out.println(deleteSql.toString());
		result =DataBaseConnection.executeUpdate(conn, deleteSql.toString())>0 ? true :false;
		return result;
	}
	/**
	 * 更新修改的方法
	 * @param entityTable 实体表名称
	 * @param propertys 更新的字段名称
	 * @param params 更新的值
	 * @param sqlWhere 条件语句
	 * @return 返回成功与否
	 * @throws SQLException
	 */
	public  boolean  modifyObject(String entityTable,String []propertys,Object[]params,String sqlWhere) throws SQLException {
		StringBuffer updateSql =new StringBuffer("");
		if(null !=entityTable &&!entityTable.equals("")) {
			updateSql.append("UPDATE ").append(entityTable.toLowerCase());
		}else {
			return result;
		}
		if(null !=propertys ) {
			if(null !=params) {
				if(propertys.length == params.length) {
					for(int i= 0 ; i<propertys.length;i++) {
						updateSql.append("  SET ");
						updateSql.append(propertys[i]).append("=").append("'").append(params[i]).append("',");
						 if(propertys[i].trim().toLowerCase().equals(entityTable.to