gerrit.onap Code Review - ui/dmaapbc.git/blob

   1 package org.onap.dcae.dmaapbc.dbcapp.service;
   2
   3 import java.util.ArrayList;
   4 import java.util.List;
   5
   6 import org.hibernate.criterion.Criterion;
   7 import org.hibernate.criterion.Restrictions;
   8 import org.onap.dcae.dmaapbc.dbcapp.domain.DmaapAccess;
   9 import org.onap.dcae.dmaapbc.dbcapp.domain.ManifestTransportModel;
  10 import org.openecomp.portalsdk.core.service.DataAccessService;
  11 import org.springframework.beans.factory.annotation.Autowired;
  12 import org.springframework.stereotype.Service;
  13 import org.springframework.transaction.annotation.Transactional;
  14
  15 /**
  16  * Hibernate-assisted methods to manipulate the DBCA_DMAAP table.
  17  */
  18 @Service("dmaapAccessService")
  19 @Transactional
  20 public class DmaapAccessServiceImpl implements DmaapAccessService {
  21
  22         @Autowired
  23         private DataAccessService dataAccessService;
  24
  25         public DataAccessService getDataAccessService() {
  26                 return dataAccessService;
  27         }
  28
  29         public void setDataAccessService(DataAccessService dataAccessService) {
  30                 this.dataAccessService = dataAccessService;
  31         }
  32
  33         /*
  34          * (non-Javadoc)
  35          * @see org.onap.dmaapbc.dbcapp.service.DmaapAccessService#getManifest()
  36          */
  37         @Override
  38         public ManifestTransportModel getManifest() {
  39                 return null;
  40         }
  41
  42         /*
  43          * (non-Javadoc)
  44          * @see org.onap.dmaapbc.dbcapp.service.DmaapAccessService#getDmaapAccessCount()
  45          */
  46         @SuppressWarnings("unchecked")
  47         @Override
  48         public int getDmaapAccessCount() {
  49                 List<DmaapAccess> accesses = (List<DmaapAccess>) getDataAccessService().getList(DmaapAccess.class, null);
  50                 return accesses.size();
  51         }
  52
  53         /*
  54          * (non-Javadoc)
  55          * @see org.onap.dmaapbc.dbcapp.service.DmaapAccessService#getDmaapAccessList(java.lang.String)
  56          */
  57         @SuppressWarnings("unchecked")
  58         @Override
  59         public List<DmaapAccess> getDmaapAccessList(String userId) {
  60                 List<Criterion> restrictionsList = new ArrayList<Criterion>();
  61                 Criterion criterion1 = Restrictions.eq("userId", userId);
  62                 restrictionsList.add(criterion1);
  63                 List<DmaapAccess> accesses = (List<DmaapAccess>) getDataAccessService().getList(DmaapAccess.class, null,
  64                                 restrictionsList, null);
  65                 return accesses;
  66         }
  67
  68         /*
  69          * (non-Javadoc)
  70          * @see org.onap.dmaapbc.dbcapp.service.DmaapAccessService#getDmaapAccess(java.lang.Long)
  71          */
  72         @Override
  73         public DmaapAccess getDmaapAccess(Long dmaapId) {
  74                 return (DmaapAccess) getDataAccessService().getDomainObject(DmaapAccess.class, dmaapId, null);
  75         }
  76
  77         /*
  78          * (non-Javadoc)
  79          * @see org.onap.dmaapbc.dbcapp.service.DmaapAccessService#saveDmaapAccess(org.onap.dmaapbc.dbcapp.domain.DmaapAccess)
  80          */
  81         @Override
  82         public void saveDmaapAccess(DmaapAccess dmaap) {
  83                 getDataAccessService().saveDomainObject(dmaap, null);
  84         }
  85
  86         /*
  87          * (non-Javadoc)
  88          * @see org.onap.dmaapbc.dbcapp.service.DmaapAccessService#deleteDmaapAccess(java.lang.Long)
  89          */
  90         @Override
  91         public void deleteDmaapAccess(Long dmaapId) {
  92                 DmaapAccess dmaapAccess = getDmaapAccess(dmaapId);
  93                 if (dmaapAccess != null)
  94                         getDataAccessService().deleteDomainObject(dmaapAccess, null);
  95         }
  96
  97 }