processionrecordoperate.java

JAVA实现的酒店管理系统

package file1;

/*
 * Description:对损益记录的处理情况的封装
 * @Author:黄顺武
 * Create Time:2007-12-22
 */
import java.sql.*;
import java.util.*;
import javax.swing.*;
import sun.jdbc.rowset.*;

public class ProcessionRecordOperate {

	public ProcessionRecordOperate() {
	}

	public void insertToDB(Object object) {// 插入处理情况时调用的方法
		ProcessionRecord procession_record = (ProcessionRecord) object;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer(
					"insert into ProcessionRecord values(");
			if (procession_record.getGoodNotEqualID() == -1) {
				JOptionPane.showMessageDialog(null, "处理情况所针对的损益记录不能为空!", "",
						JOptionPane.INFORMATION_MESSAGE);
				return;
			}
			if (procession_record.getOperater()==-1) {
				JOptionPane.showMessageDialog(null, "处理人不能为空!", "",
						JOptionPane.INFORMATION_MESSAGE);
				return;
			}
			if (procession_record.getOperateTime().equals("")) {
				JOptionPane.showMessageDialog(null, "处理时间不能为空!", "",
						JOptionPane.INFORMATION_MESSAGE);
				return;
			}
			sqlSB.append(procession_record.getGoodNotEqualID()).append(",");
			sqlSB.append(procession_record.getOperater()).append(",'");
			sqlSB.append(procession_record.getOperateTime()).append("','");
			sqlSB.append(procession_record.getSuggestion()).append("')");
			con.addSql(sqlSB.toString());
			con.doDML();
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
	}

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

		ProcessionRecord procession_record = (ProcessionRecord) object;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer(
					"delete from  ProcessionRecord where id=");
			if (procession_record.getID() == -1) {
				JOptionPane.showMessageDialog(null, "要删除的处理情况不能为空!", "",
						JOptionPane.INFORMATION_MESSAGE);
				return;
			}
			sqlSB.append(procession_record.getID());
			con.addSql(sqlSB.toString());
			con.doDML();
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
	}

	public void modifyToDB(Object object) {// 修改处理情况时调用的方法
		ProcessionRecord procession_record = (ProcessionRecord) object;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer(
					"update  ProcessionRecord set ");
			if (procession_record.getID() == -1) {
				JOptionPane.showMessageDialog(null, "要修改的处理情况不能为空!", "",
						JOptionPane.INFORMATION_MESSAGE);
				return;
			}
			if (procession_record.getGoodNotEqualID() == -1) {
				JOptionPane.showMessageDialog(null, "处理情况所针对的损益记录不能为空!", "",
						JOptionPane.INFORMATION_MESSAGE);
				return;
			}
			if (procession_record.getOperater()==-1) {
				JOptionPane.showMessageDialog(null, "处理人不能为空!", "",
						JOptionPane.INFORMATION_MESSAGE);
				return;
			}
			if (procession_record.getOperateTime().equals("")) {
				JOptionPane.showMessageDialog(null, "处理时间不能为空!", "",
						JOptionPane.INFORMATION_MESSAGE);
				return;
			}
			sqlSB.append("GoodNotEqualID=").append(
					procession_record.getGoodNotEqualID()).append(",");
			sqlSB.append("Operater='").append(procession_record.getOperater())
					.append("',");
			sqlSB.append("OperateTime='").append(
					procession_record.getOperateTime()).append("',");
			sqlSB.append("Suggestion='").append(
					procession_record.getSuggestion()).append("' ");
			sqlSB.append("where id=").append(procession_record.getID());
			con.addSql(sqlSB.toString());
			con.doDML();
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
	}

	public HashMap selectFromDB(Object object) {// 查询处理情况时调用的方法

		ProcessionRecord procession_record = (ProcessionRecord) object;
		if (procession_record.getID() == -1) {
			JOptionPane.showMessageDialog(null, "要查询的处理情况id不能为空!", "",
					JOptionPane.INFORMATION_MESSAGE);
			return null;
		}
		HashMap valuesHM = new HashMap();
		CachedRowSet crs = null;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer("");
			if (procession_record.getID() == 0) {
				sqlSB.append("select* from ProcessionRecord");
			}
			if (procession_record.getID() != -1
					&& procession_record.getID() != 0) {
				sqlSB.append("select* from ProcessionRecord where id=").append(
						procession_record.getID());
			}
			crs = con.getResultSet(sqlSB.toString());
			while (crs.next()) {
				ProcessionRecord processionRecord = new ProcessionRecord();
				processionRecord.setID(crs.getInt(1));
				processionRecord.setGoodNotEqualID(crs.getInt(2));
				processionRecord.setOperater(crs.getInt(3));
				processionRecord.setOperateTime(crs.getString(4));
				processionRecord.setSuggestion(crs.getString(5));
				valuesHM.put(crs.getInt(1), processionRecord);
			}
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
		return valuesHM;
	}
}