📄 userdao.java

📁 一套购物车项目。电子商务系统。实现了前台和后台的业务逻辑。
💻 JAVA
字号:
package com.softfz.jn0708.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import com.softfz.jn0708.bean.UserBean;
import com.softfz.jn0708.util.DateUtil;
import com.softfz.jn0708.util.SqlUtil;


/**
 * 用户信息操作DAO
 * @author student
 *
 */
public class UserDAO{

	/**
	 * 用户名和用户标识获取用户的详细信息
	 */
	public UserBean getUser(String username, int i) {
		UserBean bean = null;
		Connection conn = SqlUtil.getConn();
		PreparedStatement st = null;
		ResultSet rs = null;
		String sql = "select * from T_userinfo where username=? and userflag=?";
		
		try {
			st = conn.prepareStatement(sql);
			st.setString(1, username);
			st.setInt(2, i);
			rs = st.executeQuery();
			if (rs.next()) {
				bean = new UserBean();
				bean.setUserid(rs.getInt("USERID"));
				bean.setUsername(rs.getString("USERNAME"));
				bean.setTruename(rs.getString("TRUENAME"));	
				bean.setUpassword(rs.getString("UPASSWORD"));
				bean.setUsersex(rs.getString("USERSEX"));				
				bean.setUseremail(rs.getString("USEREMAIL"));
				bean.setUseraddress(rs.getString("USERADDRESS"));
				bean.setUserphone(rs.getString("USERPHONE"));
				bean.setUserborndate(rs.getString("USERBORNDATE"));
				bean.setUsercode(rs.getString("USERCODE"));
				bean.setUserwork(rs.getString("USERWORK"));
				bean.setUsermemo(rs.getString("USERMEMO"));
				bean.setUserflag(rs.getString("USERFLAG"));
				bean.setAddtime(rs.getString("ADDTIME"));
				bean.setIslocked(rs.getString("ISLOCKED"));			
				
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} finally {
			SqlUtil.tryToClose(rs, st, conn);
		}		
		return bean;
	}
	
	/**
	 * 用户ID获取用户的详细信息
	 */
	public UserBean getUserByID(String userid,String userflag) {
		UserBean bean = null;
		Connection conn = SqlUtil.getConn();
		PreparedStatement st = null;
		ResultSet rs = null;
		String sql = "select * from T_userinfo where userid=? and userflag=?";
		try {
			st = conn.prepareStatement(sql);
			st.setString(1, userid);
			st.setString(2, userflag);
			rs = st.executeQuery();
			if (rs.next()) {
				bean = new UserBean();
				bean.setUserid(rs.getInt("USERID"));
				bean.setUsername(rs.getString("USERNAME"));
				bean.setTruename(rs.getString("TRUENAME"));	
				bean.setUpassword(rs.getString("UPASSWORD"));
				bean.setUsersex(rs.getString("USERSEX"));				
				bean.setUseremail(rs.getString("USEREMAIL"));
				bean.setUseraddress(rs.getString("USERADDRESS"));
				bean.setUserphone(rs.getString("USERPHONE"));
				bean.setUserborndate(rs.getString("USERBORNDATE"));
				bean.setUsercode(rs.getString("USERCODE"));
				bean.setUserwork(rs.getString("USERWORK"));
				bean.setUsermemo(rs.getString("USERMEMO"));
				bean.setUserflag(rs.getString("USERFLAG"));
				bean.setAddtime(rs.getString("ADDTIME"));
				bean.setIslocked(rs.getString("ISLOCKED"));			
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} finally {
			SqlUtil.tryToClose(rs, st, conn);
		}		
		return bean;
	}
	
	
	/**
	 * 添加用户
	 */
	public boolean addUser(UserBean bean,String userflag) {
		boolean flag = false;
		Connection conn = SqlUtil.getConn();
		PreparedStatement st = null;
		ResultSet rs = null;
		try {
			st = conn.prepareStatement("insert into T_userinfo(USERID,USERNAME,TRUENAME,UPASSWORD,USERSEX,USEREMAIL,USERADDRESS,USERPHONE,USERBORNDATE,USERCODE,USERWORK,USERMEMO,USERFLAG,ADDTIME,ISLOCKED)values(SEQ_T_USERINFO.Nextval,?,?,?,?,?,?,?,?,?,?,?,?,?,?)");
			st.setString(1,bean.getUsername());
			st.setString(2,bean.getTruename());
			st.setString(3,bean.getUpassword());
			st.setString(4,bean.getUsersex());
			st.setString(5,bean.getUseremail());
			st.setString(6,bean.getUseraddress());
			st.setString(7,bean.getUserphone());
			st.setString(8,bean.getUserborndate());
			st.setString(9,bean.getUsercode());
			st.setString(10,bean.getUserwork());
			st.setString(11,bean.getUsermemo());
			st.setString(12,userflag);
			st.setString(13,DateUtil.getDateTime());	
			st.setString(14,bean.getIslocked());	
			st.executeUpdate();
			flag = true;

		}catch (SQLException e){
			e.printStackTrace();

		} finally {
			SqlUtil.tryToClose(rs, st, conn);
		}		
		return flag;		
	}

	/**
	 * 修改系统用户
	 */
	public boolean updateUser(UserBean bean,String userflag) {
		boolean flag = false;
		Connection conn = SqlUtil.getConn();
		PreparedStatement st = null;
		ResultSet rs = null;
		try {
			st = conn.prepareStatement("update T_userinfo set USERNAME=?,TRUENAME=?,UPASSWORD=?,USERSEX=?,USEREMAIL=?,USERADDRESS=?,USERPHONE=?,USERBORNDATE=?,USERCODE=?,USERWORK=?,USERMEMO=?,USERFLAG=?,ADDTIME=?,ISLOCKED=? where USERID = ?");
			st.setString(1,bean.getUsername());
			st.setString(2,bean.getTruename());
			st.setString(3,bean.getUpassword());
			st.setString(4,bean.getUsersex());
			st.setString(5,bean.getUseremail());
			st.setString(6,bean.getUseraddress());
			st.setString(7,bean.getUserphone());
			st.setString(8,bean.getUserborndate());
			st.setString(9,bean.getUsercode());
			st.setString(10,bean.getUserwork());
			st.setString(11,bean.getUsermemo());
			st.setString(12,userflag);
			st.setString(13,DateUtil.getDateTime());	
			st.setString(14,bean.getIslocked());
			st.setInt(15,bean.getUserid());	
			st.executeUpdate();
			flag = true;

		}catch (SQLException e){
			e.printStackTrace();

		} finally {
			SqlUtil.tryToClose(rs, st, conn);
		}		
		return flag;		
	}
	
	/**
	 * 删除系统用户
	 */
	public boolean del(String userid) {
		boolean flag = false;
		Connection conn = SqlUtil.getConn();
		PreparedStatement st = null;
		ResultSet rs = null;
		try {
			st = conn.prepareStatement("delete T_userinfo where userid = ?");
			st.setString(1,userid);
			st.executeUpdate();
			flag = true;

		}catch (SQLException e){
			e.printStackTrace();

		} finally {
			SqlUtil.tryToClose(rs, st, conn);
		}		
		return flag;		
	}	
	
	/**
	 * 获取注册用户列表
	 * @param currentPage 当前页码
	 * @param count当前显示页数
	 * @param user 用户Bean对象
	 * @return
	 */
	public List getRegUser(int currentPage, int count, UserBean user) {
		StringBuffer sql = new StringBuffer();
		sql.append("SELECT * FROM(")
		.append("select tu.*,ROWNUM AS num from T_userinfo tu where userflag=0")
		.append(")t WHERE ");
		sql.append(" t.num<=").append(currentPage*count);
		sql.append(" AND t.num>").append((currentPage-1)*count);
		sql.append(" order by t.userid");
		Connection conn = null;
		Statement st = null;
		ResultSet rs = null;
		conn = SqlUtil.getConn();
		List list = null;
		try {
			st = conn.createStatement();
			rs = st.executeQuery(sql.toString());
			list = new ArrayList();
			while (rs.next()) {
				user = new UserBean();				
				user.setUserid(rs.getInt("USERID"));
				user.setUsername(rs.getString("USERNAME"));
				user.setTruename(rs.getString("TRUENAME"));	
				user.setUpassword(rs.getString("UPASSWORD"));
				user.setUsersex(rs.getString("USERSEX"));				
				user.setUseremail(rs.getString("USEREMAIL"));
				user.setUseraddress(rs.getString("USERADDRESS"));
				user.setUserphone(rs.getString("USERPHONE"));
				user.setUserborndate(rs.getString("USERBORNDATE"));
				user.setUsercode(rs.getString("USERCODE"));
				user.setUserwork(rs.getString("USERWORK"));
				user.setUsermemo(rs.getString("USERMEMO"));
				user.setUserflag(rs.getString("USERFLAG"));
				user.setAddtime(rs.getString("ADDTIME"));
				user.setIslocked(rs.getString("ISLOCKED"));					
				list.add(user);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			SqlUtil.tryClose(rs, st, conn);
		}

		return list;
	}
	
	/**
	 * 获取系统用户列表
	 * @param currentPage 当前显示页码
	 * @param count 当前显示页数
	 * @param user 用户Bean对象
	 * @return
	 */
	public List getSysUser(int currentPage, int count, UserBean user) {
		StringBuffer sql = new StringBuffer();
		sql.append("SELECT * FROM(")
		.append("select tu.*,ROWNUM AS num from T_userinfo tu where userflag=1")
		.append(")t WHERE ");
		sql.append(" t.num<=").append(currentPage*count);
		sql.append(" AND t.num>").append((currentPage-1)*count);
		sql.append(" order by t.userid");
		Connection conn = null;
		Statement st = null;
		ResultSet rs = null;
		conn = SqlUtil.getConn();
		List list = null;
		try {
			st = conn.createStatement();
			rs = st.executeQuery(sql.toString());
			list = new ArrayList();
			while (rs.next()) {
				user = new UserBean();				
				user.setUserid(rs.getInt("USERID"));
				user.setUsername(rs.getString("USERNAME"));
				user.setTruename(rs.getString("TRUENAME"));	
				user.setUpassword(rs.getString("UPASSWORD"));
				user.setUsersex(rs.getString("USERSEX"));				
				user.setUseremail(rs.getString("USEREMAIL"));
				user.setUseraddress(rs.getString("USERADDRESS"));
				user.setUserphone(rs.getString("USERPHONE"));
				user.setUserborndate(rs.getString("USERBORNDATE"));
				user.setUsercode(rs.getString("USERCODE"));
				user.setUserwork(rs.getString("USERWORK"));
				user.setUsermemo(rs.getString("USERMEMO"));
				user.setUserflag(rs.getString("USERFLAG"));
				user.setAddtime(rs.getString("ADDTIME"));
				user.setIslocked(rs.getString("ISLOCKED"));					
				list.add(user);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			SqlUtil.tryClose(rs, st, conn);
		}

		return list;
	}
	/**
	 * 冻结和解冻用户	  
	 *  0为解冻用户，1为冻结用户
	 */
	public boolean lock(String userid, String islocked) {
		Connection conn = SqlUtil.getConn();
		PreparedStatement ps = null;
		ResultSet rs = null;
		String Sql = null;
		boolean flag = false;
		try {
			if (userid != null) {
				Sql = "update T_userinfo set islocked=? where userid=?";
				ps = conn.prepareStatement(Sql);
				ps.setString(1, islocked);
				ps.setString(2, userid);
				int i = ps.executeUpdate();
				if (i > 0) {
					flag = true;
				}
			}
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			// 关闭连接
			SqlUtil.tryToClose(rs, ps, conn);
		}
		return flag;
	}

	/**
	 * 通过用户ID和用户名查找用户信息
	 * @param userid 用户ID
	 * @param username 用户名
	 * @param i
	 * @return
	 */
	public UserBean getsUser(String userid, String username, int i) {
		UserBean bean = null;
		Connection conn = SqlUtil.getConn();
		PreparedStatement st = null;
		ResultSet rs = null;
		String sql = "select * from T_userinfo where username=? and userflag=? and userid!=?";
		
		try {
			st = conn.prepareStatement(sql);
			st.setString(1, username);
			st.setInt(2, i);
			st.setString(3, userid);
			rs = st.executeQuery();
			if (rs.next()) {
				bean = new UserBean();
				bean.setUserid(rs.getInt("USERID"));
				bean.setUsername(rs.getString("USERNAME"));
				bean.setTruename(rs.getString("TRUENAME"));	
				bean.setUpassword(rs.getString("UPASSWORD"));
				bean.setUsersex(rs.getString("USERSEX"));				
				bean.setUseremail(rs.getString("USEREMAIL"));
				bean.setUseraddress(rs.getString("USERADDRESS"));
				bean.setUserphone(rs.getString("USERPHONE"));
				bean.setUserborndate(rs.getString("USERBORNDATE"));
				bean.setUsercode(rs.getString("USERCODE"));
				bean.setUserwork(rs.getString("USERWORK"));
				bean.setUsermemo(rs.getString("USERMEMO"));
				bean.setUserflag(rs.getString("USERFLAG"));
				bean.setAddtime(rs.getString("ADDTIME"));
				bean.setIslocked(rs.getString("ISLOCKED"));			
				
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} finally {
			SqlUtil.tryToClose(rs, st, conn);
		}		
		return bean;
	}



	
}
⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -