DriverRegistroServiziDB_connettoriDriver.java

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



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

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

  31. import org.apache.commons.lang.StringUtils;
  32. import org.openspcoop2.core.byok.IDriverBYOK;
  33. import org.openspcoop2.core.commons.CoreException;
  34. import org.openspcoop2.core.commons.DBUtils;
  35. import org.openspcoop2.core.constants.CostantiConnettori;
  36. import org.openspcoop2.core.constants.CostantiDB;
  37. import org.openspcoop2.core.constants.TipiConnettore;
  38. import org.openspcoop2.core.registry.Connettore;
  39. import org.openspcoop2.core.registry.Property;
  40. import org.openspcoop2.core.registry.driver.ConnettorePropertiesUtilities;
  41. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  42. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  43. import org.openspcoop2.utils.UtilsException;
  44. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  45. import org.openspcoop2.utils.sql.ISQLQueryObject;
  46. import org.openspcoop2.utils.sql.SQLObjectFactory;

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

  59.     private DriverRegistroServiziDB driver = null;
  60.     
  61.     protected DriverRegistroServiziDB_connettoriDriver(DriverRegistroServiziDB driver) {
  62.         this.driver = driver;
  63.     }
  64.     
  65.     protected Connettore getConnettore(long idConnettore) throws DriverRegistroServiziException, DriverRegistroServiziNotFound {
  66.         String nomeMetodo = "getConnettore(id)";
  67.         
  68.         Connection con = null;
  69.         if (this.driver.atomica) {
  70.             try {
  71.                 con = this.driver.getConnectionFromDatasource(nomeMetodo);
  72.             } catch (Exception e) {
  73.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  75.             }

  77.         } else
  78.             con = this.driver.globalConnection;

  80.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  82.         try {

  84.             Connettore connettore = getConnettore(idConnettore, con);
  85.             if(connettore==null) {
  86.                 throw new DriverRegistroServiziNotFound("Connettore con id '"+idConnettore+"' non esistente");
  87.             }
  88.             return connettore;
  89.             
  90.         } catch (Exception qe) {
  91.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  92.         } finally {

  94.             this.driver.closeConnection(con);
  95.         }
  96.     }
  97.     protected Connettore getConnettore(String nomeConnettore) throws DriverRegistroServiziException {
  98.         String nomeMetodo = "getConnettore(nome)";
  99.         
  100.         Connection con = null;
  101.         PreparedStatement stmt=null;
  102.         ResultSet risultato=null;
  103.         
  104.         if (this.driver.atomica) {
  105.             try {
  106.                 con = this.driver.getConnectionFromDatasource(nomeMetodo);
  107.             } catch (Exception e) {
  108.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Exception accedendo al datasource :" + e.getMessage(),e);

  110.             }

  112.         } else
  113.             con = this.driver.globalConnection;

  115.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  117.         try {

  119.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  120.             sqlQueryObject.addFromTable(CostantiDB.CONNETTORI);
  121.             sqlQueryObject.addSelectField("id");
  122.             sqlQueryObject.addWhereCondition("nome_connettore=?");
  123.             String queryString = sqlQueryObject.createSQLQuery();
  124.             stmt = con.prepareStatement(queryString);
  125.             stmt.setString(1, nomeConnettore);
  126.             risultato = stmt.executeQuery();

  128.             Long idConnettore = null;
  129.             if (risultato.next()) {
  130.                 idConnettore = risultato.getLong("id");
  131.             }
  132.             else {
  133.                 throw new DriverRegistroServiziNotFound("Connettore con nome '"+nomeConnettore+"' non esistente");
  134.             }
  135.                     
  136.             Connettore connettore = getConnettore(idConnettore, con);
  137.             if(connettore==null) {
  138.                 throw new DriverRegistroServiziNotFound("Connettore con id '"+idConnettore+"' non esistente");
  139.             }
  140.             return connettore;
  141.             
  142.         } catch (Exception qe) {
  143.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::" + nomeMetodo + "] Errore : " + qe.getMessage(),qe);
  144.         } finally {

  146.             //Chiudo statement and resultset
  147.             JDBCUtilities.closeResources(risultato, stmt);

  149.             this.driver.closeConnection(con);
  150.         }
  151.     }
  152.     
  153.     protected Connettore getConnettore(long idConnettore, Connection connection) throws DriverRegistroServiziException {

  155.         Connettore connettore = null;

  157.         // accedo alla tab regserv_connettori

  159.         PreparedStatement stm = null;
  160.         ResultSet rs = null;

  162.         try {
  163.             IDriverBYOK driverBYOK = this.driver.getDriverUnwrapBYOK();
  164.             
  165.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  166.             sqlQueryObject.addFromTable(CostantiDB.CONNETTORI);
  167.             sqlQueryObject.addSelectField("*");
  168.             sqlQueryObject.addWhereCondition("id = ?");
  169.             String sqlQuery = sqlQueryObject.createSQLQuery();

  171.             stm = connection.prepareStatement(sqlQuery);
  172.             stm.setLong(1, idConnettore);

  174.             this.driver.logDebug("eseguo query : " + DriverRegistroServiziDB_LIB.formatSQLString(sqlQuery, idConnettore));

  176.             rs = stm.executeQuery();

  178.             if (rs.next()) {
  179.                 String endpoint = rs.getString(CostantiDB.CONNETTORI_COLUMN_ENDPOINT_TYPE);
  180.                 if (endpoint == null || endpoint.equals("") || endpoint.equals(TipiConnettore.DISABILITATO.getNome())) {
  181.                     connettore = new Connettore();
  182.                     connettore.setNome(rs.getString(CostantiDB.CONNETTORI_COLUMN_NOME));
  183.                     connettore.setTipo(TipiConnettore.DISABILITATO.getNome());
  184.                     connettore.setId(idConnettore);

  186.                 } else {
  187.                     Property prop = null;
  188.                     connettore = new Connettore();
  189.                     connettore.setNome(rs.getString(CostantiDB.CONNETTORI_COLUMN_NOME));
  190.                     connettore.setTipo(endpoint);
  191.                     //l'id del connettore e' quello passato come parametro
  192.                     connettore.setId(idConnettore);

  194.                     // Debug
  195.                     if(rs.getInt("debug")==1){
  196.                         prop = new Property();
  197.                         prop.setNome(CostantiDB.CONNETTORE_DEBUG);
  198.                         prop.setValore("true");
  199.                         connettore.addProperty(prop);
  200.                     }

  202.                     // Proxy
  203.                     readConnettoreProxy(rs, connettore, driverBYOK);
  204.                     
  205.                     // Tempi Risposta
  206.                     readConnettoreTempiRisposta(rs, connettore);
  207.                     
  208.                     // transfer_mode
  209.                     readConnettoreTransferMode(rs, connettore);
  210.                     
  211.                     // redirect_mode
  212.                     readConnettoreRedirectMode(rs, connettore); 
  213.                                 
  214.                     // token policy
  215.                     String tokenPolicy = rs.getString("token_policy");
  216.                     if(tokenPolicy!=null && !"".equals(tokenPolicy)){
  217.                         
  218.                         prop = new Property();
  219.                         prop.setNome(CostantiDB.CONNETTORE_TOKEN_POLICY);
  220.                         prop.setValore(tokenPolicy.trim());
  221.                         connettore.addProperty(prop);
  222.                         
  223.                     }
  224.                     
  225.                     // api key
  226.                     readAutenticazioneApiKey(rs, connettore, driverBYOK);
  227.                     
  228.                     if (endpoint.equals(CostantiDB.CONNETTORE_TIPO_HTTP)) {
  229.                         readConnettoreHttp(rs, connettore, driverBYOK);
  230.                     } else if (endpoint.equals(TipiConnettore.JMS.getNome())){
  231.                         readConnettoreJms(rs, connettore, driverBYOK);
  232.                     }else if(endpoint.equals(TipiConnettore.NULL.getNome())){
  233.                         //nessuna proprieta per connettore null
  234.                     }else if(endpoint.equals(TipiConnettore.NULLECHO.getNome())){
  235.                         //nessuna proprieta per connettore nullEcho
  236.                     }else if (!endpoint.equals(TipiConnettore.DISABILITATO.getNome())) {
  237.                         if(rs.getLong("custom")==1){
  238.                             // connettore custom
  239.                             readPropertiesConnettoreCustom(idConnettore,connettore,connection,driverBYOK);
  240.                             connettore.setCustom(true);
  241.                         }
  242.                         else{
  243.                             // legge da file properties
  244.                             connettore.setPropertyList(ConnettorePropertiesUtilities.getPropertiesConnettore(endpoint,connection,this.driver.tipoDB));
  245.                         }
  246.                     }

  248.                 }
  249.             }
  250.             
  251.             // Extended Info
  252.             this.readPropertiesConnettoreExtendedInfo(idConnettore,connettore,connection,driverBYOK);
  253.             
  254.             return connettore;
  255.         } catch (SQLException sqle) {
  256.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getConnettore] SQLException : " + sqle.getMessage(),sqle);
  257.         } catch (CoreException e) {
  258.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getConnettore] CoreException : " + e.getMessage(),e);
  259.         }catch (Exception sqle) {
  260.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getConnettore] Exception : " + sqle.getMessage(),sqle);
  261.         }finally {
  262.             // chiudo lo statement e resultset
  263.             JDBCUtilities.closeResources(rs, stm);
  264.         }
  265.     }
  266.     
  267.     private static void readConnettoreProxy(ResultSet rs, Connettore connettore, IDriverBYOK driverBYOK) throws SQLException, UtilsException {
  268.         if(rs.getInt("proxy")==1){
  269.             
  270.             String tmp = rs.getString("proxy_type");
  271.             if(tmp!=null && !"".equals(tmp)){
  272.                 Property prop = new Property();
  273.                 prop.setNome(CostantiDB.CONNETTORE_PROXY_TYPE);
  274.                 prop.setValore(tmp.trim());
  275.                 connettore.addProperty(prop);
  276.             }
  277.             
  278.             tmp = rs.getString("proxy_hostname");
  279.             if(tmp!=null && !"".equals(tmp)){
  280.                 Property prop = new Property();
  281.                 prop.setNome(CostantiDB.CONNETTORE_PROXY_HOSTNAME);
  282.                 prop.setValore(tmp.trim());
  283.                 connettore.addProperty(prop);
  284.             }
  285.             
  286.             tmp = rs.getString("proxy_port");
  287.             if(tmp!=null && !"".equals(tmp)){
  288.                 Property prop = new Property();
  289.                 prop.setNome(CostantiDB.CONNETTORE_PROXY_PORT);
  290.                 prop.setValore(tmp.trim());
  291.                 connettore.addProperty(prop);
  292.             }
  293.             
  294.             readConnettoreProxyCredentials(rs, connettore, driverBYOK);
  295.         }
  296.     }
  297.     private static void readConnettoreProxyCredentials(ResultSet rs, Connettore connettore, IDriverBYOK driverBYOK) throws SQLException, UtilsException {
  298.         String tmp = rs.getString("proxy_username");
  299.         if(tmp!=null && !"".equals(tmp)){
  300.             Property prop = new Property();
  301.             prop.setNome(CostantiDB.CONNETTORE_PROXY_USERNAME);
  302.             prop.setValore(tmp.trim());
  303.             connettore.addProperty(prop);
  304.         }
  305.         
  306.         tmp = rs.getString("proxy_password");
  307.         String encValue = rs.getString("enc_proxy_password");
  308.         if(tmp!=null && !"".equals(tmp)){
  309.             Property prop = new Property();
  310.             prop.setNome(CostantiDB.CONNETTORE_PROXY_PASSWORD);
  311.             
  312.             if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  313.                 if(driverBYOK!=null) {
  314.                     prop.setValore(driverBYOK.unwrapAsString(encValue));
  315.                 }
  316.                 else {
  317.                     prop.setValore(encValue);
  318.                 }
  319.             }
  320.             else {
  321.                 prop.setValore(tmp.trim());
  322.             }
  323.             
  324.             connettore.addProperty(prop);
  325.         }
  326.     }
  327.     
  328.     private static void readConnettoreTempiRisposta(ResultSet rs, Connettore connettore) throws SQLException {
  329.         int connectionTimeout = rs.getInt("connection_timeout");
  330.         if(connectionTimeout>0){
  331.             
  332.             Property prop = new Property();
  333.             prop.setNome(CostantiDB.CONNETTORE_CONNECTION_TIMEOUT);
  334.             prop.setValore(connectionTimeout+"");
  335.             connettore.addProperty(prop);
  336.             
  337.         }
  338.         int readTimeout = rs.getInt("read_timeout");
  339.         if(readTimeout>0){
  340.             
  341.             Property prop = new Property();
  342.             prop.setNome(CostantiDB.CONNETTORE_READ_CONNECTION_TIMEOUT);
  343.             prop.setValore(readTimeout+"");
  344.             connettore.addProperty(prop);
  345.             
  346.         }
  347.         int avgResponseTime = rs.getInt("avg_response_time");
  348.         if(avgResponseTime>0){
  349.             
  350.             Property prop = new Property();
  351.             prop.setNome(CostantiDB.CONNETTORE_TEMPO_MEDIO_RISPOSTA);
  352.             prop.setValore(avgResponseTime+"");
  353.             connettore.addProperty(prop);
  354.             
  355.         }
  356.     }

  358.     private static void readConnettoreTransferMode(ResultSet rs, Connettore connettore) throws SQLException {
  359.         String transferMode = rs.getString("transfer_mode");
  360.         if(transferMode!=null && !"".equals(transferMode)){
  361.             
  362.             Property prop = new Property();
  363.             prop.setNome(CostantiDB.CONNETTORE_HTTP_DATA_TRANSFER_MODE);
  364.             prop.setValore(transferMode.trim());
  365.             connettore.addProperty(prop);
  366.             
  367.             transferMode = rs.getString("transfer_mode_chunk_size");
  368.             if(transferMode!=null && !"".equals(transferMode)){
  369.                 prop = new Property();
  370.                 prop.setNome(CostantiDB.CONNETTORE_HTTP_DATA_TRANSFER_MODE_CHUNK_SIZE);
  371.                 prop.setValore(transferMode.trim());
  372.                 connettore.addProperty(prop);
  373.             }
  374.         }
  375.     }
  376.     
  377.     private static void readConnettoreRedirectMode(ResultSet rs, Connettore connettore) throws SQLException {
  378.         String redirectMode = rs.getString("redirect_mode");
  379.         if(redirectMode!=null && !"".equals(redirectMode)){
  380.             
  381.             Property prop = new Property();
  382.             prop.setNome(CostantiDB.CONNETTORE_HTTP_REDIRECT_FOLLOW);
  383.             prop.setValore(redirectMode.trim());
  384.             connettore.addProperty(prop);
  385.             
  386.             redirectMode = rs.getString("redirect_max_hop");
  387.             if(redirectMode!=null && !"".equals(redirectMode)){
  388.                 prop = new Property();
  389.                 prop.setNome(CostantiDB.CONNETTORE_HTTP_REDIRECT_MAX_HOP);
  390.                 prop.setValore(redirectMode.trim());
  391.                 connettore.addProperty(prop);
  392.             }
  393.         }
  394.     }
  395.     
  396.     private static void readAutenticazioneApiKey(ResultSet rs, Connettore connettore, IDriverBYOK driverBYOK) throws SQLException, UtilsException {
  397.         String apiKey = rs.getString("api_key");
  398.         if(apiKey!=null && !"".equals(apiKey)){
  399.             
  400.             Property prop = new Property();
  401.             prop.setNome(CostantiDB.CONNETTORE_APIKEY);
  402.             if(driverBYOK!=null) {
  403.                 prop.setValore(driverBYOK.unwrapAsString(apiKey));
  404.             }
  405.             else {
  406.                 prop.setValore(apiKey);
  407.             }
  408.             connettore.addProperty(prop);
  409.             
  410.             String apiKeyHeader = rs.getString("api_key_header");
  411.             if(apiKeyHeader!=null && !"".equals(apiKeyHeader)){
  412.                 prop = new Property();
  413.                 prop.setNome(CostantiDB.CONNETTORE_APIKEY_HEADER);
  414.                 prop.setValore(apiKeyHeader.trim());
  415.                 connettore.addProperty(prop);
  416.             }
  417.             
  418.             
  419.             String appId = rs.getString("app_id");
  420.             if(appId!=null && !"".equals(appId)){
  421.                 
  422.                 prop = new Property();
  423.                 prop.setNome(CostantiDB.CONNETTORE_APIKEY_APPID);
  424.                 prop.setValore(appId);
  425.                 connettore.addProperty(prop);
  426.                 
  427.                 String appIdHeader = rs.getString("app_id_header");
  428.                 if(appIdHeader!=null && !"".equals(appIdHeader)){
  429.                     prop = new Property();
  430.                     prop.setNome(CostantiDB.CONNETTORE_APIKEY_APPID_HEADER);
  431.                     prop.setValore(appIdHeader.trim());
  432.                     connettore.addProperty(prop);
  433.                 }
  434.             }
  435.         }
  436.     }
  437.     
  438.     private static void readConnettoreHttp(ResultSet rs, Connettore connettore, IDriverBYOK driverBYOK) throws DriverRegistroServiziException, SQLException, UtilsException {
  439.         // url
  440.         String value = rs.getString("url");
  441.         if(value!=null)
  442.             value = value.trim();
  443.         if(value == null || "".equals(value) || " ".equals(value)){
  444.             throw new DriverRegistroServiziException("Connettore di tipo http possiede una url non definita");
  445.         }
  446.         Property prop = new Property();
  447.         prop.setNome(CostantiDB.CONNETTORE_HTTP_LOCATION);
  448.         prop.setValore(value);
  449.         connettore.addProperty(prop);
  450.         
  451.         // user
  452.         String usr = rs.getString("utente");
  453.         if (usr != null && !usr.trim().equals("")) {
  454.             prop = new Property();
  455.             prop.setNome(CostantiDB.CONNETTORE_USER);
  456.             prop.setValore(usr);
  457.             connettore.addProperty(prop);
  458.         }
  459.         // password
  460.         String pwd = rs.getString("password");
  461.         String encValue = rs.getString("enc_password");
  462.         if (pwd != null && !pwd.trim().equals("")) {
  463.             prop = new Property();
  464.             prop.setNome(CostantiDB.CONNETTORE_PWD);
  465.             
  466.             if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  467.                 if(driverBYOK!=null) {
  468.                     prop.setValore(driverBYOK.unwrapAsString(encValue));
  469.                 }
  470.                 else {
  471.                     prop.setValore(encValue);
  472.                 }
  473.             }
  474.             else {
  475.                 prop.setValore(pwd);
  476.             }
  477.             
  478.             connettore.addProperty(prop);
  479.         }
  480.     }
  481.     
  482.     private static void readConnettoreJms(ResultSet rs, Connettore connettore, IDriverBYOK driverBYOK) throws DriverRegistroServiziException, SQLException, UtilsException {
  483.         // nome coda/topic
  484.         String value = rs.getString("nome");
  485.         if(value!=null)
  486.             value = value.trim();
  487.         if(value == null || "".equals(value) || " ".equals(value)){
  488.             throw new DriverRegistroServiziException("Connettore di tipo jms possiede il nome della coda/topic non definito");
  489.         }
  490.         Property prop = new Property();
  491.         prop.setNome(CostantiDB.CONNETTORE_JMS_NOME);
  492.         prop.setValore(value);
  493.         connettore.addProperty(prop);

  495.         // tipo
  496.         value = rs.getString("tipo");
  497.         if(value!=null)
  498.             value = value.trim();
  499.         if(value == null || "".equals(value) || " ".equals(value)){
  500.             throw new DriverRegistroServiziException("Connettore di tipo jms possiede il tipo della coda non definito");
  501.         }
  502.         prop = new Property();
  503.         prop.setNome(CostantiDB.CONNETTORE_JMS_TIPO);
  504.         prop.setValore(value);
  505.         connettore.addProperty(prop);

  507.         // connection-factory
  508.         value = rs.getString("connection_factory");
  509.         if(value!=null)
  510.             value = value.trim();
  511.         if(value == null || "".equals(value) || " ".equals(value)){
  512.             throw new DriverRegistroServiziException("Connettore di tipo jms non possiede la definizione di una Connection Factory");
  513.         }
  514.         prop = new Property();
  515.         prop.setNome(CostantiDB.CONNETTORE_JMS_CONNECTION_FACTORY);
  516.         prop.setValore(value);
  517.         connettore.addProperty(prop);

  519.         // send_as
  520.         value = rs.getString("send_as");
  521.         if(value!=null)
  522.             value = value.trim();
  523.         if(value == null || "".equals(value) || " ".equals(value)){
  524.             throw new DriverRegistroServiziException("Connettore di tipo jms possiede il tipo dell'oggetto JMS non definito");
  525.         }
  526.         prop = new Property();
  527.         prop.setNome(CostantiDB.CONNETTORE_JMS_SEND_AS);
  528.         prop.setValore(value);
  529.         connettore.addProperty(prop);

  531.         readConnettoreJmsCredentials(rs, connettore, driverBYOK);
  532.         
  533.         readConnettoreJmsContext(rs, connettore);
  534.     }
  535.     private static void readConnettoreJmsCredentials(ResultSet rs, Connettore connettore, IDriverBYOK driverBYOK) throws SQLException, UtilsException {
  536.         // user
  537.         String usr = rs.getString("utente");
  538.         if (usr != null && !usr.trim().equals("")) {
  539.             Property prop = new Property();
  540.             prop.setNome(CostantiDB.CONNETTORE_USER);
  541.             prop.setValore(usr);
  542.             connettore.addProperty(prop);
  543.         }
  544.         // password
  545.         String pwd = rs.getString("password");
  546.         String encValue = rs.getString("enc_password");
  547.         if (pwd != null && !pwd.trim().equals("")) {
  548.             Property prop = new Property();
  549.             prop.setNome(CostantiDB.CONNETTORE_PWD);
  550.             
  551.             if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  552.                 if(driverBYOK!=null) {
  553.                     prop.setValore(driverBYOK.unwrapAsString(encValue));
  554.                 }
  555.                 else {
  556.                     prop.setValore(encValue);
  557.                 }
  558.             }
  559.             else {
  560.                 prop.setValore(pwd);
  561.             }
  562.             
  563.             connettore.addProperty(prop);
  564.         }
  565.     }
  566.     private static void readConnettoreJmsContext(ResultSet rs, Connettore connettore) throws SQLException {
  567.         // context-java.naming.factory.initial
  568.         String initcont = rs.getString("initcont");
  569.         if (initcont != null && !initcont.trim().equals("")) {
  570.             Property prop = new Property();
  571.             prop.setNome(CostantiDB.CONNETTORE_JMS_CONTEXT_JAVA_NAMING_FACTORY_INITIAL);
  572.             prop.setValore(initcont);
  573.             connettore.addProperty(prop);
  574.         }
  575.         // context-java.naming.factory.url.pkgs
  576.         String urlpkg = rs.getString("urlpkg");
  577.         if (urlpkg != null && !urlpkg.trim().equals("")) {
  578.             Property prop = new Property();
  579.             prop.setNome(CostantiDB.CONNETTORE_JMS_CONTEXT_JAVA_NAMING_FACTORY_URL_PKG);
  580.             prop.setValore(urlpkg);
  581.             connettore.addProperty(prop);
  582.         }
  583.         // context-java.naming.provider.url
  584.         String provurl = rs.getString("provurl");
  585.         if (provurl != null && !provurl.trim().equals("")) {
  586.             Property prop = new Property();
  587.             prop.setNome(CostantiDB.CONNETTORE_JMS_CONTEXT_JAVA_NAMING_PROVIDER_URL);
  588.             prop.setValore(provurl);
  589.             connettore.addProperty(prop);
  590.         }
  591.     }
  592.     
  593.     
  594.     protected void readPropertiesConnettoreCustom(long idConnettore, Connettore connettore, Connection connection,
  595.             IDriverBYOK driverBYOK) throws DriverRegistroServiziException {

  597.         PreparedStatement stm = null;
  598.         ResultSet rs = null;

  600.         try {
  601.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  602.             sqlQueryObject.addFromTable(CostantiDB.CONNETTORI_CUSTOM);
  603.             sqlQueryObject.addSelectField("*");
  604.             sqlQueryObject.addWhereCondition("id_connettore = ?");
  605.             String sqlQuery = sqlQueryObject.createSQLQuery();

  607.             stm = connection.prepareStatement(sqlQuery);
  608.             stm.setLong(1, idConnettore);

  610.             this.driver.logDebug("eseguo query : " + DBUtils.formatSQLString(sqlQuery, idConnettore));

  612.             rs = stm.executeQuery();

  614.             while (rs.next()) {
  615.                 processPropertiesConnettoreCustom(rs, connettore, driverBYOK);
  616.             }

  618.             rs.close();
  619.             stm.close();

  621.         } catch (SQLException sqle) {

  623.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::readPropertiesConnettoreCustom] SQLException : " + sqle.getMessage(),sqle);
  624.         }catch (Exception sqle) {

  626.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::readPropertiesConnettoreCustom] Exception : " + sqle.getMessage(),sqle);
  627.         } finally {
  628.             //Chiudo statement and resultset
  629.             JDBCUtilities.closeResources(rs, stm);
  630.         }
  631.     }
  632.     private static void processPropertiesConnettoreCustom(ResultSet rs, Connettore connettore, 
  633.             IDriverBYOK driverBYOK) throws SQLException, UtilsException {
  634.         String nome = rs.getString(CostantiDB.CONNETTORI_CUSTOM_COLUMN_NAME);
  635.         String valore = rs.getString(CostantiDB.CONNETTORI_CUSTOM_COLUMN_VALUE);
  636.         String encValue = rs.getString(CostantiDB.CONNETTORI_CUSTOM_COLUMN_ENC_VALUE);

  638.         if(CostantiDB.CONNETTORE_DEBUG.equals(nome)){ // lo posso aver aggiunto prima
  639.             boolean found = false;
  640.             for (int i = 0; i < connettore.sizePropertyList(); i++) {
  641.                 if(CostantiDB.CONNETTORE_DEBUG.equals(connettore.getProperty(i).getNome())){
  642.                     // already exists
  643.                     found = true;
  644.                     break;
  645.                 }
  646.             }
  647.             if(found){
  648.                 return; // è gia stato aggiunto.
  649.             }
  650.         }
  651.         
  652.         Property prop = new Property();
  653.         prop.setNome(nome);
  654.         if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  655.             if(driverBYOK!=null) {
  656.                 prop.setValore(driverBYOK.unwrapAsString(encValue));
  657.             }
  658.             else {
  659.                 prop.setValore(encValue);
  660.             }
  661.         }
  662.         else {
  663.             prop.setValore(valore);
  664.         }
  665.         connettore.addProperty(prop);
  666.     }
  667.     
  668.     protected void readPropertiesConnettoreExtendedInfo(long idConnettore, Connettore connettore, Connection connection,
  669.             IDriverBYOK driverBYOK) throws DriverRegistroServiziException {

  671.         PreparedStatement stm = null;
  672.         ResultSet rs = null;

  674.         try {
  675.             ISQLQueryObject sqlQueryObject = SQLObjectFactory.createSQLQueryObject(this.driver.tipoDB);
  676.             sqlQueryObject.addFromTable(CostantiDB.CONNETTORI_CUSTOM);
  677.             sqlQueryObject.addSelectField("*");
  678.             sqlQueryObject.addWhereCondition("id_connettore = ?");
  679.             sqlQueryObject.addWhereLikeCondition(CostantiDB.CONNETTORI_CUSTOM_COLUMN_NAME, CostantiConnettori.CONNETTORE_EXTENDED_PREFIX+"%");
  680.             String sqlQuery = sqlQueryObject.createSQLQuery();

  682.             stm = connection.prepareStatement(sqlQuery);
  683.             stm.setLong(1, idConnettore);

  685.             this.driver.logDebug("eseguo query : " + DBUtils.formatSQLString(sqlQuery, idConnettore));

  687.             rs = stm.executeQuery();

  689.             while (rs.next()) {
  690.                 processPropertiesConnettoreExtendedInfo(rs, connettore, 
  691.                         driverBYOK);
  692.             }

  694.             rs.close();
  695.             stm.close();

  697.         } catch (SQLException sqle) {

  699.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::readPropertiesConnettoreExtendedInfo] SQLException : " + sqle.getMessage(),sqle);
  700.         }catch (Exception sqle) {

  702.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::readPropertiesConnettoreExtendedInfo] Exception : " + sqle.getMessage(),sqle);
  703.         } finally {
  704.             //Chiudo statement and resultset
  705.             JDBCUtilities.closeResources(rs, stm);
  706.         }
  707.     }
  708.     private static void processPropertiesConnettoreExtendedInfo(ResultSet rs, Connettore connettore, 
  709.             IDriverBYOK driverBYOK) throws SQLException, UtilsException {
  710.         String nome = rs.getString(CostantiDB.CONNETTORI_CUSTOM_COLUMN_NAME);
  711.         String valore = rs.getString(CostantiDB.CONNETTORI_CUSTOM_COLUMN_VALUE);
  712.         String encValue = rs.getString(CostantiDB.CONNETTORI_CUSTOM_COLUMN_ENC_VALUE);

  714.         // Le proprietà sono già state inserite in caso di connettore custom
  715.         boolean found = false;
  716.         for (int i = 0; i < connettore.sizePropertyList(); i++) {
  717.             if(nome.equals(connettore.getProperty(i).getNome())){
  718.                 // already exists
  719.                 found = true;
  720.                 break;
  721.             }
  722.         }
  723.         if(found){
  724.             return; // è gia stato aggiunto.
  725.         }
  726.         
  727.         Property prop = new Property();
  728.         prop.setNome(nome);
  729.         if(encValue!=null && StringUtils.isNotEmpty(encValue)) {
  730.             if(driverBYOK!=null) {
  731.                 prop.setValore(driverBYOK.unwrapAsString(encValue));
  732.             }
  733.             else {
  734.                 prop.setValore(encValue);
  735.             }
  736.         }
  737.         else {
  738.             prop.setValore(valore);
  739.         }
  740.         connettore.addProperty(prop);
  741.     }

  743.     protected Property[] getPropertiesConnettore(String nomeConnettore) throws DriverRegistroServiziException {
  744.         Connection con = null;
  745.         if (this.driver.atomica) {
  746.             try {
  747.                 con = this.driver.getConnectionFromDatasource("getPropertiesConnettore");

  749.             } catch (Exception e) {
  750.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getPropertiesConnettore] Exception accedendo al datasource :" + e.getMessage(),e);

  752.             }

  754.         } else
  755.             con = this.driver.globalConnection;
  756.         return getPropertiesConnettore(nomeConnettore,con);
  757.     }
  758.     protected Property[] getPropertiesConnettore(String nomeConnettore, Connection connection) throws DriverRegistroServiziException {
  759.         try {
  760.             List<Property> l = ConnettorePropertiesUtilities.getPropertiesConnettore(nomeConnettore, connection,this.driver.tipoDB);
  761.             return l!=null && !l.isEmpty() ? l.toArray(new Property[1]) : null;
  762.         } catch (CoreException e) {
  763.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::getPropertiesConnettore] CoreException : " + e.getMessage(),e);
  764.         }
  765.     }
  766.     
  767.     protected void createConnettore(Connettore connettore) throws DriverRegistroServiziException {
  768.         if (connettore == null)
  769.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createConnettore] Parametro non valido.");

  771.         Connection con = null;
  772.         boolean error = false;

  774.         if (this.driver.atomica) {
  775.             try {
  776.                 con = this.driver.getConnectionFromDatasource("createConnettore");
  777.                 con.setAutoCommit(false);
  778.             } catch (Exception e) {
  779.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createConnettore] Exception accedendo al datasource :" + e.getMessage(),e);

  781.             }

  783.         } else
  784.             con = this.driver.globalConnection;

  786.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  788.         try {
  789.             this.driver.logDebug("CRUDConnettore type = 1");
  790.             // creo connettore
  791.             DriverRegistroServiziDB_connettoriLIB.CRUDConnettore(1, connettore, con, this.driver.getDriverWrapBYOK());

  793.         } catch (Exception qe) {
  794.             error = true;
  795.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::createConnettore] Errore durante la creazione del connettore : " + qe.getMessage(),qe);
  796.         } finally {

  798.             this.driver.closeConnection(error,con);
  799.         }
  800.     }

  802.     protected void updateConnettore(Connettore connettore) throws DriverRegistroServiziException {
  803.         if (connettore == null)
  804.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateConnettore] Parametro non valido.");

  806.         Connection con = null;
  807.         boolean error = false;

  809.         if (this.driver.atomica) {
  810.             try {
  811.                 con = this.driver.getConnectionFromDatasource("updateConnettore");
  812.                 con.setAutoCommit(false);
  813.             } catch (Exception e) {
  814.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateConnettore] Exception accedendo al datasource :" + e.getMessage(),e);

  816.             }

  818.         } else
  819.             con = this.driver.globalConnection;

  821.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  823.         try {
  824.             this.driver.logDebug("CRUDConnettore type = 2");
  825.             // update connettore
  826.             DriverRegistroServiziDB_connettoriLIB.CRUDConnettore(2, connettore, con, this.driver.getDriverWrapBYOK());

  828.         } catch (Exception qe) {
  829.             error = true;
  830.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::updateConnettore] Errore durante l'aggiornamento del connettore : " + qe.getMessage(),qe);
  831.         } finally {

  833.             this.driver.closeConnection(error,con);
  834.         }
  835.     }

  837.     protected void deleteConnettore(Connettore connettore) throws DriverRegistroServiziException {
  838.         if (connettore == null)
  839.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteConnettore] Parametro non valido.");

  841.         Connection con = null;
  842.         boolean error = false;

  844.         if (this.driver.atomica) {
  845.             try {
  846.                 con = this.driver.getConnectionFromDatasource("deleteConnettore");
  847.                 con.setAutoCommit(false);
  848.             } catch (Exception e) {
  849.                 throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteConnettore] Exception accedendo al datasource :" + e.getMessage(),e);

  851.             }

  853.         } else
  854.             con = this.driver.globalConnection;

  856.         this.driver.logDebug("operazione this.driver.atomica = " + this.driver.atomica);

  858.         try {
  859.             this.driver.logDebug("CRUDConnettore type = 3");
  860.             // delete connettore
  861.             DriverRegistroServiziDB_connettoriLIB.CRUDConnettore(3, connettore, con, this.driver.getDriverWrapBYOK());

  863.         } catch (Exception qe) {
  864.             error = true;
  865.             throw new DriverRegistroServiziException("[DriverRegistroServiziDB::deleteConnettore] Errore durante la rimozione del connettore : " + qe.getMessage(),qe);
  866.         } finally {

  868.             this.driver.closeConnection(error,con);
  869.         }
  870.     }
  871. }
Created with JaCoCo 0.8.8.202204050719