/*  OpenOlap viewer
 *  パッケージ名：openolap.viewer.dao
 *  ファイル：PostgresAxisDAO.java
 *  説明：軸オブジェクトの永続化を管理するクラスです。
 *
 *  作成日: 2004/01/13
 */
package openolap.viewer.dao;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;

import javax.servlet.http.HttpServletRequest;

import openolap.viewer.Axis;
import openolap.viewer.AxisMember;
import openolap.viewer.Dimension;
import openolap.viewer.Edge;
import openolap.viewer.Measure;
import openolap.viewer.Report;
import openolap.viewer.common.CommonSettings;
import openolap.viewer.common.CommonUtils;
import openolap.viewer.common.Constants;
import openolap.viewer.common.StringUtil;
import openolap.viewer.controller.RequestHelper;


/**
 *  クラス：PostgresAxisDAO
 *  説明：軸オブジェクトの永続化を管理するクラスです。
 */
public class PostgresAxisDAO implements AxisDAO {

	// ********** インスタンス変数 **********

	/** Connectionオブジェクト */
	Connection conn = null;

	// ********** コンストラクタ **********

	/**
	 * 軸オブジェクトの永続化を管理するオブジェクトを生成します。
	 */
	PostgresAxisDAO(Connection conn) {
		this.conn = conn;
	}

	// ********** メソッド **********

	/**
	 * クライアントから送信されたパラメータをもとに、軸のメンバのセレクタ選択情報、ドリル情報を反映する。
	 * @param helper RequestHelperオブジェクト
	 * @param commonSettings アプリケーションの共通設定オブジェクト
	 */
	public void registSelectedMemberAndDrillStat(RequestHelper helper, CommonSettings commonSettings) {

		HttpServletRequest request = helper.getRequest();
		Report report = (Report)helper.getRequest().getSession().getAttribute("report");

		String axisID = null;
		for (int i = 0; i < report.getTotalDimensionNumber()+1; i++ ) {	// ディメンション＋１(メジャー)回実行

			if (i == report.getTotalDimensionNumber()) {	// メジャー
				axisID = Constants.MeasureID;
			} else {										// ディメンション
				axisID = Integer.toString(i+1);				// 軸IDは1startのため、補正。
			}

			String selectedMemberAndDrillStat = (String)request.getParameter("dim" + axisID);	// クライアントからの送信されてきたパラメータを取得

			// axisが持つメンバーの選択状況を順に更新
			Axis axis = report.getAxisByID(axisID);

			// セレクタ選択情報、ドリル情報を次元オブジェクトにセット
			if (!selectedMemberAndDrillStat.equals("")) {	// セレクタ選択情報もしくはドリル情報もしくはその両方が更新された

				// ある軸の選択済みであるメンバをKey,そのドリル状態をvalueとするHashMapを生成
				HashMap memberNameDrillMap = new HashMap();
				ArrayList selectedMemberAndDrillStatList = StringUtil.splitString(selectedMemberAndDrillStat,",");
				Iterator it = selectedMemberAndDrillStatList.iterator();
				while (it.hasNext()) {
					String aSelectedMemberAndDrillStat = (String) it.next();
					ArrayList aSelectedMemberAndDrillStatList = StringUtil.splitString(aSelectedMemberAndDrillStat,":");
				
					String selectedMemberUniqueName = (String) aSelectedMemberAndDrillStatList.get(0); // 選択済みメンバのユニーク名
					String selectedMemberDrillStat  = (String) aSelectedMemberAndDrillStatList.get(1); // ドリル状態(1:ドリル,0:未ドリル)
					memberNameDrillMap.put(selectedMemberUniqueName, selectedMemberDrillStat);
				}

				// メンバー情報、ドリル情報を更新
				if(axis instanceof Dimension){	// ディメンション
					Dimension dim = (Dimension)axis;
					dim.setSelectedMemberDrillStat(memberNameDrillMap);
				} else if (axis instanceof Measure){// メジャー：メジャーメンバに対し、セレクタで選択されたメンバかどうかを順に設定していく
					Iterator axisMemIt = axis.getAxisMemberList().iterator();
					while (axisMemIt.hasNext()) {
						AxisMember axisMember = (AxisMember) axisMemIt.next();
						if (memberNameDrillMap.containsKey(axisMember.getUniqueName())) {	// セレクタで選択されたメンバ
							axisMember.setIsSelected(true);
						} else {															// セレクタで選択されなかったメンバ
							axisMember.setIsSelected(false);
						}
					}
				}

				// デフォルトメンバー情報を更新(デフォルトメンバがセレクタで外された場合、デフォルトメンバ設定を初期化する)
				axis.modifyDefaultMember(memberNameDrillMap);

			} else {	// この軸にたいしては、今回セレクタ選択情報、ドリル情報が更新されなかった
				// 何もしない
			}
		}
	}


