package kmd.gxml;
import kmd.Debug;
import kmd.commo.PageList;
import kmd.commo.SQLTools;
import kmd.commo.SequenceProducer;
import kmd.jdbc.DBConnection;

import java.util.ArrayList;
import java.sql.Connection;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Types;


/**
 * 針對對象類型信息進行管理的類，此類包括新增、刪除、修改和查詢對象類型信息的基本方法
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2007</p>
 * <p>Company: 重慶科美達電腦有限公司</p>
 * @author not attributable
 * @version 1.0
 */
public class DataTypeManager {
  /**
   * 構造符
   */
  public DataTypeManager() {}


  /**
   * 新增對象類型基本信息以及屬性信息。名稱、父編號以及屬性信息必須填寫，如果此類型處于最頂級父編號傳0
   * @param info DataTypeInfo 對象類型信息
   * @throws Exception 保存信息失敗時拋出此異常。
   */
  public void addDataType(DataTypeInfo info) throws Exception {
    Connection cn = null;
    PreparedStatement ps = null;
    ResultSet rs = null;
    try {
      cn = DBConnection.getConnection();
      //cn.setAutoCommit(false);
      info.setTid(SequenceProducer.getId());
      ps = cn.prepareStatement(
          "INSERT INTO DataType(TId, PId, Name, Digest) VALUES(?,?,?,?)");
      ps.setLong(1, info.getTid());
      ps.setLong(2, info.getPid());
      ps.setString(3, info.getName());
      if (info.getDigest() == null) {
        ps.setNull(4, Types.VARCHAR);
      } else {
        ps.setString(4, info.getDigest());
      }
      ps.executeUpdate();
      ps.close();
      ps = null;
      ArrayList attributeList = info.getAttributeList();
      AttributeManager aMan = new AttributeManager();
      for (int i = 0; i < attributeList.size(); i++) {
        AttributeInfo aInfo = (AttributeInfo) attributeList.get(i);
        aInfo.setTid(info.getTid());
        aMan.addAttribute(aInfo, cn);
      }
      //cn.commit();
      //cn.setAutoCommit(true);
    } catch (Exception ex) {
      if (Debug.isJavaBeanDebug) {
        ex.printStackTrace();
      }
      /**
      try {
        if (cn != null && !cn.getAutoCommit()) {
          cn.rollback();
          cn.setAutoCommit(true);
        }
      } catch (Exception e) {}
      */
      throw ex;
    } finally {
      if (rs != null) {try {rs.close();
      rs = null;
      } catch (Exception e) {}
      }
      if (ps != null) {try {ps.close();
      ps = null;
      } catch (Exception e) {}
      }
      if (cn != null) {try {cn.close();
      cn = null;
      } catch (Exception e) {}
      }
    }
  }


  /**
   * 修改對象類型信息，包括修改其基本信息以及屬性信息
   * 名稱、編號、父編號以及屬性信息必須填寫
   * @param info DataTypeInfo 對象類型信息
   * @throws Exception 修改信息失敗時拋出此異常
   */
  public void modifyDataType(DataTypeInfo info) throws Exception {
    Connection cn = null;
    PreparedStatement ps = null;
    ResultSet rs = null;
    try {
      cn = DBConnection.getConnection();
      cn.setAutoCommit(false);
      ps = cn.prepareStatement("UPDATE DataType SET Name = ? WHERE TId = ?");
      ps.setString(1, info.getName());
      ps.setLong(2, info.getTid());
      ps.executeUpdate();
      ps.close();
      ps = null;
      AttributeManager aMan = new AttributeManager();
      ArrayList aids = aMan.getAids(info.getTid());
      ArrayList newAttributeList = info.getAttributeList();
      for (int i = 0; i < aids.size(); i++) {
        AttributeInfo aInfo = (AttributeInfo) newAttributeList.get(i);
        boolean exist = false;
        for (int j = 0; j < aids.size(); j++) {
          if (String.valueOf(aInfo.getAid()).equals((String) aids.get(j))) {
            exist = true;
            aids.remove(j);
            break;
          } else {
            continue;
          }
        }
        if (exist) {
          aMan.modifyAttribute(aInfo, cn);
        } else {
          aMan.addAttribute(aInfo, cn);
        }
      }
      for (int i = 0; i < aids.size(); i++) {
        aMan.deleteAttribute(Long.parseLong((String) aids.get(i)), cn);
      }
      cn.commit();
      cn.setAutoCommit(true);
    } catch (Exception ex) {
      if (Debug.isJavaBeanDebug) {
        ex.printStackTrace();
      }
      try {
        if (cn != null && !cn.getAutoCommit()) {
          cn.rollback();
          cn.setAutoCommit(true);
        }
      } catch (Exception e) {}
    } finally {
      if (rs != null) {try {rs.close();
      rs = null;
      } catch (Exception e) {}
      }
      if (ps != null) {try {ps.close();
      ps = null;
      } catch (Exception e) {}
      }
      if (cn != null) {try {cn.close();
      cn = null;
      } catch (Exception e) {}
      }
    }
  }


