usertable.java

这是基于jsp的相册管理系统。数据库是mysql

package huitong.util.db;

import huitong.javabean.*;
import huitong.util.*;
import java.sql.*;
public class UserTable 
{
	private String encoding(String str)
	{
		try
		{
			str = new String(str.getBytes("iso-8859-1"));
			return str;
		}
		catch( Exception e)
		{
			e.printStackTrace();
		}
		return null;
	}
   public boolean addUser(User user)
   {//添加到数据库中，并建立相应的文件夹
	   String insertSQL = "insert into users (userName,userAlia,userPWD,userType,userEmail)" +  
	   		            " values("+
	                     "'"+user.getUserName()+"','"+encoding(user.getUserAlia())+"','"+user.getUserPWD()+"'," +
	                     user.getUserType() +",'"+user.getUserEmail()+"')";
	   System.out.println(insertSQL);
	   if (new Folder().create(user.getUserName()))
	   {//如果文件创建成功
		   if ( new Connecter().insert(insertSQL))
		   {//如果数据库操作成功
			   return true;
		   }
		   else
		   {//数据可操作不成功
			   System.out.print("数据库操作失败");
			   new Folder().del(user.getUserName());
			   System.out.println(",删除已建立的文件夹"+user.getUserName());
			   return false;
		   }
	   }
	   System.out.println("文件夹创建失败");
	   return false;
   }
  
   public boolean hasUser(String userName,String userPWD,int userType)
   {
	   if (userName == null || userPWD == null) return false;
	   String query = "select * from users where userName='_"+userName+"' and userPWD='"+userPWD+"' and userType="+userType;
	  System.out.println(query);
	   ResultSet result = new Connecter().getResultSet(query);
	   try
	   {
		   if (result.next())
			   return true;
	   }
	   catch (SQLException e)
	   {
		   e.printStackTrace();
	   }
	  
	   return false;
	   
   }
   
   public User getUser(String userName)
   {
	   if (userName == null) return null;
	   String query = "select * from users where userName='"+userName+"'";
	   ResultSet result = new Connecter().getResultSet(query);
	   return User.getUser(result);
   }
   
   public boolean modifyUser(User user)
   {
	   String modifySQL = "update users  set " +
                            "userAlia = '"+user.getUserAlia()+"',"+
	                        "userPWD = '"+user.getUserPWD()+"',"+
	                        "userEmail = '"+user.getUserEmail()+"'"+
	                         "  where  userName ='"+user.getUserName()+"'";
	   		
	  if( new Connecter().update(modifySQL) ==1) return true;
	   return false;
   }
  
   public boolean delUser(String userName)
   {//把访问状态设置为-1，并且修改用户名为系统时间，改变所有与之相关的数据表
	   if (userName == null) return false;
	   String delSQL = "delete users where userName='"+userName+"'";
	   return new Connecter().delete(delSQL);
   }
  
   public int getUserCount()
   {
	   String queryAll = "select userName from users ";
	  ResultSet result= new Connecter().getResultSet(queryAll);
	  try
	  {
		  result.last();
		  //result.afterLast();
		  int rowCount = result.getRow();;
		  System.out.println("resultSet rowCount = "+rowCount);
		   return rowCount;
	  }
	  catch (SQLException e)
	  {
		  e.printStackTrace();
	  }
	   return 0;
   }
}