package zhaobiao.db;

import java.util.*;
import java.sql.*;
import zhaobiao.db.*;
import zhaobiao.data.*;

/**
 * <p>Title: 招標管理信息系統</p>
 * <p>Description: 招標管理信息系統設計</p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Company: 招標信息管理系統</p>
 * @author csk
 * @version 1.0
 */

public class NewProject {

  public NewProject() {
  }

  /**添加一個新項目
   *
   * @param pj(項目對象實例)
   * @return 無
   */
  public void addProject(Project pj)
  {
    db=DBConnectionManager.getInstance();
    con=db.getConnection("idb");
    long maxid=0;
    try {
      PreparedStatement ps1 = con.prepareStatement("select max(project_id) as id from project");
      rs =ps1.executeQuery();
      if(rs.next() ){
        maxid = rs.getLong("id")+1 ;
      }
      else
        maxid=1;
      if(ps1!=null)
        ps1.close();
    }
    catch (SQLException ex) {
      ex.printStackTrace() ;
    }
    String sql="insert into project(project_id,project_name,project_time,project_company,project_cost,project_content)values(?,?,?,?,?,?)";
    try {
      ps=con.prepareStatement(sql);
      ps.setLong(1,maxid);
      ps.setString(2,pj.getProject_name());
      ps.setString(3,pj.getProject_time());
      ps.setString(4,pj.getProject_company());
      ps.setString(5,pj.getProject_cost());
      ps.setString(6,pj.getProject_content());
      ps.executeUpdate();
    }
    catch (SQLException ex) {
      freeCon();
      ex.printStackTrace();
    }
    freeCon();
  }

  /**更新一個項目記錄
   *
   * @param pj（項目對象實例）
   * @return 無
   */
  public void updateProject(Project pj)
  {
    db=DBConnectionManager.getInstance();
    con=db.getConnection("idb");
    String sql="update project set project_name=?,project_time=?,project_company=?,"
              +"project_cost=?,project_content=? where project_id=?";
    try {
      ps=con.prepareStatement(sql);
      ps.setString(1,pj.getProject_name());
      ps.setString(2,pj.getProject_time());
      ps.setString(3,pj.getProject_company());
      ps.setString(4,pj.getProject_cost());
      ps.setString(5,pj.getProject_content());
      ps.setLong(6,pj.getProject_id());
      ps.executeUpdate();
    }
    catch (SQLException ex) {
      freeCon();
      ex.printStackTrace();
    }
    freeCon();
  }

  /**根據項目id刪除該項目,并且還刪除項目_類別關聯表中該項目相關記錄，
   * 在其中還刪除ppm表中的該項目相關的記錄
   *
   * @param pjid（項目id）
   * @return 無
   */
  public void delProject(long pjid)
  {
    db=DBConnectionManager.getInstance();
    con=db.getConnection("idb");
    String sql="delete from project where project_id=?";
    try {
      ps=con.prepareStatement(sql);
      ps.setLong(1,pjid);
      ps.executeUpdate();
      PreparedStatement ps1=con.prepareStatement("delete from project_product where project_id=?");
      ps1.setLong(1,pjid);
      ps1.executeUpdate();

      //刪除ppm表中的該項目相關的記錄
      NewPPM newppm=new NewPPM();
      newppm.delPPMProjectid(pjid);
      newppm.freeCon();

      if(ps1!=null)
        ps1.close() ;

    }
    catch (SQLException ex) {
      freeCon();
      ex.printStackTrace() ;
    }
    freeCon();
  }

  /**由項目id和類別id，在項目_類別關聯表中添加一條記錄
   *
   * @param pjid(項目id)
   * @param typeid(類別id)
   */
  public void addProjectType(long pjid,long typeid)
  {
    db=DBConnectionManager.getInstance();
    con=db.getConnection("idb");
    String sql="insert into project_product(project_id,type_id) values(?,?)";
    try {
      ps=con.prepareStatement(sql);
       ps.setLong(1,pjid);
       ps.setLong(2,typeid);
       ps.executeUpdate();
    }
    catch (SQLException ex) {
      freeCon();
      ex.printStackTrace();
    }
    freeCon();

  }

  /**根據項目id刪除項目_類別關聯表中的記錄
   *
   * @param pjid（項目id）
   */
  public void delProjectidType(long pjid)
  {
    db=DBConnectionManager.getInstance();
    con=db.getConnection("idb");
    String sql="delete from project_product where project_id=?";
    try {
      ps=con.prepareStatement(sql);
      ps.setLong(1,pjid);
      ps.executeUpdate();
    }
    catch (SQLException ex) {
      freeCon();
      ex.printStackTrace();
    }
    freeCon();
  }

  /**根據類別id刪除項目_類別關聯表中的記錄
   *
   * @param typeid（類別id）
   */
 public void delProjectTypeid(long typeid)
 {
   db=DBConnectionManager.getInstance();//這兩句你開始沒有加上
    con=db.getConnection("idb");
    String sql="delete from project_product where type_id=?";
    try {
      ps=con.prepareStatement(sql);
      ps.setLong(1,typeid);
      ps.executeQuery();
    }
    catch (SQLException ex) {
      freeCon();
      ex.printStackTrace();

    }

    freeCon();
 }

 /**根據項目id和類別id刪除項目_類別關聯表中的記錄
  *
  * @param pjid（項目id）
  * @param typeid（類別id）
  * @return 無
  */
 public void delProjectidTypeid(long pjid,long typeid)
 {
   db=DBConnectionManager.getInstance();
   con=db.getConnection("idb");
   String sql="delete from project_product where project_id=? and type_id=?";
   try {
     ps=con.prepareStatement(sql);
     ps.setLong(1,pjid);
     ps.setLong(2,typeid);
     ps.executeQuery();
   }
   catch (SQLException ex) {
     freeCon();
     ex.printStackTrace();

   }

   freeCon();
 }

 /**
     * 釋放數據庫資源<p>
     *PreparedStatement和ResultSep將關閉，Connection返回給連接池
     * @param      無
     * @repurn     無
     * @exception  SQLException
     *
     */
    public void freeCon(){
      try {
        if (rs!=null)
          rs.close() ;
        if (ps!=null)
          ps.close() ;
      }
      catch (SQLException ex) {
      }
      if (db!=null)
        db.freeConnection("idb",con) ;
    }

  private PreparedStatement ps=null;
  private DBConnectionManager db;
 private Connection con=null;
  private ResultSet rs=null;
}