package com.megatim.fdxcommons.tools.database.queries;

import com.megatim.fdxcommons.model.dataproduction.CommonDataProduction;
import com.megatim.fdxcommons.tools.database.contrat.QueryMetaData;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;
import javax.naming.NamingException;

/**
 *
 * @author Gabuntu
 */
public class CreateDataProductionQuery implements QueryMetaData<Long> {

    private final CommonDataProduction dataProduction;
    private final Connection connection;

    public CreateDataProductionQuery(CommonDataProduction dataProduction, Connection connection) {
        this.dataProduction = dataProduction;
        this.connection = connection;
    }

    private String queryString() {
        return "INSERT INTO dataproduction(id, dateproduction, referentielversion, codetypefichier, codeparticipant, source, filename, statutdataproduction, filedate, dataProductionType, token, nbreElements, tailleFichier, tokenDirectory)"
                + " VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
    }

    @Override
    public Long execute() throws NamingException, SQLException {

        System.out.println("<-------------------------------------------------------------------------->");
        System.out.println(queryString());
        System.out.println("<-------------------------------------------------------------------------->");

        String getNextIdQuery = "SELECT nextval('SEQ_DATA_PRODUCTION')";

        try (
                 PreparedStatement statement = connection.prepareStatement(queryString());  PreparedStatement getIdStatement = connection.prepareStatement(getNextIdQuery);// Fetch the next sequence value
                ) {

            long generatedId = dataProduction.getId() != null ? dataProduction.getId() : 0;

            if (dataProduction.getId() == null || dataProduction.getId() <= 0) {//Si l'id de la production n'est pas encore initialisé (FdxApi)
                ResultSet resultSet = getIdStatement.executeQuery();
                if (resultSet.next()) {
                    generatedId = resultSet.getLong(1);
                }
            }

            statement.setLong(1, generatedId);
            statement.setTimestamp(2, dataProduction.getDateProduction() != null ? Timestamp.valueOf(dataProduction.getDateProduction()) : null);
            statement.setString(3, dataProduction.getReferentielVersion());
            statement.setString(4, dataProduction.getCodeTypeFichier());
            statement.setString(5, dataProduction.getCodeParticipant());
            statement.setString(6, dataProduction.getSource().name());
            statement.setString(7, dataProduction.getFileName());
            statement.setString(8, dataProduction.getStatutDataProduction().name());
            statement.setTimestamp(9, dataProduction.getFileDate() != null ? Timestamp.valueOf(dataProduction.getFileDate()) : null);
            statement.setString(10, dataProduction.getDataProductionType().name());
            statement.setString(11, dataProduction.getToken());
            statement.setLong(12, dataProduction.getNbreElements());
            statement.setLong(13, dataProduction.getTailleFichier());
            statement.setString(14, dataProduction.getTokenDirectory());

            statement.executeUpdate();

            return generatedId;
        }
    }
}