bankdao.java

程序为银行管理系统,分为四个子模块,分别为人事管理系统,计算机管理系统,机构管理系统和bbs论坛

package org.xjtu.bank.empdao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;


import org.xjtu.bank.empdb.Bankdb;
import org.xjtu.bank.empvo.Bankvo;



public class Bankdao {
	private Connection con;
	private Bankdb bankdb;
	private PreparedStatement stmt;
    private ResultSet rs;
    private String strInsert = "insert into emp values(?,?,?,?,?,?,?,?)";
    private String strDelete = "delete from emp where ID=?";
    private String strUpdate = "update emp set WorkerID=?,Name=?,Birthday=?,Department=?,JobName=?,password=?,Unit=? where ID=?";  
    private String strQuery = "select * from emp";
    private String strQueryID="select * from emp where ID=?";
    private String strQueryName="select * from emp where Name=?";
    private String strQueryWorkerID="select * from emp where WorkerID=?";
    
    public void insert(Bankvo vo)
	{
		bankdb=new Bankdb();
		bankdb.getCon();
		con=bankdb.Conndb();

    	try {
			stmt=con.prepareStatement(strInsert);
			stmt.setString(1, vo.getWorkerID());
			stmt.setString(2, vo.getName());
			stmt.setString(3, vo.getSex());
			stmt.setString(4, vo.getBirthday());
			stmt.setInt(5, vo.getDepartment());
			stmt.setString(6, vo.getJobName());
			stmt.setString(7, vo.getPassword());
			stmt.setString(8, vo.getUnit());
			stmt.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		}
    	
}
	
	public void delete (Bankvo vo)
	{
		bankdb =new Bankdb();
		bankdb.getCon();
		con=bankdb.Conndb();
		try {
			stmt=con.prepareStatement(strDelete);
			stmt.setInt(1, vo.getID());
			stmt.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		
	}
	
	public void update(Bankvo vo)
	{
		bankdb=new Bankdb();
		bankdb.getCon();
		con=bankdb.Conndb();
		try {
			stmt=con.prepareStatement(strUpdate);
			stmt.setString(1, vo.getWorkerID());
			stmt.setString(2, vo.getName());
			stmt.setString(3, vo.getBirthday());
			stmt.setInt(4, vo.getDepartment());
			stmt.setString(5, vo.getJobName());
			stmt.setString(6, vo.getPassword());
			stmt.setString(7, vo.getUnit());
			stmt.setInt(8, vo.getID());
			stmt.executeUpdate();

		} catch (SQLException e) {
			e.printStackTrace();
		}
		
	}
	
	public List findall()
	{
		List list=new ArrayList();
		bankdb=new Bankdb();
		bankdb.getCon();
		con=bankdb.Conndb();
		Bankvo vo = null;
		try {
			stmt=con.prepareStatement(strQuery);
			rs=stmt.executeQuery();
			while(rs.next())
			{
				
				vo=new Bankvo();
				vo.setWorkerID(rs.getString("WorkerID"));
				vo.setName(rs.getString("Name"));
				vo.setSex(rs.getString("Sex"));
				vo.setBirthday(rs.getString("Birthday"));
				vo.setDepartment(rs.getInt("Department"));
				vo.setJobName(rs.getString("JobName"));
				vo.setPassword(rs.getString("password"));
				vo.setUnit(rs.getString("Unit"));
		        vo.setID(rs.getInt("ID"));
				list.add(vo);
			}
			return list;
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return null;
		
	}
	
	public List query(Bankvo vo,String str)
	{
		bankdb=new Bankdb();
		bankdb.getCon();
		con=bankdb.Conndb();
		List list=new ArrayList();
		Bankvo bvo=new Bankvo();
		if(str.equalsIgnoreCase("ID"))
		{
		try {
			stmt=con.prepareStatement(strQueryID);
			stmt.setInt(1, vo.getID());
			rs=stmt.executeQuery();
			while(rs.next())
			{
				
		        bvo.setWorkerID(rs.getString("WorkerID"));
		        bvo.setName(rs.getString("Name"));
		        bvo.setSex(rs.getString("Sex"));
		        bvo.setBirthday(rs.getString("Birthday"));
		        bvo.setDepartment(rs.getInt("Department"));
		        bvo.setJobName(rs.getString("JobName"));
		        bvo.setPassword(rs.getString("password"));
		        bvo.setUnit(rs.getString("Unit"));
		        bvo.setID(rs.getInt("ID"));
		        list.add(bvo);
			}
			return list;
		} catch (SQLException e) {
			e.printStackTrace();
		}
		}
		else if(str.equalsIgnoreCase("WorkerID"))
		{
		try {
			stmt=con.prepareStatement(strQueryWorkerID);
			stmt.setString(1, vo.getWorkerID());
			rs=stmt.executeQuery();
			while(rs.next())
			{
				
		        bvo.setWorkerID(rs.getString("WorkerID"));
		        bvo.setName(rs.getString("Name"));
		        bvo.setSex(rs.getString("Sex"));
		        bvo.setBirthday(rs.getString("Birthday"));
		        bvo.setDepartment(rs.getInt("Department"));
		        bvo.setJobName(rs.getString("JobName"));
		        bvo.setPassword(rs.getString("password"));
		        bvo.setUnit(rs.getString("Unit"));
		        bvo.setID(rs.getInt("ID"));
		        list.add(bvo);
			}
			return list;
		} catch (SQLException e) {
			e.printStackTrace();
		}
		}
		else if(str.equalsIgnoreCase("Name"))
		{
			
			try {
				stmt=con.prepareStatement(strQueryName);
				stmt.setString(1, vo.getName());
				rs=stmt.executeQuery();
				while(rs.next())
				{
					  
					    bvo.setWorkerID(rs.getString("WorkerID"));
				        bvo.setName(rs.getString("Name"));
				        bvo.setSex(rs.getString("Sex"));
				        bvo.setBirthday(rs.getString("Birthday"));
				        bvo.setDepartment(rs.getInt("Department"));
				        bvo.setJobName(rs.getString("JobName"));
				        bvo.setPassword(rs.getString("password"));
				        bvo.setUnit(rs.getString("Unit"));
				        bvo.setID(rs.getInt("ID"));
			        list.add(bvo);
				}
				return list;
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return null;
		
	}
//	public static void main(String args[])
//	{
//		Bankdao dao =new Bankdao();
//		Bankvo vo =new Bankvo();
//		
//	}
	public static void main(String args[])
	{
		Bankvo vo= new Bankvo();
		Bankdao dao = new Bankdao();
		vo.setID(2);
		String str="ID";
        List list=dao.query(vo,str);
        for(int i=0;i<list.size();i++)
        {
        vo=(Bankvo)list.get(i);
        System.out.println(vo.getBirthday());
        }
        
	}
}