userbean.java

商品管理系统

package com.accp.struts.Bean;

import java.sql.*;
import com.accp.struts.form.*;

public class UserBean {
	Connection con;
	PreparedStatement psm;
	ResultSet rs;
	
	//连接数据库
	public UserBean(){
		try{
			Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
			con=DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;databasename=shops","sa","sa");
			System.out.print("OK");
		}catch(SQLException ex){
			
		}catch(Exception ex){
			
		}
	}
	
	// 用户登陆方法
	public String logoUser(UserLogoForm lf){
		try{
			String sql="select * from [user] where user_name=? and password=?";
			psm=con.prepareStatement(sql);
			psm.setString(1,lf.getUser_name());
			psm.setString(2,lf.getPassword());
			rs=psm.executeQuery();
			if(rs.next()){
				return rs.getString(4);
			}else{
				return null;
			}
		}catch(SQLException ex){
			System.out.println(ex.getMessage());
			return null;
		}
	}
	
	//添加新用户
	public boolean addUser(UserLogoForm lf){
		try{
			String sql="insert into [user] values(?,?,?)";
			psm=con.prepareStatement(sql);
			psm.setString(1, lf.getUser_name());
			psm.setString(2, lf.getPassword());
			psm.setString(3,lf.getPrivil());
			int i=psm.executeUpdate();
			if(i>0)return true;
			else  return false;
		}catch(SQLException ex){
			System.out.println(ex);
			return false;
		}
	}
	
	//删除用户 
	public boolean delUser(UserLogoForm lf){
		try{
			String sql="delete [user] where user_id=?";
			psm=con.prepareStatement(sql);
			psm.setInt(1,lf.getUser_id());
			int i=psm.executeUpdate();
			if(i>0)return true;
			else return false;
		}catch(SQLException ex){
			System.out.println(ex.getMessage());
			return false;
		}
	}
	
	//修改用户密码
	public boolean updateUser(String pwd,String name){
		try{
			String sql="update [user] set password=?  where user_name=?";
			psm=con.prepareStatement(sql);
			psm.setString(1,pwd);
			psm.setString(2,name);
			int i=psm.executeUpdate();
			if(i>0){
				
				return true;
			}else{
				return false;
			}
			
		}catch(SQLException ex){
			System.out.println("updateuser方法有错");
			System.out.println(ex.getMessage());
			return false;
		}
	}
//	修改用户权限
	public boolean updatePrivil(UserLogoForm lf){
		try{
			String sql="update [user] set privil=?  where user_name=?";
			psm=con.prepareStatement(sql);
			psm.setString(1,lf.getPrivil());
			psm.setString(3,lf.getUser_name());
			psm.executeQuery();
			return true;
		}catch(SQLException ex){
			
			System.out.println(ex);
			return false;
		}
			
	
	}
	
	//查找所有用户的方法
	public ResultSet selectAllUser(){
		try{
			String sql="select * from [user]";
			psm=con.prepareStatement(sql);
			rs=psm.executeQuery();
			return rs;
			
		}catch(SQLException ex){
			System.out.println(ex);
			return null;
		}
	}
	
	//关闭的方法
	public void close(){
		try{
			if(rs!=null)rs.close();
			if(psm!=null)psm.close();
			if(con!=null)con.close();
		}catch(SQLException ex){
			System.out.println(ex);
		}
	}
}