goodbuyoperate.java

JAVA实现的酒店管理系统

package file1;

/*
 * 功能描述：实现对进货记录封装类GoodBuy的调用，然后存取数据库
 * @Author:黄顺武
 * Create Time:2007-12-18
 */
import java.sql.*;
import java.util.*;
import javax.swing.*;
import sun.jdbc.rowset.*;

public class GoodBuyOperate {

	public GoodBuyOperate() {
	}

	public void insertToDB(Object object) {// 增加进货记录时调用的方法
		GoodBuy gb = (GoodBuy) object;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer("insert into GoodBuy values(");
			sqlSB.append(gb.getGood_ID()).append(",");
			sqlSB.append(gb.getNumber_Buy()).append(",'");
			sqlSB.append(gb.getDate_Buy()).append("')");
			con.addSql(sqlSB.toString());// 插入记录
			String sqlUpdate = "update Good set storeIn=storeIn+"
					+ gb.getNumber_Buy() + " where ID=" + gb.getGood_ID();
			con.addSql(sqlUpdate);// 更新Good表
			con.doDML();
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
	}

	public void deleteFromDB(Object object) {// 删除进货记录时调用的方法
		GoodBuy gb = (GoodBuy) object;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer(
					"delete from GoodBuy where ID=");
			if (gb.getID() == -1) {
				JOptionPane.showMessageDialog(null, "要删除的进货记录不能为空!", "",
						JOptionPane.INFORMATION_MESSAGE);
				return;
			}
			sqlSB.append(gb.getID());
			con.addSql(sqlSB.toString());
			con.doDML();
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
	}

	public void modifyToDB(Object object) {// 修改进货记录时调用的方法

		GoodBuy gb = (GoodBuy) object;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer("update GoodBuy set");
			sqlSB.append(" good_id=").append(gb.getGood_ID()).append(",");
			sqlSB.append("number_buy=").append(gb.getNumber_Buy()).append(",");
			sqlSB.append("date_buy='").append(gb.getDate_Buy()).append("' ");
			sqlSB.append("where id=").append(gb.getID());
			con.addSql(sqlSB.toString());
			String sqlUpdate = "update Good set storeIn=storeIn+"
					+ gb.getProperty("difference") + " where ID="
					+ gb.getGood_ID();
			con.addSql(sqlUpdate);// 更新Good表
			con.doDML();
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
	}

	public HashMap selectFromDB(Object object) {// 查询进货记录时调用的方法

		GoodBuy gb = (GoodBuy) object;
		HashMap valuesHM = new HashMap();
		CachedRowSet crs = null;
		try {
			DBConnection con = new DBConnection();
			StringBuffer sqlSB = new StringBuffer("");
			if (gb.getID() == 0) {// 表示查询数据库中的全部进货记录，传参数的时候一定要注意
				sqlSB
						.append("select GoodBuy.ID,good_id,goodName,typeID,typeName,number_buy,date_buy from GoodBuy,Good,GoodType where good_id=Good.ID and Good.typeID=GoodType.ID");
			}
			if (gb.getID() != -1 && gb.getID() != 0) {// 表示查询数据库中的某一进货记录，传参数的时候一定要注意
				sqlSB
						.append("select GoodBuy.ID,good_id,goodName,typeID,typeName,number_buy,date_buy from GoodBuy,Good,GoodType where good_id=Good.ID and Good.typeID=GoodType.ID and  GoodBuy.ID="
								+ gb.getID());
			}
			crs = con.getResultSet(sqlSB.toString());
			while (crs.next()) {
				GoodBuy goodBuy = new GoodBuy();
				goodBuy.setID(crs.getInt(1));
				goodBuy.setGood_ID(crs.getInt(2));
				goodBuy.setProperty("goodName", crs.getString(3).trim());
				goodBuy.setProperty("typeID", crs.getInt(4));
				goodBuy.setProperty("typeName", crs.getString(5).trim());
				goodBuy.setNumber_Buy(crs.getInt(6));
				goodBuy.setDate_Buy(crs.getString(7).trim());
				valuesHM.put(crs.getInt(1), goodBuy);
			}
		} catch (ClassNotFoundException cnfe) {
			cnfe.printStackTrace();
		} catch (SQLException sqle) {
			sqle.printStackTrace();
		}
		return valuesHM;
	}
}