employinfomanager.java

关于商品的进、销、存管理系统

package supercms;
import superdb.*;
import supershopmanager.*;

import java.util.*;
import java.sql.*;
/*
 * 完成对员工信息的插入，删除。查询。修改功能
 * 
 * 
 * 
 * */
public class EmployInfoManager {
	private SuperDBConn sdb;
	private SuperInfoManager sim;
	private Statement stmt;
	public EmployInfoManager()
	{
		sdb=new SuperDBConn();
		sim=new SuperInfoManager(sdb.getConn());
		stmt=sim.getStmt();
	}
	/*------------完成对员工信息的插入--------------*/
	public void addEmployInfo(EmployInfo employInfo)
	{
		String sql="insert into employinfo(employname," +
				"employpassword," +
				"roleid)values('"+employInfo.getEmployname()+"'," +
				"'"+employInfo.getEmploypassword()+"','"+employInfo.getRoleid()+"')";
		try
		{
		stmt.executeUpdate(sql);
		System.out.println("员工信息插入---------成功！！！！");
		}catch(Exception e)
		{
			System.out.println("员工信息插入---------失败！！！！");
		}
	}
	/*-------------完成对员工信息的查询--------------*/
	public Vector selectEmployInfo(EmployInfo employInfo,int type)
	{
		Vector allEmployInfo=new Vector();
		
		String sql="";
		if(type==1)//说明按员工编号查询
		{
		 sql="select * from employinfo where employid="+employInfo.getEmployid();
		}
		if(type==2)//说明按员工姓名进行查询
		{
			sql="select * from employinfo where employname='"+employInfo.getEmployname()+"'";
		}
		try
		{
			ResultSet rs=stmt.executeQuery(sql);//执行查询
			while(rs.next())
			{
				EmployInfo ei=new EmployInfo();
				ei.setEmployid(rs.getInt("employid"));
				ei.setEmployname(rs.getString("employname"));
				ei.setRoleid(rs.getInt("roleid"));
				allEmployInfo.addElement(ei);
				System.out.println("员工信息查询------成功！！！！");
				
			}
			
		}catch(Exception e)
		{
			e.printStackTrace();
			System.out.println("员工信息查询------失败！！！！");
		}
		
		
		return allEmployInfo;
	}
	/*-------------------完成对员工信息的修改------------------*/
	public void updateEmployInfo(EmployInfo employInfo)
	{
		String sql="update employinfo set employname='"+employInfo.getEmployname()+"'," +
				"roleid='"+employInfo.getRoleid()+"' where employid="+employInfo.getEmployid();
		try
		{
		stmt.executeUpdate(sql);
		System.out.println("员工信息修改------成功！！！！");
		}catch(Exception e)
		{
			System.out.println("员工信息修改------失败！！！！");
		}
	}
	/*--------------完成员工信息的删除--------------*/
	public void deleteEmployInfo(EmployInfo employInfo)
	{
		String sql="DELETE from employinfo where employid="+employInfo.getEmployid();
		try
		{
		stmt.executeUpdate(sql);
		System.out.println("员工信息删除------成功！！！！");
		}catch(Exception e)
		{
			System.out.println("员工信息删除------失败！！！！");
		}
		
	}
	 /*------查询分页-----*/
	  
	public List getAllInfo(int pagesize,int nowpage) throws Exception
	{List allinfo=new ArrayList();
	String sql="select * from employinfo order by employid";	
	  ResultSet rs=stmt.executeQuery(sql);
	  rs.last();// 定位到最后一条记录
	  int rows=rs.getRow();
	  int num=pagesize;
	  int pagecount=rows/pagesize;//总页数
	  if(rows%pagesize>0){pagecount++;}
	  if(nowpage>0&&nowpage<=pagecount)
	  {
		if(nowpage==1){rs.beforeFirst();}
		if(nowpage>1){rs.absolute((nowpage-1)*pagesize);}
	  while(rs.next()&&num>0)
	  { 
		  EmployInfo ei=new EmployInfo();
		  ei.setEmployid(rs.getInt("employid"));
		  ei.setEmployname(rs.getString("employname"));
		  ei.setEmploypassword(rs.getString("employpassword"));
		  ei.setRoleid(rs.getInt("roleid"));
		

		  
	    num--;
	    allinfo.add(ei);
	  }
	  return allinfo;
	 }
	  return null;
	}
  
	public int getcount()throws Exception
	{
		int count=0;
		String sql="select * from employinfo order by employid";
		 ResultSet rs=stmt.executeQuery(sql);
		 rs.last();
		 count=rs.getRow();
		return count;
	}

}