add fdx-commons and fdx-consultation

Kenmegne

7 days ago 23a46b4be35277e06ec89f48730eeb694e686be8

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
package com.megatim.fdxcommons.tools.database.queries.metadata;
 
import com.megatim.fdxcommons.model.integration.ColumnDefinition;
import com.megatim.fdxcommons.model.integration.TableDefinition;
import com.megatim.fdxcommons.model.integration.enums.FileExtension;
import com.megatim.fdxcommons.model.referentiel.natureproduction.NatureProduction;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import javax.naming.NamingException;
 
/**
 *
 * @author Gabuntu
 */
public class FdxTableDefinition {
 
    private final String referentielVersion;
    private final String codeTypeFichier;
    private final Connection connection;
    private TableDefinition tableDefinition;
    private final List<Boolean> cachedNatureProduction = new ArrayList<>(1);
 
    public FdxTableDefinition(String referentielVersion, String codeTypeFichier, Connection connection) {
        this.referentielVersion = referentielVersion;
        this.codeTypeFichier = codeTypeFichier;
        this.connection = connection;
    }
 
    public TableDefinition tableDefinition() throws SQLException, NamingException {
        if (tableDefinition == null) {
            tableDefinition = tableDefinition(columnDefinitions());
        }
        return tableDefinition;
    }
 
    public boolean isReferentiel() throws NamingException, SQLException {
 
        if (cachedNatureProduction.isEmpty()) { 
 
            String query = "SELECT natureproduction "
                    + "FROM natureproductionfichier "
                    + "WHERE typefichier_code = ? AND referentiel_version = ?";
 
            try ( PreparedStatement statement = connection.prepareStatement(query)) {
 
                statement.setString(1, codeTypeFichier);
                statement.setString(2, referentielVersion);
 
                try ( ResultSet resultSet = statement.executeQuery()) {
                    if (resultSet.next()) {
                        cachedNatureProduction.add(resultSet.getString("natureproduction").equals(NatureProduction.REFERENTIELLE.getValue()));
                    } else {
                        cachedNatureProduction.add(Boolean.TRUE);
                    }
                }
            }
 
        }
 
        return cachedNatureProduction.get(0);
    }
 
    private List<ColumnDefinition> columnDefinitions() throws NamingException, SQLException {
        List<ColumnDefinition> columnDefinitions = new ArrayList<>();
 
        String query = "SELECT name, formatdate, position, taille, taillepartiedecimale, typedonnee "
                + "FROM columndefinition "
                + "WHERE codetypefichier = ? AND referentielversion = ?";
 
        try ( PreparedStatement statement = connection.prepareStatement(query)) {
 
            statement.setString(1, codeTypeFichier);
            statement.setString(2, referentielVersion);
 
            try ( ResultSet resultSet = statement.executeQuery()) {
 
                while (resultSet.next()) {
 
                    String name = resultSet.getString("name");
                    String typeDonnee = resultSet.getString("typedonnee");
                    String formatDate = resultSet.getString("formatdate");
                    int position = resultSet.getInt("position");
                    int taille = resultSet.getInt("taille");
                    int taillePartieDecimale = resultSet.getInt("taillepartiedecimale");
 
                    columnDefinitions.add(new ColumnDefinition(codeTypeFichier, referentielVersion, name, typeDonnee, taille, taillePartieDecimale, formatDate, position));
                }
            }
        }
        Collections.sort(columnDefinitions, (ColumnDefinition c1, ColumnDefinition c2) -> Integer.valueOf(c1.getPosition()).compareTo(c2.getPosition()));
        return columnDefinitions;
    }
 
    private TableDefinition tableDefinition(List<ColumnDefinition> colDefs) throws SQLException {
        String query = "SELECT columndelimiter, linedelimiter, extension, headerpresent"
                + " FROM tableDefinition"
                + " WHERE codetypefichier = ? AND referentielversion = ?";
 
        try ( PreparedStatement statement = connection.prepareStatement(query)) {
 
            statement.setString(1, codeTypeFichier);
            statement.setString(2, referentielVersion);
 
            try ( ResultSet resultSet = statement.executeQuery()) {
 
                if (resultSet.next()) {
                    String columndelimiter = resultSet.getString("columndelimiter");
                    String linedelimiter = resultSet.getString("linedelimiter");
                    String extension = resultSet.getString("extension");
                    Boolean headerpresent = resultSet.getBoolean("headerpresent");
 
                    return new TableDefinition(referentielVersion, codeTypeFichier, headerpresent, 
                            columndelimiter, linedelimiter, FileExtension.fromValeur(extension), colDefs);
                }
            }
        }
        return new TableDefinition(referentielVersion, codeTypeFichier, null, null, null, null, colDefs);
    }
}