package com.megatim.fdxcommons.tools.database.tables;
|
|
import com.megatim.fdxcommons.model.enumeration.Operateur;
|
import com.megatim.fdxcommons.tools.database.queries.DataWithTokenToDataProductionQuery;
|
import com.megatim.fdxcommons.tools.database.tables.appcolumns.FdxApiColumnDefinitions;
|
import com.megatim.fdxcommons.model.dataproduction.CommonDataProduction;
|
import com.megatim.fdxcommons.model.integration.ColumnDefinition;
|
import com.megatim.fdxcommons.tools.database.queries.FdxApiInsert;
|
import com.megatim.fdxcommons.tools.database.queries.metadata.QueryCriterion;
|
import com.megatim.fdxcommons.tools.database.contrat.TypeFichierUpdateMetaData;
|
import com.megatim.fdxcommons.tools.database.exceptions.TypeFichierDataBadRequest;
|
import com.megatim.fdxcommons.tools.database.contrat.TypeFichierInsertMetaData;
|
import com.megatim.fdxcommons.tools.database.exceptions.MoreThanOneTableDataNotFoundException;
|
import com.megatim.fdxcommons.tools.database.exceptions.TableDataNotFoundException;
|
import com.megatim.fdxcommons.tools.database.queries.CreateTableIfNotExistQuery;
|
import com.megatim.fdxcommons.tools.database.queries.FdxUpdate;
|
import com.megatim.fdxcommons.tools.database.queries.metadata.ApiTypeFichierInsertData;
|
import com.megatim.fdxcommons.tools.database.queries.metadata.ApiUpdateTypeFichierData;
|
import com.megatim.fdxcommons.tools.database.queries.metadata.FdxParsedData;
|
import com.megatim.fdxcommons.tools.database.queries.metadata.FdxParsedDataRow;
|
import com.megatim.fdxcommons.tools.database.queries.metadata.FdxTableDefinition;
|
import com.megatim.fdxcommons.tools.database.queries.metadata.ParsedQueryCriterion;
|
import com.megatim.fdxcommons.tools.database.tables.appcolumns.TokenColumnDefinition;
|
|
import java.sql.Connection;
|
import java.sql.SQLException;
|
import java.util.Arrays;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
import javax.naming.NamingException;
|
|
/**
|
*
|
* @author Gabuntu
|
*/
|
public class FdxApiTable extends FdxTable {
|
|
public FdxApiTable(String codeTypeFichier, String referentielVersion) {
|
super(codeTypeFichier, referentielVersion);
|
}
|
|
@Override
|
public void createTable(List<ColumnDefinition> columnsDefinition, Connection connection) throws NamingException, SQLException, Exception {
|
new CreateTableIfNotExistQuery(tableName, columnsDefinition, new FdxApiColumnDefinitions(), connection).execute();
|
}
|
|
@Override
|
public void deleteOne(QueryCriterion queryCriterion, CommonDataProduction dataProduction, Connection connection) throws TypeFichierDataBadRequest, SQLException, NamingException, Exception {
|
|
stopIfTableIsReferentiel(connection);
|
|
ParsedQueryCriterion parsedQueryCriterion = parsedQueryCriterion(queryCriterion, connection);
|
|
stopIfTableDataNotFound(parsedQueryCriterion, connection);
|
|
processDelete(parsedQueryCriterion.parsedCriterion(), dataProduction, connection);
|
|
}
|
|
@Override
|
public void updateOne(Map<String, Object> dataToUpdate, QueryCriterion queryCriterion, CommonDataProduction dataProduction, Connection connection)
|
throws TypeFichierDataBadRequest, SQLException, NamingException, Exception {
|
|
stopIfTableIsReferentiel(connection);
|
|
ParsedQueryCriterion parsedQueryCriteria = parsedQueryCriterion(queryCriterion, connection);
|
|
stopIfTableDataNotFound(parsedQueryCriteria, connection);
|
stopIfNotOneTableDataFound(parsedQueryCriteria, connection);
|
|
processUpdate(dataToUpdate, parsedQueryCriteria.parsedCriterion(), dataProduction, connection);
|
|
}
|
|
@Override
|
public void update(Map<String, Object> dataToUpdate, QueryCriterion queryCriterion, CommonDataProduction dataProduction, Connection connection) throws TypeFichierDataBadRequest, SQLException, NamingException, Exception {
|
|
stopIfTableIsReferentiel(connection);
|
|
ParsedQueryCriterion parsedQueryCriterion = parsedQueryCriterion(queryCriterion, connection);
|
|
stopIfTableDataNotFound(parsedQueryCriterion, connection);
|
|
processUpdate(dataToUpdate, parsedQueryCriterion.parsedCriterion(), dataProduction, connection);
|
|
}
|
|
public void insert(List<LinkedHashMap<String, Object>> originalData, Long dataProductionId, Connection connection) throws TypeFichierDataBadRequest, SQLException, NamingException, Exception {
|
FdxParsedData fdxParsedData = new FdxParsedData(originalData, tableDefinition(connection).tableDefinition());
|
TypeFichierInsertMetaData insertMetaData = new ApiTypeFichierInsertData(tableName.name(connection), fdxParsedData);
|
new FdxApiInsert(connection, dataProductionId).insert(insertMetaData);
|
}
|
|
public void insert(List<LinkedHashMap<String, Object>> originalData, String token, Connection connection) throws TypeFichierDataBadRequest, SQLException, NamingException, Exception {
|
FdxParsedData fdxParsedData = new FdxParsedData(originalData, tableDefinition(connection).tableDefinition());
|
TypeFichierInsertMetaData insertMetaData = new ApiTypeFichierInsertData(tableName.name(connection), fdxParsedData);
|
new FdxApiInsert(connection, null).insert(insertMetaData, token);
|
}
|
|
public void linkDataWithTokenToDataProduction(CommonDataProduction dataProduction, String token, Connection connection) throws Exception {
|
new DataWithTokenToDataProductionQuery(connection, dataProduction, token, tableName.name(connection)).execute();
|
}
|
|
public void deleteDataLinkedToToken(String token, Connection connection) throws TypeFichierDataBadRequest, SQLException, NamingException, Exception {
|
ParsedQueryCriterion parsedQueryCriterion = parsedQueryCriterion(new QueryCriterion(new TokenColumnDefinition().name(), token, Operateur.EQUALS, null, Arrays.asList()), connection);
|
processPermanentDelete(parsedQueryCriterion.parsedCriterion(), connection);
|
}
|
|
private void processUpdate(Map<String, Object> dataToUpdate, QueryCriterion queryCriterion, CommonDataProduction dataProduction, Connection connection) throws NamingException, Exception, SQLException {
|
FdxTableDefinition tableDefinition = tableDefinition(connection);
|
|
FdxParsedDataRow parsedDataRow = new FdxParsedDataRow(dataToUpdate, tableDefinition.tableDefinition());
|
TypeFichierUpdateMetaData updateMetaData = new ApiUpdateTypeFichierData(tableName.name(connection), parsedDataRow);
|
new FdxUpdate(connection, parsedQueryCriterion(queryCriterion, connection).parsedCriterion(), updateMetaData, dataProduction).update();
|
}
|
|
private void stopIfTableDataNotFound(ParsedQueryCriterion parsedQueryCriterion, Connection connection) throws TableDataNotFoundException, Exception {
|
Long count = count(parsedQueryCriterion.parsedCriterion(), connection);
|
if (count == 0) {
|
throw new TableDataNotFoundException("Aucune valeur trouvée dans la table pour les critères indiqués");
|
}
|
}
|
|
private void stopIfNotOneTableDataFound(ParsedQueryCriterion parsedQueryCriterion, Connection connection) throws TableDataNotFoundException, Exception {
|
Long count = count(parsedQueryCriterion.parsedCriterion(), connection);
|
if (count != 1) {
|
throw new MoreThanOneTableDataNotFoundException("Plus d'une ligne trouvée dans la table pour les critères indiqués");
|
}
|
}
|
|
}
|
