DriverRegistroServiziDB_accordiSoapLIB.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;

  34. import org.openspcoop2.core.byok.IDriverBYOK;
  35. import org.openspcoop2.core.commons.DBUtils;
  36. import org.openspcoop2.core.constants.CostantiDB;
  37. import org.openspcoop2.core.constants.ProprietariProtocolProperty;
  38. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  39. import org.openspcoop2.core.registry.Azione;
  40. import org.openspcoop2.core.registry.MessagePart;
  41. import org.openspcoop2.core.registry.Operation;
  42. import org.openspcoop2.core.registry.PortType;
  43. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  44. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  45. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  46. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  47. import org.openspcoop2.utils.sql.ISQLQueryObject;
  48. import org.openspcoop2.utils.sql.SQLObjectFactory;

  50. /**
  51.  * Classe utilizzata per effettuare query ad un registro dei servizi openspcoop
  52.  * formato db.
  53.  * 
  54.  * 
  55.  * @author Sandra Giangrandi (sandra@link.it)
  56.  * @author Stefano Corallo (corallo@link.it)
  57.  * @author $Author$
  58.  * @version $Rev$, $Date$
  59.  */
  60. public class DriverRegistroServiziDB_accordiSoapLIB {
  61.     
  62.     

  64.     public static long CRUDAzione(int type, AccordoServizioParteComune as,Azione azione, Connection con, long idAccordo, IDriverBYOK driverBYOK) throws DriverRegistroServiziException {
  65.         PreparedStatement updateStmt = null;
  66.         String updateQuery;
  67.         PreparedStatement selectStmt = null;
  68.         String selectQuery = "";
  69.         ResultSet selectRS = null;
  70.         long n = 0;
  71.         if (idAccordo <= 0)
  72.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDAzione] ID Accordo non valido.");

  74.         try {
  75.             switch (type) {
  76.             case CREATE:
  77.                 // create
  78.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  79.                 sqlQueryObject.addInsertTable(CostantiDB.ACCORDI_AZIONI);
  80.                 sqlQueryObject.addInsertField("id_accordo", "?");
  81.                 sqlQueryObject.addInsertField("nome", "?");
  82.                 sqlQueryObject.addInsertField("profilo_azione", "?");
  83.                 sqlQueryObject.addInsertField("filtro_duplicati", "?");
  84.                 sqlQueryObject.addInsertField("conferma_ricezione", "?");
  85.                 sqlQueryObject.addInsertField("identificativo_collaborazione", "?");
  86.                 sqlQueryObject.addInsertField("id_riferimento_richiesta", "?");
  87.                 sqlQueryObject.addInsertField("consegna_in_ordine", "?");
  88.                 sqlQueryObject.addInsertField("scadenza", "?");
  89.                 sqlQueryObject.addInsertField("profilo_collaborazione", "?");
  90.                 sqlQueryObject.addInsertField("correlata", "?");
  91.                 updateQuery = sqlQueryObject.createSQLInsert();
  92.                 updateStmt = con.prepareStatement(updateQuery);
  93.                 int index = 1;
  94.                 updateStmt.setLong(index++, idAccordo);
  95.                 updateStmt.setString(index++, azione.getNome());
  96.                 updateStmt.setString(index++, azione.getProfAzione());

  98.                 DriverRegistroServiziDB_LIB.log.debug("Aggiungo azione ["+azione.getNome()+"] con profilo ["+azione.getProfAzione()+"]");

  100.                 if(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(azione.getProfAzione())){
  101.                     DriverRegistroServiziDB_LIB.log.debug("ridefinizione...");
  102.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getFiltroDuplicati()));
  103.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getConfermaRicezione()));
  104.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getIdCollaborazione()));
  105.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getIdRiferimentoRichiesta()));
  106.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getConsegnaInOrdine()));
  107.                     updateStmt.setString(index++, azione.getScadenza());
  108.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getProfiloCollaborazione()));
  109.                 }else{
  110.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getFiltroDuplicati()));
  111.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConfermaRicezione()));
  112.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdCollaborazione()));
  113.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdRiferimentoRichiesta()));
  114.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConsegnaInOrdine()));
  115.                     updateStmt.setString(index++, as.getScadenza());
  116.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getProfiloCollaborazione()));
  117.                 }
  118.                 updateStmt.setString(index++, azione.getCorrelata());

  120.                 DriverRegistroServiziDB_LIB.log.debug("CRUDAzione CREATE :\n"+DriverRegistroServiziDB_LIB.formatSQLString(updateQuery,idAccordo,azione.getNome(),azione.getProfAzione()));
  121.                 n = updateStmt.executeUpdate();

  123.                 DriverRegistroServiziDB_LIB.log.debug("CRUDAzione type = " + type + " row affected =" + n);
  124.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  125.                 sqlQueryObject.addFromTable(CostantiDB.ACCORDI_AZIONI);
  126.                 sqlQueryObject.addSelectField("id");
  127.                 sqlQueryObject.addWhereCondition("id_accordo = ?");
  128.                 sqlQueryObject.addWhereCondition("nome = ?");
  129.                 sqlQueryObject.setANDLogicOperator(true);
  130.                 selectQuery = sqlQueryObject.createSQLQuery();
  131.                 selectStmt = con.prepareStatement(selectQuery);
  132.                 selectStmt.setLong(1, idAccordo);
  133.                 selectStmt.setString(2, azione.getNome());

  135.                 break;

  137.             case UPDATE:
  138.                 // update
  139.                 //
  140.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  141.                 sqlQueryObject.addUpdateTable(CostantiDB.ACCORDI_AZIONI);
  142.                 sqlQueryObject.addUpdateField("profilo_azione", "?");
  143.                 sqlQueryObject.addUpdateField("filtro_duplicati", "?");
  144.                 sqlQueryObject.addUpdateField("conferma_ricezione", "?");
  145.                 sqlQueryObject.addUpdateField("identificativo_collaborazione", "?");
  146.                 sqlQueryObject.addUpdateField("id_riferimento_richiesta", "?");
  147.                 sqlQueryObject.addUpdateField("consegna_in_ordine", "?");
  148.                 sqlQueryObject.addUpdateField("scadenza", "?");
  149.                 sqlQueryObject.addUpdateField("profilo_collaborazione", "?");
  150.                 sqlQueryObject.addUpdateField("correlata", "?");
  151.                 sqlQueryObject.addWhereCondition("id_accordo=?");
  152.                 sqlQueryObject.addWhereCondition("nome=?");
  153.                 sqlQueryObject.setANDLogicOperator(true);
  154.                 updateQuery = sqlQueryObject.createSQLUpdate();
  155.                 updateStmt = con.prepareStatement(updateQuery);
  156.                 index = 1;
  157.                 updateStmt.setString(1, azione.getProfAzione());

  159.                 if(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(azione.getProfAzione())){
  160.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getFiltroDuplicati()));
  161.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getConfermaRicezione()));
  162.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getIdCollaborazione()));
  163.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getIdRiferimentoRichiesta()));
  164.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getConsegnaInOrdine()));
  165.                     updateStmt.setString(index++, azione.getScadenza());
  166.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getProfiloCollaborazione()));
  167.                 }else{
  168.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getFiltroDuplicati()));
  169.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConfermaRicezione()));
  170.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdCollaborazione()));
  171.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdRiferimentoRichiesta()));
  172.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConsegnaInOrdine()));
  173.                     updateStmt.setString(index++, as.getScadenza());
  174.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getProfiloCollaborazione()));
  175.                 }

  177.                 updateStmt.setString(index++, azione.getCorrelata());

  179.                 updateStmt.setLong(index++, idAccordo);
  180.                 updateStmt.setString(index++, azione.getNome());
  181.                 n = updateStmt.executeUpdate();

  183.                 DriverRegistroServiziDB_LIB.log.debug("CRUDAzione type = " + type + " row affected =" + n);
  184.                 // log.debug("CRUDAzione UPDATE :
  185.                 // \n"+formatSQLString(updateQuery,wsdlImplementativoErogatore,wsdlImplementativoFruitore,
  186.                 // idServizio,idSoggettoFruitore,idConnettore));

  188.                 break;

  190.             case DELETE:
  191.                 // delete

  193.                 // ProtocolProperties
  194.                 DriverRegistroServiziDB_LIB.CRUDProtocolProperty(CostantiDB.DELETE, null, 
  195.                         azione.getId(), ProprietariProtocolProperty.AZIONE_ACCORDO, con, DriverRegistroServiziDB_LIB.tipoDB, driverBYOK);
  196.                 
  197.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  198.                 sqlQueryObject.addDeleteTable(CostantiDB.ACCORDI_AZIONI);
  199.                 sqlQueryObject.addWhereCondition("id_accordo=?");
  200.                 sqlQueryObject.addWhereCondition("nome=?");
  201.                 sqlQueryObject.setANDLogicOperator(true);
  202.                 String sqlQuery = sqlQueryObject.createSQLDelete();
  203.                 updateStmt = con.prepareStatement(sqlQuery);
  204.                 updateStmt.setLong(1, idAccordo);
  205.                 updateStmt.setString(2, azione.getNome());
  206.                 n=updateStmt.executeUpdate();
  207.                 updateStmt.close();
  208.                 DriverRegistroServiziDB_LIB.log.debug("CRUDAzione type = " + type + " row affected =" + n);
  209.                 // log.debug("CRUDAzione DELETE :
  210.                 // \n"+formatSQLString(updateQuery,idServizio,idSoggettoFruitore,idConnettore));

  212.                 break;
  213.             }



  217.             if (CostantiDB.CREATE == type) {
  218.                 if(selectStmt!=null) {
  219.                     selectRS = selectStmt.executeQuery();
  220.                     if (selectRS.next()) {
  221.     
  222.                         azione.setId(selectRS.getLong("id"));
  223.                         
  224.                         // ProtocolProperties
  225.                         DriverRegistroServiziDB_LIB.CRUDProtocolProperty(type, azione.getProtocolPropertyList(), 
  226.                                 azione.getId(), ProprietariProtocolProperty.AZIONE_ACCORDO, con, DriverRegistroServiziDB_LIB.tipoDB, driverBYOK);
  227.                         
  228.                         return azione.getId();
  229.     
  230.                     }
  231.                 }
  232.             }

  234.             return n;

  236.         } catch (SQLException se) {
  237.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDAzione] SQLException : " + se.getMessage(),se);
  238.         } catch (Exception se) {
  239.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDAzione] Exception : " + se.getMessage(),se);
  240.         } finally {
  241.             JDBCUtilities.closeResources(selectRS, selectStmt);
  242.             JDBCUtilities.closeResources(updateStmt);
  243.         }
  244.     }

  246.     public static long CRUDPortType(int type, AccordoServizioParteComune as,PortType pt, Connection con, long idAccordo, IDriverBYOK driverBYOK) throws DriverRegistroServiziException {
  247.         PreparedStatement updateStmt = null;
  248.         String updateQuery;
  249.         PreparedStatement selectStmt = null;
  250.         ResultSet selectRS = null;
  251.         long n = 0;
  252.         if (idAccordo <= 0)
  253.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDPortType] ID Accordo non valido.");

  255.         try {
  256.             switch (type) {
  257.             case CREATE:
  258.                 // create
  259.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  260.                 sqlQueryObject.addInsertTable(CostantiDB.PORT_TYPE);
  261.                 sqlQueryObject.addInsertField("id_accordo", "?");
  262.                 sqlQueryObject.addInsertField("nome", "?");
  263.                 sqlQueryObject.addInsertField("descrizione", "?");
  264.                 sqlQueryObject.addInsertField("message_type", "?");
  265.                 sqlQueryObject.addInsertField("profilo_pt", "?");
  266.                 sqlQueryObject.addInsertField("filtro_duplicati", "?");
  267.                 sqlQueryObject.addInsertField("conferma_ricezione", "?");
  268.                 sqlQueryObject.addInsertField("identificativo_collaborazione", "?");
  269.                 sqlQueryObject.addInsertField("id_riferimento_richiesta", "?");
  270.                 sqlQueryObject.addInsertField("consegna_in_ordine", "?");
  271.                 sqlQueryObject.addInsertField("scadenza", "?");
  272.                 sqlQueryObject.addInsertField("profilo_collaborazione", "?");
  273.                 sqlQueryObject.addInsertField("soap_style", "?");
  274.                 updateQuery = sqlQueryObject.createSQLInsert();
  275.                 updateStmt = con.prepareStatement(updateQuery);
  276.                 int index = 1;
  277.                 updateStmt.setLong(index++, idAccordo);
  278.                 updateStmt.setString(index++, pt.getNome());
  279.                 updateStmt.setString(index++, pt.getDescrizione());
  280.                 updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getMessageType()));
  281.                 updateStmt.setString(index++, pt.getProfiloPT());

  283.                 DriverRegistroServiziDB_LIB.log.debug("Aggiungo port-type ["+pt.getNome()+"] con profilo ["+pt.getProfiloPT()+"]");

  285.                 if(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(pt.getProfiloPT())){
  286.                     DriverRegistroServiziDB_LIB.log.debug("ridefinizione...");
  287.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getFiltroDuplicati()));
  288.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getConfermaRicezione()));
  289.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getIdCollaborazione()));
  290.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getIdRiferimentoRichiesta()));
  291.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getConsegnaInOrdine()));
  292.                     updateStmt.setString(index++, pt.getScadenza());
  293.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getProfiloCollaborazione()));
  294.                 }else{
  295.                     if(pt.getFiltroDuplicati()!=null)
  296.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getFiltroDuplicati()));
  297.                     else
  298.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getFiltroDuplicati()));
  299.                     if(pt.getConfermaRicezione()!=null)
  300.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getConfermaRicezione()));
  301.                     else
  302.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConfermaRicezione()));
  303.                     if(pt.getIdCollaborazione()!=null)
  304.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getIdCollaborazione()));
  305.                     else
  306.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdCollaborazione()));
  307.                     if(pt.getIdRiferimentoRichiesta()!=null)
  308.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getIdRiferimentoRichiesta()));
  309.                     else
  310.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdRiferimentoRichiesta()));
  311.                     if(pt.getConsegnaInOrdine()!=null)
  312.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getConsegnaInOrdine()));
  313.                     else
  314.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConsegnaInOrdine()));
  315.                     if(pt.getScadenza()!=null)
  316.                         updateStmt.setString(index++, pt.getScadenza());
  317.                     else
  318.                         updateStmt.setString(index++, as.getScadenza());
  319.                     if(pt.getProfiloCollaborazione()!=null)
  320.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getProfiloCollaborazione()));
  321.                     else
  322.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getProfiloCollaborazione()));
  323.                 }
  324.                 updateStmt.setString(index++,DriverRegistroServiziDB_LIB.getValue(pt.getStyle()));
  325.                 // log.debug("CRUDAzione CREATE :
  326.                 // \n"+formatSQLString(updateQuery,idAccordo,idSoggettoFruitore,idConnettore,wsdlImplementativoErogatore,wsdlImplementativoFruitore));
  327.                 n = updateStmt.executeUpdate();

  329.                 DriverRegistroServiziDB_LIB.log.debug("CRUDPortType type = " + type + " row affected =" + n);

  331.                 break;

  333.             case UPDATE:
  334.                 // update
  335.                 //
  336.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  337.                 sqlQueryObject.addUpdateTable(CostantiDB.PORT_TYPE);
  338.                 sqlQueryObject.addUpdateField("descrizione", "?");
  339.                 sqlQueryObject.addUpdateField("message_type", "?");
  340.                 sqlQueryObject.addUpdateField("profilo_pt", "?");
  341.                 sqlQueryObject.addUpdateField("filtro_duplicati", "?");
  342.                 sqlQueryObject.addUpdateField("conferma_ricezione", "?");
  343.                 sqlQueryObject.addUpdateField("identificativo_collaborazione", "?");
  344.                 sqlQueryObject.addUpdateField("id_riferimento_richiesta", "?");
  345.                 sqlQueryObject.addUpdateField("consegna_in_ordine", "?");
  346.                 sqlQueryObject.addUpdateField("scadenza", "?");
  347.                 sqlQueryObject.addUpdateField("profilo_collaborazione", "?");
  348.                 sqlQueryObject.addUpdateField("soap_style", "?");
  349.                 sqlQueryObject.addWhereCondition("id_accordo=?");
  350.                 sqlQueryObject.addWhereCondition("nome=?");
  351.                 sqlQueryObject.setANDLogicOperator(true);
  352.                 updateQuery = sqlQueryObject.createSQLUpdate();
  353.                 updateStmt = con.prepareStatement(updateQuery);
  354.                 index = 1;
  355.                 updateStmt.setString(index++, pt.getDescrizione());
  356.                 updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getMessageType()));
  357.                 updateStmt.setString(index++, pt.getProfiloPT());


  360.                 if(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(pt.getProfiloPT())){
  361.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getFiltroDuplicati()));
  362.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getConfermaRicezione()));
  363.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getIdCollaborazione()));
  364.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getIdRiferimentoRichiesta()));
  365.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getConsegnaInOrdine()));
  366.                     updateStmt.setString(index++, pt.getScadenza());
  367.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getProfiloCollaborazione()));
  368.                 }else{
  369.                     if(pt.getFiltroDuplicati()!=null)
  370.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getFiltroDuplicati()));
  371.                     else
  372.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getFiltroDuplicati()));
  373.                     if(pt.getConfermaRicezione()!=null)
  374.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getConfermaRicezione()));
  375.                     else
  376.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConfermaRicezione()));
  377.                     if(pt.getIdCollaborazione()!=null)
  378.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getIdCollaborazione()));
  379.                     else
  380.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdCollaborazione()));
  381.                     if(pt.getIdRiferimentoRichiesta()!=null)
  382.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getIdRiferimentoRichiesta()));
  383.                     else
  384.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdRiferimentoRichiesta()));
  385.                     if(pt.getConsegnaInOrdine()!=null)
  386.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getConsegnaInOrdine()));
  387.                     else
  388.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConsegnaInOrdine()));
  389.                     if(pt.getScadenza()!=null)
  390.                         updateStmt.setString(index++, pt.getScadenza());
  391.                     else
  392.                         updateStmt.setString(index++, as.getScadenza());
  393.                     if(pt.getProfiloCollaborazione()!=null)
  394.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getProfiloCollaborazione()));
  395.                     else
  396.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getProfiloCollaborazione()));
  397.                 }
  398.                 updateStmt.setString(index++,DriverRegistroServiziDB_LIB.getValue(pt.getStyle()));
  399.                 updateStmt.setLong(index++, idAccordo);
  400.                 updateStmt.setString(index++, pt.getNome());
  401.                 n = updateStmt.executeUpdate();

  403.                 DriverRegistroServiziDB_LIB.log.debug("CRUDPortType type = " + type + " row affected =" + n);
  404.                 // log.debug("CRUDAzione UPDATE :
  405.                 // \n"+formatSQLString(updateQuery,wsdlImplementativoErogatore,wsdlImplementativoFruitore,
  406.                 // idServizio,idSoggettoFruitore,idConnettore));

  408.                 break;

  410.             case DELETE:
  411.                 // delete

  413.                 Long idPT = 0l;
  414.                 if(pt.getId()==null || pt.getId()<=0){
  415.                     idPT = DBUtils.getIdPortType(idAccordo, pt.getNome(), con);
  416.                     if(idPT==null || idPT<=0)
  417.                         throw new Exception("ID del porttype["+pt.getNome()+"] idAccordo["+idAccordo+"] non trovato");
  418.                 }
  419.                 else {
  420.                     idPT = pt.getId();
  421.                 }

  423.                 // Operations
  424.                 for(int i=0;i<pt.sizeAzioneList();i++){
  425.                     DriverRegistroServiziDB_accordiSoapLIB.CRUDAzionePortType(CostantiDB.DELETE, as, pt, pt.getAzione(i), con, idPT, driverBYOK);
  426.                 }

  428.                 // ProtocolProperties
  429.                 DriverRegistroServiziDB_LIB.CRUDProtocolProperty(CostantiDB.DELETE, null, 
  430.                         idPT, ProprietariProtocolProperty.PORT_TYPE, con, DriverRegistroServiziDB_LIB.tipoDB, driverBYOK);
  431.                 
  432.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  433.                 sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE);
  434.                 sqlQueryObject.addWhereCondition("id_accordo=?");
  435.                 sqlQueryObject.addWhereCondition("nome=?");
  436.                 sqlQueryObject.setANDLogicOperator(true);
  437.                 updateQuery = sqlQueryObject.createSQLDelete();
  438.                 updateStmt = con.prepareStatement(updateQuery);

  440.                 updateStmt.setLong(1, idAccordo);
  441.                 updateStmt.setString(2, pt.getNome());
  442.                 n = updateStmt.executeUpdate();

  444.                 DriverRegistroServiziDB_LIB.log.debug("CRUDPortType type = " + type + " row affected =" + n);
  445.                 // log.debug("CRUDAzione DELETE :
  446.                 // \n"+formatSQLString(updateQuery,idServizio,idSoggettoFruitore,idConnettore));

  448.                 break;
  449.             }



  453.             if ( (CostantiDB.CREATE == type) || (CostantiDB.UPDATE == type)) {
  454.                 Long idPT = DBUtils.getIdPortType(idAccordo, pt.getNome(), con);
  455.                 if(idPT==null || idPT<=0)
  456.                     throw new Exception("ID del porttype["+pt.getNome()+"] idAccordo["+idAccordo+"] non trovato");

  458.                 DriverRegistroServiziDB_LIB.log.debug("ID port type: "+idPT);

  460.                 if ( CostantiDB.UPDATE == type ){
  461.                     n = 0;
  462.                     for(int i=0;i<pt.sizeAzioneList();i++){
  463.                         n += DriverRegistroServiziDB_accordiSoapLIB.CRUDAzionePortType(CostantiDB.DELETE, as, pt, pt.getAzione(i), con, idPT, driverBYOK);
  464.                     }
  465.                     
  466. //                  ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  467. //                  sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE_AZIONI);
  468. //                  sqlQueryObject.addWhereCondition("id_port_type=?");
  469. //                  sqlQueryObject.setANDLogicOperator(true);
  470. //                  String sqlQuery = sqlQueryObject.createSQLDelete();
  471. //                  updateStmt=con.prepareStatement(sqlQuery);
  472. //                  updateStmt.setLong(1, idPT);
  473. //                  n=updateStmt.executeUpdate();
  474. //                  updateStmt.close();
  475.                     DriverRegistroServiziDB_LIB.log.info("Cancellate "+n+" azioni del port type ["+idPT+"] associate all'accordo "+idAccordo);
  476.                 }

  478.                 // Azioni PortType
  479.                 Operation azione = null;
  480.                 for (int i = 0; i < pt.sizeAzioneList(); i++) {
  481.                     azione = pt.getAzione(i);
  482.                     DriverRegistroServiziDB_accordiSoapLIB.CRUDAzionePortType(CostantiDB.CREATE,as,pt, azione, con, idPT, driverBYOK);
  483.                 }
  484.                 DriverRegistroServiziDB_LIB.log.debug("inserite " + pt.sizeAzioneList() + " azioni relative al port type["+pt.getNome()+"] id-porttype["+pt.getId()+"] dell'accordo :" + IDAccordoFactory.getInstance().getUriFromAccordo(as) + " id-accordo :" + idAccordo);
  485.                 
  486.                 
  487.                 // ProtocolProperties
  488.                 DriverRegistroServiziDB_LIB.CRUDProtocolProperty(type, pt.getProtocolPropertyList(), 
  489.                         idPT, ProprietariProtocolProperty.PORT_TYPE, con, DriverRegistroServiziDB_LIB.tipoDB, driverBYOK);
  490.             }


  493.             return n;

  495.         } catch (SQLException se) {
  496.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDPortType] SQLException : " + se.getMessage(),se);
  497.         } catch (Exception se) {
  498.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDPortType] Exception : " + se.getMessage(),se);
  499.         } finally {
  500.             JDBCUtilities.closeResources(selectRS, selectStmt);
  501.             JDBCUtilities.closeResources(updateStmt);
  502.         }
  503.     }

  505.     public static long CRUDAzionePortType(int type, AccordoServizioParteComune as,PortType pt,Operation azione, Connection con, long idPortType, IDriverBYOK driverBYOK) throws DriverRegistroServiziException {
  506.         PreparedStatement updateStmt = null;
  507.         String updateQuery;
  508.         PreparedStatement selectStmt = null;
  509.         String selectQuery = "";
  510.         ResultSet selectRS = null;
  511.         long n = 0;
  512.         if (idPortType <= 0)
  513.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDAzionePortType] ID Port Type non valido.");

  515.         try {
  516.             switch (type) {
  517.             case CREATE:
  518.                 // create
  519.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  520.                 sqlQueryObject.addInsertTable(CostantiDB.PORT_TYPE_AZIONI);
  521.                 sqlQueryObject.addInsertField("id_port_type", "?");
  522.                 sqlQueryObject.addInsertField("nome", "?");
  523.                 sqlQueryObject.addInsertField("profilo_pt_azione", "?");
  524.                 sqlQueryObject.addInsertField("filtro_duplicati", "?");
  525.                 sqlQueryObject.addInsertField("conferma_ricezione", "?");
  526.                 sqlQueryObject.addInsertField("identificativo_collaborazione", "?");
  527.                 sqlQueryObject.addInsertField("id_riferimento_richiesta", "?");
  528.                 sqlQueryObject.addInsertField("consegna_in_ordine", "?");
  529.                 sqlQueryObject.addInsertField("scadenza", "?");
  530.                 sqlQueryObject.addInsertField("profilo_collaborazione", "?");
  531.                 sqlQueryObject.addInsertField("soap_style", "?");
  532.                 sqlQueryObject.addInsertField("soap_action", "?");
  533.                 sqlQueryObject.addInsertField("soap_use_msg_input", "?");
  534.                 sqlQueryObject.addInsertField("soap_namespace_msg_input", "?");
  535.                 sqlQueryObject.addInsertField("soap_use_msg_output", "?");
  536.                 sqlQueryObject.addInsertField("soap_namespace_msg_output", "?");
  537.                 sqlQueryObject.addInsertField("correlata_servizio", "?");
  538.                 sqlQueryObject.addInsertField("correlata", "?");
  539.                 updateQuery = sqlQueryObject.createSQLInsert();
  540.                 updateStmt = con.prepareStatement(updateQuery);
  541.                 int index = 1;
  542.                 updateStmt.setLong(index++, idPortType);
  543.                 updateStmt.setString(index++, azione.getNome());
  544.                 updateStmt.setString(index++, azione.getProfAzione());

  546.                 DriverRegistroServiziDB_LIB.log.debug("Aggiungo azione ["+azione.getNome()+"] pt ["+pt.getNome()+"] con profilo ["+azione.getProfAzione()+"]");

  548.                 if(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(azione.getProfAzione())){
  549.                     DriverRegistroServiziDB_LIB.log.debug("ridefinizione...");
  550.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getFiltroDuplicati()));
  551.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getConfermaRicezione()));
  552.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getIdCollaborazione()));
  553.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getIdRiferimentoRichiesta()));
  554.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getConsegnaInOrdine()));
  555.                     updateStmt.setString(index++, azione.getScadenza());
  556.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getProfiloCollaborazione()));
  557.                 }else{
  558.                     if(azione.getFiltroDuplicati()!=null)
  559.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getFiltroDuplicati()));
  560.                     else if(pt.getFiltroDuplicati()!=null)
  561.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getFiltroDuplicati()));
  562.                     else
  563.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getFiltroDuplicati()));

  565.                     if(azione.getConfermaRicezione()!=null)
  566.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getConfermaRicezione()));
  567.                     else if(pt.getConfermaRicezione()!=null)
  568.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getConfermaRicezione()));
  569.                     else
  570.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConfermaRicezione()));

  572.                     if(azione.getIdCollaborazione()!=null)
  573.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getIdCollaborazione()));
  574.                     else if(pt.getIdCollaborazione()!=null)
  575.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getIdCollaborazione()));
  576.                     else
  577.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdCollaborazione()));
  578.                     
  579.                     if(azione.getIdRiferimentoRichiesta()!=null)
  580.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getIdRiferimentoRichiesta()));
  581.                     else if(pt.getIdRiferimentoRichiesta()!=null)
  582.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getIdRiferimentoRichiesta()));
  583.                     else
  584.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdRiferimentoRichiesta()));

  586.                     if(azione.getConsegnaInOrdine()!=null)
  587.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getConsegnaInOrdine()));
  588.                     else if(pt.getConsegnaInOrdine()!=null)
  589.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getConsegnaInOrdine()));
  590.                     else
  591.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConsegnaInOrdine()));

  593.                     if(azione.getScadenza()!=null)
  594.                         updateStmt.setString(index++, azione.getScadenza());
  595.                     else if(pt.getScadenza()!=null)
  596.                         updateStmt.setString(index++, pt.getScadenza());
  597.                     else
  598.                         updateStmt.setString(index++, as.getScadenza());

  600.                     if(azione.getProfiloCollaborazione()!=null)
  601.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getProfiloCollaborazione()));
  602.                     else if(pt.getProfiloCollaborazione()!=null)
  603.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getProfiloCollaborazione()));
  604.                     else
  605.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getProfiloCollaborazione()));
  606.                 }
  607.                 updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getStyle()));
  608.                 updateStmt.setString(index++, azione.getSoapAction());
  609.                 if(azione.getMessageInput()!=null){
  610.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getMessageInput().getUse()));
  611.                     updateStmt.setString(index++, azione.getMessageInput().getSoapNamespace());
  612.                 }else{
  613.                     updateStmt.setString(index++, null);
  614.                     updateStmt.setString(index++, null);
  615.                 }
  616.                 if(azione.getMessageOutput()!=null){
  617.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getMessageOutput().getUse()));
  618.                     updateStmt.setString(index++, azione.getMessageOutput().getSoapNamespace());
  619.                 }else{
  620.                     updateStmt.setString(index++, null);
  621.                     updateStmt.setString(index++, null);
  622.                 }

  624.                 updateStmt.setString(index++, azione.getCorrelataServizio());
  625.                 updateStmt.setString(index++, azione.getCorrelata());

  627.                 DriverRegistroServiziDB_LIB.log.debug("CRUDPortTypeAzione CREATE :\n"+updateQuery);
  628.                 n = updateStmt.executeUpdate();

  630.                 DriverRegistroServiziDB_LIB.log.debug("CRUDAzionePortType type = " + type + " row affected =" + n);
  631.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  632.                 sqlQueryObject.addFromTable(CostantiDB.PORT_TYPE_AZIONI);
  633.                 sqlQueryObject.addSelectField("id");
  634.                 sqlQueryObject.addWhereCondition("id_port_type = ?");
  635.                 sqlQueryObject.addWhereCondition("nome = ?");
  636.                 sqlQueryObject.setANDLogicOperator(true);
  637.                 selectQuery = sqlQueryObject.createSQLQuery();
  638.                 selectStmt = con.prepareStatement(selectQuery);
  639.                 selectStmt.setLong(1, idPortType);
  640.                 selectStmt.setString(2, azione.getNome());

  642.                 break;

  644.             case UPDATE:
  645.                 // update
  646.                 //
  647.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  648.                 sqlQueryObject.addUpdateTable(CostantiDB.PORT_TYPE_AZIONI);
  649.                 sqlQueryObject.addUpdateField("profilo_azione", "?");
  650.                 sqlQueryObject.addUpdateField("filtro_duplicati", "?");
  651.                 sqlQueryObject.addUpdateField("conferma_ricezione", "?");
  652.                 sqlQueryObject.addUpdateField("identificativo_collaborazione", "?");
  653.                 sqlQueryObject.addUpdateField("id_riferimento_richiesta", "?");
  654.                 sqlQueryObject.addUpdateField("consegna_in_ordine", "?");
  655.                 sqlQueryObject.addUpdateField("scadenza", "?");
  656.                 sqlQueryObject.addUpdateField("profilo_collaborazione", "?");
  657.                 sqlQueryObject.addUpdateField("soap_style", "?");
  658.                 sqlQueryObject.addUpdateField("soap_action", "?");
  659.                 sqlQueryObject.addUpdateField("soap_use_msg_input", "?");
  660.                 sqlQueryObject.addUpdateField("soap_namespace_msg_input", "?");
  661.                 sqlQueryObject.addUpdateField("soap_use_msg_output", "?");
  662.                 sqlQueryObject.addUpdateField("soap_namespace_msg_output", "?");
  663.                 sqlQueryObject.addUpdateField("correlata_servizio", "?");
  664.                 sqlQueryObject.addUpdateField("correlata", "?");
  665.                 sqlQueryObject.addWhereCondition("id_port_type=?");
  666.                 sqlQueryObject.addWhereCondition("nome=?");
  667.                 sqlQueryObject.setANDLogicOperator(true);
  668.                 updateQuery = sqlQueryObject.createSQLUpdate();
  669.                 updateStmt = con.prepareStatement(updateQuery);
  670.                 index = 1;
  671.                 updateStmt.setString(1, azione.getProfAzione());

  673.                 if(CostantiRegistroServizi.PROFILO_AZIONE_RIDEFINITO.equals(azione.getProfAzione())){
  674.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getFiltroDuplicati()));
  675.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getConfermaRicezione()));
  676.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getIdCollaborazione()));
  677.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getIdRiferimentoRichiesta()));
  678.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getConsegnaInOrdine()));
  679.                     updateStmt.setString(index++, azione.getScadenza());
  680.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getProfiloCollaborazione()));
  681.                 }else{
  682.                     if(azione.getFiltroDuplicati()!=null)
  683.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getFiltroDuplicati()));
  684.                     else if(pt.getFiltroDuplicati()!=null)
  685.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getFiltroDuplicati()));
  686.                     else
  687.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getFiltroDuplicati()));

  689.                     if(azione.getConfermaRicezione()!=null)
  690.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getConfermaRicezione()));
  691.                     else if(pt.getConfermaRicezione()!=null)
  692.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getConfermaRicezione()));
  693.                     else
  694.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConfermaRicezione()));

  696.                     if(azione.getIdCollaborazione()!=null)
  697.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getIdCollaborazione()));
  698.                     else if(pt.getIdCollaborazione()!=null)
  699.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getIdCollaborazione()));
  700.                     else
  701.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdCollaborazione()));
  702.                     
  703.                     if(azione.getIdRiferimentoRichiesta()!=null)
  704.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getIdRiferimentoRichiesta()));
  705.                     else if(pt.getIdRiferimentoRichiesta()!=null)
  706.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getIdRiferimentoRichiesta()));
  707.                     else
  708.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getIdRiferimentoRichiesta()));

  710.                     if(azione.getConsegnaInOrdine()!=null)
  711.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getConsegnaInOrdine()));
  712.                     else if(pt.getConsegnaInOrdine()!=null)
  713.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getConsegnaInOrdine()));
  714.                     else
  715.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getConsegnaInOrdine()));

  717.                     if(azione.getScadenza()!=null)
  718.                         updateStmt.setString(index++, azione.getScadenza());
  719.                     else if(pt.getScadenza()!=null)
  720.                         updateStmt.setString(index++, pt.getScadenza());
  721.                     else
  722.                         updateStmt.setString(index++, as.getScadenza());

  724.                     if(azione.getProfiloCollaborazione()!=null)
  725.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getProfiloCollaborazione()));
  726.                     else if(pt.getProfiloCollaborazione()!=null)
  727.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(pt.getProfiloCollaborazione()));
  728.                     else
  729.                         updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(as.getProfiloCollaborazione()));
  730.                 }
  731.                 updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getStyle()));
  732.                 updateStmt.setString(index++, azione.getSoapAction());
  733.                 if(azione.getMessageInput()!=null){
  734.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getMessageInput().getUse()));
  735.                     updateStmt.setString(index++, azione.getMessageInput().getSoapNamespace());
  736.                 }else{
  737.                     updateStmt.setString(index++, null);
  738.                     updateStmt.setString(index++, null);
  739.                 }
  740.                 if(azione.getMessageOutput()!=null){
  741.                     updateStmt.setString(index++, DriverRegistroServiziDB_LIB.getValue(azione.getMessageOutput().getUse()));
  742.                     updateStmt.setString(index++, azione.getMessageOutput().getSoapNamespace());
  743.                 }else{
  744.                     updateStmt.setString(index++, null);
  745.                     updateStmt.setString(index++, null);
  746.                 }

  748.                 updateStmt.setString(index++, azione.getCorrelataServizio());
  749.                 updateStmt.setString(index++, azione.getCorrelata());

  751.                 updateStmt.setLong(index++, idPortType);
  752.                 updateStmt.setString(index++, azione.getNome());
  753.                 n = updateStmt.executeUpdate();

  755.                 DriverRegistroServiziDB_LIB.log.debug("CRUDAzionePortType type = " + type + " row affected =" + n);
  756.                 // log.debug("CRUDAzione UPDATE :
  757.                 // \n"+formatSQLString(updateQuery,wsdlImplementativoErogatore,wsdlImplementativoFruitore,
  758.                 // idServizio,idSoggettoFruitore,idConnettore));

  760.                 break;

  762.             case DELETE:
  763.                 // delete

  765.                 // message-part
  766.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  767.                 sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE_AZIONI_OPERATION_MESSAGES);
  768.                 sqlQueryObject.addWhereCondition("id_port_type_azione=?");
  769.                 sqlQueryObject.setANDLogicOperator(true);
  770.                 updateQuery = sqlQueryObject.createSQLDelete();
  771.                 DriverRegistroServiziDB_LIB.log.debug("CRUDAzione DELETE MESSAGES:\n"+DriverRegistroServiziDB_LIB.formatSQLString(updateQuery,azione.getId()));
  772.                 updateStmt = con.prepareStatement(updateQuery);
  773.                 updateStmt.setLong(1, azione.getId());
  774.                 n = updateStmt.executeUpdate();
  775.                 updateStmt.close();

  777.                 // ProtocolProperties
  778.                 DriverRegistroServiziDB_LIB.CRUDProtocolProperty(CostantiDB.DELETE, null, 
  779.                         azione.getId(), ProprietariProtocolProperty.OPERATION, con, DriverRegistroServiziDB_LIB.tipoDB, driverBYOK);
  780.                 
  781.                 // azioni
  782.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  783.                 sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE_AZIONI);
  784.                 sqlQueryObject.addWhereCondition("id_port_type=?");
  785.                 sqlQueryObject.addWhereCondition("nome=?");
  786.                 sqlQueryObject.setANDLogicOperator(true);
  787.                 updateQuery = sqlQueryObject.createSQLDelete();
  788.                 DriverRegistroServiziDB_LIB.log.debug("CRUDAzione DELETE AZIONI:\n"+DriverRegistroServiziDB_LIB.formatSQLString(updateQuery,idPortType,azione.getNome()));
  789.                 updateStmt = con.prepareStatement(updateQuery);
  790.                 updateStmt.setLong(1, idPortType);
  791.                 updateStmt.setString(2, azione.getNome());
  792.                 n = updateStmt.executeUpdate();

  794.                 DriverRegistroServiziDB_LIB.log.debug("CRUDAzionePortType type = " + type + " row affected =" + n);

  796.                 break;
  797.             }



  801.             if (CostantiDB.CREATE == type) {
  802.                 selectRS = selectStmt.executeQuery();
  803.                 if (selectRS.next()) {

  805.                     azione.setId(selectRS.getLong("id"));
  806.                     azione.setIdPortType(idPortType);

  808.                     // creo message-part
  809.                     DriverRegistroServiziDB_accordiSoapLIB.CRUDMessageAzionePortType(CostantiDB.CREATE, azione, con);

  811.                     // ProtocolProperties
  812.                     DriverRegistroServiziDB_LIB.CRUDProtocolProperty(type, azione.getProtocolPropertyList(), 
  813.                             azione.getId(), ProprietariProtocolProperty.OPERATION, con, DriverRegistroServiziDB_LIB.tipoDB, driverBYOK);
  814.                     
  815.                     return azione.getId();

  817.                 }
  818.             }

  820.             return n;

  822.         } catch (SQLException se) {
  823.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDAzionePortType] SQLException : " + se.getMessage(),se);
  824.         } catch (Exception se) {
  825.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDAzionePortType] Exception : " + se.getMessage(),se);
  826.         } finally {
  827.             JDBCUtilities.closeResources(selectRS, selectStmt);
  828.             JDBCUtilities.closeResources(updateStmt);
  829.         }
  830.     }


  833.     public static void CRUDMessageAzionePortType(int type, Operation azione, Connection con) throws DriverRegistroServiziException {
  834.         PreparedStatement updateStmt = null;
  835.         String updateQuery;
  836.         PreparedStatement selectStmt = null;
  837.         ResultSet selectRS = null;
  838.         if (azione.getId() <= 0)
  839.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDMessageAzionePortType] ID Operation Port Type non valida.");

  841.         try {
  842.             switch (type) {
  843.             case CREATE:
  844.                 // create
  845.                 ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  846.                 sqlQueryObject.addInsertTable(CostantiDB.PORT_TYPE_AZIONI_OPERATION_MESSAGES);
  847.                 sqlQueryObject.addInsertField("id_port_type_azione", "?");
  848.                 sqlQueryObject.addInsertField("input_message", "?");
  849.                 sqlQueryObject.addInsertField("name", "?");
  850.                 sqlQueryObject.addInsertField("element_name", "?");
  851.                 sqlQueryObject.addInsertField("element_namespace", "?");
  852.                 sqlQueryObject.addInsertField("type_name", "?");
  853.                 sqlQueryObject.addInsertField("type_namespace", "?");
  854.                 updateQuery = sqlQueryObject.createSQLInsert();


  857.                 // message input
  858.                 if(azione.getMessageInput()!=null){
  859.                     for(int i=0; i<azione.getMessageInput().sizePartList(); i++){
  860.                         updateStmt = con.prepareStatement(updateQuery);
  861.                         MessagePart part = azione.getMessageInput().getPart(i);

  863.                         updateStmt.setLong(1, azione.getId());
  864.                         updateStmt.setInt(2, 1);
  865.                         updateStmt.setString(3, part.getName());
  866.                         updateStmt.setString(4, part.getElementName());
  867.                         updateStmt.setString(5, part.getElementNamespace());
  868.                         updateStmt.setString(6, part.getTypeName());
  869.                         updateStmt.setString(7, part.getTypeNamespace());

  871.                         DriverRegistroServiziDB_LIB.log.debug("Aggiungo part element input  ["+part.getName()+"] per azione ["+azione.getNome()+"]");

  873.                         DriverRegistroServiziDB_LIB.log.debug("CRUDMessageAzionePortType CREATE :\n"+updateQuery);
  874.                         updateStmt.executeUpdate();
  875.                         updateStmt.close();
  876.                     }
  877.                 }

  879.                 // message output
  880.                 if(azione.getMessageOutput()!=null){
  881.                     for(int i=0; i<azione.getMessageOutput().sizePartList(); i++){
  882.                         updateStmt = con.prepareStatement(updateQuery);
  883.                         MessagePart part = azione.getMessageOutput().getPart(i);

  885.                         updateStmt.setLong(1, azione.getId());
  886.                         updateStmt.setInt(2, 0);
  887.                         updateStmt.setString(3, part.getName());
  888.                         updateStmt.setString(4, part.getElementName());
  889.                         updateStmt.setString(5, part.getElementNamespace());
  890.                         updateStmt.setString(6, part.getTypeName());
  891.                         updateStmt.setString(7, part.getTypeNamespace());

  893.                         DriverRegistroServiziDB_LIB.log.debug("Aggiungo part element output ["+part.getName()+"] per azione ["+azione.getNome()+"]");

  895.                         DriverRegistroServiziDB_LIB.log.debug("CRUDMessageAzionePortType CREATE :\n"+updateQuery);
  896.                         updateStmt.executeUpdate();
  897.                         updateStmt.close();
  898.                     }
  899.                 }

  901.                 break;

  903.             case UPDATE:
  904.                 // update
  905.                 //
  906.                 throw new Exception("Non implementato");

  908.             case DELETE:
  909.                 // delete

  911.                 sqlQueryObject = SQLObjectFactory.createSQLQueryObject(DriverRegistroServiziDB_LIB.tipoDB);
  912.                 sqlQueryObject.addDeleteTable(CostantiDB.PORT_TYPE_AZIONI_OPERATION_MESSAGES);
  913.                 sqlQueryObject.addWhereCondition("id_port_type_azione=?");
  914.                 sqlQueryObject.setANDLogicOperator(true);
  915.                 updateQuery = sqlQueryObject.createSQLDelete();
  916.                 updateStmt = con.prepareStatement(updateQuery);

  918.                 updateStmt.setLong(1, azione.getId());
  919.                 long n = updateStmt.executeUpdate();
  920.                 updateStmt.close();

  922.                 DriverRegistroServiziDB_LIB.log.debug("CRUDMessageAzionePortType type = " + type + " row affected =" + n);
  923.                 // log.debug("CRUDAzione DELETE :
  924.                 // \n"+formatSQLString(updateQuery,idServizio,idSoggettoFruitore,idConnettore));

  926.                 break;
  927.             }


  930.         } catch (SQLException se) {
  931.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDMessageAzionePortType] SQLException : " + se.getMessage(),se);
  932.         } catch (Exception se) {
  933.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB_LIB::CRUDMessageAzionePortType] Exception : " + se.getMessage(),se);
  934.         } finally {
  935.             JDBCUtilities.closeResources(selectRS, selectStmt);
  936.             JDBCUtilities.closeResources(updateStmt);
  937.         }
  938.     }

  940.     
  941. }
Created with JaCoCo 0.8.8.202204050719