customerinfodao.java

基于jsp的固定资产管理系统,自己做的

package DAO;

import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;

import VO.CustomerInfo;


public class CustomerInfoDAO {

	//如果表中含有所要查找的元素，则返回含有该元素信息的对象user，没有或出错user=null
	public CustomerInfo getUser(CustomerInfo v)
	{
		String sql="select * from customerinfo where DOC_TYPE='"+v.getDOC_TYPE()+"' and DOC_NUM='"+v.getDOC_NUM()+"'";
		ConnectTo conto=new ConnectTo();
		Connection conn=conto.connect();
		PreparedStatement pstm=null;
		CustomerInfo user=null;
		if(conn!=null)
		{
			try
			{
				pstm=conn.prepareStatement(sql);
				ResultSet rs=pstm.executeQuery();
				while(rs.next())
				{
					user=new CustomerInfo();
					String ID=rs.getString("ID");
					String type=rs.getString("DOC_TYPE");
					String num=rs.getString("DOC_NUM");
					String name=rs.getString("CUS_NAME");
					Date birth=rs.getDate("CUS_BIRTH");
					String sex=rs.getString("CUS_SEX");
					String addr=rs.getString("CUS_ADDR");
					user.setID(ID);
					user.setDOC_TYPE(type);
					user.setDOC_NUM(num);
					user.setCUS_NAME(name);
					user.setCUS_BIRTH(birth);
					user.setCUS_SEX(sex);
					user.setCUS_ADDR(addr);
				}
			}
			catch(Exception e)
			{
				e.printStackTrace();
				try
				{
					pstm.close();
					conn.close();
				}
				catch(Exception e1)
				{
					e1.printStackTrace();
				}
			}
			
		}
		return user;
	}
	
	
	
	
	public int addUser(CustomerInfo v)
	{
		String type=v.getDOC_TYPE();
		String num=v.getDOC_NUM();
		String addr=v.getCUS_ADDR();
		String ID=v.getID();
		Date birth=v.getCUS_BIRTH();
		String name=v.getCUS_NAME();
		String sex=v.getCUS_SEX();
		type=EncodingChange.getReadStr(type);
		name=EncodingChange.getReadStr(name);
		addr=EncodingChange.getReadStr(addr);
		int k=-1;
		String sql="insert into customerinfo values(?,?,?,?,?,?,?)";
		ConnectTo conto=new ConnectTo();
		Connection conn=conto.connect();
		PreparedStatement pstm=null;
		if(conn!=null)
		{
			try{
			pstm=conn.prepareStatement(sql);
			pstm.setString(1,ID);
			pstm.setString(2,type);
			pstm.setString(3,num);
			pstm.setString(4,name);
			pstm.setDate(5,birth);
			pstm.setString(6,sex);
			pstm.setString(7,addr);
			k=pstm.executeUpdate();
			pstm.close();
			conn.close();
			}
			catch(Exception e)
			{
				e.printStackTrace();
				try
				{
					pstm.close();
					conn.close();
					return k;
				}catch(Exception e1){e1.printStackTrace();}
			}
			
		}
		return k;
	}
	
	
	
	
	//查询数据库,返回al,出错al=null
	public ArrayList<String> getAllUserID()
	{
		ArrayList<String> al=null;
		String sql="select ID from customerinfo order by ID";
		ConnectTo conto=new ConnectTo();
		Connection conn=conto.connect();
		PreparedStatement pstm=null;
		if(conn!=null)
		{
			try{
				pstm=conn.prepareStatement(sql);
				ResultSet rs=pstm.executeQuery();
				al=new ArrayList<String>();
				while(rs.next())
				{
					String ID=rs.getString("ID");
					al.add(ID);
				}
				pstm.close();
				conn.close();
			}
			catch(Exception e)
			{
				e.printStackTrace();
				try
				{
					pstm.close();
					conn.close();
				}catch(Exception e1){e1.printStackTrace();}
			}
		}
		return al;
	}
	
	
	
	
	//返回最后一个操作员的下一个应该的id，失败id=null;
	public String getLastID()
	{
		ArrayList<String> al=this.getAllUserID();
		String lastID=null;
		if(al!=null)
		{
			if(al.size()!=0)
			{
				lastID=al.get(al.size()-1);
				int IDtemp=Integer.parseInt(lastID.substring(2))+1;
				if(IDtemp<10)
				{
					lastID="QD0000000"+IDtemp;
				}
				else if(IDtemp<100)
				{
					lastID="QD000000"+IDtemp;
				}
				else if(IDtemp<1000)
				{
					lastID="QD00000"+IDtemp;
				}
				else if(IDtemp<10000)
				{
					lastID="QD0000"+IDtemp;
				}
				else if(IDtemp<100000)
				{
					lastID="QD000"+IDtemp;
				}
				else if(IDtemp<1000000)
				{
				lastID="QD00"+IDtemp;
				}
			}
			else
			{
				lastID="QD00000001";
				return lastID;
			}
		}
		else lastID="QD00000001";
		return lastID;
	}
}