adminusersbean.java

j2ee框架下的mvc模式的一个网上销售系统

package com.qrsx.buyflowers.beans;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Collection;

public class AdminUsersBean extends DBConnection {

	public AdminUsersBean() throws ClassNotFoundException, SQLException {
		super();
		// TODO Auto-generated constructor stub
	}

	private UsersClass usersClass;

	private Collection collection = null;

	private PreparedStatement ptst = null;

	private ResultSet rs = null;

	// 设置实体
	public void setUserInfo(UsersClass usersClass) {
		this.usersClass = usersClass;
	}

	// 添加管理员
	public void addUserInfo() {
		String sql = "insert into users(usersName,usersPass,usersRepass,usersPassQuestion,usersPassReply,usersTrueName,usersAddress,usersPhone,usersE_mail) values(?,?,?,?,?,?,?,?,?);";
		try {
			ptst = con.prepareStatement(sql);
			ptst.setString(1, this.usersClass.getUsersName());
			ptst.setString(2, this.usersClass.getUsersPass());
			ptst.setString(3, this.usersClass.getUsersRepass());
			ptst.setString(4, this.usersClass.getUsersPassQuestion());
			ptst.setString(5, this.usersClass.getUsersPassReply());
			ptst.setString(6, this.usersClass.getUsersTrueName());
			ptst.setString(7, this.usersClass.getUsersAddress());
			ptst.setString(8, this.usersClass.getUsersPhone());
			ptst.setString(9, this.usersClass.getUsersE_mail());
			ptst.executeUpdate();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

//	 按管理员ID删除管理员
	public void deleteUser(String usersId) {
		String sql = "delete from users where usersId=?;";
		try {
			ptst = con.prepareStatement(sql);
			ptst.setString(1, usersId);
			ptst.executeUpdate();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
//	获取所有的用户信息
	public Collection getAllUserInfo(){
		String sql="select * from users;";
		
		
		try {
			ptst=con.prepareStatement(sql);
			rs=ptst.executeQuery();
			collection=new ArrayList();
			while(rs.next()){
				usersClass=new UsersClass();
				usersClass.setUsersName(rs.getString("usersName"));
				usersClass.setUsersId(rs.getString("usersId"));
				usersClass.setUsersPass(rs.getString("usersPass"));
				usersClass.setUsersRepass(rs.getString("usersRepass"));
				usersClass.setUsersPassQuestion(rs.getString("usersPassQuestion"));
				usersClass.setUsersPassReply(rs.getString("usersPassReply"));
				usersClass.setUsersTrueName(rs.getString("usersTrueName"));
				usersClass.setUsersAddress(rs.getString("usersAddress"));
				usersClass.setUsersPhone(rs.getString("usersPhone"));
				usersClass.setUsersE_mail(rs.getString("usersE_mail"));
				collection.add(usersClass);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return collection;
	}
	
	// 按姓名查询
	public Collection getUserByUserName(String usersName) {
		String sql = "select * from users where usersName=?;";

		try {

			ptst = con.prepareStatement(sql);
			ptst.setString(1, usersName);
			rs = ptst.executeQuery();
			collection = new ArrayList();
			while (rs.next()) {
				usersClass=new UsersClass();
				usersClass.setUsersName(rs.getString("usersName"));
				usersClass.setUsersId(rs.getString("usersId"));
				usersClass.setUsersPass(rs.getString("usersPass"));
				usersClass.setUsersRepass(rs.getString("usersRepass"));
				usersClass.setUsersPassQuestion(rs.getString("usersPassQuestion"));
				usersClass.setUsersPassReply(rs.getString("usersPassReply"));
				usersClass.setUsersTrueName(rs.getString("usersTrueName"));
				usersClass.setUsersAddress(rs.getString("usersAddress"));
				usersClass.setUsersPhone(rs.getString("usersPhone"));
				usersClass.setUsersE_mail(rs.getString("usersE_mail"));
				collection.add(usersClass);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

		return collection;

	}

	// 按ID查询
	public Collection getUserByUserId(String usersId) {
		String sql = "select * from  users where usersId=?;";

		try {
			ptst = con.prepareStatement(sql);
			ptst.setString(1, usersId);
			rs = ptst.executeQuery();
			collection = new ArrayList();
			while (rs.next()) {
				usersClass=new UsersClass();
				usersClass.setUsersName(rs.getString("usersName"));
				usersClass.setUsersId(rs.getString("usersId"));
				usersClass.setUsersPass(rs.getString("usersPass"));
				usersClass.setUsersRepass(rs.getString("usersRepass"));
				usersClass.setUsersPassQuestion(rs.getString("usersPassQuestion"));
				usersClass.setUsersPassReply(rs.getString("usersPassReply"));
				usersClass.setUsersTrueName(rs.getString("usersTrueName"));
				usersClass.setUsersAddress(rs.getString("usersAddress"));
				usersClass.setUsersPhone(rs.getString("usersPhone"));
				usersClass.setUsersE_mail(rs.getString("usersE_mail"));
				collection.add(usersClass);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

		return collection;
	}
}