Convert tabs to spaces basic refactoring
[policy/engine.git] / ONAP-REST / src / main / java / org / onap / policy / rest / daoimpl / PolicyValidationDaoImpl.java
index 8aa0435..66401cc 100644 (file)
@@ -47,10 +47,10 @@ import org.springframework.stereotype.Component;
 @Component
 public class PolicyValidationDaoImpl implements CommonClassDao{
 
-       private static final Logger LOGGER = FlexLogger.getLogger(PolicyValidationDaoImpl.class);
-       private static final String DB_CONNECTION_CLOSING_ERROR = "Error While Closing Connection/Statement";
-       private static final String DBTABLE_QUERY_ERROR = "Error While Querying Table";
-       private static SessionFactory sessionfactory;
+    private static final Logger LOGGER = FlexLogger.getLogger(PolicyValidationDaoImpl.class);
+    private static final String DB_CONNECTION_CLOSING_ERROR = "Error While Closing Connection/Statement";
+    private static final String DBTABLE_QUERY_ERROR = "Error While Querying Table";
+    private static SessionFactory sessionfactory;
     
     public static SessionFactory getSessionfactory() {
           return sessionfactory;
@@ -69,350 +69,350 @@ public class PolicyValidationDaoImpl implements CommonClassDao{
           //Default Constructor
     }
 
-       @SuppressWarnings({ "unchecked", "rawtypes" })
-       @Override
-       public List<Object> getData(Class className) {
-               Session session = sessionfactory.openSession();
-               List<Object> data = null;
-               try{
-                       Criteria cr = session.createCriteria(className);
-                       data = cr.list();
-               }catch(Exception e){
-                       LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DBTABLE_QUERY_ERROR + e); 
-               }finally{
-                       try{
-                               session.close();
-                       }catch(Exception e){
-                               LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR+e);
-                       }
-               }
-               return data;
-       }
-
-
-       @SuppressWarnings({ "rawtypes", "unchecked" })
-       @Override
-       public List<Object> getDataById(Class className, String columnName, String key) {
-               Session session = sessionfactory.openSession();
-               List<Object> data = null;
-               try {
-                       Criteria cr = session.createCriteria(className);
-                       if(columnName.contains(":") && key.contains(":")){
-                               String[] columns = columnName.split(":");
-                               String[] keys = key.split(":");
-                               for(int i=0; i < columns.length; i++){
-                                       cr.add(Restrictions.eq(columns[i], keys[i]));
-                               }
-                       }else{
-                               cr.add(Restrictions.eq(columnName, key));       
-                       }
-                       data = cr.list();
-               } catch (Exception e) {
-                       LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DBTABLE_QUERY_ERROR + e); 
-               }finally{
-                       try{
-                               session.close();
-                       }catch(Exception e1){
-                               LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
-                       }
-               }
-               return data;
-       }
-       
-       @Override
-       public void save(Object entity) {
-               Session session = sessionfactory.openSession();
-               Transaction tx = session.beginTransaction();
-               try {
-                       session.persist(entity);
-                       tx.commit();    
-               }catch(Exception e){
-                       LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Saving data to Table"+e);    
-               }finally{
-                       try{
-                               session.close();
-                       }catch(Exception e1){
-                               LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
-                       }
-               }
-               
-       }
-
-       @Override
-       public void delete(Object entity) {
-               Session session = sessionfactory.openSession();
-               Transaction tx = session.beginTransaction();
-               try {
-                       session.delete(entity);
-                       tx.commit();    
-               }catch(Exception e){
-                       LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Deleting data from Table"+e);        
-               }finally{
-                       try{
-                               session.close();
-                       }catch(Exception e1){
-                               LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
-                       }
-               }
-               
-       }
-
-
-       @Override
-       public void update(Object entity) {
-               Session session = sessionfactory.openSession();
-               Transaction tx = session.beginTransaction();
-               try {
-                       session.update(entity);
-                       tx.commit();    
-               }catch(Exception e){
-                       LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Updating data to Table"+e);  
-               }finally{
-                       try{
-                               session.close();
-                       }catch(Exception e1){
-                               LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
-                       }
-               }
-               
-       }
-
-
-       @SuppressWarnings({ "unchecked", "rawtypes" })
-       @Override
-       public List<Object> checkDuplicateEntry(String value, String columnName, Class className) {
-               Session session = sessionfactory.openSession();
-               Transaction tx = session.beginTransaction();
-               List<Object> data = null;
-               String[] columnNames = null;
-               if(columnName != null && columnName.contains(":")){
-                       columnNames = columnName.split(":");
-               }
-               String[] values = null;
-               if(value != null && value.contains(":")){
-                       values = value.split(":");
-               }               
-               try {
-                       Criteria cr = session.createCriteria(className);
-                       if(columnNames != null && values != null && columnNames.length == values.length){
-                               for (int i = 0; i < columnNames.length; i++){
-                                       cr.add(Restrictions.eq(columnNames[i],values[i]));
-                               }
-                       }else{
-                               cr.add(Restrictions.eq(columnName,value));
-                       }
-                       data = cr.list();
-                       tx.commit();
-               } catch (Exception e) {
-                       LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Querying for Duplicate Entries for Table"+e + className);    
-               }finally{
-                       try{
-                               session.close();
-                       }catch(Exception e1){
-                               LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
-                       }
-               }
-               return data;
-       }
-
-
-       @SuppressWarnings("unchecked")
-       @Override
-       public List<PolicyRoles> getUserRoles() {
-               Session session = sessionfactory.openSession();
-               Transaction tx = session.beginTransaction();
-               List<PolicyRoles> rolesData = null;
-               try {
-                       Criteria cr = session.createCriteria(PolicyRoles.class);                
-                       Disjunction disjunction = Restrictions.disjunction(); 
-                       Conjunction conjunction1  = Restrictions.conjunction();
-                       conjunction1.add(Restrictions.eq("role", "admin"));
-                       Conjunction conjunction2  = Restrictions.conjunction();
-                       conjunction2.add(Restrictions.eq("role", "editor"));    
-                       Conjunction conjunction3  = Restrictions.conjunction();
-                       conjunction3.add(Restrictions.eq("role", "guest"));     
-                       disjunction.add(conjunction1);
-                       disjunction.add(conjunction2);
-                       disjunction.add(conjunction3);
-                       rolesData = cr.add(disjunction).list();
-                       tx.commit();
-               } catch (Exception e) {
-                       LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Querying PolicyRoles Table"+e);      
-               }finally{
-                       try{
-                               session.close();
-                       }catch(Exception e1){
-                               LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
-                       }
-               }
-               return rolesData;
-       }
-
-
-       @Override
-       public List<Object> checkExistingGroupListforUpdate(String arg0, String arg1) {
-               return Collections.emptyList();
-       }
-
-
-       @Override
-       public void deleteAll() {
-               // Do nothing because this method is not used and is a placeholder to avoid 'Unimplemented Method' error
-       }
-
-       
-       @SuppressWarnings("unchecked")
-       @Override
-       public List<Object> getDataByQuery(String query, SimpleBindings params) {
-               Session session = sessionfactory.openSession();
-               Transaction tx = session.beginTransaction();
-               List<Object> data = null;
-               try {
-                       Query hbquery = session.createQuery(query);
-                       for (Map.Entry<String, Object> paramPair : params.entrySet()) {
-                               if(paramPair.getValue() instanceof java.lang.Long){
-                                       hbquery.setLong(paramPair.getKey(), (long) paramPair.getValue());
-                               }
-                               else{
-                                       hbquery.setParameter(paramPair.getKey(), paramPair.getValue());
-                               }
-                       }
-                       data = hbquery.list();
-                       tx.commit();
-               } catch (Exception e) {
-                       LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DBTABLE_QUERY_ERROR + e); 
-                       throw e;
-               }finally{
-                       try{
-                               session.close();
-                       }catch(HibernateException e1){
-                               LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
-                       }
-               }
-               return data;
-       }
-
-
-       @SuppressWarnings("rawtypes")
-       @Override
-       public Object getEntityItem(Class className, String columnName, String key) {
-               Session session = sessionfactory.openSession();
-               Transaction tx = session.beginTransaction();
-               Object data = null;
-               try {
-                       Criteria cr = session.createCriteria(className);
-                       if(columnName.contains(":") && key.contains(":")){
-                               String[] columns = columnName.split(":");
-                               String[] keys = key.split(":");
-                               for(int i=0; i < columns.length; i++){
-                                       cr.add(Restrictions.eq(columns[i], keys[i]));
-                               }
-                       }else{
-                               cr.add(Restrictions.eq(columnName, key));       
-                       }
-                       data = cr.list().get(0);
-                       tx.commit();
-               } catch (Exception e) {
-                       LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DBTABLE_QUERY_ERROR + e); 
-               }finally{
-                       try{
-                               session.close();
-                       }catch(Exception e1){
-                               LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
-                       }
-               }
-               return data;
-       }
-
-
-       @Override
-       public void updateClAlarms(String arg0, String arg1) {
-               // Do nothing because this method is not used and is a placeholder to avoid 'Unimplemented Method' error
-       }
-
-
-       @Override
-       public void updateClYaml(String arg0, String arg1) {
-               // Do nothing because this method is not used and is a placeholder to avoid 'Unimplemented Method' error
-       }
-
-
-       @Override
-       public void updateQuery(String query) {
-               Session session = sessionfactory.openSession();
-               Transaction tx = session.beginTransaction();    
-               try {
-                       Query hbquery = session.createQuery(query);
-                       hbquery.executeUpdate();
-                       tx.commit();
-               } catch (Exception e) {
-                       LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Updating Database Table"+e); 
-               }finally{
-                       try{
-                               session.close();
-                       }catch(Exception e1){
-                               LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
-                       }
-               }
-               
-       }
-
-
-       @SuppressWarnings({ "rawtypes", "unchecked" })
-       @Override
-       public List<String> getDataByColumn(Class className, String columnName) {
-               Session session = sessionfactory.openSession();
-               List<String> data = null;
-               try{
-                       Criteria cr = session.createCriteria(className);
-                       cr.setProjection(Projections.property(columnName));
-                       data = cr.list();
-               }catch(Exception e){
-                       LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DBTABLE_QUERY_ERROR + e); 
-               }finally{
-                       try{
-                               session.close();
-                       }catch(Exception e){
-                               LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e);
-                       }
-               }
-               return data;
-       }
-
-
-       @SuppressWarnings({ "rawtypes", "unchecked" })
-       @Override
-       public List<Object> getMultipleDataOnAddingConjunction(Class className, String columnName, List<String> data) {
-               Session session = sessionfactory.openSession();
-               Transaction tx = session.beginTransaction();
-               List<Object> entityData = null;
-               try {
-                       Criteria cr = session.createCriteria(className);                
-                       Disjunction disjunction = Restrictions.disjunction(); 
-                       List<Conjunction> conjunctionList = new ArrayList<>();
-                       String[] columNames = columnName.split(":");
-                       for(int i =0; i < data.size(); i++){
-                               String[] entiySplit = data.get(i).split(":");
-                               Conjunction conjunction = Restrictions.conjunction();
-                               conjunction.add(Restrictions.eq(columNames[0], entiySplit[0]));
-                               conjunction.add(Restrictions.eq(columNames[1], entiySplit[1]));
-                               conjunctionList.add(conjunction);
-                       }
-                       for(int j =0 ; j < conjunctionList.size(); j++){
-                               disjunction.add(conjunctionList.get(j));
-                       }
-                       entityData = cr.add(disjunction).list();
-                       tx.commit();
-               } catch (Exception e) {
-                       LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DBTABLE_QUERY_ERROR + className + e);     
-               }finally{
-                       try{
-                               session.close();
-                       }catch(Exception e1){
-                               LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
-                       }
-               }
-               return entityData;
-       }
+    @SuppressWarnings({ "unchecked", "rawtypes" })
+    @Override
+    public List<Object> getData(Class className) {
+        Session session = sessionfactory.openSession();
+        List<Object> data = null;
+        try{
+            Criteria cr = session.createCriteria(className);
+            data = cr.list();
+        }catch(Exception e){
+            LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DBTABLE_QUERY_ERROR + e);
+        }finally{
+            try{
+                session.close();
+            }catch(Exception e){
+                LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR+e);
+            }
+        }
+        return data;
+    }
+
+
+    @SuppressWarnings({ "rawtypes", "unchecked" })
+    @Override
+    public List<Object> getDataById(Class className, String columnName, String key) {
+        Session session = sessionfactory.openSession();
+        List<Object> data = null;
+        try {
+            Criteria cr = session.createCriteria(className);
+            if(columnName.contains(":") && key.contains(":")){
+                String[] columns = columnName.split(":");
+                String[] keys = key.split(":");
+                for(int i=0; i < columns.length; i++){
+                    cr.add(Restrictions.eq(columns[i], keys[i]));
+                }
+            }else{
+                cr.add(Restrictions.eq(columnName, key));
+            }
+            data = cr.list();
+        } catch (Exception e) {
+            LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DBTABLE_QUERY_ERROR + e);
+        }finally{
+            try{
+                session.close();
+            }catch(Exception e1){
+                LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
+            }
+        }
+        return data;
+    }
+
+    @Override
+    public void save(Object entity) {
+        Session session = sessionfactory.openSession();
+        Transaction tx = session.beginTransaction();
+        try {
+            session.persist(entity);
+            tx.commit();
+        }catch(Exception e){
+            LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Saving data to Table"+e);
+        }finally{
+            try{
+                session.close();
+            }catch(Exception e1){
+                LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
+            }
+        }
+
+    }
+
+    @Override
+    public void delete(Object entity) {
+        Session session = sessionfactory.openSession();
+        Transaction tx = session.beginTransaction();
+        try {
+            session.delete(entity);
+            tx.commit();
+        }catch(Exception e){
+            LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Deleting data from Table"+e);
+        }finally{
+            try{
+                session.close();
+            }catch(Exception e1){
+                LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
+            }
+        }
+
+    }
+
+
+    @Override
+    public void update(Object entity) {
+        Session session = sessionfactory.openSession();
+        Transaction tx = session.beginTransaction();
+        try {
+            session.update(entity);
+            tx.commit();
+        }catch(Exception e){
+            LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Updating data to Table"+e);
+        }finally{
+            try{
+                session.close();
+            }catch(Exception e1){
+                LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
+            }
+        }
+
+    }
+
+
+    @SuppressWarnings({ "unchecked", "rawtypes" })
+    @Override
+    public List<Object> checkDuplicateEntry(String value, String columnName, Class className) {
+        Session session = sessionfactory.openSession();
+        Transaction tx = session.beginTransaction();
+        List<Object> data = null;
+        String[] columnNames = null;
+        if(columnName != null && columnName.contains(":")){
+            columnNames = columnName.split(":");
+        }
+        String[] values = null;
+        if(value != null && value.contains(":")){
+            values = value.split(":");
+        }
+        try {
+            Criteria cr = session.createCriteria(className);
+            if(columnNames != null && values != null && columnNames.length == values.length){
+                for (int i = 0; i < columnNames.length; i++){
+                    cr.add(Restrictions.eq(columnNames[i],values[i]));
+                }
+            }else{
+                cr.add(Restrictions.eq(columnName,value));
+            }
+            data = cr.list();
+            tx.commit();
+        } catch (Exception e) {
+            LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Querying for Duplicate Entries for Table"+e + className);
+        }finally{
+            try{
+                session.close();
+            }catch(Exception e1){
+                LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
+            }
+        }
+        return data;
+    }
+
+
+    @SuppressWarnings("unchecked")
+    @Override
+    public List<PolicyRoles> getUserRoles() {
+        Session session = sessionfactory.openSession();
+        Transaction tx = session.beginTransaction();
+        List<PolicyRoles> rolesData = null;
+        try {
+            Criteria cr = session.createCriteria(PolicyRoles.class);
+            Disjunction disjunction = Restrictions.disjunction();
+            Conjunction conjunction1  = Restrictions.conjunction();
+            conjunction1.add(Restrictions.eq("role", "admin"));
+            Conjunction conjunction2  = Restrictions.conjunction();
+            conjunction2.add(Restrictions.eq("role", "editor"));
+            Conjunction conjunction3  = Restrictions.conjunction();
+            conjunction3.add(Restrictions.eq("role", "guest"));
+            disjunction.add(conjunction1);
+            disjunction.add(conjunction2);
+            disjunction.add(conjunction3);
+            rolesData = cr.add(disjunction).list();
+            tx.commit();
+        } catch (Exception e) {
+            LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Querying PolicyRoles Table"+e);
+        }finally{
+            try{
+                session.close();
+            }catch(Exception e1){
+                LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
+            }
+        }
+        return rolesData;
+    }
+
+
+    @Override
+    public List<Object> checkExistingGroupListforUpdate(String arg0, String arg1) {
+        return Collections.emptyList();
+    }
+
+
+    @Override
+    public void deleteAll() {
+        // Do nothing because this method is not used and is a placeholder to avoid 'Unimplemented Method' error
+    }
+
+
+    @SuppressWarnings("unchecked")
+    @Override
+    public List<Object> getDataByQuery(String query, SimpleBindings params) {
+        Session session = sessionfactory.openSession();
+        Transaction tx = session.beginTransaction();
+        List<Object> data = null;
+        try {
+            Query hbquery = session.createQuery(query);
+            for (Map.Entry<String, Object> paramPair : params.entrySet()) {
+                if(paramPair.getValue() instanceof java.lang.Long){
+                    hbquery.setLong(paramPair.getKey(), (long) paramPair.getValue());
+                }
+                else{
+                    hbquery.setParameter(paramPair.getKey(), paramPair.getValue());
+                }
+            }
+            data = hbquery.list();
+            tx.commit();
+        } catch (Exception e) {
+            LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DBTABLE_QUERY_ERROR + e);
+            throw e;
+        }finally{
+            try{
+                session.close();
+            }catch(HibernateException e1){
+                LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
+            }
+        }
+        return data;
+    }
+
+
+    @SuppressWarnings("rawtypes")
+    @Override
+    public Object getEntityItem(Class className, String columnName, String key) {
+        Session session = sessionfactory.openSession();
+        Transaction tx = session.beginTransaction();
+        Object data = null;
+        try {
+            Criteria cr = session.createCriteria(className);
+            if(columnName.contains(":") && key.contains(":")){
+                String[] columns = columnName.split(":");
+                String[] keys = key.split(":");
+                for(int i=0; i < columns.length; i++){
+                    cr.add(Restrictions.eq(columns[i], keys[i]));
+                }
+            }else{
+                cr.add(Restrictions.eq(columnName, key));
+            }
+            data = cr.list().get(0);
+            tx.commit();
+        } catch (Exception e) {
+            LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DBTABLE_QUERY_ERROR + e);
+        }finally{
+            try{
+                session.close();
+            }catch(Exception e1){
+                LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
+            }
+        }
+        return data;
+    }
+
+
+    @Override
+    public void updateClAlarms(String arg0, String arg1) {
+        // Do nothing because this method is not used and is a placeholder to avoid 'Unimplemented Method' error
+    }
+
+
+    @Override
+    public void updateClYaml(String arg0, String arg1) {
+        // Do nothing because this method is not used and is a placeholder to avoid 'Unimplemented Method' error
+    }
+
+
+    @Override
+    public void updateQuery(String query) {
+        Session session = sessionfactory.openSession();
+        Transaction tx = session.beginTransaction();
+        try {
+            Query hbquery = session.createQuery(query);
+            hbquery.executeUpdate();
+            tx.commit();
+        } catch (Exception e) {
+            LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Updating Database Table"+e);
+        }finally{
+            try{
+                session.close();
+            }catch(Exception e1){
+                LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
+            }
+        }
+
+    }
+
+
+    @SuppressWarnings({ "rawtypes", "unchecked" })
+    @Override
+    public List<String> getDataByColumn(Class className, String columnName) {
+        Session session = sessionfactory.openSession();
+        List<String> data = null;
+        try{
+            Criteria cr = session.createCriteria(className);
+            cr.setProjection(Projections.property(columnName));
+            data = cr.list();
+        }catch(Exception e){
+            LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DBTABLE_QUERY_ERROR + e);
+        }finally{
+            try{
+                session.close();
+            }catch(Exception e){
+                LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e);
+            }
+        }
+        return data;
+    }
+
+
+    @SuppressWarnings({ "rawtypes", "unchecked" })
+    @Override
+    public List<Object> getMultipleDataOnAddingConjunction(Class className, String columnName, List<String> data) {
+        Session session = sessionfactory.openSession();
+        Transaction tx = session.beginTransaction();
+        List<Object> entityData = null;
+        try {
+            Criteria cr = session.createCriteria(className);
+            Disjunction disjunction = Restrictions.disjunction();
+            List<Conjunction> conjunctionList = new ArrayList<>();
+            String[] columNames = columnName.split(":");
+            for(int i =0; i < data.size(); i++){
+                String[] entiySplit = data.get(i).split(":");
+                Conjunction conjunction = Restrictions.conjunction();
+                conjunction.add(Restrictions.eq(columNames[0], entiySplit[0]));
+                conjunction.add(Restrictions.eq(columNames[1], entiySplit[1]));
+                conjunctionList.add(conjunction);
+            }
+            for(int j =0 ; j < conjunctionList.size(); j++){
+                disjunction.add(conjunctionList.get(j));
+            }
+            entityData = cr.add(disjunction).list();
+            tx.commit();
+        } catch (Exception e) {
+            LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DBTABLE_QUERY_ERROR + className + e);
+        }finally{
+            try{
+                session.close();
+            }catch(Exception e1){
+                LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + DB_CONNECTION_CLOSING_ERROR + e1);
+            }
+        }
+        return entityData;
+    }
 
 }