/*******************************************************************************
 * Copyright (c) 1998, 2013 Oracle and/or its affiliates. All rights reserved.
 * This program and the accompanying materials are made available under the 
 * terms of the Eclipse Public License v1.0 and Eclipse Distribution License v. 1.0 
 * which accompanies this distribution. 
 * The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
 * and the Eclipse Distribution License is available at 
 * http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * Contributors:
 *     Oracle - initial API and implementation from Oracle TopLink
 ******************************************************************************/  
package org.eclipse.persistence.testing.tests.history;

import org.eclipse.persistence.testing.models.employee.relational.*;
import org.eclipse.persistence.sessions.*;
import org.eclipse.persistence.queries.*;
import org.eclipse.persistence.tools.history.*;
import org.eclipse.persistence.tools.schemaframework.SchemaManager;
import org.eclipse.persistence.testing.tests.workbenchintegration.*;

/**
 * <b>Purpose:</b>A specialized Employee System for testing generic historical schema support.
 * <p>
 * This EmployeeSystem creates descriptors with history policies configured, and
 * generates a historical schema on the database when tables are created.
 * <p>
 * The specialized descriptors are effected using the HistoryFacade, and two
 * options are to write those descriptors to a Project xml file and read them back,
 * or to write them to a Project Class generated file and compile and load the
 * class on the fly.  The latter two are for testing the workbench integration.
 * @author Stephen McRitchie
 * @since 10.0.3
 */
public class HistoricalEmployeeSystem extends EmployeeSystem {
	// Allow history tests to be run with a hard coded project, a project 
    // loaded from an xml file, or one loaded from a project class file 
    // which is generated on the fly.
	int mode;

	public HistoricalEmployeeSystem(int mode) {
		this("MWIntegrationTestHistoricalEmployeeProject", mode);
	}
    
	public HistoricalEmployeeSystem(String fileName, int mode) {
		this.mode = mode;
		initializeProject(getInitialProject(), fileName);
	}

	public void initializeProject(org.eclipse.persistence.sessions.Project initialProject, String fileName) {
		if (mode == HistoryTestModel.BASIC) {
			project = initialProject;
		} else if (mode == HistoryTestModel.PROJECT_XML) {
			project = WorkbenchIntegrationSystemHelper.buildProjectXML(initialProject, fileName);
		} else if (mode == HistoryTestModel.PROJECT_CLASS_GENERATED) {
			project = WorkbenchIntegrationSystemHelper.buildProjectClass(initialProject, fileName);
		}
	}

	public org.eclipse.persistence.sessions.Project getInitialProject() {
		org.eclipse.persistence.sessions.Project initialProject = new EmployeeProject();
		HistoryFacade.generateHistoryPolicies(initialProject);
		return initialProject;
	}

	public void createTables(DatabaseSession session) {
		if (!SchemaManager.FAST_TABLE_CREATOR) {
    	    if (session.getPlatform().isOracle()) {
                
    			executeCall(session, "drop table PHONE CASCADE CONSTRAINTS");
    			executeCall(session, "drop table RESPONS CASCADE CONSTRAINTS");
    			executeCall(session, "drop table SALARY CASCADE CONSTRAINTS");
    			executeCall(session, "drop table PROJ_EMP CASCADE CONSTRAINTS");
    			executeCall(session, "drop table LPROJECT CASCADE CONSTRAINTS");
    			executeCall(session, "drop table PROJECT CASCADE CONSTRAINTS");
    			executeCall(session, "drop table EMPLOYEE CASCADE CONSTRAINTS");
    			executeCall(session, "drop table ADDRESS CASCADE CONSTRAINTS");
    		} else {
    			executeCall(session, "drop table PHONE");
    			executeCall(session, "drop table RESPONS");
    			executeCall(session, "drop table SALARY");
    			executeCall(session, "drop table PROJ_EMP");
    			executeCall(session, "drop table LPROJECT");
    			executeCall(session, "drop table PROJECT");
    			executeCall(session, "drop table EMPLOYEE");
    			executeCall(session, "drop table ADDRESS");
    		}
		}

		EmployeeTableCreator creator = new EmployeeTableCreator();
		HistoryFacade.generateHistoricalTableDefinitions(creator, session);
		// reset creator as it might have been set by tests that used
		// the non-historical table definitions
		creator.resetFastTableCreator();
		creator.replaceTables(session);
	}
    
    private void executeCall(DatabaseSession session, String call) {
        try {
            session.executeNonSelectingCall(new SQLCall(call));
		} catch (Exception e) {
            // ignore exception
        }
    }
}