DriverRegistroServiziDB_documentiDriver.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */



  23. package org.openspcoop2.core.registry.driver.db;

  25. import java.sql.Connection;
  26. import java.sql.PreparedStatement;
  27. import java.sql.ResultSet;
  28. import java.util.ArrayList;
  29. import java.util.List;

  31. import org.openspcoop2.core.commons.DBUtils;
  32. import org.openspcoop2.core.commons.ISearch;
  33. import org.openspcoop2.core.commons.Liste;
  34. import org.openspcoop2.core.constants.CostantiDB;
  35. import org.openspcoop2.core.id.IDAccordo;
  36. import org.openspcoop2.core.id.IDServizio;
  37. import org.openspcoop2.core.registry.Documento;
  38. import org.openspcoop2.core.registry.constants.ProprietariDocumento;
  39. import org.openspcoop2.core.registry.constants.RuoliDocumento;
  40. import org.openspcoop2.core.registry.constants.TipiDocumentoLivelloServizio;
  41. import org.openspcoop2.core.registry.constants.TipiDocumentoSemiformale;
  42. import org.openspcoop2.core.registry.constants.TipiDocumentoSicurezza;
  43. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  44. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  45. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  46. import org.openspcoop2.utils.sql.ISQLQueryObject;
  47. import org.openspcoop2.utils.sql.SQLObjectFactory;

  49. /**
  50.  * DriverRegistroServiziDB_scopeDriver
  51.  * 
  52.  * 
  53.  * @author Sandra Giangrandi (sandra@link.it)
  54.  * @author Stefano Corallo (corallo@link.it)
  55.  * @author $Author$
  56.  * @version $Rev$, $Date$
  57.  */
  58. public class DriverRegistroServiziDB_documentiDriver {

  60.     private DriverRegistroServiziDB driver = null;
  61.     
  62.     protected DriverRegistroServiziDB_documentiDriver(DriverRegistroServiziDB driver) {
  63.         this.driver = driver;
  64.     }
  65.     
  66.     protected boolean existsDocumento(String nome, String tipo, String ruolo, long idProprietario, ProprietariDocumento proprietarioDocumento) throws DriverRegistroServiziException {

  68.         boolean exist = false;
  69.         Connection connection;
  70.         PreparedStatement stm = null;
  71.         ResultSet rs = null;
  72.         if (this.driver.atomica) {
  73.             try {
  74.                 connection = this.driver.getConnectionFromDatasource("existsDocumento");
  75.             } catch (Exception e) {
  76.                 throw new DriverRegistroServiziException("DriverRegistroServiziDB::existsDocumento] Exception accedendo al datasource :" + e.getMessage(),e);

  78.             }

  80.         } else
  81.             connection = this.driver.globalConnection;

  83.         this.driver.logDebug("operazione atomica = " + this.driver.atomica);
  84.         try {
  85.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  86.             sqlQueryObject.addFromTable(CostantiDB.DOCUMENTI);
  87.             sqlQueryObject.addSelectField("*");
  88.             sqlQueryObject.addWhereCondition("id_proprietario = ?");
  89.             sqlQueryObject.addWhereCondition("tipo_proprietario = ?");
  90.             sqlQueryObject.addWhereCondition("nome = ?");
  91.             if(tipo!=null) {
  92.                 sqlQueryObject.addWhereCondition("tipo = ?");
  93.             }
  94.             if(ruolo!=null) {
  95.                 sqlQueryObject.addWhereCondition("ruolo = ?");
  96.             }
  97.             sqlQueryObject.setANDLogicOperator(true);
  98.             String sqlQuery = sqlQueryObject.createSQLQuery();
  99.             stm = connection.prepareStatement(sqlQuery);
  100.             int index = 1;
  101.             stm.setLong(index++, idProprietario);
  102.             stm.setString(index++, proprietarioDocumento.toString());
  103.             stm.setString(index++, nome);
  104.             if(tipo!=null) {
  105.                 stm.setString(index++, tipo);
  106.             }
  107.             if(ruolo!=null) {
  108.                 stm.setString(index++, ruolo);
  109.             }
  110.             rs = stm.executeQuery();
  111.             if (rs.next())
  112.                 exist = true;
  113.             rs.close();
  114.             stm.close();
  115.         } catch (Exception e) {
  116.             exist = false;
  117.             throw new DriverRegistroServiziException(e.getMessage(),e);
  118.         } finally {

  120.             //Chiudo statement and resultset
  121.             JDBCUtilities.closeResources(rs, stm);

  123.             this.driver.closeConnection(connection);
  124.         }

  126.         return exist;
  127.     }

  129.     protected Documento getDocumento(String nome, String tipo, String ruolo, long idProprietario,boolean readBytes,ProprietariDocumento tipoProprietario) throws DriverRegistroServiziException, DriverRegistroServiziNotFound {
  130.         String nomeMetodo = "getDocumento";

  132.         Connection con = null;

  134.         if (this.driver.atomica) {
  135.             try {
  136.                 con = this.driver.getConnectionFromDatasource("getDocumento");

  138.             } catch (Exception e) {
  139.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(), e);

  141.             }

  143.         } else {
  144.             con = this.driver.globalConnection;
  145.         }

  147.         try {
  148.             String tipoProprietarioAsString = null;
  149.             if(tipoProprietario!=null){
  150.                 tipoProprietarioAsString = tipoProprietario.toString();
  151.             }
  152.             long idDoc = DBUtils.getIdDocumento(nome, tipo, ruolo, idProprietario,con,this.driver.tipoDB,tipoProprietarioAsString);
  153.             if(idDoc <= 0 ) {
  154.                 throw new DriverRegistroServiziNotFound("Documento richiesto non esistente (nome:"+nome+", tipo:"+tipo+", ruolo:"+ruolo+", idProprietario:"+idProprietario+", tipoProprietario:"+tipoProprietarioAsString+")");
  155.             }
  156.             return DriverRegistroServiziDB_documentiLIB.getDocumento(idDoc, readBytes, con, this.driver.tipoDB);

  158.         } 
  159.         catch (DriverRegistroServiziNotFound se) {
  160.             throw se;
  161.         }
  162.         catch (Exception se) {
  163.             throw new DriverRegistroServiziException("[DriverRegistroServiziException::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  164.         } finally {
  165.             this.driver.closeConnection(con);
  166.         }
  167.     }

  169.     protected Documento getDocumento(long idDocumento,boolean readBytes) throws DriverRegistroServiziException {
  170.         String nomeMetodo = "getDocumento";

  172.         Connection con = null;

  174.         if (this.driver.atomica) {
  175.             try {
  176.                 con = this.driver.getConnectionFromDatasource("getDocumento");

  178.             } catch (Exception e) {
  179.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(), e);

  181.             }

  183.         } else {
  184.             con = this.driver.globalConnection;
  185.         }

  187.         try {

  189.             return DriverRegistroServiziDB_documentiLIB.getDocumento(idDocumento, readBytes, con, this.driver.tipoDB);

  191.         } catch (Exception se) {
  192.             throw new DriverRegistroServiziException("[DriverRegistroServiziException::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  193.         } finally {
  194.             this.driver.closeConnection(con);
  195.         }
  196.     }

  198.     protected List<Documento> serviziAllegatiList(long idServizio, ISearch ricerca) throws DriverRegistroServiziException {
  199.         String nomeMetodo = "serviziAllegatiList";
  200.         int idLista = Liste.SERVIZI_ALLEGATI;
  201.         int offset;
  202.         int limit;
  203.         String search;
  204.         String queryString;

  206.         limit = ricerca.getPageSize(idLista);
  207.         offset = ricerca.getIndexIniziale(idLista);
  208.         search = (org.openspcoop2.core.constants.Costanti.SESSION_ATTRIBUTE_VALUE_RICERCA_UNDEFINED.equals(ricerca.getSearchString(idLista)) ? "" : ricerca.getSearchString(idLista));
  209.         ricerca.getSearchString(idLista);

  211.         Connection con = null;
  212.         PreparedStatement stmt = null;
  213.         ResultSet risultato = null;

  215.         ArrayList<Documento> lista = new ArrayList<Documento>();

  217.         if (this.driver.atomica) {
  218.             try {
  219.                 con = this.driver.getConnectionFromDatasource("serviziAllegatiList");

  221.             } catch (Exception e) {
  222.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  224.             }

  226.         } else
  227.             con = this.driver.globalConnection;

  229.         try {

  231.             if (!search.equals("")) {
  232.                 //query con search
  233.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  234.                 sqlQueryObject.addFromTable(CostantiDB.DOCUMENTI);
  235.                 sqlQueryObject.addSelectCountField("*", "cont");
  236.                 sqlQueryObject.addWhereCondition("id_proprietario = ?");
  237.                 sqlQueryObject.addWhereCondition("tipo_proprietario = ?");
  238.                 sqlQueryObject.addWhereCondition(false, 
  239.                         //sqlQueryObject.getWhereLikeCondition("ruolo",search,true,true),
  240.                         sqlQueryObject.getWhereLikeCondition("nome",search,true,true));
  241.                 sqlQueryObject.setANDLogicOperator(true);
  242.                 queryString = sqlQueryObject.createSQLQuery();
  243.             } else {
  244.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  245.                 sqlQueryObject.addFromTable(CostantiDB.DOCUMENTI);
  246.                 sqlQueryObject.addSelectCountField("*", "cont");
  247.                 sqlQueryObject.addWhereCondition("id_proprietario = ?");
  248.                 sqlQueryObject.addWhereCondition("tipo_proprietario = ?");
  249.                 sqlQueryObject.setANDLogicOperator(true);
  250.                 queryString = sqlQueryObject.createSQLQuery();
  251.             }

  253.             stmt = con.prepareStatement(queryString);
  254.             stmt.setLong(1,idServizio);
  255.             stmt.setString(2,ProprietariDocumento.servizio.toString());
  256.             risultato = stmt.executeQuery();
  257.             if (risultato.next())
  258.                 ricerca.setNumEntries(idLista,risultato.getInt("cont"));
  259.             risultato.close();
  260.             stmt.close();

  262.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  263.             sqlQueryObject.addFromTable(CostantiDB.DOCUMENTI);
  264.             sqlQueryObject.addSelectField("id");
  265.             sqlQueryObject.addSelectField("nome");
  266.             sqlQueryObject.addSelectField("ruolo");
  267.             sqlQueryObject.addSelectField("id_proprietario");
  268.             sqlQueryObject.addSelectField("tipo_proprietario");
  269.             //where
  270.             sqlQueryObject.addWhereCondition("id_proprietario = ?");
  271.             sqlQueryObject.addWhereCondition("tipo_proprietario = ?");

  273.             // ricavo le entries
  274.             if (limit == 0) // con limit
  275.                 limit = ISQLQueryObject.LIMIT_DEFAULT_VALUE;

  277.             if (!search.equals("")) { // con search
  278.                 sqlQueryObject.addWhereCondition(false, 
  279.                         //sqlQueryObject.getWhereLikeCondition("ruolo",search,true,true),
  280.                         sqlQueryObject.getWhereLikeCondition("nome",search,true,true));
  281.             } 

  283.             sqlQueryObject.setANDLogicOperator(true);
  284.             sqlQueryObject.addOrderBy("nome");
  285.             sqlQueryObject.setSortType(true);
  286.             sqlQueryObject.setLimit(limit);
  287.             sqlQueryObject.setOffset(offset);
  288.             queryString = sqlQueryObject.createSQLQuery();

  290.             stmt = con.prepareStatement(queryString);
  291.             stmt.setLong(1, idServizio);
  292.             stmt.setString(2,ProprietariDocumento.servizio.toString());
  293.             risultato = stmt.executeQuery();

  295.             while(risultato.next()){
  296.                 Documento doc = DriverRegistroServiziDB_documentiLIB.getDocumento(risultato.getLong("id"),false, con, this.driver.tipoDB); 
  297.                 lista.add(doc);
  298.             }

  300.             return lista;

  302.         } catch (Exception se) {

  304.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  305.         } finally {
  306.             //Chiudo statement and resultset
  307.             JDBCUtilities.closeResources(risultato, stmt);
  308.             this.driver.closeConnection(con);
  309.         }
  310.     }

  312.     protected Documento getAllegato(IDServizio idASPS, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  313.         return getEngineDocumento(idASPS, RuoliDocumento.allegato.toString(), null, nome);
  314.     }
  315.     protected Documento getSpecificaSemiformale(IDServizio idASPS, TipiDocumentoSemiformale tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  316.         return getEngineDocumento(idASPS, RuoliDocumento.specificaSemiformale.toString(), tipo.toString(), nome);
  317.     }
  318.     protected Documento getSpecificaSicurezza(IDServizio idASPS, TipiDocumentoSicurezza tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  319.         return getEngineDocumento(idASPS, RuoliDocumento.specificaSicurezza.toString(), tipo.toString(), nome);
  320.     }
  321.     protected Documento getSpecificaLivelloServizio(IDServizio idASPS, TipiDocumentoLivelloServizio tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  322.         return getEngineDocumento(idASPS, RuoliDocumento.specificaLivelloServizio.toString(), tipo.toString(), nome);
  323.     }
  324.     private Documento getEngineDocumento(IDServizio idASPS, String ruolo, String tipo, String nome) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  325.         String nomeMetodo = "getDocumento";
  326.         String queryString;
  327.         
  328.         Connection con = null;
  329.         PreparedStatement stmt = null;
  330.         ResultSet risultato = null;

  332.         if (this.driver.atomica) {
  333.             try {
  334.                 con = this.driver.getConnectionFromDatasource("serviziAllegatiList");

  336.             } catch (Exception e) {
  337.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  339.             }

  341.         } else
  342.             con = this.driver.globalConnection;

  344.         try {

  346.             long idServizio = DBUtils.getIdAccordoServizioParteSpecifica(idASPS, con, this.driver.tipoDB);
  347.             if(idServizio<=0) {
  348.                 throw new DriverRegistroServiziNotFound("ApiImpl '"+idASPS+"' undefined");
  349.             }   

  351.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  352.             sqlQueryObject.addFromTable(CostantiDB.DOCUMENTI);
  353.             sqlQueryObject.addSelectField("id");
  354.             sqlQueryObject.addWhereCondition("id_proprietario = ?");
  355.             sqlQueryObject.addWhereCondition("tipo_proprietario = ?");
  356.             sqlQueryObject.addWhereCondition("ruolo = ?");
  357.             if(tipo!=null) {
  358.                 sqlQueryObject.addWhereCondition("tipo = ?");
  359.             }
  360.             sqlQueryObject.addWhereCondition("nome = ?");
  361.             
  362.             sqlQueryObject.setANDLogicOperator(true);
  363.             queryString = sqlQueryObject.createSQLQuery();

  365.             stmt = con.prepareStatement(queryString);
  366.             int index = 1;
  367.             stmt.setLong(index++, idServizio);
  368.             stmt.setString(index++, ProprietariDocumento.servizio.toString());
  369.             stmt.setString(index++, ruolo);
  370.             if(tipo!=null) {
  371.                 stmt.setString(index++, tipo);
  372.             }
  373.             stmt.setString(index++, nome);
  374.             risultato = stmt.executeQuery();

  376.             if(risultato.next()){
  377.                 Documento doc = DriverRegistroServiziDB_documentiLIB.getDocumento(risultato.getLong("id"),true, con, this.driver.tipoDB); 
  378.                 return doc;
  379.             }

  381.             String tipoS = (tipo!=null) ? ("tipo:"+tipo+" ") : "";
  382.             throw new DriverRegistroServiziNotFound("Documento (ruolo:"+ruolo+" "+tipoS+"nome:"+nome+") non trovato");

  384.         } catch(DriverRegistroServiziNotFound notFound) {
  385.             throw notFound;
  386.         }
  387.         catch (Exception se) {
  388.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  389.         } finally {
  390.             //Chiudo statement and resultset
  391.             JDBCUtilities.closeResources(risultato, stmt);
  392.             this.driver.closeConnection(con);
  393.         }
  394.     }

  396.     
  397.     protected Documento getAllegato(IDAccordo idAccordo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  398.         return getEngineDocumento(idAccordo, RuoliDocumento.allegato.toString(), null, nome);
  399.     }
  400.     protected Documento getSpecificaSemiformale(IDAccordo idAccordo, TipiDocumentoSemiformale tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  401.         return getEngineDocumento(idAccordo, RuoliDocumento.specificaSemiformale.toString(), tipo.toString(), nome);
  402.     }
  403.     private Documento getEngineDocumento(IDAccordo idAccordo, String ruolo, String tipo, String nome) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  404.         String nomeMetodo = "getDocumento";
  405.         String queryString;
  406.         
  407.         Connection con = null;
  408.         PreparedStatement stmt = null;
  409.         ResultSet risultato = null;

  411.         if (this.driver.atomica) {
  412.             try {
  413.                 con = this.driver.getConnectionFromDatasource("serviziAllegatiList");

  415.             } catch (Exception e) {
  416.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  418.             }

  420.         } else
  421.             con = this.driver.globalConnection;

  423.         try {

  425.             long idAccordoLong = DBUtils.getIdAccordoServizioParteComune(idAccordo, con, this.driver.tipoDB);
  426.             if(idAccordoLong<=0) {
  427.                 throw new DriverRegistroServiziNotFound("Api '"+idAccordo+"' undefined");
  428.             }   

  430.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  431.             sqlQueryObject.addFromTable(CostantiDB.DOCUMENTI);
  432.             sqlQueryObject.addSelectField("id");
  433.             sqlQueryObject.addWhereCondition("id_proprietario = ?");
  434.             sqlQueryObject.addWhereCondition("tipo_proprietario = ?");
  435.             sqlQueryObject.addWhereCondition("ruolo = ?");
  436.             if(tipo!=null) {
  437.                 sqlQueryObject.addWhereCondition("tipo = ?");
  438.             }
  439.             sqlQueryObject.addWhereCondition("nome = ?");
  440.             
  441.             sqlQueryObject.setANDLogicOperator(true);
  442.             queryString = sqlQueryObject.createSQLQuery();

  444.             stmt = con.prepareStatement(queryString);
  445.             int index = 1;
  446.             stmt.setLong(index++, idAccordoLong);
  447.             stmt.setString(index++, ProprietariDocumento.accordoServizio.toString());
  448.             stmt.setString(index++, ruolo);
  449.             if(tipo!=null) {
  450.                 stmt.setString(index++, tipo);
  451.             }
  452.             stmt.setString(index++, nome);
  453.             risultato = stmt.executeQuery();

  455.             if(risultato.next()){
  456.                 Documento doc = DriverRegistroServiziDB_documentiLIB.getDocumento(risultato.getLong("id"),true, con, this.driver.tipoDB); 
  457.                 return doc;
  458.             }

  460.             String tipoS = (tipo!=null) ? ("tipo:"+tipo+" ") : "";
  461.             throw new DriverRegistroServiziNotFound("Documento (ruolo:"+ruolo+" "+tipoS+"nome:"+nome+") non trovato");

  463.         } catch(DriverRegistroServiziNotFound notFound) {
  464.             throw notFound;
  465.         }
  466.         catch (Exception se) {
  467.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception: " + se.getMessage(),se);
  468.         } finally {
  469.             //Chiudo statement and resultset
  470.             JDBCUtilities.closeResources(risultato, stmt);
  471.             this.driver.closeConnection(con);
  472.         }
  473.     }
  474. }
Created with JaCoCo 0.8.8.202204050719