2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 - 2019 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
11 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
21 package org.openecomp.core.tools.store;
23 import com.datastax.driver.core.ResultSet;
24 import com.datastax.driver.core.Row;
25 import com.datastax.driver.mapping.Result;
26 import com.datastax.driver.mapping.annotations.Accessor;
27 import com.datastax.driver.mapping.annotations.Query;
28 import org.openecomp.core.nosqldb.api.NoSqlDb;
29 import org.openecomp.core.nosqldb.factory.NoSqlDbFactory;
30 import org.openecomp.sdc.itempermissions.type.ItemPermissionsEntity;
32 import java.util.List;
33 import java.util.Objects;
34 import java.util.Optional;
37 public class PermissionHandler {
39 private static NoSqlDb noSqlDb = NoSqlDbFactory.getInstance().createInterface();
40 private static PermissionAccessor accessor =
41 noSqlDb.getMappingManager().createAccessor(PermissionAccessor.class);
44 public Optional<String> getItemUserPermission(String itemId, String user) {
45 ResultSet resultSet = accessor.getItemUserPermission(itemId, user);
46 Row row = resultSet.one();
48 if (Objects.nonNull(row)) {
49 return Optional.of(row.getString("permission"));
51 return Optional.empty();
55 public void setItemUserPermission(String itemId, String user, String permission) {
56 accessor.setItemUserPermission(itemId, user, permission);
59 public void addItem(Set<String> items, String userId, String permission){
60 accessor.addItem(items,userId,permission);
63 public List<ItemPermissionsEntity> getAll(){
64 return accessor.getAll().all();
69 interface PermissionAccessor {
72 @Query("INSERT into dox.item_permissions (item_id,user_id,permission) VALUES (?,?,?)")
73 void setItemUserPermission(String permission, String itemId, String userId);
76 @Query("SELECT permission FROM dox.item_permissions WHERE item_id=? AND user_id=?")
77 ResultSet getItemUserPermission(String itemId, String userId);
79 @Query("SELECT * from dox.item_permissions")
80 Result<ItemPermissionsEntity> getAll();
82 @Query("update dox.user_permission_items set item_list=item_list+? WHERE user_id = ? AND permission = ?")
83 void addItem(Set<String> items, String userId, String permission);