mysqltchargeruledao.java

这是我在东方标准学习的时候做的一个项目

package dao.product.mysql;
import java.sql.*;
import java.util.*;

import dao.product.DbUtil;
import dao.product.TChargeRuleDAO;
import bean.*;

public class MySQLTChargeRuleDAO implements TChargeRuleDAO
{
	public boolean add(TChargeRule chargeRule) {
		DbUtil db = new MySQLDbUtil();
		Connection conn = db.getConnection();
		String sql = "insert into TCharge_Rule values(?,?,?)";
		try {
			PreparedStatement prepStmt = conn.prepareStatement(sql);
			prepStmt.setString(1, chargeRule.getFunc_id());
			prepStmt.setString(2,chargeRule.getCharge_code());
			prepStmt.setString(3,chargeRule.getFunc_name());
			prepStmt.executeUpdate();
			return true;
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		} finally {
			db.close();
		}
	}	
	public Boolean update(TChargeRule chargeRule){
		DbUtil db = new MySQLDbUtil();
		Connection conn = db.getConnection();
		String sql = "update TCharge_Rule set Charge_code=?, Func_name=? where Func_id=?";
		try {
			PreparedStatement prepStmt = conn.prepareStatement(sql);
			prepStmt.setString(1,chargeRule.getCharge_code());
			prepStmt.setString(2,chargeRule.getFunc_name());
			prepStmt.setString(3, chargeRule.getFunc_id());
			prepStmt.execute();
			return true;
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		} finally {
			db.close();
		}
	}
	
	public Boolean delete(String func_id){
		DbUtil db = new MySQLDbUtil();
		Connection conn = db.getConnection();
		String sql = "delete TCharge_Rule where func_id=?";
		try
		{	
			PreparedStatement prepStmt = conn.prepareStatement(sql);
			prepStmt.setString(1,func_id);
			prepStmt.execute();
			return true;
		}
		catch (SQLException e)
		{
			e.printStackTrace();
			return false;
		}
		finally
		{
			db.close();
		}
	}
	
	public List findById (String func_id){
		List<TChargeRule> list = new ArrayList<TChargeRule>();
		DbUtil db = new MySQLDbUtil();
		String sql = "select * from TCharge_Rule where func_id='"+func_id+"'";
		ResultSet rs = db.executeQuery(sql);
		try
		{
			if(rs.next())
			{
				TChargeRule p = new TChargeRule();
				p.setFunc_id("func_id");
				p.setCharge_code(rs.getString("charge_code"));
				p.setFunc_name(rs.getString("func_name"));
				list.add(p);
			}
		}
		catch (SQLException e)
		{
			e.printStackTrace();
		}
		finally
		{
			db.close();
		}
		return list;
	}
	
	public List findAll(){
		List<TChargeRule> list = new ArrayList<TChargeRule>();
		DbUtil db = new MySQLDbUtil();
		String sql = "select * from TCharge_rule";
		ResultSet rs = db.executeQuery(sql);
		try
		{
			while(rs.next())
			{
				TChargeRule p = new TChargeRule();
				p.setFunc_id("func_id");
				p.setCharge_code(rs.getString("charge_code"));
				p.setFunc_name(rs.getString("func_name"));
				list.add(p);
			}
		}
		catch (SQLException e)
		{
			e.printStackTrace();
		}
		finally
		{
			db.close();
		}
		return list;
	}
}