DriverRegistroServiziDB_accordiRestLIB.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.util.ArrayList;
  34. import java.util.List;

  36. import org.openspcoop2.core.byok.IDriverBYOK;
  37. import org.openspcoop2.core.commons.DBUtils;
  38. import org.openspcoop2.core.constants.CostantiDB;
  39. import org.openspcoop2.core.constants.ProprietariProtocolProperty;
  40. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  41. import org.openspcoop2.core.registry.Resource;
  42. import org.openspcoop2.core.registry.ResourceParameter;
  43. import org.openspcoop2.core.registry.ResourceRepresentation;
  44. import org.openspcoop2.core.registry.ResourceRequest;
  45. import org.openspcoop2.core.registry.ResourceResponse;
  46. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  47. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  48. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  49. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  50. import org.openspcoop2.utils.sql.ISQLQueryObject;
  51. import org.openspcoop2.utils.sql.SQLObjectFactory;

  53. /**
  54.  * Classe utilizzata per effettuare query ad un registro dei servizi openspcoop
  55.  * formato db.
  56.  * 
  57.  * 
  58.  * @author Sandra Giangrandi (sandra@link.it)
  59.  * @author Stefano Corallo (corallo@link.it)
  60.  * @author $Author$
  61.  * @version $Rev$, $Date$
  62.  */
  63. public class DriverRegistroServiziDB_accordiRestLIB {
  64.     
  65.     
  66.     public static int CRUDResource(int type, AccordoServizioParteComune as,Resource resource, Connection con, long idAccordo, IDriverBYOK driverBYOK) throws DriverRegistroServiziException {
  67.         PreparedStatement updateStmt = null;
  68.         String updateQuery;
  69.         PreparedStatement selectStmt = null;
  70.         ResultSet selectRS = null;
  71.         int n = 0;
  72.         if (idAccordo <= 0)
  73.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDResource] ID Accordo non valido.");

  75.         try {
  76.             switch (type) {
  77.             case CREATE:
  78.                 // create
  79.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  80.                 sqlQueryObject.addInsertTable(CostantiDB.API_RESOURCES);
  81.                 sqlQueryObject.addInsertField("id_accordo", "?");
  82.                 sqlQueryObject.addInsertField("nome", "?");
  83.                 sqlQueryObject.addInsertField("descrizione", "?");
  84.                 sqlQueryObject.addInsertField("http_method", "?");
  85.                 sqlQueryObject.addInsertField("path", "?");
  86.                 sqlQueryObject.addInsertField("message_type", "?");
  87.                 sqlQueryObject.addInsertField("message_type_request", "?");
  88.                 sqlQueryObject.addInsertField("message_type_response", "?");
  89.                 sqlQueryObject.addInsertField("profilo_azione", "?");
  90.                 sqlQueryObject.addInsertField("filtro_duplicati", "?");
  91.                 sqlQueryObject.addInsertField("conferma_ricezione", "?");
  92.                 sqlQueryObject.addInsertField("identificativo_collaborazione", "?");
  93.                 sqlQueryObject.addInsertField("id_riferimento_richiesta", "?");
  94.                 sqlQueryObject.addInsertField("consegna_in_ordine", "?");
  95.                 sqlQueryObject.addInsertField("scadenza", "?");
  96.                 updateQuery = sqlQueryObject.createSQLInsert();
  97.                 updateStmt = con.prepareStatement(updateQuery);
  98.                 int index = 1;
  99.                 updateStmt.setLong(index++, idAccordo);
  100.                 updateStmt.setString(index++, resource.getNome());
  101.                 updateStmt.setString(index++, resource.getDescrizione());
  102.                 updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getMethod()));
  103.                 if(resource.getPath()==null) {
  104.                     updateStmt.setString(index++, CostantiDB.API_RESOURCE_PATH_ALL_VALUE);
  105.                 }
  106.                 else {
  107.                     updateStmt.setString(index++, resource.getPath());
  108.                 }
  109.                 updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getMessageType()));
  110.                 updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getRequestMessageType()));
  111.                 updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getResponseMessageType()));
  112.                 
  113.                 DriverRegistroServiziDB_LIB.log.debug("Aggiungo resource ["+resource.getNome()+"] con profilo ["+resource.getProfAzione()+"]");

  115.                 updateStmt.setString(index++, resource.getProfAzione());
  116.                 
  117.                 if(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(resource.getProfAzione())){
  118.                     DriverRegistroServiziDB_LIB.log.debug("ridefinizione...");
  119.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getFiltroDuplicati()));
  120.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getConfermaRicezione()));
  121.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getIdCollaborazione()));
  122.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getIdRiferimentoRichiesta()));
  123.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getConsegnaInOrdine()));
  124.                     updateStmt.setString(index++, resource.getScadenza());
  125.                 }else{
  126.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getFiltroDuplicati()));
  127.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConfermaRicezione()));
  128.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdCollaborazione()));
  129.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdRiferimentoRichiesta()));
  130.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConsegnaInOrdine()));
  131.                     updateStmt.setString(index++, as.getScadenza());
  132.                 }

  134.                 // log.debug("CRUDAzione CREATE :
  135.                 // \n"+formatSQLString(updateQuery,idAccordo,idSoggettoFruitore,idConnettore,wsdlImplementativoErogatore,wsdlImplementativoFruitore));
  136.                 n = updateStmt.executeUpdate();

  138.                 DriverRegistroServiziDB_LIB.log.debug("CRUDResource type = " + type + " row affected =" + n);

  140.                 break;

  142.             case UPDATE:
  143.                 // update
  144.                 //
  145.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  146.                 sqlQueryObject.addUpdateTable(CostantiDB.PORT_TYPE);
  147.                 sqlQueryObject.addUpdateField("descrizione", "?");
  148.                 sqlQueryObject.addUpdateField("http_method", "?");
  149.                 sqlQueryObject.addUpdateField("path", "?");
  150.                 sqlQueryObject.addUpdateField("message_type", "?");
  151.                 sqlQueryObject.addUpdateField("message_type_request", "?");
  152.                 sqlQueryObject.addUpdateField("message_type_response", "?");
  153.                 sqlQueryObject.addUpdateField("profilo_azione", "?");
  154.                 sqlQueryObject.addUpdateField("filtro_duplicati", "?");
  155.                 sqlQueryObject.addUpdateField("conferma_ricezione", "?");
  156.                 sqlQueryObject.addUpdateField("identificativo_collaborazione", "?");
  157.                 sqlQueryObject.addUpdateField("id_riferimento_richiesta", "?");
  158.                 sqlQueryObject.addUpdateField("consegna_in_ordine", "?");
  159.                 sqlQueryObject.addUpdateField("scadenza", "?");
  160.                 sqlQueryObject.addWhereCondition("id_accordo=?");
  161.                 sqlQueryObject.addWhereCondition("nome=?");
  162.                 sqlQueryObject.setANDLogicOperator(true);
  163.                 updateQuery = sqlQueryObject.createSQLUpdate();
  164.                 updateStmt = con.prepareStatement(updateQuery);
  165.                 index = 1;
  166.                 updateStmt.setString(index++, resource.getDescrizione());
  167.                 updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getMethod()));
  168.                 if(resource.getPath()==null) {
  169.                     updateStmt.setString(index++, CostantiDB.API_RESOURCE_PATH_ALL_VALUE);
  170.                 }
  171.                 else {
  172.                     updateStmt.setString(index++, resource.getPath());
  173.                 }
  174.                 updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getMessageType()));
  175.                 updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getRequestMessageType()));
  176.                 updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getResponseMessageType()));
  177.                 
  178.                 updateStmt.setString(index++, resource.getProfAzione());
  179.                 
  180.                 if(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(resource.getProfAzione())){
  181.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getFiltroDuplicati()));
  182.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getConfermaRicezione()));
  183.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getIdCollaborazione()));
  184.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getIdRiferimentoRichiesta()));
  185.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(resource.getConsegnaInOrdine()));
  186.                     updateStmt.setString(index++, resource.getScadenza());
  187.                 }else{
  188.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getFiltroDuplicati()));
  189.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConfermaRicezione()));
  190.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdCollaborazione()));
  191.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdRiferimentoRichiesta()));
  192.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConsegnaInOrdine()));
  193.                     updateStmt.setString(index++, as.getScadenza());
  194.                 }
  195.                 
  196.                 updateStmt.setLong(index++, idAccordo);
  197.                 updateStmt.setString(index++, resource.getNome());
  198.                 n = updateStmt.executeUpdate();

  200.                 DriverRegistroServiziDB_LIB.log.debug("CRUDResource type = " + type + " row affected =" + n);
  201.                 // log.debug("CRUDAzione UPDATE :
  202.                 // \n"+formatSQLString(updateQuery,wsdlImplementativoErogatore,wsdlImplementativoFruitore,
  203.                 // idServizio,idSoggettoFruitore,idConnettore));

  205.                 break;

  207.             case DELETE:
  208.                 // delete

  210.                 Long idResource = 0l;
  211.                 if(resource.getId()==null || resource.getId()<=0){
  212.                     idResource = DBUtils.getIdResource(idAccordo, resource.getNome(), con);
  213.                     if(idResource==null || idResource<=0)
  214.                         throw new Exception("ID della risorsa ["+resource.getNome()+"] idAccordo["+idAccordo+"] non trovato");
  215.                 }
  216.                 else {
  217.                     idResource = resource.getId();
  218.                 }
  219.                 
  220.                 // gestione request
  221.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  222.                 sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES_MEDIA);
  223.                 sqlQueryObject.addWhereCondition("id_resource_media=?");
  224.                 sqlQueryObject.setANDLogicOperator(true);
  225.                 updateQuery = sqlQueryObject.createSQLDelete();
  226.                 updateStmt=con.prepareStatement(updateQuery);
  227.                 updateStmt.setLong(1, idResource );
  228.                 updateStmt.executeUpdate();
  229.                 updateStmt.close();
  230.                 
  231.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  232.                 sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES_PARAMETER);
  233.                 sqlQueryObject.addWhereCondition("id_resource_parameter=?");
  234.                 sqlQueryObject.setANDLogicOperator(true);
  235.                 updateQuery = sqlQueryObject.createSQLDelete();
  236.                 updateStmt=con.prepareStatement(updateQuery);
  237.                 updateStmt.setLong(1, idResource);
  238.                 updateStmt.executeUpdate();
  239.                 updateStmt.close();
  240.                 
  241.                 // gestione response
  242.                 List<Long> idResourceResponse = new ArrayList<Long>();
  243.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  244.                 sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_RESPONSE);
  245.                 sqlQueryObject.addSelectField("id");
  246.                 sqlQueryObject.addWhereCondition("id_resource=?");
  247.                 updateQuery = sqlQueryObject.createSQLQuery();
  248.                 updateStmt=con.prepareStatement(updateQuery);
  249.                 updateStmt.setLong(1, idResource);
  250.                 selectRS=updateStmt.executeQuery();
  251.                 while(selectRS.next()){
  252.                     idResourceResponse.add(selectRS.getLong("id"));
  253.                 }
  254.                 selectRS.close();
  255.                 updateStmt.close();
  256.     
  257.                 while(idResourceResponse.size()>0){
  258.                     
  259.                     long idRR = idResourceResponse.remove(0);
  260.                     
  261.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  262.                     sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES_MEDIA);
  263.                     sqlQueryObject.addWhereCondition("id_resource_response_media=?");
  264.                     sqlQueryObject.setANDLogicOperator(true);
  265.                     updateQuery = sqlQueryObject.createSQLDelete();
  266.                     updateStmt=con.prepareStatement(updateQuery);
  267.                     updateStmt.setLong(1, idRR );
  268.                     updateStmt.executeUpdate();
  269.                     updateStmt.close();
  270.                     
  271.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  272.                     sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES_PARAMETER);
  273.                     sqlQueryObject.addWhereCondition("id_resource_response_par=?");
  274.                     sqlQueryObject.setANDLogicOperator(true);
  275.                     updateQuery = sqlQueryObject.createSQLDelete();
  276.                     updateStmt=con.prepareStatement(updateQuery);
  277.                     updateStmt.setLong(1, idRR);
  278.                     updateStmt.executeUpdate();
  279.                     updateStmt.close();
  280.                 }
  281.                 
  282.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  283.                 sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES_RESPONSE);
  284.                 sqlQueryObject.addWhereCondition("id_resource=?");
  285.                 sqlQueryObject.setANDLogicOperator(true);
  286.                 updateQuery = sqlQueryObject.createSQLDelete();
  287.                 updateStmt=con.prepareStatement(updateQuery);
  288.                 updateStmt.setLong(1, idResource);
  289.                 updateStmt.executeUpdate();
  290.                 updateStmt.close();
  291.                 
  292.                 // elimino risorsa
  293.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  294.                 sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES);
  295.                 sqlQueryObject.addWhereCondition("id=?");
  296.                 sqlQueryObject.setANDLogicOperator(true);
  297.                 updateQuery = sqlQueryObject.createSQLDelete();
  298.                 updateStmt=con.prepareStatement(updateQuery);
  299.                 updateStmt.setLong(1, idResource);
  300.                 n = updateStmt.executeUpdate();
  301.                 updateStmt.close();

  303.                 DriverRegistroServiziDB_LIB.log.debug("CRUDResource type = " + type + " row affected =" + n);
  304.                 // log.debug("CRUDAzione DELETE :
  305.                 // \n"+formatSQLString(updateQuery,idServizio,idSoggettoFruitore,idConnettore));

  307.                 break;
  308.             }



  312.             if ( (CostantiDB.CREATE == type) || (CostantiDB.UPDATE == type)) {
  313.                 Long idResource = DBUtils.getIdResource(idAccordo, resource.getNome(), con);
  314.                 if(idResource==null || idResource<=0)
  315.                     throw new Exception("ID della risorsa ["+resource.getNome()+"] idAccordo["+idAccordo+"] non trovato");

  317.                 DriverRegistroServiziDB_LIB.log.debug("ID risorsa: "+idResource);

  319.                 if ( CostantiDB.UPDATE == type ){
  320.                     
  321.                     if(resource.getRequest()!=null) {
  322.                         DriverRegistroServiziDB_accordiRestLIB.CRUDResourceRequest(CostantiDB.DELETE, as, resource, resource.getRequest(), con, idResource);
  323.                         DriverRegistroServiziDB_LIB.log.info("Cancellato dettagli di richiesta della risorsa ["+idResource+"] associata all'accordo "+idAccordo);
  324.                     }
  325.                     
  326.                     n = 0;
  327.                     for(int i=0;i<resource.sizeResponseList();i++){
  328.                         DriverRegistroServiziDB_accordiRestLIB.CRUDResourceResponse(CostantiDB.DELETE, as, resource, resource.getResponse(i), con, idResource);
  329.                     }
  330.                     DriverRegistroServiziDB_LIB.log.info("Cancellate "+n+" dettagli di risposta della risorsa ["+idResource+"] associata all'accordo "+idAccordo);
  331.                 }

  333.                 if(resource.getRequest()!=null) {
  334.                     DriverRegistroServiziDB_accordiRestLIB.CRUDResourceRequest(CostantiDB.CREATE, as, resource, resource.getRequest(), con, idResource);
  335.                 }
  336.                 
  337.                 for(int i=0;i<resource.sizeResponseList();i++){
  338.                     DriverRegistroServiziDB_accordiRestLIB.CRUDResourceResponse(CostantiDB.CREATE, as, resource, resource.getResponse(i), con, idResource);
  339.                 }                   
  340.                 DriverRegistroServiziDB_LIB.log.debug("inserite " + resource.sizeResponseList() + " dettagli di risposta relative alla risorsa ["+resource.getNome()+"] id-risorsa["+resource.getId()+"] dell'accordo :" + IDAccordoFactory.getInstance().getUriFromAccordo(as) + " id-accordo :" + idAccordo);
  341.                 
  342.                 
  343.                 // ProtocolProperties
  344.                 DriverRegistroServiziDB_LIB.CRUDProtocolProperty(type, resource.getProtocolPropertyList(), 
  345.                         idResource, ProprietariProtocolProperty.RESOURCE, con, DriverRegistroServiziDB_LIB.tipoDB, driverBYOK);
  346.             }


  349.             return n;

  351.         } catch (SQLException se) {
  352.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDResource] SQLException : " + se.getMessage(),se);
  353.         } catch (Exception se) {
  354.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDResource] Exception : " + se.getMessage(),se);
  355.         } finally {
  356.             JDBCUtilities.closeResources(selectRS, selectStmt);
  357.             JDBCUtilities.closeResources(updateStmt);
  358.         }
  359.     }
  360.     
  361.     public static void CRUDResourceRequest(int type, AccordoServizioParteComune as,Resource resource,ResourceRequest resourceRequest, Connection con, long idResource) throws DriverRegistroServiziException {
  362.         _CRUDResourceRequestResponse(type, as, resource, resourceRequest, null, con, idResource);
  363.     }
  364.     public static void CRUDResourceResponse(int type, AccordoServizioParteComune as,Resource resource,ResourceResponse resourceResponse, Connection con, long idResource) throws DriverRegistroServiziException {
  365.         _CRUDResourceRequestResponse(type, as, resource, null, resourceResponse, con, idResource);
  366.     }
  367.     
  368.     private static void _CRUDResourceRequestResponse(int type, AccordoServizioParteComune as,Resource resource,
  369.             ResourceRequest resourceRequest,ResourceResponse resourceResponse, Connection con, long idResource) throws DriverRegistroServiziException {

  371.         PreparedStatement updateStmt = null;
  372.         String updateQuery;
  373.         PreparedStatement selectStmt = null;
  374.         String selectQuery = "";
  375.         ResultSet selectRS = null;
  376.         long n = 0;
  377.         if (idResource <= 0)
  378.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::_CRUDResourceRequestResponse] ID Risorda non valido.");

  380.         try {
  381.             switch (type) {
  382.             case CREATE:
  383.                 
  384.                 long idFK = -1;
  385.                 if(resourceRequest!=null) {
  386.                     idFK = idResource;
  387.                 }
  388.                 else {
  389.                     
  390.                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  391.                     sqlQueryObject.addInsertTable(CostantiDB.API_RESOURCES_RESPONSE);
  392.                     sqlQueryObject.addInsertField("id_resource", "?");
  393.                     sqlQueryObject.addInsertField("descrizione", "?");
  394.                     sqlQueryObject.addInsertField("status", "?");
  395.                     updateQuery = sqlQueryObject.createSQLInsert();
  396.                     updateStmt = con.prepareStatement(updateQuery);
  397.                     int index = 1;
  398.                     updateStmt.setLong(index++, idResource);
  399.                     updateStmt.setString(index++, resourceResponse.getDescrizione());
  400.                     updateStmt.setInt(index++, resourceResponse.getStatus());
  401.                     DriverRegistroServiziDB_LIB.log.debug("_CRUDResourceRequestResponse (RESPONSE) CREATE :\n"+updateQuery);
  402.                     n = updateStmt.executeUpdate();
  403.                     updateStmt.close();
  404.                     DriverRegistroServiziDB_LIB.log.debug("_CRUDResourceRequestResponse (RESPONSE) type = " + type + " row affected =" + n);
  405.                     
  406.                     index = 1;
  407.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  408.                     sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_RESPONSE);
  409.                     sqlQueryObject.addSelectField("id");
  410.                     sqlQueryObject.addWhereCondition("id_resource = ?");
  411.                     sqlQueryObject.addWhereCondition("status = ?");
  412.                     sqlQueryObject.setANDLogicOperator(true);
  413.                     selectQuery = sqlQueryObject.createSQLQuery();
  414.                     selectStmt = con.prepareStatement(selectQuery);
  415.                     selectStmt.setLong(index++, idResource);
  416.                     selectStmt.setInt(index++, resourceResponse.getStatus());
  417.                     selectRS = selectStmt.executeQuery();
  418.                     if (selectRS.next()) {
  419.                         idFK = selectRS.getLong("id");
  420.                     }
  421.                     else {
  422.                         throw new Exception("Recupero dell'id della tabella '"+CostantiDB.API_RESOURCES_RESPONSE+"' con id_resource='"+idResource+"' e status='"+resourceResponse.getStatus()+"' non riuscito");
  423.                     }
  424.                 }
  425.                 if(idFK<=0) {
  426.                     throw new Exception("Recupero dell'id della tabella padre non riuscito");
  427.                 }
  428.                 if(resourceRequest!=null) {
  429.                     resourceRequest.setIdResource(idFK);
  430.                 }
  431.                 else {
  432.                     resourceResponse.setIdResource(idFK);
  433.                 }
  434.                 
  435.                 List<ResourceRepresentation> lRR = null;
  436.                 if(resourceRequest!=null) {
  437.                     lRR = resourceRequest.getRepresentationList();
  438.                 }
  439.                 else {
  440.                     lRR = resourceResponse.getRepresentationList();
  441.                 }
  442.                 for (ResourceRepresentation rr : lRR) {
  443.                     
  444.                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  445.                     sqlQueryObject.addInsertTable(CostantiDB.API_RESOURCES_MEDIA);
  446.                     if(resourceRequest!=null) {
  447.                         sqlQueryObject.addInsertField("id_resource_media", "?");
  448.                     }
  449.                     else {
  450.                         sqlQueryObject.addInsertField("id_resource_response_media", "?");
  451.                     }
  452.                     sqlQueryObject.addInsertField("media_type", "?");
  453.                     sqlQueryObject.addInsertField("message_type", "?");
  454.                     sqlQueryObject.addInsertField("nome", "?");
  455.                     sqlQueryObject.addInsertField("descrizione", "?");
  456.                     sqlQueryObject.addInsertField("tipo", "?");
  457.                     sqlQueryObject.addInsertField("xml_tipo", "?");
  458.                     sqlQueryObject.addInsertField("xml_name", "?");
  459.                     sqlQueryObject.addInsertField("xml_namespace", "?");
  460.                     sqlQueryObject.addInsertField("json_type", "?");
  461.                     updateQuery = sqlQueryObject.createSQLInsert();
  462.                     updateStmt = con.prepareStatement(updateQuery);
  463.                     int index = 1;
  464.                     updateStmt.setLong(index++, idFK);
  465.                     updateStmt.setString(index++, rr.getMediaType());
  466.                     updateStmt.setString(index++,  DriverRegistroServiziDB_LIB.getValue(rr.getMessageType()));
  467.                     updateStmt.setString(index++, rr.getNome());
  468.                     updateStmt.setString(index++, rr.getDescrizione());
  469.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(rr.getRepresentationType()));
  470.                     updateStmt.setString(index++, rr.getXml()!=null ? DriverRegistroServiziDB_LIB.getValue(rr.getXml().getXmlType()) : null);
  471.                     updateStmt.setString(index++, rr.getXml()!=null ? rr.getXml().getNome() : null);
  472.                     updateStmt.setString(index++, rr.getXml()!=null ? rr.getXml().getNamespace() : null);
  473.                     updateStmt.setString(index++, rr.getJson()!=null ? rr.getJson().getTipo() : null);                  
  474.                     DriverRegistroServiziDB_LIB.log.debug("_CRUDResourceRequestResponse (MEDIA) CREATE :\n"+updateQuery);
  475.                     n = updateStmt.executeUpdate();
  476.                     DriverRegistroServiziDB_LIB.log.debug("_CRUDResourceRequestResponse (MEDIA) type = " + type + " row affected =" + n);
  477.                     updateStmt.close();
  478.                     
  479.                 }
  480.                 
  481.                 List<ResourceParameter> lRP = null;
  482.                 if(resourceRequest!=null) {
  483.                     lRP = resourceRequest.getParameterList();
  484.                 }
  485.                 else {
  486.                     lRP = resourceResponse.getParameterList();
  487.                 }
  488.                 for (ResourceParameter rp : lRP) {
  489.                     
  490.                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  491.                     sqlQueryObject.addInsertTable(CostantiDB.API_RESOURCES_PARAMETER);
  492.                     if(resourceRequest!=null) {
  493.                         sqlQueryObject.addInsertField("id_resource_parameter", "?");
  494.                     }
  495.                     else {
  496.                         sqlQueryObject.addInsertField("id_resource_response_par", "?");
  497.                     }
  498.                     sqlQueryObject.addInsertField("nome", "?");
  499.                     sqlQueryObject.addInsertField("descrizione", "?");
  500.                     sqlQueryObject.addInsertField("tipo_parametro", "?");
  501.                     sqlQueryObject.addInsertField("required", "?");
  502.                     sqlQueryObject.addInsertField("tipo", "?");
  503.                     sqlQueryObject.addInsertField("restrizioni", "?");
  504.                     updateQuery = sqlQueryObject.createSQLInsert();
  505.                     updateStmt = con.prepareStatement(updateQuery);
  506.                     int index = 1;
  507.                     updateStmt.setLong(index++, idFK);
  508.                     updateStmt.setString(index++, rp.getNome());
  509.                     updateStmt.setString(index++, rp.getDescrizione());
  510.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(rp.getParameterType()));
  511.                     updateStmt.setBoolean(index++, rp.isRequired());
  512.                     updateStmt.setString(index++, rp.getTipo());            
  513.                     updateStmt.setString(index++, rp.getRestrizioni());
  514.                     DriverRegistroServiziDB_LIB.log.debug("_CRUDResourceRequestResponse (PARAMETER) CREATE :\n"+updateQuery);
  515.                     n = updateStmt.executeUpdate();
  516.                     DriverRegistroServiziDB_LIB.log.debug("_CRUDResourceRequestResponse (PARAMETER) type = " + type + " row affected =" + n);
  517.                     updateStmt.close();
  518.                     
  519.                 }
  520.                 
  521.                 break;

  523.             case UPDATE:
  524.                 throw new Exception("Not Implemented");

  526.                 //break;

  528.             case DELETE:
  529.                 // delete

  531.                 
  532.                 // gestione request
  533.                 if(resourceRequest!=null) {
  534.                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  535.                     sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES_MEDIA);
  536.                     sqlQueryObject.addWhereCondition("id_resource_media=?");
  537.                     sqlQueryObject.setANDLogicOperator(true);
  538.                     updateQuery = sqlQueryObject.createSQLDelete();
  539.                     updateStmt=con.prepareStatement(updateQuery);
  540.                     updateStmt.setLong(1, idResource );
  541.                     updateStmt.executeUpdate();
  542.                     updateStmt.close();
  543.                     
  544.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  545.                     sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES_PARAMETER);
  546.                     sqlQueryObject.addWhereCondition("id_resource_parameter=?");
  547.                     sqlQueryObject.setANDLogicOperator(true);
  548.                     updateQuery = sqlQueryObject.createSQLDelete();
  549.                     updateStmt=con.prepareStatement(updateQuery);
  550.                     updateStmt.setLong(1, idResource);
  551.                     updateStmt.executeUpdate();
  552.                     updateStmt.close();
  553.                 }
  554.                 else {
  555.                 
  556.                     // gestione response
  557.                     List<Long> idResourceResponse = new ArrayList<Long>();
  558.                     ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  559.                     sqlQueryObject.addFromTable(CostantiDB.API_RESOURCES_RESPONSE);
  560.                     sqlQueryObject.addSelectField("id");
  561.                     sqlQueryObject.addWhereCondition("id_resource=?");
  562.                     updateQuery = sqlQueryObject.createSQLQuery();
  563.                     updateStmt=con.prepareStatement(updateQuery);
  564.                     updateStmt.setLong(1, idResource);
  565.                     selectRS=updateStmt.executeQuery();
  566.                     while(selectRS.next()){
  567.                         idResourceResponse.add(selectRS.getLong("id"));
  568.                     }
  569.                     selectRS.close();
  570.                     updateStmt.close();
  571.         
  572.                     while(idResourceResponse.size()>0){
  573.                         
  574.                         long idRR = idResourceResponse.remove(0);
  575.                         
  576.                         sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  577.                         sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES_MEDIA);
  578.                         sqlQueryObject.addWhereCondition("id_resource_response_media=?");
  579.                         sqlQueryObject.setANDLogicOperator(true);
  580.                         updateQuery = sqlQueryObject.createSQLDelete();
  581.                         updateStmt=con.prepareStatement(updateQuery);
  582.                         updateStmt.setLong(1, idRR );
  583.                         updateStmt.executeUpdate();
  584.                         updateStmt.close();
  585.                         
  586.                         sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  587.                         sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES_PARAMETER);
  588.                         sqlQueryObject.addWhereCondition("id_resource_response_par=?");
  589.                         sqlQueryObject.setANDLogicOperator(true);
  590.                         updateQuery = sqlQueryObject.createSQLDelete();
  591.                         updateStmt=con.prepareStatement(updateQuery);
  592.                         updateStmt.setLong(1, idRR);
  593.                         updateStmt.executeUpdate();
  594.                         updateStmt.close();
  595.                     }
  596.                     
  597.                     sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  598.                     sqlQueryObject.addDeleteTable(CostantiDB.API_RESOURCES_RESPONSE);
  599.                     sqlQueryObject.addWhereCondition("id_resource=?");
  600.                     sqlQueryObject.setANDLogicOperator(true);
  601.                     updateQuery = sqlQueryObject.createSQLDelete();
  602.                     updateStmt=con.prepareStatement(updateQuery);
  603.                     updateStmt.setLong(1, idResource);
  604.                     updateStmt.executeUpdate();
  605.                     updateStmt.close();
  606.                 
  607.                 }
  608.                 
  609.                 break;
  610.             }


  613.         } catch (SQLException se) {
  614.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::_CRUDResourceRequestResponse] SQLException : " + se.getMessage(),se);
  615.         } catch (Exception se) {
  616.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::_CRUDResourceRequestResponse] Exception : " + se.getMessage(),se);
  617.         } finally {
  618.             JDBCUtilities.closeResources(selectRS, selectStmt);
  619.             JDBCUtilities.closeResources(updateStmt);
  620.         }
  621.     }
  622.     
  623. }
Created with JaCoCo 0.8.8.202204050719