package com.megatim.fdxconsultation.core.impl.integration;

import com.megatim.fdxcommons.core.ifaces.helper.referentiel.DynamicTableCreator;
import com.megatim.fdxcommons.model.integration.TableDefinition;
import com.megatim.fdxcommons.tools.database.connection.DBConnection;
import com.megatim.fdxconsultation.core.impl.factory.FdxConsultationTableFactory;
import com.megatim.fdxconsultation.tools.context.AppCommonContext;
import java.sql.Connection;
import java.util.List;
import javax.annotation.Resource;
import javax.enterprise.context.Dependent;
import javax.sql.DataSource;

/**
 *
 * @author lenovo
 */
@Dependent
public class DynamicTableCreatorImpl implements DynamicTableCreator {

    @Resource(lookup = AppCommonContext.JNDI_NAME)
    private DataSource dataSource;

    @Override
    public void createDynamicTables(List<TableDefinition> tableDefinitions) throws Exception {

        try ( Connection connection = new DBConnection(dataSource).connection()) {

            for (TableDefinition tableDefinition : tableDefinitions) {
                FdxConsultationTableFactory.createTable(tableDefinition.getCodeTypeFichier(),
                        tableDefinition.getReferentielVersion(),
                        connection)
                        .createTable(tableDefinition.getColumnDefinitions(), connection);

            }
        }
    }
}