waiterconsumeddao.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.WaiterInfo;

import common.dbconnection.DbConnection;


public class WaiterConsumedDao {
     
	  private Connection con = null;
	  private Statement sta = null;
	  private ResultSet res = null;
	  private Vector v = null;

//构造从数据库获得服务员信息的方法	  
	  public Vector getWaiterInfo() {
		    Vector v = null;
		    Connection con = null;
		    Statement stmt = null;
		    ResultSet set = null;
		    String sql = "select * from KTV_Waiter";
		    System.out.println(sql);
		    try {

		      con = new DbConnection().getConnection();
		      stmt = con.createStatement();
		      set = stmt.executeQuery(sql);
		      v = new Vector();
		      while (set.next()) {
		        int waiter_id = Integer.parseInt(set.getString(1));
		        String waiter_name = set.getString(2);
		        String waiter_sex = set.getString(3);
		        String tel = set.getString(4);
		        String area = set.getString(5);
		        String leveling = set.getString(6);

		        v.addElement(new WaiterInfo(waiter_id,waiter_name,waiter_sex,tel,area,leveling));
		      }
		    } catch (Exception e) {
		      System.out.println("异常信息: " + e.getMessage());
		    }
		    return v;
		  }  

//构造插入服务员信息的方法
  
public boolean insertWaiterInfo(WaiterInfo value) {

	boolean flag = false;
	Connection con = null;
	Statement stmt = null;
	ResultSet set = null;
	String sql = "insert into ktv_waiter(waiter_id,waiter_name,waiter_sex,waiter_tel,waiter_area,leveling)"
			+ " values('"
			+ value.getWaiter_id()
			+ "','"
			+ value.getWaiter_name()
			+ "','"
			+ value.getWaiter_sex()
			+ "','"
			+ value.getWaiter_tel()
			+ "','"
			+ value.getWaiter_area()
			+ "','"
			+ value.getLeveling()
			+ "')";

	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 updateWaiterInfo(WaiterInfo value) {
	boolean flag = false;
	Connection con = null;
	PreparedStatement stmt = null;
	ResultSet set = null;

	try {
		con = new DbConnection().getConnection();
		String sql = "update ktv_waiter set WAITER_ID='"
				+ value.getWaiter_id() + "', WAITER_NAME='"
				+ value.getWaiter_name() + "',WAITER_SEX='"
				+ value.getWaiter_sex() + "',WAITER_TEL='"
				+ value.getWaiter_tel() + "',WAITER_AREA'"
				+ value.getWaiter_area()+ "',LEVELING=" 
				+ value.getLeveling() + "'";
		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 boolean deleteWaiterInfo(String waiter_id) {
	boolean flag = false;
	Connection con = null;
	PreparedStatement stmt = null;
	ResultSet set = null;
	String sql = "delete from ktv_waiter where waiter_id =?";
	System.out.println(sql);
	try {
		con = new DbConnection().getConnection();
		stmt = con.prepareStatement(sql);
		stmt.setString(0, waiter_id);
		stmt.executeUpdate();
		flag = true;
	} catch (Exception e) {
		System.out.println("异常信息: " + e.getMessage());
	}
	return flag;
}
/**
 * 构造选中编辑记录的方法
 * 
 * @return
 */
public boolean findEditInfo(String waiter_id) {
  boolean flag = false;
  Connection con = null;
  PreparedStatement stmt = null;
  ResultSet set = null;
  String sql = "select * from ktv_waiter where waiter_id =?";
   System.out.println(sql);
  try {
    con = new DbConnection().getConnection();
    stmt = con.prepareStatement(sql);
    stmt.setString(1, waiter_id);
    stmt.executeUpdate();
    flag = true;
  } catch (Exception e) {
    System.out.println("异常信息: " + e.getMessage());
  }
  return flag;
}





}