unitdao.java

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

package org.xjtu.bank.sysdao;

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


import org.xjtu.bank.sysdb.DBAccess;
import org.xjtu.bank.sysvo.UnitVo;



public class UnitDao 
{
	
	private static final String UnitId = null;
	private static final String UnidId = null;
	private Connection con;
	private PreparedStatement stmt;
	private DBAccess dbaccess;
	private ResultSet rs;
	
	private String strFindByAll = "select * from unit";
	private String strInsert ="insert into unit values(?,?,?,?)";
	private String strDelete = "delete from unit where UnitId=?";
	private String strUpdate = "update unit set UnitId=?,UnitName=?,UpUnit=?,Unitmemo=? where ID=?";
	private String strFindByKey = "select * from unit where ID=?";

	
	public int insert(UnitVo vo)
	{
		dbaccess = new DBAccess();
		dbaccess.getConn();
		con = dbaccess.connDB();
		
		try 
		{
			stmt = con.prepareStatement(strInsert);
			stmt.setString(1, vo.getUnitId());
			stmt.setString(2, vo.getUnitName());
			stmt.setString(3, vo.getUpUnit());
			stmt.setString(4,vo.getUnitmemo());
			stmt.executeUpdate();
			return 1;
			
		} catch (SQLException e)
		{
			// TODO Auto-generated catch block
			e.printStackTrace();
			return -1;
		}
			
	}
	
	public int update(UnitVo vo,int ID)
	{
		dbaccess =new DBAccess();
		dbaccess.getConn();
		con = dbaccess.connDB();
		try 
		{
			stmt = con.prepareStatement(strUpdate);
			stmt.setString(1, vo.getUnitId());
			stmt.setString(2, vo.getUnitName());
			stmt.setString(3, vo.getUpUnit());
			stmt.setString(4, vo.getUnitmemo());
			stmt.setInt(5, ID);
			stmt.executeUpdate();
			return 1;
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			return -1;
		}
		
	}
	
	
	public List findByAll()
	{
		List list =new ArrayList();
		dbaccess =new DBAccess();
		dbaccess.getConn();
		con =dbaccess.connDB();
		UnitVo vo;
		
		try 
		{
			stmt=con.prepareStatement(strFindByAll);
			rs = stmt.executeQuery();
			
			while(rs.next())
			{
				vo = new UnitVo();
				vo.setID(rs.getInt("ID"));
				vo.setUnitId(rs.getString("UnitId"));
				vo.setUnitName(rs.getString("UnitName"));
				vo.setUpUnit(rs.getString("UpUnit"));
				vo.setUnitmemo(rs.getString("Unitmemo"));
				list.add(vo);
			}
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;
	}
	
	public UnitVo findByKey(int ID)
	{
		dbaccess =new DBAccess();
		dbaccess.getConn();
		con =dbaccess.connDB();
		UnitVo vo = null;
		
		try {		
			stmt = con.prepareStatement(strFindByKey);		
			stmt.setInt(1, ID);
			rs = stmt.executeQuery();
			
			if(rs.next())
			{
				vo = new UnitVo();
				vo.setID(rs.getInt("ID"));
				vo.setUnitId(rs.getString("UnitId"));
				vo.setUnitName(rs.getString("UnitName"));
				vo.setUpUnit(rs.getString("UpUnit"));
				vo.setUnitmemo(rs.getString("Unitmemo"));
			}
		
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally
		{
			dbaccess.closeConn(con);
			dbaccess = null;
		}
		return vo;
	}
	
	
//  删除	
	public int delete(UnitVo vo)
	{
		dbaccess =new DBAccess();
		dbaccess.getConn();
		con =dbaccess.connDB();
		
		try {
			stmt=con.prepareStatement(strDelete);
			stmt.setString(1,vo.getUnitId());
//			stmt.setString(2,vo.getUnitName());
			stmt.executeUpdate();
			return 1;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			return -1;
		}
	}
	
	public static void main(String args[])
	{
		UnitDao dao = new UnitDao();
		UnitVo vo = new UnitVo();
		
		
//		添加
//		vo.setUnitId("11");
//		vo.setUnitName("长子支行");
//		vo.setUpUnit("1");
//		vo.setUnitmemo("长子支行");
//		dao.insert(vo);
		
//		查询所有
//		List list =dao.findByAll();
//		for(int i=0;i<list.size();i++)
//		{
//			UnitVo xvo =(UnitVo)list.get(i);
//			System.out.println(xvo.getUnitId());
//			System.out.println(xvo.getUnitName());
//			System.out.println(xvo.getUpUnit());
//			System.out.println(xvo.getUnitmemo());
//		
//		}
//		按编号来查询
		
//		vo = dao.findByKey(3);
//		
//		System.out.println(vo.getUnitId());
//		System.out.println(vo.getUnitName());
//		System.out.println(vo.getUpUnit());
//		System.out.println(vo.getUnitmemo());
		
//      更新
		vo.setUnitId("20");
		vo.setUnitName("基阿鲁支行");
		vo.setUpUnit("jdf");
		vo.setUnitmemo("dddddddd");
		dao.update(vo,34);
		
// 		删除
//		vo.setUnitId("2");
//		
//		dao.delete(vo);
	}

	

}