admindealer.java

Email营销是在用户事先许可的前提下

package com.qq.content;

import java.sql.*;
//import javax.sql.*;
//import com.qq.content.*;
import java.util.ArrayList;
//import javax.sql.rowset.CachedRowSet;

public class adminDealer
{

	private Connection conn = null;
	private  Statement stat = null;
//	private  ResultSet rset = null;

	
	public adminDealer() throws SQLException,ClassNotFoundException,Exception
	{
	
		Class.forName("org.gjt.mm.mysql.Driver").newInstance();
		conn = java.sql.DriverManager.getConnection("jdbc:mysql://"+db_config.server+":"+db_config.port+"/"+db_config.db,db_config.user,db_config.password);
		stat = conn.createStatement();
		//conn.close();
	}
	
	public ResultSet dbQuery(String tsql) throws SQLException
	{
		ResultSet r;
		r = stat.executeQuery(tsql);
		return r;
	}
	
	public void dbclose() throws SQLException
	{
		conn.close();	
	}
	
	public String getPwd(String uname) throws Exception
	{
		String userPwd;
		String tsql = "";
		
		tsql = tsql +"select password from admin where username='"+uname +"'";
		
		System.out.println(tsql);
		ResultSet r=stat.executeQuery(tsql);
	
		if(r.next())
		{
			userPwd=r.getString("password");
		}
		else
		{
			userPwd = null;
		}
		r = null;
		return userPwd;
	}


	public ArrayList getAllAdmins() throws Exception{
		ArrayList list = new ArrayList();
		String sql = "select username, group_id from admin";
		ResultSet rs = dbQuery(sql);
		while(rs.next()){
			AdminsInfo info = new AdminsInfo();
			info.username = rs.getString("username");
			info.group_id  = rs.getInt("group_id");
			list.add(info);
		}
		return list;

	}
	
	public int getGroupID(String uname) throws Exception
	{
		int groupID;
		String tsql = "";
		
		tsql = tsql +"select group_id from admin where username='"+uname +"'";
		
		System.out.println(tsql);
		ResultSet r=stat.executeQuery(tsql);
		
		
		if(r.next())
		{
			groupID=r.getInt("group_id");
		}
		else
		{
			groupID = -1;
		}
		r = null;
		return groupID;
	}
	
	
	
	public int getUserID(String uname) throws Exception
	{
		int userID;
		String tsql = "";
		
		tsql = tsql +"select userid from admin where username='"+uname +"'";
		
		System.out.println(tsql);
		ResultSet r=stat.executeQuery(tsql);
		
		
		if(r.next())
		{
			userID = r.getInt("userid");
		}
		else
		{
			userID = -1;
		}
		r = null;
		return userID;
	}
	
    public int getTotal() throws SQLException
    {
    	
    	int ret;
    	String tsql= "";
    	tsql = tsql +"select count(*) from admin";
		ResultSet r=stat.executeQuery(tsql);

		if (r.next()) 
			ret = r.getInt(1); 
		else 
			ret = 0;	
			
		r = null;
			
		return ret;
		
    }	


 
 	public String getUnameByID(int id) throws Exception
 	{
 		String ret;
 		String tsql= "";
    	tsql = tsql +"select username from admin where userid="+id;
 		ResultSet r=stat.executeQuery(tsql);

		if(r.next())
			ret = r.getString("username"); 
		else
			ret = null;
		
		r = null;
		return ret;
   	   	
 	}
 
 
    	
   public  int testUser(String uname) throws SQLException
    {
    	
    	int ret;
    	String tsql= "";
    	tsql = tsql +"select count(*) from admin where username='"+uname +"'";
		ResultSet r=stat.executeQuery(tsql);

		if (r.next()) 
			ret = r.getInt(1); 
		else 
			ret = 0;	
			
		r = null;
			
		return ret;
		
    }




  
  	public int createUser(String name, String pwd, String gid)  throws Exception
  	{
  		String tsql="";

  		int num = testUser(name);
  		
  		if(num == 0 )
  		{
  			
  			int total = getTotal();
  			if(total < 0)
  				return -1;
  			tsql = "insert into admin values('" + name+"'," + "'',"+total+","+gid+",'')";
  		}
  		else//用户已存在，表明是更改用户权限
  		{
  			tsql = "update admin set group_id="+gid +" where username='"+name+"'";
  		}
  		
  		System.out.println(tsql);
  		try{
  		stat.execute(tsql);
  		}
  		catch(SQLException e)
  		{
  			System.out.println(e.getMessage());
  			return -1;
  		}

  		return 0;
  		
  	}
  	
 
    
  public int chpwd(String name, String pwd) throws Exception
  {
	if((name==null)||(pwd==null))
  		{
  			return -1;
  		}
  		if(testUser(name)==0)
  			return -1;
		String newpwd = Encode_md5.encode(pwd,"changeit");
  		String tsql = "update admin set password='"+newpwd+"' where username='"+name+"'";
  		stat.execute(tsql);
  		return 0;
  	
  }


  public int verifyPwd(String uname,String pwd) throws Exception
  {

		if((uname==null)||(pwd==null))
  		{
  			return -1;
  		}

		String dbpwd= getPwd(uname);

		if(dbpwd==null)
  		{
  			return -1;
  		}

		if((dbpwd.length()==0)&&(pwd.length()==0)) return 0;
		String newpwd = Encode_md5.encode(pwd,"changeit");
		if(newpwd.equals(dbpwd)) return 0;
		else 
			return 1;  	
  }
  
  
  
  	int getIDByUname(String uname) throws Exception
 	{
 		int ret;
 		String tsql= "";
    	tsql = tsql +"select userid from admin where username='"+uname+"'";
 		ResultSet r=stat.executeQuery(tsql);

		r.first();
		ret = r.getInt("userid"); 
		
		r = null;
		return ret;
   	   	
 	} 
  
  
  
  public int deleteUser(String user) throws Exception
  {

		int ret = testUser(user);
		if(ret<=0) return -1;
		String tsql = "";
		tsql= "delete from admin where username='"+user+"'";
		stat.execute(tsql);
		return 0;
	  	
  }
    
 


	public static void main(String [] args) throws Exception
	{
		adminDealer dD=new adminDealer();
		ResultSet rs = dD.dbQuery("select * from admin");
		rs.next();
		String nm = rs.getString("username");
		
		dD.dbclose();
		System.out.println(nm);
	}

}