/*
|
* Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
|
* Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
|
*/
|
package com.megatim.fdxconsultation.core.impl.integration;
|
|
import com.megatim.fdxcommons.tools.database.connection.DBConnection;
|
import com.megatim.fdxcommons.tools.database.contrat.AppColumnDefinition;
|
import com.megatim.fdxcommons.tools.database.tables.FdxConsultationTable;
|
import com.megatim.fdxcommons.tools.database.tables.appcolumns.DataProductionUpdateIdColumnDefinition;
|
import com.megatim.fdxcommons.tools.database.tables.appcolumns.DateCreationColumnDefinition;
|
import com.megatim.fdxcommons.tools.database.tables.appcolumns.DateMiseAJourColumnDefinition;
|
import com.megatim.fdxcommons.tools.database.tables.appcolumns.EnCoursProductionColumnDefinition;
|
import com.megatim.fdxconsultation.core.ifaces.integration.ColumnDefinitionManager;
|
import com.megatim.fdxconsultation.tools.context.AppCommonContext;
|
import java.sql.Connection;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.logging.Level;
|
import java.util.logging.Logger;
|
import javax.annotation.Resource;
|
import javax.enterprise.context.Dependent;
|
import javax.inject.Inject;
|
import javax.persistence.Tuple;
|
import javax.sql.DataSource;
|
import com.megatim.fdxcommons.core.ifaces.integration.AppColumnCreator;
|
|
/**
|
*
|
* @author ASUS
|
*/
|
@Dependent
|
public class AppColumnCreatorImpl implements AppColumnCreator {
|
|
@Inject
|
ColumnDefinitionManager columnDefinitionManager;
|
|
@Resource(lookup = AppCommonContext.JNDI_NAME)
|
private DataSource dataSource;
|
|
@Override
|
public void create() {
|
List<Tuple> refVersionAndTypeFichier = columnDefinitionManager.byRefVersionAndByTypeFichier();
|
final String encoursProductionColumnName = new EnCoursProductionColumnDefinition().name();
|
|
try ( Connection connection = new DBConnection(dataSource).connection()) {
|
|
refVersionAndTypeFichier.stream().forEach(r -> {
|
FdxConsultationTable consTable = new FdxConsultationTable((String) r.get(0), (String) r.get(1));
|
|
try {
|
for (AppColumnDefinition appColumn : columnsToAdd()) {
|
if (consTable.checkIfTableExists(connection) && !consTable.checkIfColumnExists(connection, appColumn.name())) {
|
|
consTable.addAppColumn(connection, appColumn);
|
}
|
}
|
} catch (SQLException ex) {
|
Logger.getLogger(AppColumnCreatorImpl.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
|
}
|
});
|
} catch (SQLException ex) {
|
Logger.getLogger(AppColumnCreatorImpl.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
|
}
|
}
|
|
private List<AppColumnDefinition> columnsToAdd() {
|
return new ArrayList<>(Arrays.asList(
|
new DateCreationColumnDefinition(),
|
new DateMiseAJourColumnDefinition(),
|
new DataProductionUpdateIdColumnDefinition()
|
));
|
}
|
|
}
|
