eventbo.java

使用eclipse开发的web程序

package com.wrox.tourism.business;

import com.wrox.tourism.entity.Event;

import com.wrox.tourism.db.EventDAO;
import com.wrox.tourism.db.AttractionDAO;
import com.wrox.tourism.db.CreateException;
import com.wrox.tourism.db.FinderException;

import com.wrox.tourism.db.util.ConnectionPool;

import java.sql.SQLException;
import java.sql.Connection;

public class EventBO {


  private ConnectionPool pool;

  public EventBO() {
    pool = ConnectionPool.getInstance();
  }


  public void createEvent(Event event) throws EventException {

    validateEvent(event);

    Connection con = null;

    try {

      con = pool.getConnection();

      AttractionDAO attractionDAO = new AttractionDAO(con);
      attractionDAO.findByPrimaryKey(event.getUserId());

      EventDAO eventDAO = new EventDAO(con);
      eventDAO.create(event);

      con.commit();

    } catch (Exception e) {
      try {
        if (con != null) {
          con.rollback();
          throw new EventException(e.getMessage());
        }
      } catch (SQLException sqle) {
        e.printStackTrace();
        throw new RuntimeException("error.unexpected");
      }
    } finally {
      try {
        if (con != null) {
          con.close();
        }
      } catch (SQLException sqle) {
        sqle.printStackTrace();
        throw new RuntimeException("error.unexpected");
      }
    }

  }


  public void updateEvent(Event event) throws EventException {

    validateEvent(event);

    Connection con = null;

    try {

      con = pool.getConnection();

      EventDAO eventDAO = new EventDAO(con);
      eventDAO.update(event);

      con.commit();

    } catch (Exception e) {
      try {
        if (con != null) {
          con.rollback();
          throw new EventException(e.getMessage());
        }
      } catch (SQLException sqle) {
        e.printStackTrace();
        throw new RuntimeException("error.unexpected");
      }
    } finally {
      try {
        if (con != null) {
          con.close();
        }
      } catch (SQLException sqle) {
        sqle.printStackTrace();
        throw new RuntimeException("error.unexpected");
      }
    }

  }


  public void removeEvent(int eventId)
    throws EventException {

    Connection con = null;

    try {

      con = pool.getConnection();

      EventDAO eventDAO = new EventDAO(con);
      eventDAO.remove(eventId);

      con.commit();

    } catch (Exception e) {
      try {
        if (con != null) {
          con.rollback();
          throw new EventException(e.getMessage());
        }
      } catch (SQLException sqle) {
        e.printStackTrace();
        throw new RuntimeException("error.unexpected");
      }
    } finally {
      try {
        if (con != null) {
          con.close();
        }
      } catch (SQLException sqle) {
        sqle.printStackTrace();
        throw new RuntimeException("error.unexpected");
      }
    }

  }


  private void validateEvent(Event event) throws EventException {

    if (event.getName().trim().equals("")) {
      throw new EventException("error.missing.name");
    }

    if (event.getDescription().trim().equals("")) {
      throw new EventException("error.missing.description");
    }

    if (event.getTicketPrice() < 0) {
      throw new EventException("error.missing.ticketPrice");
    }

  }

}