consumedtypesettingdao.java

一个KTV管理系统

package dao.consumeddao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Vector;

import javax.swing.JOptionPane;

import vo.Room;
import vo.ConsumedTypeInfo;
import common.dbconnection.DbConnection;

//消费类型Dao
public class ConsumedTypeSettingDao {

	// 通过消费类型名称取得相应的折扣
	public double getRebate(String value) {
		Connection con = null;
		Statement stmt = null;
		ResultSet set = null;
		double rebate = 0d;
		String sql = "select * from ktv_consumed_type_info where CONSUMED_TYPE_NAME = '"
				+ value + "'";
		try {
			con = new DbConnection().getConnection();
			stmt = con.createStatement();
			set = stmt.executeQuery(sql);
			if (set.next()) {
				rebate = set.getDouble("REBATE");
				System.out.println("取得折扣成功");
			}
		} catch (Exception e) {
			System.out.println("异常信息: " + e.getMessage());
		}
		return rebate;
	}

	// 新建一条消费类型信息成功
	public boolean insertConsumedTypeInfo(ConsumedTypeInfo value) {

		boolean flag = false;
		Connection con = null;
		Statement stmt = null;
		ResultSet set = null;

		String sql = "insert into ktv_consumed_type_info(CONSUMED_TYPE_NAME,REBATE)"
				+ " values('"
				+ value.getConsumedTypeName().trim()
				+ "','"
				+ value.getRebate() + "')";

		System.out.println(sql);
		try {
			con = new DbConnection().getConnection();
			stmt = con.createStatement();
			set = stmt.executeQuery(sql);
			if (set.next()) {
				flag = true;
			}
		} catch (Exception e) {
			JOptionPane.showMessageDialog(null, "增加的消费类型"
					+ e.getMessage().substring(10), "插入提示",
					JOptionPane.YES_OPTION);
		}
		return flag;
	}

	// 删除一条消费类型信息
	public boolean deleteConsumedTypeInfo(String consumedTypeName) {
		boolean flag = false;
		Connection con = null;
		PreparedStatement stmt = null;
		ResultSet set = null;
		String sql = "delete from ktv_consumed_type_info where consumed_type_name ='"
				+ consumedTypeName.trim() + "'";
		System.out.println(sql);
		try {
			con = new DbConnection().getConnection();
			stmt = con.prepareStatement(sql);

			stmt.executeUpdate();
			flag = true;
		} catch (Exception e) {
			System.out.println("异常信息: " + e.getMessage());
		}
		return flag;
	}

	// 更新一条消费类型信息
	public boolean updateConsumedTypeInfo(ConsumedTypeInfo value) {
		boolean flag = false;
		Connection con = null;
		PreparedStatement stmt = null;
		ResultSet set = null;

		try {
			con = new DbConnection().getConnection();
			String sql = "update ktv_consumed_type_info set REBATE='"
					+ value.getRebate() + "' where CONSUMED_TYPE_NAME='"
					+ value.getConsumedTypeName() + "'";
			System.out.println(sql);
			stmt = con.prepareStatement(sql);
			set = stmt.executeQuery(sql);
			flag = true;
		} catch (Exception e) {
			System.out.println("异常信息: " + e.getMessage());
		}
		return flag;
	}

	// 取得所有消费类型信息
	public Vector getConsumedTypeInfo() {
		Vector v = null;
		Connection con = null;
		Statement stmt = null;
		ResultSet set = null;
		String sql = "select * from KTV_Consumed_type_INFO";
		System.out.println(sql);
		try {
			con = new DbConnection().getConnection();
			stmt = con.createStatement();
			set = stmt.executeQuery(sql);
			v = new Vector();
			while (set.next()) {
				String consumedTypeName = set.getString(1);
				double rebate = Double.parseDouble(set.getString(2));
				v.addElement(new ConsumedTypeInfo(consumedTypeName, rebate));
			}
		} catch (Exception e) {
			System.out.println("异常信息: " + e.getMessage());
		}
		return v;
	}
	


}