package com.megatim.fdxconsultation.core.impl.dataproductionworker;
|
|
import com.megatim.fdxcommons.tools.database.connection.DBConnection;
|
import com.megatim.fdxcommons.tools.database.tables.FdxConsultationTable;
|
import com.megatim.fdxconsultation.core.impl.factory.FdxConsultationTableFactory;
|
import com.megatim.fdxconsultation.model.dataproduction.DataProduction;
|
import java.sql.Connection;
|
import java.util.logging.Level;
|
import java.util.logging.Logger;
|
import javax.sql.DataSource;
|
|
/**
|
*
|
* @author Gabuntu
|
*/
|
class DeleteDataProductionTask implements DataProductionTask {
|
|
private final DataProduction dataProduction;
|
private final DataSource dataSource;
|
|
public DeleteDataProductionTask(DataProduction dataProduction, DataSource dataSource) {
|
this.dataProduction = dataProduction;
|
this.dataSource = dataSource;
|
}
|
|
@Override
|
public void processProduction() {
|
|
try ( Connection connection = new DBConnection(dataSource).connection()) {
|
|
connection.setAutoCommit(false);
|
|
FdxConsultationTable fdxConsTable = FdxConsultationTableFactory.createTable(dataProduction.getCodeTypeFichier(), dataProduction.getReferentielVersion(), connection);
|
fdxConsTable.delete(null, dataProduction, connection);
|
connection.commit();
|
|
} catch (Exception ex) {
|
Logger.getLogger(DeleteDataProductionTask.class.getName()).log(Level.SEVERE, ex.getMessage(), ex);
|
}
|
|
}
|
|
}
|
