ECOMP-PAP-REST/src/main/java/org/openecomp/policy/pap/xacml/rest/daoimpl/ActionPolicyDictDaoImpl.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ECOMP-PAP-REST
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.openecomp.policy.pap.xacml.rest.daoimpl;
  22
  23 import java.util.ArrayList;
  24 import java.util.List;
  25
  26 import org.apache.commons.logging.Log;
  27 import org.apache.commons.logging.LogFactory;
  28 import org.hibernate.Criteria;
  29 import org.hibernate.Session;
  30 import org.hibernate.SessionFactory;
  31 import org.hibernate.Transaction;
  32 import org.hibernate.criterion.Restrictions;
  33 import org.openecomp.policy.pap.xacml.rest.HibernateSession;
  34 import org.openecomp.policy.rest.dao.ActionPolicyDictDao;
  35 import org.openecomp.policy.rest.jpa.ActionPolicyDict;
  36 import org.springframework.beans.factory.annotation.Autowired;
  37 import org.springframework.stereotype.Service;
  38
  39 import org.openecomp.policy.xacml.api.XACMLErrorConstants;
  40
  41
  42 @Service("ActionPolicyDictDao")
  43 public class ActionPolicyDictDaoImpl implements ActionPolicyDictDao {
  44         private static final Log logger = LogFactory.getLog(ActionPolicyDictDaoImpl.class);
  45         @Autowired
  46         SessionFactory sessionfactory;
  47
  48         public SessionFactory getSessionfactory() {
  49                 return sessionfactory;
  50         }
  51
  52         public void setSessionfactory(SessionFactory sessionfactory) {
  53                 this.sessionfactory = sessionfactory;
  54         }
  55
  56
  57         @SuppressWarnings("unchecked")
  58         @Override
  59         public List<ActionPolicyDict> getActionDictData() {
  60                 Session session = HibernateSession.getSessionFactory();
  61                 Transaction tx = session.beginTransaction();
  62
  63         List<ActionPolicyDict> actionDictData = null;
  64         try {
  65                 Criteria cr = session.createCriteria(ActionPolicyDict.class);
  66                 actionDictData = cr.list();
  67                         tx.commit();
  68                 } catch (Exception e) {
  69                         logger.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Querying ActionDictionary Table"+e);
  70                 }finally{
  71                         try{
  72                                 session.close();
  73                         }catch(Exception e1){
  74                                 logger.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Closing Connection/Statement"+e1);
  75                         }
  76                 }
  77                 return actionDictData;
  78         }
  79
  80         @Override
  81         public void Save(ActionPolicyDict action) {
  82                 Session session = HibernateSession.getSessionFactory();
  83                 Transaction tx = session.beginTransaction();
  84                 try {
  85                         session.persist(action);
  86                         tx.commit();
  87                 }catch(Exception e){
  88                         logger.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Saving ActionDictionary Table"+e);
  89                 }finally{
  90                         try{
  91                                 session.close();
  92                         }catch(Exception e1){
  93                                 logger.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Closing Connection/Statement"+e1);
  94                         }
  95                 }
  96         }
  97
  98         @Override
  99         public void delete(ActionPolicyDict action) {
 100                 Session session = HibernateSession.getSessionFactory();
 101                 Transaction tx = session.beginTransaction();
 102                 try {
 103                         session.delete(action);
 104                         tx.commit();
 105                 }catch(Exception e){
 106                         logger.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Deleting ActionDictionary Table"+e);
 107                 }finally{
 108                         try{
 109                                 session.close();
 110                         }catch(Exception e1){
 111                                 logger.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Closing Connection/Statement"+e1);
 112                         }
 113                 }
 114         }
 115
 116         @Override
 117         public void update(ActionPolicyDict action) {
 118                 Session session = HibernateSession.getSessionFactory();
 119                 Transaction tx = session.beginTransaction();
 120                 try {
 121                         session.update(action);
 122                         tx.commit();
 123                 }catch(Exception e){
 124                         logger.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Updating ActionDictionary Table"+e);
 125                 }finally{
 126                         try{
 127                                 session.close();
 128                         }catch(Exception e1){
 129                                 logger.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Closing Connection/Statement"+e1);
 130                         }
 131                 }
 132
 133         }
 134
 135         @SuppressWarnings("unchecked")
 136         @Override
 137         public List<String> getActionDictDataByName() {
 138                 Session session = HibernateSession.getSessionFactory();
 139                 Transaction tx = session.beginTransaction();
 140                 List<String> data = new ArrayList<String>();
 141                 try {
 142                         Criteria cr = session.createCriteria(ActionPolicyDict.class);
 143                         List<ActionPolicyDict> attributeData = cr.list();
 144                         for(int i = 0; i < attributeData.size(); i++){
 145                                 data.add(attributeData.get(i).getAttributeName());
 146                         }
 147                         tx.commit();
 148                 } catch (Exception e) {
 149                         logger.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Querying ActionDictionary Table"+e);
 150                 }finally{
 151                         try{
 152                                 session.close();
 153                         }catch(Exception e1){
 154                                 logger.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Closing Connection/Statement"+e1);
 155                         }
 156                 }
 157                 return data;
 158         }
 159
 160         @SuppressWarnings("unchecked")
 161         @Override
 162         public ActionPolicyDict getActionEntityDatabyId(String action) {
 163                 Session session = HibernateSession.getSessionFactory();
 164                 Transaction tx = session.beginTransaction();
 165                 ActionPolicyDict data = null;
 166                 try {
 167                         Criteria cr = session.createCriteria(ActionPolicyDict.class);
 168                         List<ActionPolicyDict> attributeData = cr.add(Restrictions.eq("attributeName", action)).list();
 169                         for(Object entity : attributeData){
 170                                 data = (ActionPolicyDict) entity;
 171                         }
 172                         tx.commit();
 173                 } catch (Exception e) {
 174                         logger.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Querying ActionDictionary Table"+e);
 175                 }finally{
 176                         try{
 177                                 session.close();
 178                         }catch(Exception e1){
 179                                 logger.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error While Closing Connection/Statement"+e1);
 180                         }
 181                 }
 182                 return data;
 183         }
 184
 185 }