	/**
	 * データソースから取得したレポート設定をモデルに反映する。
	 * @param report Reportオブジェクト
	 * @param commonSettings アプリケーションの共通設定オブジェクト
	 * @param conn Connectionオブジェクト
	 * @exception SQLException 処理中に例外が発生した
	 */
	public void applyAxis(Report report, CommonSettings commonSettings, Connection conn) throws SQLException {

		ArrayList colIdList = new ArrayList();
		ArrayList rowIdList = new ArrayList();
		ArrayList pageIdList = new ArrayList();
	
		String SQL = "";
		SQL += "select ";
		SQL += "    axis_id, ";
		SQL += "    dimension_seq, ";
		SQL += "    default_mem_key, ";
		SQL += "    selecter_usedFLG, ";
		SQL += "    edge_type, ";
		SQL += "    in_edge_index, ";
		SQL += "    disp_mem_name_type ";
		SQL += "from ";
		SQL += "    oo_v_axis ";
		SQL += "where ";
		SQL += "    report_id=" + report.getReportID() + " ";
		SQL += "order by ";
		SQL += "    edge_type,in_edge_index";
//System.out.println("apply axis SQL:" + SQL);
	
		Statement stmt = null;
		ResultSet rs = null;
	
		try {
			stmt = conn.createStatement();
			rs = stmt.executeQuery(SQL);
			while ( rs.next() ) {

				String axisID = rs.getString("axis_id");

				// 配置場所情報を取得
				if (Constants.Col.equals(rs.getString("edge_type"))) {
					colIdList.add(axisID);	
				} else if (Constants.Row.equals(rs.getString("edge_type"))) {
					rowIdList.add(axisID);
				} else if (Constants.Page.equals(rs.getString("edge_type"))) {
					pageIdList.add(axisID);
				} else {
					throw new IllegalStateException();
				}

				// defaultMemberKey、isUsedSelecter、dispMemberNameTypeの更新
				Axis axis = report.getAxisByID(axisID);
				axis.setDefaultMemberKey(rs.getString("default_mem_key"));
				axis.setUsedSelecter(CommonUtils.FLGTobool(rs.getString("selecter_usedFLG")));
				if(!axis.isMeasure()) {
					((Dimension)axis).setDispMemberNameType(rs.getString("disp_mem_name_type"));
				}

				// メンバ情報の更新
				AxisMemberDAO axisMemberDAO = DAOFactory.getDAOFactory().getAxisMemberDAO(conn,axis);
				axisMemberDAO.applyAxis(report, axis, commonSettings);

			}

			// 配置場所情報を更新
			DAOFactory daoFactory = DAOFactory.getDAOFactory();
			daoFactory.getReportDAO(conn).registAxisPosition(colIdList, rowIdList, pageIdList, report);

		} catch (SQLException e) {
			throw e;
		} catch (Exception e) { 
			e.printStackTrace();
		} finally {
			try {
				if (rs != null){
					rs.close();
				}
			} catch (SQLException e) {
				throw e;
			} finally {
				try {
					if (stmt != null){
						stmt.close();
					}
				} catch (SQLException e) {
					throw e;
				}
			}
		}

	}

