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.AddMoneyBean;
import org.itstar.netbar.dao.IAddMoneyDao;
import org.itstar.netbar.utils.ConnectDB;

public class AddMoneyDaoImpl implements IAddMoneyDao
{

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

	public int insert(AddMoneyBean amBean) 
	{
		String strSQL="insert into addMoney values('"+amBean.getAddCusCardNum()+"','" 
											         +amBean.getAddAmount()+"','"
											         +amBean.getAddDate()+"')";
		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 addMoney  where 1=1";
		if(map!=null)
		{
			if(map.get("addCusCardNum")!=null)
				strSQL=strSQL+" and addCusCardNum='"+map.get("addCusCardNum")+"'";
			if(map.get("addAmount")!=null)
				strSQL=strSQL+" and addAmount='"+map.get("addAmount")+"'";
			if(map.get("addDate")!=null)
				strSQL=strSQL+" and addDate='"+map.get("addDate")+"'";
		}
		
		List list=new ArrayList();
		
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			ResultSet rs=stmt.executeQuery(strSQL);
			while(rs.next())
			{
				AddMoneyBean amBean=new AddMoneyBean();
				amBean.setAddCusCardNum(rs.getString(1));
				amBean.setAddAmount(rs.getString(2));
				amBean.setAddDate(rs.getString(3));
				list.add(amBean);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return list;
	}

	public List queryAll() 
	{
		String strSQL="select * from addMoney where 1=1";
		List list=new ArrayList();
		try {
			Statement stmt=ConnectDB.getConn().createStatement();
			ResultSet rs=stmt.executeQuery(strSQL);
			while(rs.next())
			{
				AddMoneyBean amBean=new AddMoneyBean();
				//rs.getInt(1)為自增列
				amBean.setAddCusCardNum(rs.getString(2));
				amBean.setAddAmount(rs.getString(3));
				amBean.setAddDate(rs.getString(4));
				list.add(amBean);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
		return list;
	}

	public int update(AddMoneyBean amBean) 
	{
		String strSQL="update addMoney set addAmount='"+amBean.getAddAmount()+"',"
													   +"addDate='"+amBean.getAddDate()+"',"
													   +"addCusCardNum='"+amBean.getAddCusCardNum()+"')";
		int count=0;
		try {
		Statement stmt=ConnectDB.getConn().createStatement();
		count=stmt.executeUpdate(strSQL);
		} catch (SQLException e) {
		e.printStackTrace();
		}
		
		return count;
	}

}