adminoperation.java

该系统实现了网上购物及书店管理

package db;

import java.sql.*;

import bean.*;

import java.util.*;

public class AdminOperation {
	// Connection对象
	private Connection connection = null;

	// 查询的结果集
	private ResultSet resultSet = null;

	// PreparedStatement对象
	private java.sql.PreparedStatement preparedStatement = null;

	private boolean flag = false;

	// CallableStatement对象
	private java.sql.CallableStatement callableStatement = null;

	private int pagecount = 0;

	private int pagedata = 0;

	/**
	 * 取得pagecount的值
	 * 
	 * @return
	 */
	public int getSearchCountPage() {
		return this.pagecount;
	}

	/**
	 * 取得pagedata的值
	 * 
	 * @return
	 */
	public int getSearchCountdata() {
		return this.pagedata;
	}

	/**
	 * 配置数据库的连接信息，建立与数据库的连接
	 */
	public AdminOperation() {
		try {
			// 加载数据库的驱动程序类
			Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
			// 驱动于数据库的连接
			connection = DriverManager
					.getConnection(
							"jdbc:microsoft:sqlserver://127.0.0.1:1433;databasename=MyShop",
							"sa", "");
		} catch (SQLException ex) {

		} catch (ClassNotFoundException ex) {

		}

	}

	/**
	 * 验证用户的登陆信息
	 * 
	 * @param ab
	 * @return
	 */
	public boolean checkAdminLogin(AdminBean ab) {

		boolean result = false;
		try {
			// 查询Admin表的sql语句
			String sql = "select count(*) from Admin where UserName=? and UserPwd=?";
			// 创建PreparedStatement对象
			preparedStatement = connection.prepareStatement(sql);
			// 设置sql语句的第一个参数为用户名
			preparedStatement.setString(1, ab.getUserName());
			// 设置sql语句的第二个参数为用户密码
			preparedStatement.setString(2, ab.getUserPwd());
			// 执行查询操作
			resultSet = preparedStatement.executeQuery();
			// 如果查询结果不为空就说明该用户为合法用户
			if (resultSet.next()) {
				if (resultSet.getInt(1) > 0) {
					result = true;
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return result;
	}

	/**
	 * 分页返回所有的用户
	 * 
	 * @param count
	 * @param page
	 * @return
	 */
	public ArrayList getUsersList(int count, int page) {
		ArrayList list = new ArrayList();
		try {
			// 调用存储过程，创建CallableStatement对象
			callableStatement = connection
					.prepareCall("{call proc_users_page (?,?,?)}");
			// 设置callableStatement对象的第一个参数的值
			callableStatement.setInt(1, page);
			// 设置callableStatement对象的第二个参数的值
			callableStatement.setInt(2, count);
			// 设置callableStatement对象输出值为整形
			callableStatement.registerOutParameter(3, Types.INTEGER);
			// 执行查询
			resultSet = callableStatement.executeQuery();
			// 将查询到结果组装成UserBean对象放到list中
			while (resultSet.next()) {
				UserBean ub = new UserBean();
				ub.setUserId(resultSet.getInt(1));
				ub.setUserName(resultSet.getString(2));
				ub.setUserPwd(resultSet.getString(3));
				ub.setRealName(resultSet.getString(4));
				ub.setUserSex(resultSet.getInt(5));
				ub.setUserPhone(resultSet.getString(6));
				ub.setUserMail(resultSet.getString(7));
				ub.setUserCity(resultSet.getInt(8));
				ub.setUserAdds(resultSet.getString(9));
				ub.setUserCode(resultSet.getInt(10));
				ub.setUserWork(resultSet.getString(11));
				ub.setUserCard(resultSet.getString(12));
				ub.setUserStrp(resultSet.getInt(13));
				ub.setUserAge(resultSet.getInt(14));
				list.add(ub);
			}
			pagecount = callableStatement.getInt(3);
		} catch (SQLException ex) {
			System.out.println("服务器异常发生在 getUsersList()");
			ex.printStackTrace();
		}
		return list;
	}

	/**
	 * 插入新的管理员信息
	 * 
	 * @param admin
	 * @return
	 */
	public boolean insertAdmin(AdminBean admin) {
		try {
			// 创建插入管理员信息的PreparedStatemnet对象
			preparedStatement = connection
					.prepareStatement("insert into admin (userName,UserPwd) values(?,?)");
			// 设置preparedStatement对象的第一个参数
			preparedStatement.setString(1, admin.getUserName());
			// 设置preparedStatement对象的第二个参数
			preparedStatement.setString(2, admin.getUserPwd());
			// 执行更新操作
			int flag = preparedStatement.executeUpdate();
			if (flag == 0) {
				return false;
			}
		} catch (SQLException ex) {
			ex.printStackTrace();
			return false;
		}
		return true;

	}

	/**
	 * 取得等级信息
	 * 
	 * @param stepId
	 * @return
	 */
	public String getStep(int stepId) {
		try {
			// 查询Step信息的preparedStatement语句
			preparedStatement = connection
					.prepareStatement("select Display from Step where StepId=?");
			// 设置perparedStatment语句的第一个参数
			preparedStatement.setInt(1, stepId);
			// 执行查询
			resultSet = preparedStatement.executeQuery();
			// 将结果集指针后移
			resultSet.next();
			// 取得display字段的值
			return resultSet.getString("Display");
		} catch (SQLException ex) {

			return null;
		}

	}

	/**
	 * 取得书籍等级
	 * 
	 * @param stepId
	 * @return
	 */
	public String getBookStep(int stepId) {
		try {
			// 创建从BookStep取得BookStep信息的Statement对象
			preparedStatement = connection
					.prepareStatement("select Display from BookStep where BookStepId=?");
			// 设置preparedStatement对象的第一个参数
			preparedStatement.setInt(1, stepId);
			// 执行数据库查询操作
			ResultSet res = preparedStatement.executeQuery();
			// 将结果集指针后移
			res.next();
			// 取得结果集中的display字段的值
			return res.getString("Display");
		} catch (SQLException ex) {

			return null;
		}

	}

	/**
	 * 插入BookType信息
	 * 
	 * @param btb
	 * @return
	 */
	public boolean insertBookType(BookTypeBean btb) {
		try {
			// 往Type表中插入一条记录的Statement对象
			preparedStatement = connection
					.prepareStatement("insert into Type (Display) values('"
							+ btb.getDisplay() + "')");
			// 执行更新操作
			int flag = preparedStatement.executeUpdate();
			if (flag == 0) {
				return false;
			}
		} catch (SQLException ex) {
			ex.printStackTrace();
			return false;
		}
		return true;
	}

	/**
	 * 删除BookType信息
	 * 
	 * @param BookTypeId
	 * @return
	 */
	public boolean deleteBookType(int BookTypeId) {
		try {
			// 创建从Type表中删除记录的Statement对象
			preparedStatement = connection
					.prepareStatement("delete Type where TypeId=?");
			// 设置Statement对象的第一个参数
			preparedStatement.setInt(1, BookTypeId);
			// 执行删除操作
			int flag = preparedStatement.executeUpdate();
			if (flag == 0) {
				return false;
			}
		} catch (SQLException ex) {
			ex.printStackTrace();
			return false;
		}
		return true;
	}

	/**