	/**
	 * クライアントから送信されたパラメータをもとに、モデルの軸メンバーのデフォルトメンバ情報を更新する。
	 * @param helper RequestHelperオブジェクト
	 * @param commonSettings アプリケーションの共通設定オブジェクト
	 */
	public void registDefaultMember(RequestHelper helper, CommonSettings commonSettings) {
		
		HttpServletRequest request = helper.getRequest();
		String defaultMembers = (String)request.getParameter("defaultMembers");
		if ( (defaultMembers == null) || (defaultMembers == "")) {
			throw new IllegalStateException();
		}
		// 書式：＜軸ID.軸のUNameの繰り返し(カンマ区切り、軸IDの昇順)＞
		// 　　　例：1.0,2.NA,16.0
		//　　　　　　1.0:AxisID=1のディメンションのデフォルトメンバのUName
		//　　　　　　2.NA:AxisID=2のディメンションのデフォルトメンバのUName（未設定の場合は、NAという文字列）
		//　　　　　　16.0:AxisID=16(メジャー)のデフォルトメンバのUName

		Report report = (Report)helper.getRequest().getSession().getAttribute("report");

		ArrayList defaultMemberList = StringUtil.splitString(defaultMembers, ",");
		Iterator it = defaultMemberList.iterator();
		int measureIndex = defaultMemberList.size();
//System.out.println("measureIndex:" + measureIndex);

		while (it.hasNext()) {

			//軸情報、デフォルトメンバ情報を取得
			String axisIdAndDefaultMemberString = (String) it.next();
			ArrayList axisIdAndDefaultMemberList = StringUtil.splitString(axisIdAndDefaultMemberString, ".");
			String axisID = (String) axisIdAndDefaultMemberList.get(0);
			String defaultMember = (String) axisIdAndDefaultMemberList.get(1);
		
			//デフォルトメンバが設定されていない状態をClient側では、「NA」で表す。
			if (defaultMember.equals("NA")) {
				defaultMember = null;
			}

//System.out.println("axisDAO axisID" + axisID);
			report.getAxisByID(axisID).setDefaultMemberKey(defaultMember);	// デフォルトメンバ情報を更新

		}
	}

