Dépôt officiel du code source de l'ERP OpenConcerto

/*

 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.

 *

 * Copyright 2011 OpenConcerto, by ILM Informatique. All rights reserved.

 *

 * The contents of this file are subject to the terms of the GNU General Public License Version 3

 * only ("GPL"). You may not use this file except in compliance with the License. You can obtain a

 * copy of the License at http://www.gnu.org/licenses/gpl-3.0.html See the License for the specific

 * language governing permissions and limitations under the License.

 *

 * When distributing the software, include this License Header Notice in each file.

 */

 package org.openconcerto.erp.config;

import org.openconcerto.erp.config.DsnBrutCode.DsnTypeCodeBrut;

import org.openconcerto.sql.model.DBRoot;

import org.openconcerto.sql.model.SQLBase;

import org.openconcerto.sql.model.SQLName;

import org.openconcerto.sql.model.SQLRow;

import org.openconcerto.sql.model.SQLRowListRSH;

import org.openconcerto.sql.model.SQLRowValues;

import org.openconcerto.sql.model.SQLSelect;

import org.openconcerto.sql.model.SQLSyntax;

import org.openconcerto.sql.model.SQLTable;

import org.openconcerto.sql.model.Where;

import org.openconcerto.sql.request.Inserter;

import org.openconcerto.sql.request.Inserter.Insertion;

import org.openconcerto.sql.request.UpdateBuilder;

import org.openconcerto.sql.utils.AlterTable;

import org.openconcerto.sql.utils.ReOrder;

import org.openconcerto.sql.utils.SQLCreateTable;

import org.openconcerto.utils.Tuple2;

import org.openconcerto.utils.Tuple3;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

public class DSNInstallationUtils {

    private void insertUndef(final SQLCreateTable ct) throws SQLException {

        // check that we can use insertReturnFirstField()

        if (ct.getPrimaryKey().size() != 1)

            throw new IllegalStateException("Not one and only one field in the PK : " + ct.getPrimaryKey());

        final Insertion<?> insertion = new Inserter(ct).insertReturnFirstField("(" + SQLBase.quoteIdentifier(SQLSyntax.ORDER_NAME) + ") VALUES(" + ReOrder.MIN_ORDER + ")", false);

        assert insertion.getCount() == 1;

        if (insertion.getRows().size() != 1)

            throw new IllegalStateException("Missing ID " + insertion.getRows());

        SQLTable.setUndefID(ct.getRoot().getSchema(), ct.getName(), ((Number) insertion.getRows().get(0)).intValue());

    }

    private void insertValues(List<Tuple2<String, String>> values, SQLTable table) throws SQLException {

        SQLSelect sel = new SQLSelect();

        sel.addSelect(table.getField("CODE"));

        List<String> codes = (List<String>) table.getDBSystemRoot().getDataSource().executeA(sel.asString());

        for (Tuple2<String, String> tuple2 : values) {

            if (!codes.contains(tuple2.get0())) {

                SQLRowValues rowVals = new SQLRowValues(table);

                rowVals.put("CODE", tuple2.get0());

                rowVals.put("NOM", tuple2.get1());

                rowVals.commit();

            }

        }

    }

    public void updateDSNCommonTable(final DBRoot root) throws SQLException {

        SQLTable societeCommonT = root.getTable("SOCIETE_COMMON");

        if (!societeCommonT.contains("IBAN")) {

            AlterTable t = new AlterTable(societeCommonT);

            t.addVarCharColumn("IBAN", 256);

            t.addVarCharColumn("BIC", 256);

            root.getBase().getDataSource().execute(t.asString());

            root.refetchTable("SOCIETE_COMMON");

            root.getSchema().updateVersion();

        }

        if (!societeCommonT.contains("ORG_PROTECTION_SOCIAL_ID")) {

            AlterTable t = new AlterTable(societeCommonT);

            t.addVarCharColumn("ORG_PROTECTION_SOCIAL_ID", 256);

            root.getBase().getDataSource().execute(t.asString());

            root.refetchTable("SOCIETE_COMMON");

            root.getSchema().updateVersion();

        }

        SQLTable tableRubCot = root.getTable("RUBRIQUE_COTISATION");

        if (!tableRubCot.contains("ASSIETTE_PLAFONNEE")) {

            AlterTable tableRub = new AlterTable(tableRubCot);

            tableRub.addBooleanColumn("ASSIETTE_PLAFONNEE", false, false);

            root.getBase().getDataSource().execute(tableRub.asString());

            root.refetchTable("RUBRIQUE_COTISATION");

            root.getSchema().updateVersion();

        }

        if (!tableRubCot.contains("TAXABLE_CM")) {

            AlterTable tableRub = new AlterTable(tableRubCot);

            tableRub.addBooleanColumn("TAXABLE_CM", Boolean.FALSE, false);

            root.getBase().getDataSource().execute(tableRub.asString());

            root.refetchTable("RUBRIQUE_COTISATION");

            root.getSchema().updateVersion();

        }

        if (!root.contains("CODE_CAISSE_TYPE_RUBRIQUE")) {

            final SQLCreateTable createTableCode = new SQLCreateTable(root, "CODE_CAISSE_TYPE_RUBRIQUE");

            createTableCode.addVarCharColumn("CODE", 25);

            createTableCode.addVarCharColumn("NOM", 512);

            createTableCode.addVarCharColumn("CAISSE_COTISATION", 512);

            try {

                root.getBase().getDataSource().execute(createTableCode.asString());

                insertUndef(createTableCode);

                root.refetchTable("CODE_CAISSE_TYPE_RUBRIQUE");

                final SQLTable table = root.getTable("CODE_CAISSE_TYPE_RUBRIQUE");

                DsnUrssafCode codeUrssaf = new DsnUrssafCode();

                codeUrssaf.insertCode(table);

                List<String> tableRubName = Arrays.asList("RUBRIQUE_BRUT", "RUBRIQUE_COTISATION", "RUBRIQUE_NET");

                for (String t : tableRubName) {

                    AlterTable tableRub = new AlterTable(root.getTable(t));

                    tableRub.addForeignColumn("ID_CODE_CAISSE_TYPE_RUBRIQUE", table);

                    root.getBase().getDataSource().execute(tableRub.asString());

                    root.refetchTable(t);

                }

                root.getSchema().updateVersion();

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "CODE_CAISSE_TYPE_RUBRIQUE", ex);

            }

        }

