package com.megatim.fdxcommons.tools.database.tables;
|
|
import com.megatim.fdxcommons.tools.database.contrat.TableName;
|
import java.sql.Connection;
|
import java.sql.PreparedStatement;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.Objects;
|
|
/**
|
*
|
* @author Gabuntu
|
*/
|
public class FdxTableName implements TableName {
|
|
private final String referentielVersion;
|
private final String codeTypeFichier;
|
private String refVersionToUse = null;
|
|
public FdxTableName(String referentielVersion, String codeTypeFichier) {
|
this.referentielVersion = referentielVersion;
|
this.codeTypeFichier = codeTypeFichier;
|
}
|
|
@Override
|
public String name(Connection connection) throws SQLException {
|
if (refVersionToUse == null) {
|
refVersionToUse(connection);
|
}
|
return refVersionToUse != null && !refVersionToUse.isEmpty()
|
? "ref" + refVersionToUse.toLowerCase() + "_" + codeTypeFichier.toLowerCase()
|
: "ref" + referentielVersion.toLowerCase() + "_" + codeTypeFichier.toLowerCase();
|
}
|
|
private void refVersionToUse(Connection connection) throws SQLException {
|
|
try ( PreparedStatement statement = connection.prepareStatement(query())) {
|
ResultSet resultSet = statement.executeQuery();
|
|
while (resultSet.next()) {
|
refVersionToUse = resultSet.getString(1);
|
}
|
} catch (Exception ex) {
|
ex.printStackTrace();
|
}
|
}
|
|
@Override
|
public boolean equals(Object obj) {
|
if (this == obj) {
|
return true;
|
}
|
if (obj == null) {
|
return false;
|
}
|
if (getClass() != obj.getClass()) {
|
return false;
|
}
|
final FdxTableName other = (FdxTableName) obj;
|
|
if (refVersionToUse != null && other.getRefVersionToUse() != null) {
|
return refVersionToUse.equals(other.getRefVersionToUse());
|
} else {
|
return false;
|
}
|
}
|
|
@Override
|
public int hashCode() {
|
int hash = 3;
|
hash = 79 * hash + Objects.hashCode(this.referentielVersion);
|
hash = 79 * hash + Objects.hashCode(this.codeTypeFichier);
|
return hash;
|
}
|
|
public String getRefVersionToUse() {
|
return refVersionToUse;
|
}
|
|
private String query() {
|
return "SELECT DISTINCT r.referentielVersion"
|
+ " FROM referentielIntegrationHistorique r"
|
+ " JOIN ref_int_historique_depending_refs rd"
|
+ " ON r.codetypefichier = rd.codetypefichier"
|
+ " AND r.referentielVersion = rd.referentielVersion"
|
+ " WHERE rd.dependingreferentiels = '" + referentielVersion + "'"
|
+ " AND r.codetypefichier = '" + codeTypeFichier + "'";
|
}
|
}
|
