consumedaoimpl.java

swing+jdbc+sqlserver2000的小型网吧系统

package org.itstar.netbar.dao.impl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import org.itstar.netbar.bean.ConsumeBean;
import org.itstar.netbar.dao.IConsumeDao;
import org.itstar.netbar.utils.ConnectDB;

public class ConsumeDaoImpl implements IConsumeDao
{

	public int delete(String conStartTime) 
	{
		String strSQL="delete from consume where conStartTime='"+conStartTime+"'";
		int count=0;
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			count=stmt.executeUpdate(strSQL);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return count;
	}

	public int insert(ConsumeBean coBean) 
	{
		String strSQL="insert into consume values('"+coBean.getConPCNum()+"','"
		                                            +coBean.getConCardNum()+"','"
		                                            +coBean.getConName()+"','"
		                                            +coBean.getConStartTime()+"','"
		                                            +coBean.getConEndTime()+"','"
		                                            +coBean.getConMoney()+"','"
		                                            +coBean.getConCurrentBalance()+"')";
		int count=0;
		try {
		Statement stmt=ConnectDB.getConn().createStatement();
		count=stmt.executeUpdate(strSQL);
		} catch (SQLException e) {
		e.printStackTrace();
		}
		return count;
	}

	public List query(Map map) 
	{
		String strSQL="select * from consume where 1=1";
		if(map!=null)
		{
			if(map.get("conPCNum")!=null)
				strSQL=strSQL+" and conPCNum='"+map.get("conPCNum")+"'";
			if(map.get("conCardNum")!=null)
				strSQL=strSQL+" and conCardNum='"+map.get("conCardNum")+"'";
			if(map.get("conName")!=null)
				strSQL=strSQL+" and conName='"+map.get("conName")+"'";
			if(map.get("conStartTime")!=null)
				strSQL=strSQL+" and conStartTime='"+map.get("conStartTime");
			if(map.get("conEndTime")!=null)
				strSQL=strSQL+" and conEndTime='"+map.get("conEndTime")+"'";
			if(map.get("conMoney")!=null)
				strSQL=strSQL+" and conMoney='"+map.get("conMoney")+"'";
			if(map.get("conCurrentBalance")!=null)
				strSQL=strSQL+" and conCurrentBalance='"+map.get("conCurrentBalance")+"'";
		}
		
		List list=new ArrayList();
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			ResultSet rs=stmt.executeQuery(strSQL);
			while(rs.next())
			{
				ConsumeBean coBean=new ConsumeBean();
				coBean.setConPCNum(rs.getString(1));
				coBean.setConCardNum(rs.getString(2));
				coBean.setConName(rs.getString(3));
				coBean.setConStartTime(rs.getString(4));
				coBean.setConEndTime(rs.getString(5));
				coBean.setConMoney(rs.getString(6));
				coBean.setConCurrentBalance(rs.getString(7));
				list.add(coBean);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return list;
	}

	public List queryAll() 
	{
		String strSQL="select * from consume where 1=1";
		
		List list=new ArrayList();
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			ResultSet rs=stmt.executeQuery(strSQL);
			while(rs.next())
			{
				ConsumeBean coBean=new ConsumeBean();
				//rs.getInt(1) 是自增列,无需取出
				coBean.setConPCNum(rs.getString(2));
				coBean.setConCardNum(rs.getString(3));
				coBean.setConName(rs.getString(4));
				coBean.setConStartTime(rs.getString(5));
				coBean.setConEndTime(rs.getString(6));
				coBean.setConMoney(rs.getString(7));
				coBean.setConCurrentBalance(rs.getString(8));
				list.add(coBean);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return list;
	}

	public int update(ConsumeBean coBean) 
	{
		String strSQL="update consume set conCardNum='"+coBean.getConCardNum()+"',"
		                                +"conName ='"+coBean.getConName()+"',"
		                                +"conEndTime ='"+coBean.getConEndTime()+"',"
		                                +"conMoney ='"+coBean.getConMoney()+"',"
		                                +"conCurrentBalance='"+coBean.getConCurrentBalance()+"'"
		                                +" where conStartTime='"+coBean.getConStartTime()+"'"
										+" and conPCNum='"+coBean.getConPCNum()+"'";	
		int count=0;
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			count=stmt.executeUpdate(strSQL);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return count;
	}
	
	public int updateChangePC(String startTime,String destPCNum,String srcPCNum) 
	{
		String strSQL="update consume set conPCNum='"+destPCNum+"'"
		                                      +" where conStartTime='"+startTime+"'"
		                                      +" and conPCNum='"+srcPCNum+"'";
		int count=0;
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			count=stmt.executeUpdate(strSQL);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return count;
	}

	public int updateConMoneyAndEndTime(String endTime, String conMoney, String startTime, String pcNum) {
		String strSQL="update consume set conEndTime='"+endTime+"',"
							 +"conMoney='"+conMoney+"'"
					         +" where conStartTime='"+startTime+"'"
					         +" and conPCNum='"+pcNum+"'";
		System.out.println(strSQL);
		int count=0;
		try {
		Statement stmt=ConnectDB.getConn().createStatement();
		count=stmt.executeUpdate(strSQL);
		} catch (SQLException e) {
		e.printStackTrace();
		}

return count;
	}
}