        if (!root.contains("MOTIF_ARRET_TRAVAIL")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "MOTIF_ARRET_TRAVAIL");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("MOTIF_ARRET_TRAVAIL");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("MOTIF_ARRET_TRAVAIL");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("01", "maladie"));

                v.add(Tuple2.create("02", "maternité /adoption"));

                v.add(Tuple2.create("03", "paternité / accueil de l’enfant"));

                v.add(Tuple2.create("04", "congé suite à un accident de trajet"));

                v.add(Tuple2.create("05", "congé suite à maladie professionnelle"));

                v.add(Tuple2.create("06", "congé suite à accident de travail ou de service"));

                v.add(Tuple2.create("07", "femme enceinte dispensée de travail"));

                v.add(Tuple2.create("99", "annulation"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "MOTIF_ARRET_TRAVAIL", ex);

            }

        }

        if (!root.contains("DIPLOME_PREPARE")) {

            final SQLCreateTable createTableDiplome = new SQLCreateTable(root, "DIPLOME_PREPARE");

            createTableDiplome.addVarCharColumn("CODE", 25);

            createTableDiplome.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableDiplome.asString());

                insertUndef(createTableDiplome);

                root.refetchTable("DIPLOME_PREPARE");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("DIPLOME_PREPARE");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("03", "Niveau de formation équivalent au CAP (certificat d'aptitude professionnelle) ou au BEP (brevet d'études professionnelles)"));

                v.add(Tuple2.create("04", "Formation de niveau du bac (général, technologique ou professionnel), du brevet de technicien (BT) ou du brevet professionnel"));

                v.add(Tuple2.create("05", "Formation de niveau bac+2 : licence 2, BTS (brevet de technicien supérieur), DUT (diplôme universitaire de technologie), etc."));

                v.add(Tuple2.create("06", "Formation de niveau bac+3 et bac+4 : licence 3, licence professionnelle, master 1, etc."));

                v.add(Tuple2.create("07", "Formation de niveau bac+5 : master 2, diplôme d'études approfondies, diplôme d'études supérieures spécialisées, diplôme d'ingénieur, etc."));

                v.add(Tuple2.create("08", "Formation de niveau bac+8 : doctorat, habilitation à diriger des recherches, etc. "));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "DIPLOME_PREPARE", ex);

            }

        }

        if (!root.contains("TYPE_PREAVIS")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "TYPE_PREAVIS");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("TYPE_PREAVIS");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("TYPE_PREAVIS");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("01", "préavis effectué et payé"));

                v.add(Tuple2.create("02", "préavis non effectué et payé"));

                v.add(Tuple2.create("03", "préavis non effectué et non payé"));

                v.add(Tuple2.create("10", "préavis non effectué non payé dans le cadre d’un contrat de sécurisation professionnelle (CSP)"));

                v.add(Tuple2.create("50", "préavis non effectué et payé dans le cadre d’un congé de reclassement"));

                v.add(Tuple2.create("51", "préavis non effectué et payé dans le cadre d’un congé de mobilité"));

                v.add(Tuple2.create("60", "Délai de prévenance"));

                v.add(Tuple2.create("90", "pas de clause de préavis applicable"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "TYPE_PREAVIS", ex);

            }

        }

        if (!root.contains("CODE_BASE_ASSUJETTIE")) {

            final SQLCreateTable createTableCodeBase = new SQLCreateTable(root, "CODE_BASE_ASSUJETTIE");

            createTableCodeBase.addVarCharColumn("CODE", 25);

            createTableCodeBase.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableCodeBase.asString());

                insertUndef(createTableCodeBase);

                root.refetchTable("CODE_BASE_ASSUJETTIE");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("CODE_BASE_ASSUJETTIE");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("02", "Assiette brute plafonnée"));

                v.add(Tuple2.create("03", "Assiette brute déplafonnée"));

                v.add(Tuple2.create("04", "Assiette de la contribution sociale généralisée"));

                v.add(Tuple2.create("07", "Assiette des contributions d'Assurance Chômage"));

                v.add(Tuple2.create("08", "Assiette retraite CPRP SNCF"));

                v.add(Tuple2.create("09", "Assiette de compensation bilatérale maladie CPRP SNCF"));

                v.add(Tuple2.create("10", "Base brute fiscale"));

                v.add(Tuple2.create("11", "Base forfaitaire soumise aux cotisations de Sécurité Sociale"));

                v.add(Tuple2.create("12", "Assiette du crédit d'impôt compétitivité-emploi"));

                v.add(Tuple2.create("13", "Assiette du forfait social à 8%"));

                v.add(Tuple2.create("14", "Assiette du forfait social à 20%"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "CODE_BASE_ASSUJETTIE", ex);

            }

        }

        if (!tableRubCot.contains("ID_CODE_BASE_ASSUJETTIE")) {

            AlterTable alterTableCot = new AlterTable(tableRubCot);

            alterTableCot.addForeignColumn("ID_CODE_BASE_ASSUJETTIE", root.getTable("CODE_BASE_ASSUJETTIE"));

            root.getBase().getDataSource().execute(alterTableCot.asString());

            root.refetchTable("RUBRIQUE_COTISATION");

            root.getSchema().updateVersion();

        }

        if (!root.contains("CODE_TYPE_RUBRIQUE_BRUT")) {

            final SQLCreateTable createTableCodeBase = new SQLCreateTable(root, "CODE_TYPE_RUBRIQUE_BRUT");

            createTableCodeBase.addVarCharColumn("CODE", 25);

            createTableCodeBase.addVarCharColumn("NOM", 512);

            createTableCodeBase.addVarCharColumn("TYPE", 512);

            try {

                root.getBase().getDataSource().execute(createTableCodeBase.asString());

                insertUndef(createTableCodeBase);

                root.refetchTable("CODE_TYPE_RUBRIQUE_BRUT");

                root.getSchema().updateVersion();

                DsnBrutCode brutCode = new DsnBrutCode();

                brutCode.insertCode(root.getTable("CODE_TYPE_RUBRIQUE_BRUT"));

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "CODE_BASE_ASSUJETTIE", ex);

            }

        }

        SQLTable tableRubBrut = root.getTable("RUBRIQUE_BRUT");

        if (!tableRubBrut.contains("ID_CODE_TYPE_RUBRIQUE_BRUT")) {

            AlterTable alterTableBrut = new AlterTable(tableRubBrut);

            alterTableBrut.addForeignColumn("ID_CODE_TYPE_RUBRIQUE_BRUT", root.getTable("CODE_TYPE_RUBRIQUE_BRUT"));

            root.getBase().getDataSource().execute(alterTableBrut.asString());

            root.refetchTable("RUBRIQUE_BRUT");

            root.getSchema().updateVersion();

        }

        if (!tableRubBrut.contains("COTISABLE")) {

            AlterTable alterTableBrut = new AlterTable(tableRubBrut);

            alterTableBrut.addBooleanColumn("COTISABLE", Boolean.TRUE, false);

            root.getBase().getDataSource().execute(alterTableBrut.asString());

            root.refetchTable("RUBRIQUE_BRUT");

            root.getSchema().updateVersion();

        }

        if (!tableRubBrut.contains("TAXABLE_CM")) {

            AlterTable alterTableBrut = new AlterTable(tableRubBrut);

            alterTableBrut.addBooleanColumn("TAXABLE_CM", Boolean.TRUE, false);

            root.getBase().getDataSource().execute(alterTableBrut.asString());

            root.refetchTable("RUBRIQUE_BRUT");

            root.getSchema().updateVersion();

        }

        if (!tableRubBrut.contains("CSG_NORMAL")) {

            AlterTable alterTableBrut = new AlterTable(tableRubBrut);

            alterTableBrut.addBooleanColumn("CSG_NORMAL", Boolean.TRUE, false);

            root.getBase().getDataSource().execute(alterTableBrut.asString());

            root.refetchTable("RUBRIQUE_BRUT");

            root.getSchema().updateVersion();

        }

        if (!tableRubBrut.contains("CSG_REDUIT")) {

            AlterTable alterTableBrut = new AlterTable(tableRubBrut);

            alterTableBrut.addBooleanColumn("CSG_REDUIT", Boolean.FALSE, false);

            root.getBase().getDataSource().execute(alterTableBrut.asString());

            root.refetchTable("RUBRIQUE_BRUT");

            root.getSchema().updateVersion();

        }

        SQLTable tableRubNet = root.getTable("RUBRIQUE_NET");

        if (!tableRubNet.contains("ID_CODE_TYPE_RUBRIQUE_BRUT")) {

            AlterTable alterTableNet = new AlterTable(tableRubNet);

            alterTableNet.addForeignColumn("ID_CODE_TYPE_RUBRIQUE_BRUT", root.getTable("CODE_TYPE_RUBRIQUE_BRUT"));

            root.getBase().getDataSource().execute(alterTableNet.asString());

            root.refetchTable("RUBRIQUE_NET");

            root.getSchema().updateVersion();

        }

        if (!root.contains("DSN_REGIME_LOCAL")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "DSN_REGIME_LOCAL");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("DSN_REGIME_LOCAL");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("DSN_REGIME_LOCAL");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("99", "non applicable"));

                v.add(Tuple2.create("01", "régime local Alsace Moselle"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "DSN_REGIME_LOCAL", ex);

            }

        }

        if (!root.contains("CONTRAT_MODALITE_TEMPS")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "CONTRAT_MODALITE_TEMPS");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("CONTRAT_MODALITE_TEMPS");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("CONTRAT_MODALITE_TEMPS");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("10", "temps plein"));

                v.add(Tuple2.create("20", "temps partiel"));

                v.add(Tuple2.create("21", "temps partiel thérapeutique"));

                v.add(Tuple2.create("99", "salarié non concerné"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "CONTRAT_MODALITE_TEMPS", ex);

            }

        }

        if (!root.contains("CONTRAT_REGIME_MALADIE")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "CONTRAT_REGIME_MALADIE");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("CONTRAT_REGIME_MALADIE");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("CONTRAT_REGIME_MALADIE");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("134", "régime spécial de la SNCF"));

                v.add(Tuple2.create("135", "régime spécial de la RATP"));

                v.add(Tuple2.create("136", "établissement des invalides de la marine (ENIM)"));

                v.add(Tuple2.create("137", "mineurs ou assimilés (CANMSS)"));

                v.add(Tuple2.create("138", "militaires de carrière (CNMSS)"));

                v.add(Tuple2.create("140", "clercs et employés de notaires (CRPCEN)"));

                v.add(Tuple2.create("141", "chambre de commerce et d'industrie de Paris"));

                v.add(Tuple2.create("144", "Assemblée Nationale"));

                v.add(Tuple2.create("145", "Sénat"));

                v.add(Tuple2.create("146", "port autonome de Bordeaux"));

                v.add(Tuple2.create("147", "industries électriques et gazières (CAMIEG)"));

                v.add(Tuple2.create("149", "régimes des cultes (CAVIMAC)"));

                v.add(Tuple2.create("200", "régime général (CNAM)"));

                v.add(Tuple2.create("300", "régime agricole (MSA)"));

                v.add(Tuple2.create("400", "régime spécial Banque de France"));

                v.add(Tuple2.create("900", "autre régime (réservé Polynésie Française, Nouvelle Calédonie)"));

                v.add(Tuple2.create("999", "autre"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "CONTRAT_REGIME_MALADIE", ex);

            }

        }

        if (!root.contains("CONTRAT_REGIME_VIEILLESSE")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "CONTRAT_REGIME_VIEILLESSE");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("CONTRAT_REGIME_VIEILLESSE");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("CONTRAT_REGIME_VIEILLESSE");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("120", "retraite des agents des collectivités locales (CNRACL)"));

                v.add(Tuple2.create("121", "pensions des ouvriers des établissements industriels de l'Etat (FSPOEIE)"));

                v.add(Tuple2.create("122", "pensions civiles et militaires de retraite de l'Etat (SRE)"));

                v.add(Tuple2.create("134", "régime spécial de la SNCF"));

                v.add(Tuple2.create("135", "régime spécial de la RATP"));

                v.add(Tuple2.create("136", "établissement des invalides de la marine (ENIM)"));

                v.add(Tuple2.create("137", "mineurs ou assimilés (fonds Caisse des Dépôts)"));

                v.add(Tuple2.create("139", "Banque de France"));

                v.add(Tuple2.create("140", "clercs et employés de notaires (CRPCEN)"));

                v.add(Tuple2.create("141", "chambre de commerce et d'industrie de Paris"));

                v.add(Tuple2.create("144", "Assemblée Nationale"));

                v.add(Tuple2.create("145", "Sénat"));

                v.add(Tuple2.create("147", "industries électriques et gazières (CNIEG)"));

                v.add(Tuple2.create("149", "régime des cultes (CAVIMAC)"));

                v.add(Tuple2.create("157", "régime de retraite des avocats (CNBF)"));

                v.add(Tuple2.create("158", "SEITA"));

                v.add(Tuple2.create("159", "Comédie Française"));

                v.add(Tuple2.create("160", "Opéra de Paris"));

                v.add(Tuple2.create("200", "régime général (CNAV)"));

                v.add(Tuple2.create("300", "régime agricole (MSA)"));

                v.add(Tuple2.create("900", "autre régime (réservé Polynésie Française, Nouvelle Calédonie, Principauté de Monaco)"));

                v.add(Tuple2.create("903", "salariés étrangers exemptés d'affiliation pour le risque vieillesse"));

                v.add(Tuple2.create("999", "cas particuliers d'affiliation"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "CONTRAT_REGIME_VIEILLESSE", ex);

            }

        }

        if (!root.contains("CONTRAT_MOTIF_RECOURS")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "CONTRAT_MOTIF_RECOURS");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("CONTRAT_MOTIF_RECOURS");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("CONTRAT_MOTIF_RECOURS");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("01", "Remplacement d'un salarié"));

                v.add(Tuple2.create("02", "Accroissement temporaire de l'activité de l'entreprise"));

                v.add(Tuple2.create("03", "Emplois à caractère saisonnier"));

                v.add(Tuple2.create("04", "Contrat vendanges"));

                v.add(Tuple2.create("05", "Contrat à durée déterminée d’usage"));

                v.add(Tuple2.create("06", "Contrat à durée déterminée à objet défini"));

                v.add(Tuple2.create("07", "Remplacement d'un chef d'entreprise"));

                v.add(Tuple2.create("08", "Remplacement du chef d'une exploitation agricole"));

                v.add(Tuple2.create("09", "Recrutement de personnes sans emploi rencontrant des difficultés sociales et professionnelles particulières"));

                v.add(Tuple2.create("10", "Complément de formation professionnelle au salarié"));

                v.add(Tuple2.create("11",

                        "Formation professionnelle au salarié par la voie de l'apprentissage, en vue de l'obtention d'une qualification professionnelle sanctionnée par un diplôme ou un titre à finalité professionnelle enregistré au répertoire national des certifications professionnelles"));

                v.add(Tuple2.create("12", "Remplacement d’un salarié passé provisoirement à temps partiel"));

                v.add(Tuple2.create("13", "Attente de la suppression définitive du poste du salarié ayant quitté définitivement l’entreprise"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "CONTRAT_MOTIF_RECOURS", ex);

            }

        }

        if (!root.contains("CONTRAT_DETACHE_EXPATRIE")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "CONTRAT_DETACHE_EXPATRIE");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("CONTRAT_DETACHE_EXPATRIE");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("CONTRAT_DETACHE_EXPATRIE");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("01", "Détaché"));

                v.add(Tuple2.create("02", "Expatrié"));

                v.add(Tuple2.create("03", "Frontalier"));

                v.add(Tuple2.create("99", "Salarié non concerné"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "CONTRAT_DETACHE_EXPATRIE", ex);

            }

        }

        if (!root.contains("DSN_NATURE")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "DSN_NATURE");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("DSN_NATURE");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("DSN_NATURE");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("01", "DSN Mensuelle"));

                v.add(Tuple2.create("02", "Signalement Fin du contrat de travail"));

                v.add(Tuple2.create("04", "Signalement Arrêt de travail"));

                v.add(Tuple2.create("05", "Signalement Reprise suite à arrêt de travail"));

                v.add(Tuple2.create("06", "DSN reprise d'historique"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "DSN_NATURE", ex);

            }

        }

        if (!root.contains("DSN_TYPE")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "DSN_TYPE");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("DSN_TYPE");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("DSN_TYPE");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("01", "déclaration normale"));

                v.add(Tuple2.create("02", "déclaration normale néant"));

                v.add(Tuple2.create("03", "déclaration annule et remplace intégral"));

                v.add(Tuple2.create("04", "déclaration annule"));

                v.add(Tuple2.create("05", "annule et remplace néant"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "DSN_TYPE", ex);

            }

        }

        if (!root.contains("CONTRAT_DISPOSITIF_POLITIQUE")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "CONTRAT_DISPOSITIF_POLITIQUE");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("CONTRAT_DISPOSITIF_POLITIQUE");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("CONTRAT_DISPOSITIF_POLITIQUE");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("21", "CUI - Contrat Initiative Emploi"));

                v.add(Tuple2.create("41", "CUI - Contrat d'Accompagnement dans l'Emploi"));

                v.add(Tuple2.create("42", "CUI - Contrat d'accès à l'emploi - DOM"));

                v.add(Tuple2.create("50", "Emploi d'avenir secteur marchand"));

                v.add(Tuple2.create("51", "Emploi d'avenir secteur non marchand"));

                v.add(Tuple2.create("61", "Contrat de Professionnalisation"));

                v.add(Tuple2.create("64", "Contrat d'apprentissage entreprises artisanales ou de moins de 11 salariés (loi du 3 janvier 1979)"));

                v.add(Tuple2.create("65", "Contrat d’apprentissage entreprises non inscrites au répertoire des métiers d’au moins 11 salariés (loi de 1987)"));

                v.add(Tuple2.create("70", "Contrat à durée déterminée pour les séniors"));

                v.add(Tuple2.create("71", "Contrat à durée déterminée d’insertion"));

                v.add(Tuple2.create("80", "Contrat de génération"));

                v.add(Tuple2.create("81", "Contrat d'apprentissage secteur public (Loi de 1992)"));

                v.add(Tuple2.create("82", "Contrat à durée indéterminée intérimaire"));

                v.add(Tuple2.create("99", "Non concerné"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "CONTRAT_DISPOSITIF_POLITIQUE", ex);

            }

        }

        if (!root.contains("CODE_AMENAGEMENT_PARTIEL")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "CODE_AMENAGEMENT_PARTIEL");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("CODE_AMENAGEMENT_PARTIEL");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("CODE_AMENAGEMENT_PARTIEL");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("01", "Forfait hebdomadaire"));

                v.add(Tuple2.create("02", "Autre temps de travail hebdomadaire"));

                v.add(Tuple2.create("03", "Equivalent à 35h - 39h (Mayotte)"));

                v.add(Tuple2.create("04", "Forfait mensuel"));

                v.add(Tuple2.create("05", "Forfait annuel en jour"));

                v.add(Tuple2.create("06", "Forfait annuel en heures"));

                v.add(Tuple2.create("07", "Cycle"));

                v.add(Tuple2.create("08", "Modulation"));

                v.add(Tuple2.create("09", "Aménagement du temps de travail (Loi du 20 août 2008)"));

                v.add(Tuple2.create("10", "Personnel navigant ou autres"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "CODE_AMENAGEMENT_PARTIEL", ex);

            }

        }

        if (!root.contains("CODE_SUSPENSION")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "CODE_SUSPENSION");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("CODE_SUSPENSION");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("CODE_SUSPENSION");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("112", "Invalidité catégorie 1"));

                v.add(Tuple2.create("114", "Invalidité catégorie 2"));

                v.add(Tuple2.create("116", "Invalidité catégorie 3"));

                v.add(Tuple2.create("200", "COP (Congés payés)"));

                v.add(Tuple2.create("301", "Congé de Formation Professionnelle"));

                v.add(Tuple2.create("501", "Congé divers non rémunéré"));

                v.add(Tuple2.create("507", "Chômage intempéries"));

                v.add(Tuple2.create("601", "Mobilité volontaire sécurisée"));

                v.add(Tuple2.create("602", "Chômage sans rupture de contrat"));

                v.add(Tuple2.create("603", "Détention provisoire"));

                v.add(Tuple2.create("604", "Journée de perception de l'allocation journalière de présence parentale"));

                v.add(Tuple2.create("605", "Congé statutaire"));

                v.add(Tuple2.create("606", "Détachement d'un salarié IEG en France"));

                v.add(Tuple2.create("607", "Congé de présence parentale"));

                v.add(Tuple2.create("608", "CASA"));

                v.add(Tuple2.create("609", "CIF (Congé Individuel de Formation)"));

                v.add(Tuple2.create("611", "Congé de bilan de compétences"));

                v.add(Tuple2.create("612", "Congé de candidat parlementaire ou élu à un mandat local"));

                v.add(Tuple2.create("615", "Congé de formation de cadres et d'animateurs pour la jeunesse"));

                v.add(Tuple2.create("617", "Congé de formation pour les salariés de moins de 25 ans"));

                v.add(Tuple2.create("618", "Congé de formation économique, sociale et syndicale"));

                v.add(Tuple2.create("620", "Congé de mobilité"));

                v.add(Tuple2.create("621", "Congé de participation aux instances d'emploi ou de formation professionnelle"));

                v.add(Tuple2.create("625", "Congé de reclassement"));

                v.add(Tuple2.create("626", "Congé de représentation"));

                v.add(Tuple2.create("627", "Congé de solidarité familiale"));

                v.add(Tuple2.create("628", "Congé de solidarité internationale"));

                v.add(Tuple2.create("630", "Congé d'enseignement ou de recherche"));

                v.add(Tuple2.create("631", "Congé mutualiste de formation"));

                v.add(Tuple2.create("632", "Congé parental d'éducation"));

                v.add(Tuple2.create("633", "Congé pour acquisition de la nationalité"));

                v.add(Tuple2.create("634", "Congé pour catastrophe naturelle"));

                v.add(Tuple2.create("635", "Congé pour création ou reprise d'entreprise"));

                v.add(Tuple2.create("636", "Congé pour enfant malade"));

                v.add(Tuple2.create("637", "Congé pour évènement familial"));

                v.add(Tuple2.create("638", "Congé pour validation des acquis de l'expérience"));

                v.add(Tuple2.create("639", "Congé sabbatique"));

                v.add(Tuple2.create("642", "Convention FNE d'aide au passage à temps partiel"));

                v.add(Tuple2.create("643", "Congé de conversion avec prise en charge par l'Etat"));

                v.add(Tuple2.create("644", "Congé de conversion sans prise en charge par l'Etat"));

                v.add(Tuple2.create("645", "Préretraite progressive"));

                v.add(Tuple2.create("646", "Préretraite d'entreprise sans rupture de contrat de travail"));

                v.add(Tuple2.create("647", "Réduction temps d'emploi"));

                v.add(Tuple2.create("648", "Conventions d'Allocations Spéciales du FNE (ASFNE)"));

                v.add(Tuple2.create("650", "Congé de proche aidant"));

                v.add(Tuple2.create("651", "Congé pour mandat parlementaire"));

                v.add(Tuple2.create("652", "Inaptitude temporaire liée à la grossesse"));

                v.add(Tuple2.create("653", "Maintien de salaire – personnel navigant de l’aéronautique civile"));

                v.add(Tuple2.create("654", "Inactivité temps alterné – personnel navigant de l’aéronautique civile"));

                v.add(Tuple2.create("655", "[FP] Détachement conduisant à pension (ECP)"));

                v.add(Tuple2.create("656", "[FP] Congé pour cessation anticipée d’activité du fait d’une maladie professionnelle provoquée par l’amiante"));

                v.add(Tuple2.create("657", "[FP] Absence concertée de travail"));

                v.add(Tuple2.create("658", "[FP] Congé spécial"));

                v.add(Tuple2.create("659", "[FP] Période d'instruction militaire ou réserve opérationnelle"));

                v.add(Tuple2.create("660", "[FP] Congé avec traitement période d'instruction militaire obligatoire"));

                v.add(Tuple2.create("661", "[FP] Congé organisations de jeunesse"));

                v.add(Tuple2.create("662", "[FP] Congé pour siéger auprès d’une association, d’une mutuelle, d’une instance de l’Etat ou d’une collectivité territoriale"));

                v.add(Tuple2.create("663", "[FP] Congé non rémunéré de 18 jours pour mandats municipaux ou départementaux ou régionaux"));

                v.add(Tuple2.create("664", "[FP] Congé avec traitement pour période d'activité dans la réserve de sécurité civile"));

                v.add(Tuple2.create("665", "[FP] Congé pour période d'activité dans la réserve sanitaire"));

                v.add(Tuple2.create("666", "[FP] Congé pour recherches ou conversions thématiques"));

                v.add(Tuple2.create("667", "[FP] Congé pour raisons opérationnelles et activités privées des sapeurs"));

                v.add(Tuple2.create("668", "[FP] Congé pour raisons opérationnelles cotisé des sapeurs"));

                v.add(Tuple2.create("669", "[FP] Congé pour difficultés opérationnelles des sapeurs"));

                v.add(Tuple2.create("670", "[FP] Congé pour période d'activité dans la réserve civile de la police"));

                v.add(Tuple2.create("671", "[FP] Exclusion temporaire de fonctions"));

                v.add(Tuple2.create("672", "[FP] Suspension"));

                v.add(Tuple2.create("673", "[FP] Absences irrégulières (service non fait)"));

                v.add(Tuple2.create("674", "[FP] Détachement ne conduisant pas à pension (ENCP)"));

                v.add(Tuple2.create("675", "[FP] Disponibilité"));

                v.add(Tuple2.create("676", "[FP] Disponibilité pour maladie"));

                v.add(Tuple2.create("677", "[FP] Disponibilité pour élever un enfant âgé de moins de 8 ans"));

                v.add(Tuple2.create("678", "[FP] Position hors cadres"));

                v.add(Tuple2.create("680", "Congé sans solde cotisés"));

                v.add(Tuple2.create("681", "Détachement hors IEG"));

                v.add(Tuple2.create("998", "Annulation"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "CODE_SUSPENSION", ex);

            }

        }

        if (!root.contains("MOTIF_REPRISE_ARRET_TRAVAIL")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "MOTIF_REPRISE_ARRET_TRAVAIL");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("MOTIF_REPRISE_ARRET_TRAVAIL");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("MOTIF_REPRISE_ARRET_TRAVAIL");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("01", "reprise normale"));

                v.add(Tuple2.create("02", "reprise temps partiel thérapeutique"));

                v.add(Tuple2.create("03", "reprise temps partiel raison personnelle"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "MOTIF_REPRISE_ARRET_TRAVAIL", ex);

            }

        }

        if (!root.contains("MOTIF_FIN_CONTRAT")) {

            final SQLCreateTable createTableMotif = new SQLCreateTable(root, "MOTIF_FIN_CONTRAT");

            createTableMotif.addVarCharColumn("CODE", 25);

            createTableMotif.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableMotif.asString());

                insertUndef(createTableMotif);

                root.refetchTable("MOTIF_FIN_CONTRAT");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("MOTIF_FIN_CONTRAT");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("011", "licenciement suite à liquidation judiciaire ou à redressement judiciaire"));

                v.add(Tuple2.create("012", "licenciement suite à fermeture définitive de l'établissement"));

                v.add(Tuple2.create("014", "licenciement pour motif économique"));

                v.add(Tuple2.create("015", "licenciement pour fin de chantier"));

                v.add(Tuple2.create("020", "licenciement pour autre motif"));

                v.add(Tuple2.create("025", "autre fin de contrat pour motif économique"));

                v.add(Tuple2.create("026", "rupture pour motif économique dans le cadre d’un contrat de sécurisation professionnelle CSP"));

                v.add(Tuple2.create("031", "fin de contrat à durée déterminée ou fin d'accueil occasionnel"));

                v.add(Tuple2.create("032", "fin de mission d'intérim"));

                v.add(Tuple2.create("033", "rupture anticipée d’un CDD ou d’un contrat de mission en cas d’inaptitude physique constatée par le médecin du travail"));

                v.add(Tuple2.create("034", "fin de période d'essai à l'initiative de l'employeur"));

                v.add(Tuple2.create("035", "fin de période d'essai à l'initiative du salarié"));

                v.add(Tuple2.create("036", " rupture anticipée d'un CDD, d'un contrat d'apprentissage ou d’un contrat de mission à l'initiative de l'employeur"));

                v.add(Tuple2.create("037", "rupture anticipée d'un CDD, d'un contrat d'apprentissage ou d’un contrat de mission à l'initiative du salarié"));

                v.add(Tuple2.create("038", "mise à la retraite par l'employeur"));

                v.add(Tuple2.create("039", "départ à la retraite à l'initiative du salarié"));

                v.add(Tuple2.create("043", "rupture conventionnelle"));

                v.add(Tuple2.create("058", "prise d'acte de la rupture de contrat de travail"));

                v.add(Tuple2.create("059", "démission"));

                v.add(Tuple2.create("065", "décès de l'employeur ou internement / conduit à un licenciement autre motif"));

                v.add(Tuple2.create("066", "décès du salarié / rupture force majeure"));

                v.add(Tuple2.create("081", "fin de contrat d'apprentissage"));

                v.add(Tuple2.create("082", "résiliation judiciaire du contrat de travail"));

                v.add(Tuple2.create("083", "rupture de contrat de travail ou d’un contrat de mission pour force majeure"));

                v.add(Tuple2.create("084", "rupture d'un commun accord du CDD, du contrat d'apprentissage ou d’un contrat de mission"));

                v.add(Tuple2.create("085", "fin de mandat"));

                v.add(Tuple2.create("086", "licenciement convention CATS"));

                v.add(Tuple2.create("087", "licenciement pour faute grave"));

                v.add(Tuple2.create("088", "licenciement pour faute lourde"));

                v.add(Tuple2.create("089", "licenciement pour force majeure"));

                v.add(Tuple2.create("091", "licenciement pour inaptitude physique d'origine non professionnelle"));

                v.add(Tuple2.create("092", "licenciement pour inaptitude physique d'origine professionnelle"));

                v.add(Tuple2.create("093", "licenciement suite à décision d'une autorité administrative"));

                v.add(Tuple2.create("094", "rupture anticipée du contrat de travail pour arrêt de tournage"));

                v.add(Tuple2.create("095", "rupture anticipée du contrat de travail ou d’un contrat de mission pour faute grave"));

                v.add(Tuple2.create("096", "rupture anticipée du contrat de travail ou d’un contrat de mission pour faute lourde"));

                v.add(Tuple2.create("097", "rupture anticipée d’un contrat de travail ou d’un contrat de mission suite à fermeture de l'établissement"));

                v.add(Tuple2.create("098", "retrait d'enfant"));

                v.add(Tuple2.create("998", "transfert du contrat de travail sans rupture du contrat vers un autre établissement n'effectuant pas encore de DSN"));

                v.add(Tuple2.create("999", "fin de relation avec l’employeur (autres que contrat de travail) pour les cas ne portant aucun impact sur l’Assurance chômage"));

                insertValues(v, table);

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "MOTIF_FIN_CONTRAT", ex);

            }

        }

        DSNUpdateRubrique dsnUpdateRubrique = new DSNUpdateRubrique(root);

        dsnUpdateRubrique.updateRubriqueCotisation();

        // PHASE 3

        final SQLTable caisseCot = root.getTable("CAISSE_COTISATION");

        {

            SQLTable tableCaisseCotisation = root.findTable("CAISSE_COTISATION");

            if (!tableCaisseCotisation.contains("ORG_PROTECTION_SOCIALE")) {

                final AlterTable alterCaisse = new AlterTable(tableCaisseCotisation);

                alterCaisse.addBooleanColumn("ORG_PROTECTION_SOCIALE", Boolean.FALSE, false);

                alterCaisse.addBooleanColumn("URSSAF", Boolean.FALSE, false);

                root.getBase().getDataSource().execute(alterCaisse.asString());

                root.refetchTable("CAISSE_COTISATION");

                root.getSchema().updateVersion();

                {

                    UpdateBuilder upCaisse = new UpdateBuilder(tableCaisseCotisation);

                    upCaisse.setObject("ORG_PROTECTION_SOCIALE", Boolean.TRUE);

                    upCaisse.setWhere(new Where(tableCaisseCotisation.getField("NOM"), Arrays.asList("URSSAF", "AGIRC", "ARRCO")));

                    root.getBase().getDataSource().execute(upCaisse.asString());

                }

                {

                    UpdateBuilder upCaisse = new UpdateBuilder(tableCaisseCotisation);

                    upCaisse.setObject("URSSAF", Boolean.TRUE);

                    upCaisse.setWhere(new Where(tableCaisseCotisation.getField("NOM"), Arrays.asList("URSSAF")));

                    root.getBase().getDataSource().execute(upCaisse.asString());

                }

            }

            if (!root.contains("CAISSE_MODE_PAIEMENT")) {

                final SQLCreateTable createCaisseMode = new SQLCreateTable(root, "CAISSE_MODE_PAIEMENT");

                createCaisseMode.addVarCharColumn("CODE", 25);

                createCaisseMode.addVarCharColumn("NOM", 512);

                try {

                    root.getBase().getDataSource().execute(createCaisseMode.asString());

                    insertUndef(createCaisseMode);

                    root.refetchTable("CAISSE_MODE_PAIEMENT");

                    root.getSchema().updateVersion();

                    final SQLTable table = root.getTable("CAISSE_MODE_PAIEMENT");

                    List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                    v.add(Tuple2.create("01", "chèque"));

                    v.add(Tuple2.create("02", "virement"));

                    v.add(Tuple2.create("03", "prélèvement"));

                    v.add(Tuple2.create("04", "titre inter-bancaire de paiement"));

                    v.add(Tuple2.create("05", "prélèvement SEPA"));

                    v.add(Tuple2.create("06", "versement réalisé par un autre établissement"));

                    insertValues(v, table);

                } catch (SQLException ex) {

                    throw new IllegalStateException("Erreur lors de la création de la table " + "CAISSE_MODE_PAIEMENT", ex);

                }

                final SQLCreateTable createCaisseREnseignement = new SQLCreateTable(root, "CAISSE_COTISATION_RENSEIGNEMENT");

                createCaisseREnseignement.addVarCharColumn("IDENTIFIANT", 256);

                createCaisseREnseignement.addVarCharColumn("SIRET", 256);

                createCaisseREnseignement.addVarCharColumn("BIC", 256);

                createCaisseREnseignement.addVarCharColumn("IBAN", 256);

                createCaisseREnseignement.addVarCharColumn("ENTITE_AFFECTATION", 256);

                createCaisseREnseignement.addBooleanColumn("ORGANISME_COMPLEMENTAIRE", Boolean.FALSE, false);

                createCaisseREnseignement.addBooleanColumn("PAIEMENT_TRIMESTRIEL", Boolean.FALSE, false);

                createCaisseREnseignement.addVarCharColumn("CODE_DELEGATAIRE", 256);

                createCaisseREnseignement.addForeignColumn("ID_CAISSE_MODE_PAIEMENT", root.getTable("CAISSE_MODE_PAIEMENT"));

                createCaisseREnseignement.addForeignColumn("ID_CAISSE_COTISATION", caisseCot);

                createCaisseREnseignement.addForeignColumn("ID_SOCIETE_COMMON", root.getTable("SOCIETE_COMMON"));

                root.getBase().getDataSource().execute(createCaisseREnseignement.asString());

                insertUndef(createCaisseREnseignement);

                root.refetchTable("CAISSE_COTISATION_RENSEIGNEMENT");

                root.getSchema().updateVersion();

            }

            SQLTable tableCR = root.getTable("CAISSE_COTISATION_RENSEIGNEMENT");

            if (!tableCR.contains("PAIEMENT_TRIMESTRIEL")) {

                AlterTable alter = new AlterTable(tableCR);

                alter.addBooleanColumn("PAIEMENT_TRIMESTRIEL", Boolean.FALSE, false);

                root.getBase().getDataSource().execute(alter.asString());

                root.refetchTable("CAISSE_COTISATION_RENSEIGNEMENT");

                root.getSchema().updateVersion();

            }

            if (!tableCR.contains("JOUR_PAIEMENT")) {

                AlterTable alter = new AlterTable(tableCR);

                alter.addIntegerColumn("JOUR_PAIEMENT", 0);

                root.getBase().getDataSource().execute(alter.asString());

                root.refetchTable("CAISSE_COTISATION_RENSEIGNEMENT");

                root.getSchema().updateVersion();

            }

        }

        if (!root.contains("TYPE_COMPOSANT_BASE_ASSUJETTIE")) {

            final SQLCreateTable createTableTypeComposant = new SQLCreateTable(root, "TYPE_COMPOSANT_BASE_ASSUJETTIE");

            createTableTypeComposant.addVarCharColumn("CODE", 25);

            createTableTypeComposant.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableTypeComposant.asString());

                insertUndef(createTableTypeComposant);

                root.refetchTable("TYPE_COMPOSANT_BASE_ASSUJETTIE");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("TYPE_COMPOSANT_BASE_ASSUJETTIE");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("01", "Montant du SMIC retenu pour le calcul de la Réduction générale des cotisations patronales de sécurité sociale"));

                v.add(Tuple2.create("02", "Montant du SMIC retenu pour le calcul du crédit d'impôt compétitivité-emploi"));

                v.add(Tuple2.create("03", "Contributions patronales à des régimes complémentaires de retraite"));

                v.add(Tuple2.create("04", "Contributions patronales destinées au financement des prestations de prévoyance complémentaire"));

                v.add(Tuple2.create("05", "Contributions patronales destinées au financement des prestations de retraite supplémentaire"));

                v.add(Tuple2.create("06", "Plafond calculé pour salarié poly-employeurs"));

                v.add(Tuple2.create("10", "Salaire brut Prévoyance"));

                v.add(Tuple2.create("11", "Tranche A Prévoyance"));

                v.add(Tuple2.create("12", "Tranche 2 Prévoyance"));

                v.add(Tuple2.create("13", "Tranche B Prévoyance"));

                v.add(Tuple2.create("14", "Tranche C Prévoyance"));

                v.add(Tuple2.create("15", "Tranche D Prévoyance"));

                v.add(Tuple2.create("16", "Tranche D1 Prévoyance"));

                v.add(Tuple2.create("17", "Base spécifique Prévoyance"));

                v.add(Tuple2.create("18", "Base forfaitaire Prévoyance"));

                v.add(Tuple2.create("19", "Base fictive Prévoyance reconstituée"));

                v.add(Tuple2.create("20", "Montant forfaitaire Prévoyance"));

                v.add(Tuple2.create("21", "Montant Prévoyance libre ou exceptionnel"));

                v.add(Tuple2.create("22", "Montant des indemnités journalières CRPCEN"));

                v.add(Tuple2.create("90", "Retenue sur salaire"));

                v.add(Tuple2.create("91", "Base de taxe sur les salaires au taux normal"));

                insertValues(v, table);

                AlterTable tableRubCotis = new AlterTable(tableRubCot);

                tableRubCotis.addForeignColumn("ID_TYPE_COMPOSANT_BASE_ASSUJETTIE", root.getTable("TYPE_COMPOSANT_BASE_ASSUJETTIE"));

                root.getBase().getDataSource().execute(tableRubCotis.asString());

                root.refetchTable(tableRubCot.getName());

                root.getSchema().updateVersion();

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "TYPE_COMPOSANT_BASE_ASSUJETTIE", ex);

            }

        }

        if (!root.contains("CODE_COTISATION_INDIVIDUELLE")) {

            final SQLCreateTable createTableTypeComposant = new SQLCreateTable(root, "CODE_COTISATION_INDIVIDUELLE");

            createTableTypeComposant.addVarCharColumn("CODE", 25);

            createTableTypeComposant.addVarCharColumn("NOM", 512);

            try {

                root.getBase().getDataSource().execute(createTableTypeComposant.asString());

                insertUndef(createTableTypeComposant);

                root.refetchTable("CODE_COTISATION_INDIVIDUELLE");

                root.getSchema().updateVersion();

                final SQLTable table = root.getTable("CODE_COTISATION_INDIVIDUELLE");

                List<Tuple2<String, String>> v = new ArrayList<Tuple2<String, String>>();

                v.add(Tuple2.create("001", "Exonération de cotisations au titre de l'emploi d'un apprenti (loi de 1979)"));

                v.add(Tuple2.create("002", "Exonération de cotisations au titre de l'emploi d'un apprenti (loi de 1987)"));

                v.add(Tuple2.create("003", "Exonération de cotisations au titre de l'emploi d'un apprenti (loi de 1992)"));

                v.add(Tuple2.create("004", "Exonération de cotisations au titre de l'emploi d'un salarié en contrat d'accès à l'emploi"));

                v.add(Tuple2.create("006", "Exonération de cotisations au titre de l'emploi d'un salarié en contrat d'accompagnement dans l'emploi"));

                v.add(Tuple2.create("008", "Exonération de cotisations au titre de l'emploi d'un salarié en contrat de professionnalisation"));

                v.add(Tuple2.create("009", "Exonération de cotisations applicable aux associations intermédiaires"));

                v.add(Tuple2.create("010", "Exonération de cotisations applicable aux entreprises des bassins d'emploi à redynamiser"));

                v.add(Tuple2.create("011", "Exonération de cotisations applicable au créateur ou repreneur d'entreprise"));

                v.add(Tuple2.create("012", "Exonération de cotisations applicable dans les DOM"));

                v.add(Tuple2.create("013", "Exonération de cotisations applicable aux entreprises et associations d'aide à domicile"));

                v.add(Tuple2.create("014", "Exonérations de cotisations applicable aux entreprises innovantes ou universitaires"));

                v.add(Tuple2.create("015", "Exonération de cotisations applicable aux entreprises en zones franches urbaines"));

                v.add(Tuple2.create("016", "Exonération de cotisations applicable aux organismes d'intérêt général en zones de revitalisation rurale"));

                v.add(Tuple2.create("017", "Exonération de cotisations applicable aux structures agréées de l'aide sociale"));

                v.add(Tuple2.create("018", "Réduction générale des cotisations patronales de sécurité sociale"));

                v.add(Tuple2.create("019", "Réduction de cotisations applicable aux entreprises des zones de restructuration de la défense"));

                v.add(Tuple2.create("020", "Réduction de cotisations au titre de l'embauche du 1er au 50ème salarié en zones de revitalisation rurale"));

                v.add(Tuple2.create("021", "Déduction patronale au titre des heures supplémentaires"));

                v.add(Tuple2.create("022", "Exonération de cotisations applicable à une gratification de stage"));

                v.add(Tuple2.create("023", "Exonération de cotisation des sommes provenant d'un CET et réaffectées à un PERCO ou à un régime de retraite supplémentaire"));

                v.add(Tuple2.create("025", "Exonération de cotisations au titre de l’emploi d’un salarié en chantier et atelier d'insertion"));

                v.add(Tuple2.create("027", "Exonération Personnel technique CUMA, hors ateliers"));

                v.add(Tuple2.create("028", "Réduction Travailleur Occasionnel"));

                v.add(Tuple2.create("029", "CNIEG Réduction employeurs petit pool"));

                v.add(Tuple2.create("030", "Camieg Cotisation employeurs Régime spécial Complémentaire"));

                v.add(Tuple2.create("031", "Camieg Cotisation salariés Régime spécial Complémentaire"));

                v.add(Tuple2.create("032", "Camieg Cotisation salariés Régime spécial Solidarité"));

                v.add(Tuple2.create("033", "CNIEG Cotisation employeurs complément d'invalidité"));

                v.add(Tuple2.create("034", "CNIEG Cotisation employeurs régime de droit commun (population adossée)"));

                v.add(Tuple2.create("035", "CNIEG Cotisation employeurs Régime spécial (population adossée)"));

                v.add(Tuple2.create("036", "CNIEG Cotisation employeurs régime spécial (population non adossée)"));

                v.add(Tuple2.create("037", "CNIEG Cotisation salariés régime de droit commun (population adossée)"));

                v.add(Tuple2.create("038", "CNIEG Cotisation salariés régime spécial (population non adossée)"));

                v.add(Tuple2.create("039", "CNIEG Cotisations employeurs petit pool"));

                v.add(Tuple2.create("040", "Cotisation AC : assurance chômage sur rémunérations brutes après déduction, limitées à 4 fois le plafond de la SS"));

                v.add(Tuple2.create("041", "Cotisation AC majorée 1 : application d’une majoration AC + 0,5% sur les contrats d’usage inférieurs ou égaux à 3 mois"));

                v.add(Tuple2.create("042", "Cotisation AC majorée 2 : application d’une majoration AC + 3% sur les contrats d’accroissement temporaire d’activité inférieurs ou égaux à 1 mois"));

                v.add(Tuple2.create("043",

                        "Cotisation AC majorée 3 : application d’une majoration AC + 1,5% sur les contrats d’accroissement temporaire d’activité supérieurs à 1 mois mais inférieurs ou égaux à 3 mois"));

                v.add(Tuple2.create("044", "Exonération de cotisation chômage pour les moins de 26 ans"));

                v.add(Tuple2.create("045", "Cotisation Accident du travail"));

                v.add(Tuple2.create("046", "Cotisation AEF Bourse de l'emploi"));

                v.add(Tuple2.create("047", "Cotisation AEF CESA"));

                v.add(Tuple2.create("048", "Cotisation AGS : assurance garantie des salaires sur rémunérations brutes après déduction, limitées à 4 fois le plafond de la sécurité sociale"));

                v.add(Tuple2.create("049", "Cotisation Allocation de logement (FNAL)"));

                v.add(Tuple2.create("051", "Cotisation Formation professionnelle ADEFA"));

                v.add(Tuple2.create("052", "Cotisation AFNCA, ANEFA, PROVEA, ASCPA"));

                v.add(Tuple2.create("053", "Cotisation Formation professionnelle additionnelle FAFSEA"));

                v.add(Tuple2.create("054", "Cotisation Formation professionnelle AREFA"));

                v.add(Tuple2.create("055", "Cotisation Formation professionnelle CEREFAR"));