	/**
	 * 軸情報をデータソースへ保存する。
	 * @param report Reportオブジェクト
	 * @param conn Connectionオブジェクト
	 * @exception SQLException 処理中に例外が発生した
	 */
	public void saveAxis(Report report, Connection conn) throws SQLException {
		
		String SQL = "";
		Statement stmt = null;
		stmt = conn.createStatement();

		try {
		
			Iterator edgeIt = report.getEdgeList().iterator();
			while (edgeIt.hasNext()) {
				Edge edge = (Edge) edgeIt.next();
				Iterator axisIt = edge.getAxisList().iterator();
	
				int axisIndex = 0;
				while (axisIt.hasNext()) {
					Axis axis = (Axis) axisIt.next();
	
					String dispMemberNameType;
					String dimensionSeq;
					if(axis instanceof Dimension){
						dispMemberNameType = "'" + ((Dimension)axis).getDispMemberNameType() + "'";
						dimensionSeq = ((Dimension)axis).getDimensionSeq();
					} else {
						dispMemberNameType = "null";
						dimensionSeq = "0";
					}
	
					SQL =  "";
					SQL += "UPDATE oo_v_axis set";	
					SQL += "    default_mem_key=" + axis.getDefaultMemberKey() + ", ";
					SQL += "    dimension_seq=" + dimensionSeq + ", ";
					SQL += "    selecter_usedFLG='" + CommonUtils.boolToFLG(axis.isUsedSelecter()) + "', ";
					SQL += "    edge_type='" + edge.getPosition() + "', ";
					SQL += "    in_edge_index=" + axisIndex + ", ";
					SQL += "    disp_mem_name_type=" + dispMemberNameType + " ";
					SQL += "WHERE ";
					SQL += "    report_id=" + report.getReportID() + " and ";
					SQL += "    axis_id=" + axis.getId();
//System.out.println("update report:" + SQL);
	
						int updateCount = stmt.executeUpdate(SQL);
	
						// update件数が0の場合、新たにレコード作成
						if (updateCount == 0) {
	
							SQL = "";
							SQL += "INSERT INTO ";
							SQL += "    oo_v_axis ";
							SQL += "       (report_id, axis_id, dimension_seq, name, default_mem_key, selecter_usedflg, edge_type, in_edge_index, disp_mem_name_type) ";
							SQL += "values ( ";
							SQL +=                report.getReportID() + ", ";
							SQL +=                axis.getId() + ", ";
							SQL +=                dimensionSeq + ", ";
							SQL +=          "'" + axis.getName() + "', ";
							SQL +=                axis.getDefaultMemberKey() + ", ";
							SQL +=          "'" + CommonUtils.boolToFLG(axis.isUsedSelecter()) + "', ";
							SQL +=          "'" + edge.getPosition() + "', ";
							SQL +=                axisIndex + ", ";
							SQL +=                dispMemberNameType;
							SQL +=         ")";
//System.out.println("saveAxis:" + SQL);
		
							int insertCount = stmt.executeUpdate(SQL);
							if (insertCount != 1) {
								throw new IllegalStateException();
							}
						}

					// 軸メンバーの保存
					DAOFactory daoFactory = DAOFactory.getDAOFactory();
					AxisMemberDAO axisMemDAO = daoFactory.getAxisMemberDAO(conn, axis);
					axisMemDAO.saveAxisMember(report, axis, conn);

					axisIndex++;
				}
			}

		} catch (SQLException e) {
			throw e;
		} catch (IllegalStateException e) {
			throw e;
		} finally {
			if (stmt != null) {
				stmt.close();
			}
		}

	}

	/**
	 * 与えられたレポートの全ての軸の情報をデータソースから削除する。
	 * @param report Reportオブジェクト
	 * @param conn Connectionオブジェクト
	 * @exception SQLException 処理中に例外が発生した
	 */
	public void deleteAxes(Report report, Connection conn) throws SQLException {

		// 軸情報の削除
		String SQL = "";
		SQL =  "";
		SQL += "delete from oo_v_axis ";
		SQL += "where ";
		SQL += "    report_id=" + report.getReportID();

		Statement stmt = null;
		try {
			stmt = conn.createStatement();
			stmt.executeUpdate(SQL);
		} catch (SQLException e) {
			throw e;
		} finally {
			if (stmt != null) {
				stmt.close();
			}
		}

		// 軸メンバの削除
		DAOFactory daoFactory = DAOFactory.getDAOFactory();
		AxisMemberDAO axisMemDAO = daoFactory.getAxisMemberDAO(conn, null);
		axisMemDAO.deleteAxisMember(report, conn);

	}

	/**
	 * 与えられた軸の情報をデータソースから削除する。
	 * @param report レポートオブジェクト
	 * @param axis 軸オブジェクト
	 * @param conn Connectionオブジェクト
	 * @exception SQLException 処理中に例外が発生した
	 */
	public void deleteAxis(Report report, Axis axis, Connection conn) throws SQLException {

		String SQL = "";
		SQL =  "";
		SQL += "delete from oo_v_axis ";
		SQL += "where ";
		SQL += "    report_id=" + report.getReportID() + " and ";
		SQL += "    axis_id=" + axis.getId();

		Statement stmt = null;
		try {
			stmt = conn.createStatement();
			stmt.executeUpdate(SQL);
		} catch (SQLException e) {
			throw e;
		} finally {
			if (stmt != null) {
				stmt.close();
			}
		}

	}

}
