DriverRegistroServiziDB_documentiLIB.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 static org.openspcoop2.core.constants.CostantiDB.CREATE;
  26. import static org.openspcoop2.core.constants.CostantiDB.DELETE;
  27. import static org.openspcoop2.core.constants.CostantiDB.UPDATE;

  29. import java.sql.Connection;
  30. import java.sql.PreparedStatement;
  31. import java.sql.ResultSet;
  32. import java.sql.SQLException;
  33. import java.sql.Timestamp;
  34. import java.util.ArrayList;
  35. import java.util.Date;
  36. import java.util.List;

  38. import org.openspcoop2.core.commons.DBUtils;
  39. import org.openspcoop2.core.constants.CostantiDB;
  40. import org.openspcoop2.core.registry.Documento;
  41. import org.openspcoop2.core.registry.constants.ProprietariDocumento;
  42. import org.openspcoop2.core.registry.driver.BeanUtilities;
  43. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  44. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  45. import org.openspcoop2.utils.jdbc.IJDBCAdapter;
  46. import org.openspcoop2.utils.jdbc.JDBCAdapterFactory;
  47. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  48. import org.openspcoop2.utils.sql.ISQLQueryObject;
  49. import org.openspcoop2.utils.sql.SQLObjectFactory;

  51. /**
  52.  * Classe utilizzata per effettuare query ad un registro dei servizi openspcoop
  53.  * formato db.
  54.  * 
  55.  * 
  56.  * @author Sandra Giangrandi (sandra@link.it)
  57.  * @author Stefano Corallo (corallo@link.it)
  58.  * @author $Author$
  59.  * @version $Rev$, $Date$
  60.  */
  61. public class DriverRegistroServiziDB_documentiLIB {
  62.         
  63.     
  64.     public static void CRUDDocumento(int type, List<Documento> documenti, long idProprietario,
  65.             ProprietariDocumento tipologiaProprietarioDocumento, Connection connection,
  66.             String tipoDatabase) throws DriverRegistroServiziException {
  67.         
  68.         // NOTA: l'update dei documenti, essendo mega di documenti non puo' essere implementata come delete + create
  69.         
  70.         PreparedStatement stm = null;
  71.         ResultSet rs=null;
  72.         String sqlQuery;

  74.         if(idProprietario <= 0 ) 
  75.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] id proprietario non definito");
  76.         
  77.         IJDBCAdapter jdbcAdapter = null;
  78.         
  79.         try {

  81.             jdbcAdapter = JDBCAdapterFactory.createJDBCAdapter(tipoDatabase);
  82.             
  83.             switch (type) {
  84.             case CREATE:

  86.                 if((documenti == null)) 
  87.                     throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] L'oggetto documenti non puo essere null");
  88.                 
  89.                 for(int i=0; i<documenti.size(); i++){
  90.                 
  91.                     Documento doc = documenti.get(i);
  92.                     if(doc.getFile()==null || "".equals(doc.getFile()))
  93.                         throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] Nome non definito per documento ["+i+"]");
  94.                     if(doc.getRuolo()==null || "".equals(doc.getRuolo()))
  95.                         throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] Ruolo non definito per documento ["+doc.getFile()+"]");
  96.                     if(doc.getTipo()==null || "".equals(doc.getTipo()))
  97.                         throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] Tipo non definito per documento ["+doc.getFile()+"]");
  98.                     if(doc.getByteContenuto()==null || doc.getByteContenuto().length<=0)
  99.                         throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] Contenuto non definito per documento ["+doc.getFile()+"]");
  100.                     BeanUtilities.validateTipoRuolo(doc.getTipo(),doc.getRuolo());
  101.                     
  102.                     byte[] contenuto = doc.getByteContenuto();
  103.                     if(contenuto.length<3){
  104.                         String test = new String(contenuto);
  105.                         if("".equals(test.trim().replaceAll("\n", ""))){
  106.                             // eliminare \n\n
  107.                             contenuto = null;   
  108.                         }
  109.                     }
  110.                     
  111.                     
  112.                     // create
  113.                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  114.                     sqlQueryObject.addInsertTable(CostantiDB.DOCUMENTI);
  115.                     sqlQueryObject.addInsertField("ruolo", "?");
  116.                     sqlQueryObject.addInsertField("tipo", "?");
  117.                     sqlQueryObject.addInsertField("nome", "?");
  118.                     sqlQueryObject.addInsertField("id_proprietario", "?");
  119.                     sqlQueryObject.addInsertField("tipo_proprietario", "?");
  120.                     if(contenuto!=null)
  121.                         sqlQueryObject.addInsertField("contenuto", "?");
  122.                     if(doc.getOraRegistrazione()!=null)
  123.                         sqlQueryObject.addInsertField("ora_registrazione", "?");
  124.                     sqlQuery = sqlQueryObject.createSQLInsert();
  125.                     stm = connection.prepareStatement(sqlQuery);
  126.                     stm.setString(1, doc.getRuolo());
  127.                     stm.setString(2, doc.getTipo());
  128.                     stm.setString(3, doc.getFile());
  129.                     stm.setLong(4, idProprietario);
  130.                     stm.setString(5, tipologiaProprietarioDocumento.toString());
  131.                     int index = 6;
  132.                     if(contenuto!=null){
  133.                         jdbcAdapter.setBinaryData(stm,index,contenuto);
  134.                         index++;
  135.                     }
  136.                     if(doc.getOraRegistrazione()!=null){
  137.                         stm.setTimestamp(index, new Timestamp(doc.getOraRegistrazione().getTime()));
  138.                         index++;
  139.                     }
  140.                     
  141.                     DriverRegistroServiziDB_LIB.log.debug("CRUDConnettore CREATE : \n" + DBUtils.formatSQLString(sqlQuery, doc.getRuolo(), doc.getTipo(), doc.getFile(), idProprietario, tipologiaProprietarioDocumento.toString()));
  142.     
  143.                     int n = stm.executeUpdate();
  144.                     stm.close();
  145.                     DriverRegistroServiziDB_LIB.log.debug("Inserted " + n + " row(s)");
  146.         
  147.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  148.                     sqlQueryObject.addFromTable(CostantiDB.DOCUMENTI);
  149.                     sqlQueryObject.addSelectField("id");
  150.                     sqlQueryObject.addSelectField("ora_registrazione");
  151.                     sqlQueryObject.addWhereCondition("ruolo = ?");
  152.                     sqlQueryObject.addWhereCondition("tipo = ?");
  153.                     sqlQueryObject.addWhereCondition("nome = ?");
  154.                     sqlQueryObject.addWhereCondition("id_proprietario = ?");
  155.                     sqlQueryObject.addWhereCondition("tipo_proprietario = ?");
  156.                     sqlQueryObject.setANDLogicOperator(true);
  157.                     sqlQuery = sqlQueryObject.createSQLQuery();
  158.                     stm = connection.prepareStatement(sqlQuery);
  159.                     stm.setString(1, doc.getRuolo());
  160.                     stm.setString(2, doc.getTipo());
  161.                     stm.setString(3, doc.getFile());
  162.                     stm.setLong(4, idProprietario);
  163.                     stm.setString(5, tipologiaProprietarioDocumento.toString());
  164.     
  165.                     DriverRegistroServiziDB_LIB.log.debug("Recupero idConnettore e oraRegistrazione inserito : \n" + DBUtils.formatSQLString(sqlQuery,doc.getRuolo(), doc.getTipo(), doc.getFile(), idProprietario, tipologiaProprietarioDocumento.toString()));
  166.     
  167.                     rs = stm.executeQuery();
  168.     
  169.                     if (rs.next()) {
  170.                         documenti.get(i).setId(rs.getLong("id"));
  171.                         documenti.get(i).setOraRegistrazione(rs.getTimestamp("ora_registrazione"));
  172.                     } else {
  173.                         throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDConnettore] Errore tentanto di effettuare la select dopo una create, non riesco a recuperare l'id!");
  174.                     }
  175.     
  176.                     rs.close();
  177.                     stm.close();
  178.                     
  179.                 }
  180.                 break;

  182.             case UPDATE:
  183.                 
  184.                 if((documenti == null)) 
  185.                     throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] L'oggetto documenti non puo essere null");
  186.                 
  187.                 // Prelevo vecchia lista
  188.                 List<Documento> oldLista = null;
  189.                 try{
  190.                     oldLista = DriverRegistroServiziDB_documentiLIB.getListaDocumenti(idProprietario,tipologiaProprietarioDocumento, false, connection, tipoDatabase);
  191.                 }catch(DriverRegistroServiziNotFound dNotFound){
  192.                     oldLista = new ArrayList<Documento>();
  193.                 }
  194.                 
  195.                 // Gestico la nuova immagine
  196.                 for(int i=0; i<documenti.size(); i++){
  197.                     
  198.                     Documento doc = documenti.get(i);
  199.                     if(doc.getFile()==null || "".equals(doc.getFile()))
  200.                         throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] Nome non definito per documento ["+i+"]");
  201.                     if(doc.getRuolo()==null || "".equals(doc.getRuolo()))
  202.                         throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] Ruolo non definito per documento ["+doc.getFile()+"]");
  203.                     if(doc.getTipo()==null || "".equals(doc.getTipo()))
  204.                         throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] Tipo non definito per documento ["+doc.getFile()+"]");
  205.                     BeanUtilities.validateTipoRuolo(doc.getTipo(),doc.getRuolo());
  206.                     
  207.                     //if(doc.getId()<=0){
  208.                     // Rileggo sempre id, puo' essere diverso (es. importato tramite sincronizzazioni)
  209.                     String tipologiaProprietarioDocumentoString = null;
  210.                     if(tipologiaProprietarioDocumento!=null){
  211.                         tipologiaProprietarioDocumentoString = tipologiaProprietarioDocumento.toString();
  212.                     }
  213.                     doc.setId(DBUtils.getIdDocumento(doc.getFile(), doc.getTipo(), doc.getRuolo(), idProprietario, connection, 
  214.                             DriverRegistroServiziDB_LIB.tipoDB, tipologiaProprietarioDocumentoString));
  215.                     //}
  216.                     // L'ora di registrazione deve essere impostata solo se non presente, in tale caso siamo in un caso di creazione del nuovo documento
  217.                     if(doc.getOraRegistrazione()==null){
  218.                         doc.setOraRegistrazione(new Date());
  219.                     }
  220.                     
  221.                     // Assegno corretto idProprietario se id e' diverso (es. importato tramite sincronizzazioni)
  222.                     doc.setIdProprietarioDocumento(idProprietario);
  223.                     
  224.                     boolean documentoGiaPresente = false;
  225.                     boolean documentoDaAggiornare = false;
  226.                     if(doc.getId()>0){
  227.                         for(int j=0; j<oldLista.size(); j++){
  228.                             Documento old = oldLista.get(j);
  229.                             /*System.out.println("OLD["+old.getRuolo()+"]==ATTUALE["+doc.getRuolo()+"] ("+doc.getRuolo().equals(old.getRuolo())+")");
  230.                             System.out.println("OLD["+old.getTipo()+"]==ATTUALE["+doc.getTipo()+"] ("+doc.getTipo().equals(old.getTipo())+")");
  231.                             System.out.println("OLD["+old.getFile()+"]==ATTUALE["+doc.getFile()+"] ("+doc.getFile().equals(old.getFile())+")");
  232.                             System.out.println("OLD["+old.getIdProprietarioDocumento().longValue()+"]==ATTUALE["+doc.getIdProprietarioDocumento().longValue()+"] ("+(doc.getIdProprietarioDocumento().longValue() == old.getIdProprietarioDocumento().longValue())+")");
  233.                             System.out.println("OLD["+old.getTipoProprietarioDocumento()+"]==ATTUALE["+tipologiaProprietarioDocumento+"] ("+tipologiaProprietarioDocumento.equals(old.getTipoProprietarioDocumento())+")");
  234.                             if(doc.getRuolo().equals(old.getRuolo()) &&
  235.                                     doc.getTipo().equals(old.getTipo()) &&
  236.                                     doc.getFile().equals(old.getFile()) &&
  237.                                     ( (doc.getIdProprietarioDocumento().longValue()) == (old.getIdProprietarioDocumento().longValue()) ) &&
  238.                                     tipologiaProprietarioDocumento.equals(old.getTipoProprietarioDocumento()) ){*/
  239.                             
  240.                             //System.out.println("OLD["+old.getId().longValue()+"]==ATTUALE["+doc.getId().longValue()+"] ("+((doc.getId().longValue() == old.getId().longValue()))+")");
  241.                             if(doc.getId().longValue() == old.getId().longValue()){     
  242.                                     documentoGiaPresente = true; // non devo fare una insert, ma una update...
  243.                                     
  244.                                     if(doc.getOraRegistrazione()==null)
  245.                                         throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] OraRegistrazione non definita per documento, precedentemente gia inserito, ["+doc.getFile()+"] ["+doc.getTipo()+"] ["+tipologiaProprietarioDocumento+"] ["+idProprietario+"]");
  246.                                             
  247.                                     // rimuovo la vecchia immagine del documento dalla lista dei doc vecchi
  248.                                     oldLista.remove(j);
  249.                                     
  250.                                     // Il documento e' lo stesso, rimane da verificare che sia un documento successivo di modifica.
  251.                                     if(doc.getOraRegistrazione().after(old.getOraRegistrazione())){
  252.                                         documentoDaAggiornare = true;
  253.                                     }
  254.                             }
  255.                         }
  256.                     }

  258.                     byte[] contenuto = null;
  259.                     if( (documentoGiaPresente == false) || (documentoDaAggiornare) ){
  260.                         // Il contenuto ci deve essere
  261.                         if(doc.getByteContenuto()==null || doc.getByteContenuto().length<=0)
  262.                             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] Contenuto non definito per documento ["+doc.getFile()+"] ["+doc.getTipo()+"] ["+tipologiaProprietarioDocumento+"] ["+idProprietario+"]");

  264.                         contenuto = doc.getByteContenuto();
  265.                         if(contenuto.length<3){
  266.                             String test = new String(contenuto);
  267.                             if("".equals(test.trim().replaceAll("\n", ""))){
  268.                                 // eliminare \n\n
  269.                                 contenuto = null;   
  270.                             }
  271.                         }
  272.                     }
  273.                     
  274.                     if(documentoGiaPresente){
  275.                         if(documentoDaAggiornare){
  276.                             // update
  277.                             long idDocumento = doc.getId();
  278.                             if(idDocumento<=0){
  279.                                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] ID non definito per documento da aggiorare ["+doc.getFile()+"] ["+doc.getTipo()+"] ["+tipologiaProprietarioDocumento+"] ["+idProprietario+"]");
  280.                             }
  281.                             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  282.                             sqlQueryObject.addUpdateTable(CostantiDB.DOCUMENTI);
  283.                             sqlQueryObject.addUpdateField("tipo", "?");
  284.                             sqlQueryObject.addUpdateField("nome", "?");
  285.                             sqlQueryObject.addUpdateField("contenuto", "?");
  286.                             sqlQueryObject.addUpdateField("ora_registrazione", "?");
  287.                             sqlQueryObject.addWhereCondition("id=?");
  288.                             sqlQuery = sqlQueryObject.createSQLUpdate();
  289.                             stm = connection.prepareStatement(sqlQuery);
  290.                             stm.setString(1, doc.getTipo());
  291.                             stm.setString(2, doc.getFile());
  292.                             jdbcAdapter.setBinaryData(stm,3,contenuto);
  293.                             stm.setTimestamp(4, new Timestamp(doc.getOraRegistrazione().getTime()));
  294.                             stm.setLong(5, idDocumento);
  295.                             stm.executeUpdate();
  296.                             stm.close();
  297.                         }
  298.                     }else{
  299.                         // insert
  300.                         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  301.                         sqlQueryObject.addInsertTable(CostantiDB.DOCUMENTI);
  302.                         sqlQueryObject.addInsertField("ruolo", "?");
  303.                         sqlQueryObject.addInsertField("tipo", "?");
  304.                         sqlQueryObject.addInsertField("nome", "?");
  305.                         sqlQueryObject.addInsertField("id_proprietario", "?");
  306.                         sqlQueryObject.addInsertField("tipo_proprietario", "?");
  307.                         if(contenuto!=null)
  308.                             sqlQueryObject.addInsertField("contenuto", "?");
  309.                         if(doc.getOraRegistrazione()!=null)
  310.                             sqlQueryObject.addInsertField("ora_registrazione", "?");
  311.                         sqlQuery = sqlQueryObject.createSQLInsert();
  312.                         stm = connection.prepareStatement(sqlQuery);
  313.                         stm.setString(1, doc.getRuolo());
  314.                         stm.setString(2, doc.getTipo());
  315.                         stm.setString(3, doc.getFile());
  316.                         stm.setLong(4, idProprietario);
  317.                         stm.setString(5, tipologiaProprietarioDocumento.toString());
  318.                         int index = 6;
  319.                         if(contenuto!=null){
  320.                             jdbcAdapter.setBinaryData(stm,index,contenuto);
  321.                             index++;
  322.                         }
  323.                         if(doc.getOraRegistrazione()!=null){
  324.                             stm.setTimestamp(index, new Timestamp(doc.getOraRegistrazione().getTime()));
  325.                             index++;
  326.                         }
  327.                         
  328.                         DriverRegistroServiziDB_LIB.log.debug("CRUDDocumento UPDATE : \n" + DBUtils.formatSQLString(sqlQuery, doc.getRuolo(), doc.getTipo(), doc.getFile(), idProprietario, tipologiaProprietarioDocumento.toString()));
  329.         
  330.                         int n = stm.executeUpdate();
  331.                         stm.close();
  332.                         DriverRegistroServiziDB_LIB.log.debug("Inserted " + n + " row(s)");
  333.             
  334.                         sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  335.                         sqlQueryObject.addFromTable(CostantiDB.DOCUMENTI);
  336.                         sqlQueryObject.addSelectField("id");
  337.                         sqlQueryObject.addWhereCondition("ruolo = ?");
  338.                         sqlQueryObject.addWhereCondition("tipo = ?");
  339.                         sqlQueryObject.addWhereCondition("nome = ?");
  340.                         sqlQueryObject.addWhereCondition("id_proprietario = ?");
  341.                         sqlQueryObject.addWhereCondition("tipo_proprietario = ?");
  342.                         sqlQueryObject.setANDLogicOperator(true);
  343.                         sqlQuery = sqlQueryObject.createSQLQuery();
  344.                         stm = connection.prepareStatement(sqlQuery);
  345.                         stm.setString(1, doc.getRuolo());
  346.                         stm.setString(2, doc.getTipo());
  347.                         stm.setString(3, doc.getFile());
  348.                         stm.setLong(4, idProprietario);
  349.                         stm.setString(5, tipologiaProprietarioDocumento.toString());
  350.         
  351.                         DriverRegistroServiziDB_LIB.log.debug("Recupero idConnettore inserito : \n" + DBUtils.formatSQLString(sqlQuery,doc.getRuolo(), doc.getTipo(), doc.getFile(), idProprietario,tipologiaProprietarioDocumento.toString()));
  352.         
  353.                         rs = stm.executeQuery();
  354.         
  355.                         if (rs.next()) {
  356.                             documenti.get(i).setId(rs.getLong("id"));
  357.                         } else {
  358.                             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDConnettore] Errore tentanto di effettuare la select dopo una create, non riesco a recuperare l'id!");
  359.                         }
  360.         
  361.                         rs.close();
  362.                         stm.close();
  363.                     }
  364.                     
  365.                 }
  366.                 
  367.                 if(oldLista.size()>0){
  368.                     // Qualche documento e' stato cancellato.
  369.                     // Non e' piu' presente.
  370.                     for(int j=0; j<oldLista.size(); j++){
  371.                         Documento old = oldLista.get(j);
  372.                         
  373.                         ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  374.                         sqlQueryObject.addDeleteTable(CostantiDB.DOCUMENTI);
  375.                         sqlQueryObject.addWhereCondition("id=?");
  376.                         sqlQuery = sqlQueryObject.createSQLDelete();
  377.                         stm = connection.prepareStatement(sqlQuery);
  378.                         stm.setLong(1, old.getId());
  379.                         stm.executeUpdate();
  380.                         stm.close();
  381.                     }
  382.                 }
  383.                 
  384.                 break;

  386.             case DELETE:
  387.                 // delete
  388.                 
  389.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  390.                 sqlQueryObject.addDeleteTable(CostantiDB.DOCUMENTI);
  391.                 sqlQueryObject.addWhereCondition("id_proprietario=?");
  392.                 sqlQueryObject.addWhereCondition("tipo_proprietario = ?");
  393.                 sqlQueryObject.setANDLogicOperator(true);
  394.                 sqlQuery = sqlQueryObject.createSQLDelete();
  395.                 stm = connection.prepareStatement(sqlQuery);
  396.                 stm.setLong(1, idProprietario);
  397.                 stm.setString(2, tipologiaProprietarioDocumento.toString());
  398.                 stm.executeUpdate();
  399.                 stm.close();

  401.                 DriverRegistroServiziDB_LIB.log.debug("CRUDDocumento DELETE : \n" + DBUtils.formatSQLString(sqlQuery, idProprietario));

  403.                 break;
  404.             }

  406.         } catch (SQLException se) {
  407.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] SQLException : " + se.getMessage(),se);
  408.         }catch (Exception se) {
  409.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDDocumento] Exception : " + se.getMessage(),se);
  410.         } finally {
  411.             JDBCUtilities.closeResources(rs, stm);
  412.         }
  413.     }
  414.     
  415.     
  416.     public static List<Documento> getListaDocumenti(long idProprietario, ProprietariDocumento tipologiaProprietarioDocumento, boolean readBytes, 
  417.             Connection connection,
  418.             String tipoDatabase) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  419.         return DriverRegistroServiziDB_documentiLIB.getListaDocumenti(null,idProprietario,tipologiaProprietarioDocumento,readBytes,connection,tipoDatabase);
  420.     }
  421.         
  422.     public static List<Documento> getListaDocumenti(String ruoloDocumenti, long idProprietario, 
  423.             ProprietariDocumento tipologiaProprietarioDocumento, boolean readBytes, Connection connection,
  424.             String tipoDatabase) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  425.         
  426.         PreparedStatement stm = null;
  427.         ResultSet rs=null;
  428.         String sqlQuery;

  430.         if(idProprietario <= 0 ) 
  431.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::getListaDocumenti] id proprietario non definito");
  432.         
  433.         try {
  434.         
  435.             List<Documento> documenti = new ArrayList<Documento>();
  436.             
  437.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  438.             sqlQueryObject.addFromTable(CostantiDB.DOCUMENTI);
  439.             sqlQueryObject.addSelectField("id");
  440.             sqlQueryObject.addWhereCondition("id_proprietario = ?");
  441.             sqlQueryObject.addWhereCondition("tipo_proprietario = ?");
  442.             sqlQueryObject.setANDLogicOperator(true);
  443.             if(ruoloDocumenti!=null)
  444.                 sqlQueryObject.addWhereCondition("ruolo = ?");
  445.             sqlQueryObject.setANDLogicOperator(true);
  446.             sqlQuery = sqlQueryObject.createSQLQuery();
  447.             stm = connection.prepareStatement(sqlQuery);
  448.             stm.setLong(1, idProprietario);
  449.             stm.setString(2, tipologiaProprietarioDocumento.toString());
  450.             if(ruoloDocumenti!=null)
  451.                 stm.setString(3, ruoloDocumenti);
  452.             rs = stm.executeQuery();
  453.             
  454.             while(rs.next()){
  455.                 Documento doc = DriverRegistroServiziDB_documentiLIB.getDocumento(rs.getLong("id"),readBytes, connection,tipoDatabase); 
  456.                 documenti.add(doc);
  457.             }
  458.             
  459.             if(documenti.size()<=0)
  460.                 throw new DriverRegistroServiziNotFound("Documenti con ruolo["+ruoloDocumenti+"] e idProprietario["+idProprietario+"] non trovati");
  461.             
  462.             return documenti;

  464.         } catch (SQLException se) {
  465.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::getListaDocumenti] SQLException : " + se.getMessage(),se);
  466.         }catch (DriverRegistroServiziNotFound dnf) {
  467.             throw dnf;
  468.         }catch (Exception se) {
  469.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::getListaDocumenti] Exception : " + se.getMessage(),se);
  470.         } finally {
  471.             JDBCUtilities.closeResources(rs, stm);
  472.         }
  473.     }
  474.     
  475.     public static Documento getDocumento(long id, boolean readBytes, Connection connection, String tipoDatabase) throws DriverRegistroServiziException,DriverRegistroServiziNotFound {
  476.         
  477.         PreparedStatement stm = null;
  478.         ResultSet rs=null;
  479.         String sqlQuery;

  481.         if(id <= 0 ) 
  482.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::getDocumento] id non definito");
  483.         
  484.         try {
  485.         
  486.             IJDBCAdapter jdbcAdapter = null;
  487.             if(readBytes){
  488.                 // jdbcAdapter = org.openspcoop.utils.jdbc.JDBCAdapterFactory.createJDBCAdapter(DriverRegistroServiziDB_LIB.tipoDB);
  489.                 jdbcAdapter = JDBCAdapterFactory.createJDBCAdapter(tipoDatabase);
  490.             }
  491.                 
  492.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  493.             sqlQueryObject.addFromTable(CostantiDB.DOCUMENTI);
  494.             sqlQueryObject.addSelectField("ruolo");
  495.             sqlQueryObject.addSelectField("tipo");
  496.             sqlQueryObject.addSelectField("nome");
  497.             sqlQueryObject.addSelectField("id_proprietario");
  498.             sqlQueryObject.addSelectField("tipo_proprietario");
  499.             sqlQueryObject.addSelectField("ora_registrazione");
  500.             sqlQueryObject.addSelectField("id");
  501.             if(readBytes)
  502.                 sqlQueryObject.addSelectField("contenuto");
  503.             sqlQueryObject.addWhereCondition("id = ?");
  504.             sqlQueryObject.setANDLogicOperator(true);
  505.             sqlQuery = sqlQueryObject.createSQLQuery();
  506.             stm = connection.prepareStatement(sqlQuery);
  507.             stm.setLong(1, id);
  508.             rs = stm.executeQuery();
  509.             
  510.             Documento doc = null;
  511.             if(rs.next()){
  512.                 doc = new Documento();
  513.                 doc.setRuolo(rs.getString("ruolo"));
  514.                 doc.setTipo(rs.getString("tipo"));
  515.                 doc.setFile(rs.getString("nome"));
  516.                 doc.setIdProprietarioDocumento(rs.getLong("id_proprietario"));
  517.                 doc.setTipoProprietarioDocumento(rs.getString("tipo_proprietario"));
  518.                 doc.setOraRegistrazione(rs.getTimestamp("ora_registrazione"));
  519.                 doc.setId(rs.getLong("id"));
  520.                 if(readBytes){
  521.                     doc.setByteContenuto(jdbcAdapter.getBinaryData(rs,8));
  522.                 }
  523.             }
  524.             
  525.             if(doc==null)
  526.                 throw new DriverRegistroServiziNotFound("Documento con id["+id+"] non trovato");
  527.             
  528.             return doc;

  530.         } catch (SQLException se) {
  531.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::getDocumento] SQLException : " + se.getMessage(),se);
  532.         }catch (DriverRegistroServiziNotFound dnf) {
  533.             throw dnf;
  534.         }catch (Exception se) {
  535.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::getDocumento] Exception : " + se.getMessage(),se);
  536.         } finally {
  537.             JDBCUtilities.closeResources(rs, stm);
  538.         }
  539.     }
  540.     
  541. }
Created with JaCoCo 0.8.8.202204050719