openecomp-be/lib/openecomp-item-permissions-lib/openecomp-item-permissions-core/src/main/java/org/openecomp/sdc/itempermissions/dao/impl/ItemPermissionsDaoImpl.java

   1 package org.openecomp.sdc.itempermissions.dao.impl;
   2
   3 import com.datastax.driver.core.ResultSet;
   4 import com.datastax.driver.mapping.Result;
   5 import com.datastax.driver.mapping.annotations.Accessor;
   6 import com.datastax.driver.mapping.annotations.Query;
   7 import org.openecomp.core.nosqldb.api.NoSqlDb;
   8 import org.openecomp.core.nosqldb.factory.NoSqlDbFactory;
   9 import org.openecomp.sdc.itempermissions.dao.ItemPermissionsDao;
  10 import org.openecomp.sdc.itempermissions.type.ItemPermissionsEntity;
  11
  12 import java.util.Collection;
  13 import java.util.Set;
  14
  15 /**
  16  * Created by ayalaben on 6/20/2017.
  17  */
  18 public class ItemPermissionsDaoImpl implements ItemPermissionsDao {
  19   private static final NoSqlDb noSqlDb = NoSqlDbFactory.getInstance().createInterface();
  20   private static ItemPermissionsAccessor accessor =
  21       noSqlDb.getMappingManager().createAccessor(ItemPermissionsAccessor.class);
  22
  23   @Override
  24   public Collection<ItemPermissionsEntity> listItemPermissions(String itemId) {
  25     return accessor.getItemPermissions(itemId).all();
  26   }
  27
  28   @Override
  29   public void updateItemPermissions(String itemId, String permission, Set<String> addedUsersIds,
  30                                     Set<String> removedUsersIds) {
  31     addedUsersIds.forEach(userId -> accessor.addPermission(itemId,userId,permission));
  32     removedUsersIds.forEach(userId -> accessor.deletePermission(itemId,userId));
  33   }
  34
  35   @Override
  36   public void addUserPermission(String itemId, String userId, String permission){
  37     accessor.addPermission(itemId,userId,permission);
  38   }
  39
  40   @Override
  41   public String getUserItemPermiission(String itemId, String userId) {
  42
  43     ResultSet result =  accessor.getUserItemPermission(itemId,userId);
  44     if (result.getAvailableWithoutFetching() < 1) {
  45       return null;
  46     }
  47     return result.one().getString(0);
  48   }
  49
  50
  51   @Accessor
  52   interface ItemPermissionsAccessor {
  53     @Query("select * from dox.item_permissions WHERE item_id = ?")
  54     Result<ItemPermissionsEntity> getItemPermissions(String itemId);
  55
  56     @Query("select permission from dox.item_permissions WHERE item_id = ? AND user_id=?")
  57     ResultSet getUserItemPermission(String itemId,String userId);
  58
  59     @Query("delete from dox.item_permissions where item_id = ? and user_id = ?")
  60     void deletePermission(String itemId, String userId);
  61
  62     @Query("insert into dox.item_permissions (item_id,user_id,permission) values (?,?,?)")
  63     void addPermission(String itemId,String userId, String permission);
  64
  65   }
  66 }