consumeitemoperate.java

JAVA实现的酒店管理系统

package file1;

/*
 * Description:实现对ConsumeItem类的调用，并根据ConsumeItem对象的属性值进行相应的数据库的存取
 * @Author:黄顺武
 * Create Time:2007-12-21
 */
import java.sql.SQLException;
import java.util.ArrayList;
import javax.swing.JOptionPane;
import sun.jdbc.rowset.CachedRowSet;

public class ConsumeItemOperate implements Operate {

	public ConsumeItemOperate() {
	}

	public void insertToDB(Object object) {// 往数据库中插入消费项目时调用的方法
		ConsumeItem consume_item = (ConsumeItem) object;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer(
					"insert into ConsumeItems values('");
			if (consume_item.getItem_name().equals("")) {
				JOptionPane.showMessageDialog(null, "消费项目名称不能为空!", "",
						JOptionPane.INFORMATION_MESSAGE);
				return;
			}
			sqlSB.append(consume_item.getItem_name()).append("')");
			con.addSql(sqlSB.toString());
			con.doDML();
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
	}

	public void deleteFromDB(Object object) {// 从数据库中删除消费项目时调用的方法
		ConsumeItem consume_item = (ConsumeItem) object;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer(
					"delete from ConsumeItems where ID=");
			if (consume_item.getID() == -1) {
				JOptionPane.showMessageDialog(null, "要删除的消费项目不能为空!", "",
						JOptionPane.INFORMATION_MESSAGE);
				return;
			}
			sqlSB.append(consume_item.getID());
			con.addSql(sqlSB.toString());
			con.doDML();
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
	}

	public void modifyToDB(Object object) {// 修改消费项目时调用的方法
		ConsumeItem consume_item = (ConsumeItem) object;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer("update ConsumeItems set ");
			if (consume_item.getID() == -1) {
				JOptionPane.showMessageDialog(null, "要更新的消费项目不能为空!", "",
						JOptionPane.INFORMATION_MESSAGE);
				return;
			}
			if (consume_item.getItem_name().equals("")) {
				JOptionPane.showMessageDialog(null, "要更新的消费项目名称不能为空!", "",
						JOptionPane.INFORMATION_MESSAGE);
				return;
			}
			sqlSB.append("itemName='").append(consume_item.getItem_name())
					.append("' ");
			sqlSB.append("where id=").append(consume_item.getID());
			con.addSql(sqlSB.toString());
			con.doDML();
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
	}

	public ArrayList selectFromDB(Object object) {// 查询消费项目时调用的方法
		ConsumeItem consume_item = new ConsumeItem();
		if (consume_item.getID() == -1) {
			JOptionPane.showMessageDialog(null, "要查询的消费项目id不能为空!", "",
					JOptionPane.INFORMATION_MESSAGE);
			return null;
		}
		ArrayList valuesList = new ArrayList();
		CachedRowSet crs = null;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer("");
			if (consume_item.getID() == 0) {// 表示查询数据库中的全部消费项目，传参数的时候一定要注意
				sqlSB.append("select* from ConsumeItems ");
			}
			if (consume_item.getID() != -1 && consume_item.getID() != 0) {// 表示查询数据库中的某一消费项目，传参数的时候一定要注意
				sqlSB.append("select* from ConsumeItems where id="
						+ consume_item.getID());
			}
			crs = con.getResultSet(sqlSB.toString());
			while (crs.next()) {
				ConsumeItem consume_item_temp = new ConsumeItem();
				consume_item_temp.setID(crs.getInt(1));
				consume_item_temp.setItem_name(crs.getString(2));
				valuesList.add(consume_item_temp);
			}
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
		return valuesList;
	}
}