/*
 * Copyright (c) 1998, 2021 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 v. 2.0 which is available at
 * http://www.eclipse.org/legal/epl-2.0,
 * or the Eclipse Distribution License v. 1.0 which is available at
 * http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * SPDX-License-Identifier: EPL-2.0 OR BSD-3-Clause
 */

// 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;
    }

    @Override
    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 {
                if (session.getPlatform().isMySQL()) {
                    executeCall(session, "SET FOREIGN_KEY_CHECKS = 0");
                }
                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");
                if (session.getPlatform().isMySQL()) {
                    executeCall(session, "SET FOREIGN_KEY_CHECKS = 1");
                }
            }
        }

        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
        }
    }
}