operatorsettingdao.java

一个KTV管理系统

package dao.operator;

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.ConsumedTypeInfo;
import vo.Operator;

import common.dbconnection.DbConnection;

public class OperatorSettingDao {
	public boolean insertOperatorInfo(Operator value) {

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

		String sql = "insert into ktv_operator_info(OPERATOR_ID,OPERATOR_NAME,OPERATOR_LEVEL,PASSWORD)"
				+ " values('"
				+ value.getOperatorId()
				+ "','"
				+ value.getOperatorName()
				+ "','"
				+ value.getOperatorLevel()
				+ "','123')";

		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 deleteOperatorInfo(String operatorId) {
		boolean flag = false;
		Connection con = null;
		PreparedStatement stmt = null;
		ResultSet set = null;
		String sql = "delete from ktv_operator_info where operator_Id ='"
				+ operatorId.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 updateOperatorInfo(Operator value) {
		boolean flag = false;
		Connection con = null;
		PreparedStatement stmt = null;
		ResultSet set = null;

		try {
			con = new DbConnection().getConnection();
			String sql = "update ktv_operator_info set OPERATOR_NAME='"
					+ value.getOperatorName() + "' ,operator_level= '"
					+ value.getOperatorLevel() + "'where OPERATOR_ID='"
					+ value.getOperatorId() + "'";
			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 getOperatorInfo() {
		Vector v = null;
		Connection con = null;
		Statement stmt = null;
		ResultSet set = null;
		String sql = "select * from KTV_operator_INFO";
		System.out.println(sql);
		try {

			con = new DbConnection().getConnection();
			stmt = con.createStatement();
			set = stmt.executeQuery(sql);
			v = new Vector();
			while (set.next()) {
				int OPERATOR_ID = Integer.parseInt(set.getString(1));
				String OPERATOR_NAME = set.getString(2);
				String OPERATOR_LEVEL = set.getString(3);
				String PASSWORD = set.getString(4);

				v.addElement(new Operator(OPERATOR_ID, OPERATOR_NAME,
						OPERATOR_LEVEL, PASSWORD));
			}
		} catch (Exception e) {
			System.out.println("异常信息: " + e.getMessage());
		}
		return v;
	}

}