solutionrecordoperate.java

JAVA实现的酒店管理系统

package file1;

/*
 * Description:对客户申诉记录的解决情况的封装，实现对解决情况操作的面向对象性
 * @Author:黄顺武
 * Create Time:2007-12-22
 */
import java.sql.*;
import java.util.*;
import sun.jdbc.rowset.*;

public class SolutionRecordOperate implements Operate {

	public SolutionRecordOperate() {
	}

	public void insertToDB(Object object) {// 插入解决情况时调用的方法
		SolutionRecord solution_record = (SolutionRecord) object;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer(
					"insert into SolutionRecord values(");
			sqlSB.append(solution_record.getAppealID()).append(",");
			sqlSB.append(solution_record.getOperater()).append(",'");
			sqlSB.append(solution_record.getOperateTime()).append("','");
			sqlSB.append(solution_record.getSuggestion()).append("')");
			con.addSql(sqlSB.toString());
			con.doDML();
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
	}

	public void deleteFromDB(Object object) {// 删除解决情况时调用的方法

		SolutionRecord solution_record = (SolutionRecord) object;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer(
					"delete from  SolutionRecord where id=");
			sqlSB.append(solution_record.getID());
			con.addSql(sqlSB.toString());
			con.doDML();
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
	}

	public void modifyToDB(Object object) {// 修改解决情况时调用的方法
		SolutionRecord solution_record = (SolutionRecord) object;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer("update  SolutionRecord set ");
			sqlSB.append("AppealID=").append(solution_record.getAppealID())
					.append(",");
			sqlSB.append("Operater='").append(solution_record.getOperater())
					.append("',");
			sqlSB.append("OperateTime='").append(
					solution_record.getOperateTime()).append("',");
			sqlSB.append("Suggestion='")
					.append(solution_record.getSuggestion()).append("' ");
			sqlSB.append("where id=").append(solution_record.getID());
			con.addSql(sqlSB.toString());
			con.doDML();
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
	}

	public ArrayList selectFromDB(Object object) {// 查询解决情况时调用的方法

		SolutionRecord solution_record = (SolutionRecord) object;
		ArrayList valuesList = new ArrayList();
		CachedRowSet crs = null;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer("");
			if (solution_record.getID() == 0) {
				sqlSB.append("select* from SolutionRecord");
			}
			if (solution_record.getID() != -1 && solution_record.getID() != 0) {
				sqlSB.append("select* from SolutionRecord where id=").append(
						solution_record.getID());
			}
			crs = con.getResultSet(sqlSB.toString());
			while (crs.next()) {
				SolutionRecord solutionRecord = new SolutionRecord();
				solutionRecord.setID(crs.getInt(1));
				solutionRecord.setAppealID(crs.getInt(2));
				solutionRecord.setOperater(crs.getInt(3));
				solutionRecord.setOperateTime(crs.getString(4));
				solutionRecord.setSuggestion(crs.getString(5));
				valuesList.add(solutionRecord);
			}
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
		return valuesList;
	}
}