GestoreRepositoryOracle.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.protocol.engine.driver.repository;

  25. import org.openspcoop2.protocol.sdk.ProtocolException;



  29. /**
  30.  * Classe utilizzata per accedere ai flag di accesso al repository da parte di:
  31.  *  HISTORY: Busta usata per funzionalita di confermaRicezione(OUTBOX)/FiltroDuplicati(INBOX)
  32.  *  PROFILI: Busta usata per funzionalita di profili di collaborazione
  33.  *  PDD:     Busta usata eventualmente da un PdD
  34.  * 
  35.  *
  36.  * @author Poli Andrea (apoli@link.it)
  37.  * @author $Author$
  38.  * @version $Rev$, $Date$
  39.  */
  40. public class GestoreRepositoryOracle implements IGestoreRepository{

  42.     // Nota: con Oracle viene utilizzato il 2,3 e 4 bit, quindi i valori 2, 4 e 8
  43.     // Bit 2^1 = PDD
  44.     // Bit 2^2 = PROFILO
  45.     // Bit 2^3 = HISTORY
  46.     
  47.     private static final String OR_MASK_PDD = "'C103'"; // number:2, mask-bit 001 da utilizzare con OR
  48.     private static final String OR_MASK_PROFILO = "'C105'"; // number:4, mask-bit 010 da utilizzare con OR
  49.     private static final String OR_MASK_HISTORY = "'C109'"; // number:8, mask-bit 100 da utilizzare con OR
  50.     private static final String AND_MASK_PDD = "'C10D'"; // number:12, mask-bit 110 da utilizzare con AND
  51.     private static final String AND_MASK_PROFILO = "'C10B'"; // number:10, mask-bit 1.4 da utilizzare con AND
  52.     private static final String AND_MASK_HISTORY = "'C107'"; // number:6, mask-bit 011 da utilizzare con AND
  53.     
  54.     // Tabella dei valori
  55.     private static final String HISTORY_PROFILO_PDD = "'C10F'";  // number:14, bit: 111
  56.     private static final String HISTORY_PROFILO = "'C10D'";  // number:12, bit: 110
  57.     private static final String HISTORY_PDD = "'C10B'";  // number:10, bit: 101
  58.     private static final String PROFILO_PDD = "'C107'";  // number:6, bit: 011
  59.     private static final String HISTORY = "'C109'"; // number:8, bit: 100
  60.     private static final String PROFILO = "'C105'"; // number:4, bit: 010
  61.     private static final String PDD = "'C103'"; // number:2, bit: 001
  62.     private static final String NONE = "'C101'"; // number:0, bit: 000
  63.     
  64.     /** Query di utility:
  65.      * 
  66.      * CREATE TABLE TEST
  67.      * (
  68.      *     TIPO VARCHAR(255) NOT NULL,
  69.      *     T1 RAW(8) DEFAULT 'C101' NOT NULL
  70.      * );
  71.      * 
  72.      * INSERT INTO TEST (TIPO) VALUES ('TIPO');
  73.      * 
  74.      * select TIPO,T1,utl_raw.CAST_TO_NUMBER(T1) from TEST;
  75.      * 
  76.      * select TIPO,T1,utl_raw.CAST_TO_NUMBER(T1) from TEST WHERE T1 ='C101';
  77.      * 
  78.      * UPDATE TEST SET t1 = (utl_raw.bit_or(t1,utl_raw.CAST_FROM_NUMBER(2)))
  79.      * 
  80.      * UPDATE TEST SET t1 = 'C101';
  81.      * 
  82.      * */
  83.     
  84.     /**
  85.      * Imposta la modalita' di accesso per l'history
  86.      * 
  87.      * @param value
  88.      */
  89.     @Override
  90.     public String createSQLSet_History(boolean value) throws ProtocolException{
  91.         if(value)
  92.             return "REPOSITORY_ACCESS = (utl_raw.bit_or(REPOSITORY_ACCESS,"+GestoreRepositoryOracle.OR_MASK_HISTORY+"))";
  93.         else
  94.             return "REPOSITORY_ACCESS = (utl_raw.bit_and(REPOSITORY_ACCESS,"+GestoreRepositoryOracle.AND_MASK_HISTORY+"))";
  95.     }
  96.     
  97.     /**
  98.      * Imposta la modalita' di accesso per i profili di collaborazione
  99.      * 
  100.       * @param value
  101.      */
  102.     @Override
  103.     public String createSQLSet_ProfiloCollaborazione(boolean value) throws ProtocolException{
  104.         if(value)
  105.             return "REPOSITORY_ACCESS = (utl_raw.bit_or(REPOSITORY_ACCESS,"+GestoreRepositoryOracle.OR_MASK_PROFILO+"))";
  106.         else
  107.             return "REPOSITORY_ACCESS = (utl_raw.bit_and(REPOSITORY_ACCESS,"+GestoreRepositoryOracle.AND_MASK_PROFILO+"))";
  108.     }
  109.     
  110.     /**
  111.      * Imposta la modalita' di accesso per una pdd
  112.      * 
  113.       * @param value
  114.      */
  115.     @Override
  116.     public String createSQLSet_PdD(boolean value) throws ProtocolException{
  117.         if(value)
  118.             return "REPOSITORY_ACCESS = (utl_raw.bit_or(REPOSITORY_ACCESS,"+GestoreRepositoryOracle.OR_MASK_PDD+"))";
  119.         else
  120.             return "REPOSITORY_ACCESS = (utl_raw.bit_and(REPOSITORY_ACCESS,"+GestoreRepositoryOracle.AND_MASK_PDD+"))";
  121.     }
  122.     
  123.     /**
  124.      * @param value Indicazione sull'utilizzo
  125.      */
  126.     @Override
  127.     public String createSQLCondition_History(boolean value) throws ProtocolException{
  128.         
  129.         if(value)
  130.             return "(REPOSITORY_ACCESS="+GestoreRepositoryOracle.HISTORY_PROFILO_PDD+
  131.                " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.HISTORY_PDD+
  132.                " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.HISTORY_PROFILO+
  133.                " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.HISTORY+" )";
  134.         else
  135.             return "(REPOSITORY_ACCESS="+GestoreRepositoryOracle.PROFILO_PDD+
  136.                " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.PDD+
  137.                " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.PROFILO+
  138.                " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.NONE+" )";
  139.     }
  140.     
  141.     /**
  142.      * @param value Indicazione sull'utilizzo
  143.      */
  144.     @Override
  145.     public String createSQLCondition_ProfiloCollaborazione(boolean value) throws ProtocolException{
  146.         if(value)
  147.             return "(REPOSITORY_ACCESS="+GestoreRepositoryOracle.HISTORY_PROFILO_PDD+
  148.                    " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.PROFILO_PDD+
  149.                    " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.HISTORY_PROFILO+
  150.                    " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.PROFILO+" )";
  151.         
  152.         else
  153.             return "(REPOSITORY_ACCESS="+GestoreRepositoryOracle.HISTORY_PDD+
  154.                " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.PDD+
  155.                " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.HISTORY+
  156.                " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.NONE+" )";
  157.     }
  158.     
  159.     /**
  160.      * @param value Indicazione sull'utilizzo
  161.      */
  162.     @Override
  163.     public String createSQLCondition_PdD(boolean value) throws ProtocolException{
  164.         if(value)
  165.             return "(REPOSITORY_ACCESS="+GestoreRepositoryOracle.HISTORY_PROFILO_PDD+
  166.                    " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.PROFILO_PDD+
  167.                    " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.HISTORY_PDD+
  168.                    " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.PDD+" )";
  169.         
  170.         else
  171.             return "(REPOSITORY_ACCESS="+GestoreRepositoryOracle.HISTORY_PROFILO+
  172.                " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.PROFILO+
  173.                " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.HISTORY+
  174.                " OR REPOSITORY_ACCESS="+GestoreRepositoryOracle.NONE+" )";
  175.     }


  178.     @Override
  179.     public String createSQLCondition_enableOnlyHistory() throws ProtocolException{
  180.         return "(REPOSITORY_ACCESS="+GestoreRepositoryOracle.HISTORY+")";
  181.     }
  182.        

  184.     @Override
  185.     public String createSQLCondition_enableOnlyPdd() throws ProtocolException{
  186.         return "(REPOSITORY_ACCESS="+GestoreRepositoryOracle.PDD+")";
  187.     }
  188.     

  190.     @Override
  191.     public String createSQLCondition_enableOnlyProfilo() throws ProtocolException{
  192.         return "(REPOSITORY_ACCESS="+GestoreRepositoryOracle.PROFILO+")";
  193.     }
  194.     

  196.     @Override
  197.     public String createSQLCondition_enableOnlyPddAndProfilo() throws ProtocolException{
  198.         return "(REPOSITORY_ACCESS="+GestoreRepositoryOracle.PROFILO_PDD+")";
  199.     }
  200.     

  202.     @Override
  203.     public String createSQLCondition_disabledAll() throws ProtocolException{
  204.         return "(REPOSITORY_ACCESS="+GestoreRepositoryOracle.NONE+")";
  205.     }

  207.     
  208.     /**
  209.      * Ritorna il valore da associare al field che gestisce l'History
  210.      * 
  211.      * @return SQLField Value
  212.      * @throws ProtocolException
  213.      */
  214.     @Override
  215.     public String getSQLValueHistory(boolean history) throws ProtocolException{
  216.         if(history)
  217.             return GestoreRepositoryOracle.HISTORY+"";
  218.         else
  219.             return GestoreRepositoryOracle.NONE+"";
  220.     }
  221.     
  222.     /**
  223.      * Ritorna i field che gestiscono la modalita di accesso al Repository
  224.      * 
  225.      * @return SQLField
  226.      * @throws ProtocolException
  227.      */
  228.     @Override
  229.     public String createSQLFields() throws ProtocolException{
  230.         return "REPOSITORY_ACCESS";
  231.     }
  232.     
  233.     /**
  234.      * Ritorna il field che gestisce la modalita di accesso all'History flag
  235.      * 
  236.      * @return SQL Field History
  237.      * @throws ProtocolException
  238.      */
  239.     @Override
  240.     public String createSQLFieldHistory() throws ProtocolException{
  241.         return "REPOSITORY_ACCESS";
  242.     }
  243. }
Created with JaCoCo 0.8.8.202204050719