  /**
   * 刪除指定編號的對象類型信息，并且關聯在此對象類型下的具體數據對象也將會被刪除
   * @param tid long 對象類型編號
   * @param isChild boolean 是否刪除此對象類型的所有子對象類型
   * @throws Exception 刪除信息失敗時拋出此異常
   */
  public int deleteDataType(long tid, boolean isChild) throws Exception {
    Connection cn = null;
    PreparedStatement ps = null;
    ResultSet rs = null;
    int deleteNum = 0;
    try {
      cn = DBConnection.getConnection();
      cn.setAutoCommit(false);
      deleteNum = deleteNum + deleteDataType(tid, isChild, cn);
      cn.commit();
      cn.setAutoCommit(true);
    } catch (Exception ex) {
      if (Debug.isJavaBeanDebug) {
        ex.printStackTrace();
      }
      try {
        if (cn != null && !cn.getAutoCommit()) {
          cn.rollback();
          cn.setAutoCommit(true);
        }
      } catch (Exception e) {}
    } finally {
      if (rs != null) {try {rs.close();
      rs = null;
      } catch (Exception e) {}
      }
      if (ps != null) {try {ps.close();
      ps = null;
      } catch (Exception e) {}
      }
      if (cn != null) {try {cn.close();
      cn = null;
      } catch (Exception e) {}
      }
    }
    return deleteNum;
  }


  /**
   * 刪除指定編號的一組對象類型信息，并且關聯在這些對象類型下的具體數據對象也將會被刪除
   * @param tid long[] 對象類型編號
   * @param isChild boolean 是否刪除所指定對象類型的所有子對象類型
   * @return int 成功刪除的對象類型數量
   * @throws Exception
   */
  public int deleteDataType(long[] tid, boolean isChild) throws Exception {
    Connection cn = null;
    PreparedStatement ps = null;
    ResultSet rs = null;
    int deleteNum = 0;
    try {
      cn = DBConnection.getConnection();
      cn.setAutoCommit(false);
      for (int i = 0; i < tid.length; i++) {
        deleteNum = deleteNum + deleteDataType(tid[i], isChild, cn);
      }
      cn.commit();
      cn.setAutoCommit(true);
    } catch (Exception ex) {
      if (Debug.isJavaBeanDebug) {
        ex.printStackTrace();
      }
      try {
        if (cn != null && !cn.getAutoCommit()) {
          cn.rollback();
          cn.setAutoCommit(true);
        }
      } catch (Exception e) {}
    } finally {
      if (rs != null) {try {rs.close();
      rs = null;
      } catch (Exception e) {}
      }
      if (ps != null) {try {ps.close();
      ps = null;
      } catch (Exception e) {}
      }
      if (cn != null) {try {cn.close();
      cn = null;
      } catch (Exception e) {}
      }
    }
    return deleteNum;
  }


  /**
   * 刪除指定編號的對象類型信息，并且關聯在此對象類型下的具體數據對象也將會被刪除
   * @param tid long 對象類型編號
   * @param isChild boolean  是否刪除所指定對象類型的所有子對象類型
   * @param conn Connection 數據庫連接
   * @return int 成功刪除的對象類型數量
   * @throws Exception
   */
  public int deleteDataType(long tid, boolean isChild, Connection conn) throws
      Exception {
    Connection cn = null;
    PreparedStatement ps = null;
    int deleteNum = 0;
    try {
      cn = conn;
      ArrayList childIds = getChileId(tid);
      ps = cn.prepareStatement("DELETE FROM CharAttribute a WHERE EXISTS ("
                               +
                               "SELECT b.* FROM CharAttribute b WHERE a.AId = b.AId AND a.Oid IN("
                               +
                               "SELECT c.Oid FROM DataInfo c WHERE c.TId = ?))");
      ps.setLong(1, tid);
      ps.executeUpdate();
      ps.close();
      ps = null;
      ps = cn.prepareStatement("DELETE FROM DoubleAttribute a WHERE EXISTS ("
                               +
                               "SELECT b.* FROM CharAttribute b WHERE a.AId = b.AId AND a.Oid IN("
                               +
                               "SELECT c.Oid FROM DataInfo c WHERE c.TId = ?))");
      ps.setLong(1, tid);
      ps.executeUpdate();
      ps.close();
      ps = null;
      ps = cn.prepareStatement("DELETE FROM IntegerAttribute a WHERE EXISTS ("
                               +
                               "SELECT b.* FROM CharAttribute b WHERE a.AId = b.AId AND a.Oid IN("
                               +
                               "SELECT c.Oid FROM DataInfo c WHERE c.TId = ?))");
      ps.setLong(1, tid);
      ps.executeUpdate();
      ps.close();
      ps = null;
      ps = cn.prepareStatement("DELETE FROM BooleanAttribute a WHERE EXISTS ("