/*
|
* 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.fdxcommons.tools.database.queries;
|
|
import com.megatim.fdxcommons.tools.database.contrat.DefaultPreparedStatementProcessor;
|
import com.megatim.fdxcommons.tools.database.contrat.JsonTypeFichierInsertMetaData;
|
import com.megatim.fdxcommons.tools.database.contrat.PreparedStatementProcessor;
|
import com.megatim.fdxcommons.tools.database.contrat.QueryMetaData;
|
import com.megatim.fdxcommons.tools.database.contrat.TypeFichierDataColumn;
|
import com.megatim.fdxcommons.tools.database.contrat.TypeFichierDataRow;
|
import com.megatim.fdxcommons.tools.database.queries.metadata.DefaultTypeFichierDataColumn;
|
import com.megatim.fdxcommons.tools.database.queries.metadata.JsonApiTypeFichierInsertData;
|
import com.megatim.fdxcommons.tools.database.queries.metadata.JsonFdxParsedDataIterator;
|
import com.megatim.fdxcommons.tools.database.queries.metadata.QueryParam;
|
import com.megatim.fdxcommons.tools.database.tables.appcolumns.IndexColumnDefinition;
|
import com.megatim.fdxcommons.tools.database.tables.appcolumns.ParentIdColumnDefinition;
|
import java.sql.Connection;
|
import java.sql.PreparedStatement;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
*
|
* @author ASUS
|
*/
|
public class JsonInsertQuery implements QueryMetaData<Void> {
|
|
private final Connection connection;
|
private final JsonFdxParsedDataIterator parsedDataIterator;
|
private final List<DefaultTypeFichierDataColumn> dataColumnsToAdd;
|
|
public JsonInsertQuery(Connection connection, JsonFdxParsedDataIterator parsedDataIterator, List<DefaultTypeFichierDataColumn> dataColumnsToAdd) {
|
this.connection = connection;
|
this.parsedDataIterator = parsedDataIterator;
|
this.dataColumnsToAdd = dataColumnsToAdd;
|
}
|
|
@Override
|
public Void execute() throws Exception {
|
List<JsonApiTypeFichierInsertData> rows = parsedDataIterator.rows();
|
|
for (JsonApiTypeFichierInsertData insertMetaData : rows) {
|
String query = insertQueryString(insertMetaData.columnNames(), insertMetaData.tableName(), false);
|
|
TypeFichierDataRow row = insertMetaData.row();
|
|
System.out.println("---------------- parentQuery-----------------------");
|
System.out.println(query);
|
System.out.println("-----------------------------------");
|
|
try ( PreparedStatement statement = connection.prepareStatement(query);) {
|
execute(statement, row, dataColumnsToAdd, null);
|
ResultSet resultSet = statement.executeQuery();
|
|
if (resultSet.next()) {
|
Long fdxIndex = resultSet.getLong(1);
|
insertChildren(insertMetaData.children(), fdxIndex);
|
}
|
}
|
}
|
return null;
|
}
|
|
private void insertChildren(List<JsonTypeFichierInsertMetaData> data, Long parentId) throws Exception {
|
if (!data.isEmpty()) {
|
for (JsonTypeFichierInsertMetaData insertData : data) {
|
insertChild(insertData, parentId);
|
}
|
}
|
|
}
|
|
private void insertChild(JsonTypeFichierInsertMetaData child, Long parentId) throws Exception {
|
String childQuery = insertQueryString(child.columnNames(), child.tableName(), true);
|
System.out.println("------------------ childQuery---------------------------");
|
System.out.println(childQuery);
|
System.out.println("---------------------------------------------------------");
|
|
try ( PreparedStatement statement = connection.prepareStatement(childQuery);) {
|
|
TypeFichierDataRow row = child.row();
|
execute(statement, row, dataColumnsToAdd, parentId);
|
ResultSet resultSet = statement.executeQuery();
|
|
if (resultSet.next()) {
|
Long fdxIndex = resultSet.getLong(1);
|
insertChildren(child.children(), fdxIndex);
|
}
|
}
|
}
|
|
private String insertQueryString(List<String> columnNames, String tableName, boolean parentIdPresent) {
|
List<String> insertColumns = new ArrayList<>(columnNames);
|
|
for (DefaultTypeFichierDataColumn dc : dataColumnsToAdd) {
|
insertColumns.add(dc.column());
|
}
|
|
if (parentIdPresent) {
|
insertColumns.add(new ParentIdColumnDefinition().name());// Ajout de la clé du parent
|
}
|
StringBuilder query = new StringBuilder("INSERT INTO " + tableName + "(");
|
|
insertColumns.forEach(column -> query.append(column).append(","));
|
|
query.replace(query.length() - 1, query.length(), ") VALUES(");
|
|
insertColumns.forEach(s -> query.append("?,"));
|
|
query.replace(query.length() - 1, query.length(), ")");
|
|
query.append(" RETURNING ").append(new IndexColumnDefinition().name()).append(";");
|
|
return query.toString();
|
}
|
|
private void execute(PreparedStatement preparedStatement, TypeFichierDataRow row, List<DefaultTypeFichierDataColumn> dataColumnsToAdd, Long parentId) throws SQLException, Exception {
|
|
List<QueryParam> queryParameters = new ArrayList<>();
|
|
if (row != null) {
|
for (TypeFichierDataColumn dataColumn : row.columns()) {
|
queryParameters.add(new QueryParam(dataColumn.column(), dataColumn.value()));
|
}
|
}
|
|
//On ajoute les colonnes de dataColumnsToAdd
|
for (DefaultTypeFichierDataColumn dc : dataColumnsToAdd) {
|
queryParameters.add(new QueryParam(dc.column(), dc.value()));
|
}
|
|
if (parentId != null && parentId != 0L) {
|
queryParameters.add(new QueryParam(new ParentIdColumnDefinition().name(), parentId));//Ajout clé du parent
|
}
|
|
PreparedStatementProcessor statementProcessor = new DefaultPreparedStatementProcessor(0);
|
statementProcessor.process(preparedStatement, queryParameters);
|
|
}
|
}
|
