+++ /dev/null
-/*******************************************************************************\r
- * ============LICENSE_START====================================================\r
- * * org.onap.aaf\r
- * * ===========================================================================\r
- * * Copyright © 2017 AT&T Intellectual Property. All rights reserved.\r
- * * ===========================================================================\r
- * * Licensed under the Apache License, Version 2.0 (the "License");\r
- * * you may not use this file except in compliance with the License.\r
- * * You may obtain a copy of the License at\r
- * * \r
- * * http://www.apache.org/licenses/LICENSE-2.0\r
- * * \r
- * * Unless required by applicable law or agreed to in writing, software\r
- * * distributed under the License is distributed on an "AS IS" BASIS,\r
- * * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
- * * See the License for the specific language governing permissions and\r
- * * limitations under the License.\r
- * * ============LICENSE_END====================================================\r
- * *\r
- * * ECOMP is a trademark and service mark of AT&T Intellectual Property.\r
- * *\r
- ******************************************************************************/\r
-package org.onap.aaf.dao.aaf.cass;\r
-\r
-import java.io.ByteArrayOutputStream;\r
-import java.io.DataInputStream;\r
-import java.io.DataOutputStream;\r
-import java.io.IOException;\r
-import java.nio.ByteBuffer;\r
-import java.util.HashMap;\r
-import java.util.HashSet;\r
-import java.util.Iterator;\r
-import java.util.List;\r
-import java.util.Map;\r
-import java.util.Map.Entry;\r
-\r
-import org.onap.aaf.authz.env.AuthzTrans;\r
-import org.onap.aaf.authz.layer.Result;\r
-import org.onap.aaf.dao.Bytification;\r
-import org.onap.aaf.dao.Cached;\r
-import org.onap.aaf.dao.CassAccess;\r
-import org.onap.aaf.dao.CassDAOImpl;\r
-import org.onap.aaf.dao.Loader;\r
-import org.onap.aaf.dao.Streamer;\r
-\r
-import java.util.Set;\r
-\r
-import org.onap.aaf.inno.env.APIException;\r
-import org.onap.aaf.inno.env.Env;\r
-import org.onap.aaf.inno.env.TimeTaken;\r
-import com.datastax.driver.core.Cluster;\r
-import com.datastax.driver.core.ResultSet;\r
-import com.datastax.driver.core.Row;\r
-import com.datastax.driver.core.exceptions.DriverException;\r
-\r
-/**\r
- * NsDAO\r
- * \r
- * Data Access Object for Namespace Data\r
- *\r
- */\r
-public class NsDAO extends CassDAOImpl<AuthzTrans,NsDAO.Data> {\r
- public static final String TABLE = "ns";\r
- public static final String TABLE_ATTRIB = "ns_attrib";\r
- public static final int CACHE_SEG = 0x40; // yields segment 0x0-0x3F\r
- public static final int ROOT = 1;\r
- public static final int COMPANY=2;\r
- public static final int APP = 3;\r
-\r
- private static final String BEGIN_BATCH = "BEGIN BATCH\n";\r
- private static final String APPLY_BATCH = "APPLY BATCH;\n";\r
- private static final String SQSCCR = "';\n";\r
- private static final String SQCSQ = "','";\r
- \r
- private HistoryDAO historyDAO;\r
- private CacheInfoDAO infoDAO;\r
- private PSInfo psNS;\r
-\r
- public NsDAO(AuthzTrans trans, Cluster cluster, String keyspace) throws APIException, IOException {\r
- super(trans, NsDAO.class.getSimpleName(),cluster,keyspace,Data.class,TABLE, readConsistency(trans,TABLE), writeConsistency(trans,TABLE));\r
- init(trans);\r
- }\r
-\r
- public NsDAO(AuthzTrans trans, HistoryDAO hDAO, CacheInfoDAO iDAO) throws APIException, IOException {\r
- super(trans, NsDAO.class.getSimpleName(),hDAO,Data.class,TABLE, readConsistency(trans,TABLE), writeConsistency(trans,TABLE));\r
- historyDAO=hDAO;\r
- infoDAO = iDAO;\r
- init(trans);\r
- }\r
-\r
-\r
- //////////////////////////////////////////\r
- // Data Definition, matches Cassandra DM\r
- //////////////////////////////////////////\r
- private static final int KEYLIMIT = 1;\r
- /**\r
- * Data class that matches the Cassandra Table "role"\r
- * \r
- */\r
- public static class Data extends CacheableData implements Bytification {\r
- public String name;\r
- public int type;\r
- public String description;\r
- public String parent;\r
- public Map<String,String> attrib;\r
-\r
-// ////////////////////////////////////////\r
-// // Getters\r
- public Map<String,String> attrib(boolean mutable) {\r
- if (attrib == null) {\r
- attrib = new HashMap<String,String>();\r
- } else if (mutable && !(attrib instanceof HashMap)) {\r
- attrib = new HashMap<String,String>(attrib);\r
- }\r
- return attrib;\r
- }\r
-\r
- @Override\r
- public int[] invalidate(Cached<?,?> cache) {\r
- return new int[] {\r
- seg(cache,name)\r
- };\r
- }\r
-\r
- public NsSplit split(String name) {\r
- return new NsSplit(this,name);\r
- }\r
-\r
- @Override\r
- public ByteBuffer bytify() throws IOException {\r
- ByteArrayOutputStream baos = new ByteArrayOutputStream();\r
- NSLoader.deflt.marshal(this,new DataOutputStream(baos));\r
- return ByteBuffer.wrap(baos.toByteArray());\r
- }\r
- \r
- @Override\r
- public void reconstitute(ByteBuffer bb) throws IOException {\r
- NSLoader.deflt.unmarshal(this,toDIS(bb));\r
- }\r
- \r
- @Override\r
- public String toString() {\r
- return name;\r
- }\r
- \r
- }\r
- \r
- private void init(AuthzTrans trans) throws APIException, IOException {\r
- // Set up sub-DAOs\r
- if(historyDAO==null) {\r
- historyDAO = new HistoryDAO(trans, this);\r
- }\r
- if(infoDAO==null) {\r
- infoDAO = new CacheInfoDAO(trans,this);\r
- }\r
-\r
- String[] helpers = setCRUD(trans, TABLE, Data.class, NSLoader.deflt,4/*need to skip attrib */);\r
- \r
- psNS = new PSInfo(trans, SELECT_SP + helpers[FIELD_COMMAS] + " FROM " + TABLE +\r
- " WHERE parent = ?", new NSLoader(1),readConsistency);\r
-\r
- }\r
- \r
- private static final class NSLoader extends Loader<Data> implements Streamer<Data> {\r
- public static final int MAGIC=250935515;\r
- public static final int VERSION=1;\r
- public static final int BUFF_SIZE=48;\r
-\r
- public static final NSLoader deflt = new NSLoader(KEYLIMIT);\r
- \r
- public NSLoader(int keylimit) {\r
- super(keylimit);\r
- }\r
-\r
- @Override\r
- public Data load(Data data, Row row) {\r
- // Int more efficient\r
- data.name = row.getString(0);\r
- data.type = row.getInt(1);\r
- data.description = row.getString(2);\r
- data.parent = row.getString(3);\r
- return data;\r
- }\r
-\r
- @Override\r
- protected void key(Data data, int idx, Object[] obj) {\r
- obj[idx]=data.name;\r
- }\r
-\r
- @Override\r
- protected void body(Data data, int _idx, Object[] obj) {\r
- int idx = _idx;\r
-\r
- obj[idx]=data.type;\r
- obj[++idx]=data.description;\r
- obj[++idx]=data.parent;\r
- }\r
- \r
- @Override\r
- public void marshal(Data data, DataOutputStream os) throws IOException {\r
- writeHeader(os,MAGIC,VERSION);\r
- writeString(os, data.name);\r
- os.writeInt(data.type);\r
- writeString(os,data.description);\r
- writeString(os,data.parent);\r
- if(data.attrib==null) {\r
- os.writeInt(-1);\r
- } else {\r
- os.writeInt(data.attrib.size());\r
- for(Entry<String, String> es : data.attrib(false).entrySet()) {\r
- writeString(os,es.getKey());\r
- writeString(os,es.getValue());\r
- }\r
- }\r
- }\r
-\r
- @Override\r
- public void unmarshal(Data data, DataInputStream is) throws IOException {\r
- /*int version = */readHeader(is,MAGIC,VERSION);\r
- // If Version Changes between Production runs, you'll need to do a switch Statement, and adequately read in fields\r
- \r
- byte[] buff = new byte[BUFF_SIZE];\r
- data.name = readString(is, buff);\r
- data.type = is.readInt();\r
- data.description = readString(is,buff);\r
- data.parent = readString(is,buff);\r
- int count = is.readInt();\r
- if(count>0) {\r
- Map<String, String> da = data.attrib(true);\r
- for(int i=0;i<count;++i) {\r
- da.put(readString(is,buff), readString(is,buff));\r
- }\r
- }\r
- }\r
-\r
- }\r
- \r
- @Override\r
- public Result<Data> create(AuthzTrans trans, Data data) {\r
- String ns = data.name;\r
- // Ensure Parent is set\r
- int ldot = ns.lastIndexOf('.');\r
- data.parent=ldot<0?".":ns.substring(0,ldot);\r
-\r
- // insert Attributes\r
- StringBuilder stmt = new StringBuilder();\r
- stmt.append(BEGIN_BATCH);\r
- attribInsertStmts(stmt, data);\r
- stmt.append(APPLY_BATCH);\r
- try {\r
- getSession(trans).execute(stmt.toString());\r
-//// TEST CODE for Exception \r
-// boolean force = true; \r
-// if(force) {\r
-// throw new com.datastax.driver.core.exceptions.NoHostAvailableException(new HashMap<InetSocketAddress,Throwable>());\r
-//// throw new com.datastax.driver.core.exceptions.AuthenticationException(new InetSocketAddress(9999),"Sample Message");\r
-// }\r
-////END TEST CODE\r
-\r
- } catch (DriverException | APIException | IOException e) {\r
- reportPerhapsReset(trans,e);\r
- trans.info().log(stmt);\r
- return Result.err(Result.ERR_Backend, "Backend Access");\r
- }\r
- return super.create(trans, data);\r
- }\r
-\r
- @Override\r
- public Result<Void> update(AuthzTrans trans, Data data) {\r
- String ns = data.name;\r
- // Ensure Parent is set\r
- int ldot = ns.lastIndexOf('.');\r
- data.parent=ldot<0?".":ns.substring(0,ldot);\r
-\r
- StringBuilder stmt = new StringBuilder();\r
- stmt.append(BEGIN_BATCH);\r
- try {\r
- Map<String, String> localAttr = data.attrib;\r
- Result<Map<String, String>> rremoteAttr = readAttribByNS(trans,ns);\r
- if(rremoteAttr.notOK()) {\r
- return Result.err(rremoteAttr);\r
- }\r
- // update Attributes\r
- String str;\r
- for(Entry<String, String> es : localAttr.entrySet()) {\r
- str = rremoteAttr.value.get(es.getKey());\r
- if(str==null || !str.equals(es.getValue())) {\r
- attribInsertStmt(stmt, ns, es.getKey(),es.getValue());\r
- }\r
- }\r
- \r
- // No point in deleting... insert overwrites...\r
-// for(Entry<String, String> es : remoteAttr.entrySet()) {\r
-// str = localAttr.get(es.getKey());\r
-// if(str==null || !str.equals(es.getValue())) {\r
-// attribDeleteStmt(stmt, ns, es.getKey());\r
-// }\r
-// }\r
- if(stmt.length()>BEGIN_BATCH.length()) {\r
- stmt.append(APPLY_BATCH);\r
- getSession(trans).execute(stmt.toString());\r
- }\r
- } catch (DriverException | APIException | IOException e) {\r
- reportPerhapsReset(trans,e);\r
- trans.info().log(stmt);\r
- return Result.err(Result.ERR_Backend, CassAccess.ERR_ACCESS_MSG);\r
- }\r
-\r
- return super.update(trans,data);\r
- }\r
-\r
- /* (non-Javadoc)\r
- * @see org.onap.aaf.dao.CassDAOImpl#read(org.onap.aaf.inno.env.TransStore, java.lang.Object)\r
- */\r
- @Override\r
- public Result<List<Data>> read(AuthzTrans trans, Data data) {\r
- Result<List<Data>> rld = super.read(trans, data);\r
- \r
- if(rld.isOKhasData()) {\r
- for(Data d : rld.value) {\r
- // Note: Map is null at this point, save time/mem by assignment\r
- Result<Map<String, String>> rabn = readAttribByNS(trans,d.name);\r
- if(rabn.isOK()) {\r
- d.attrib = rabn.value;\r
- } else {\r
- return Result.err(rabn);\r
- }\r
- }\r
- }\r
- return rld;\r
- }\r
-\r
- /* (non-Javadoc)\r
- * @see org.onap.aaf.dao.CassDAOImpl#read(org.onap.aaf.inno.env.TransStore, java.lang.Object[])\r
- */\r
- @Override\r
- public Result<List<Data>> read(AuthzTrans trans, Object... key) {\r
- Result<List<Data>> rld = super.read(trans, key);\r
-\r
- if(rld.isOKhasData()) {\r
- for(Data d : rld.value) {\r
- // Note: Map is null at this point, save time/mem by assignment\r
- Result<Map<String, String>> rabn = readAttribByNS(trans,d.name);\r
- if(rabn.isOK()) {\r
- d.attrib = rabn.value;\r
- } else {\r
- return Result.err(rabn);\r
- }\r
- }\r
- }\r
- return rld;\r
- }\r
-\r
- @Override\r
- public Result<Void> delete(AuthzTrans trans, Data data, boolean reread) {\r
- TimeTaken tt = trans.start("Delete NS Attributes " + data.name, Env.REMOTE);\r
- try {\r
- StringBuilder stmt = new StringBuilder();\r
- attribDeleteAllStmt(stmt, data);\r
- try {\r
- getSession(trans).execute(stmt.toString());\r
- } catch (DriverException | APIException | IOException e) {\r
- reportPerhapsReset(trans,e);\r
- trans.info().log(stmt);\r
- return Result.err(Result.ERR_Backend, CassAccess.ERR_ACCESS_MSG);\r
- }\r
- } finally {\r
- tt.done();\r
- }\r
- return super.delete(trans, data, reread);\r
-\r
- }\r
- \r
- public Result<Map<String,String>> readAttribByNS(AuthzTrans trans, String ns) {\r
- Map<String,String> map = new HashMap<String,String>();\r
- TimeTaken tt = trans.start("readAttribByNS " + ns, Env.REMOTE);\r
- try {\r
- ResultSet rs = getSession(trans).execute("SELECT key,value FROM " \r
- + TABLE_ATTRIB \r
- + " WHERE ns='"\r
- + ns\r
- + "';");\r
- \r
- for(Iterator<Row> iter = rs.iterator();iter.hasNext(); ) {\r
- Row r = iter.next();\r
- map.put(r.getString(0), r.getString(1));\r
- }\r
- } catch (DriverException | APIException | IOException e) {\r
- reportPerhapsReset(trans,e);\r
- return Result.err(Result.ERR_Backend, CassAccess.ERR_ACCESS_MSG);\r
- } finally {\r
- tt.done();\r
- }\r
- return Result.ok(map);\r
- }\r
-\r
- public Result<Set<String>> readNsByAttrib(AuthzTrans trans, String key) {\r
- Set<String> set = new HashSet<String>();\r
- TimeTaken tt = trans.start("readNsBykey " + key, Env.REMOTE);\r
- try {\r
- ResultSet rs = getSession(trans).execute("SELECT ns FROM " \r
- + TABLE_ATTRIB \r
- + " WHERE key='"\r
- + key\r
- + "';");\r
- \r
- for(Iterator<Row> iter = rs.iterator();iter.hasNext(); ) {\r
- Row r = iter.next();\r
- set.add(r.getString(0));\r
- }\r
- } catch (DriverException | APIException | IOException e) {\r
- reportPerhapsReset(trans,e);\r
- return Result.err(Result.ERR_Backend, CassAccess.ERR_ACCESS_MSG);\r
- } finally {\r
- tt.done();\r
- }\r
- return Result.ok(set);\r
- }\r
-\r
- public Result<Void> attribAdd(AuthzTrans trans, String ns, String key, String value) {\r
- try {\r
- getSession(trans).execute(attribInsertStmt(new StringBuilder(),ns,key,value).toString());\r
- return Result.ok();\r
- } catch (DriverException | APIException | IOException e) {\r
- reportPerhapsReset(trans,e);\r
- return Result.err(Result.ERR_Backend, CassAccess.ERR_ACCESS_MSG);\r
- }\r
- }\r
- \r
- private StringBuilder attribInsertStmt(StringBuilder sb, String ns, String key, String value) {\r
- sb.append("INSERT INTO ");\r
- sb.append(TABLE_ATTRIB);\r
- sb.append(" (ns,key,value) VALUES ('");\r
- sb.append(ns);\r
- sb.append(SQCSQ);\r
- sb.append(key);\r
- sb.append(SQCSQ);\r
- sb.append(value);\r
- sb.append("');");\r
- return sb;\r
- }\r
- \r
- public Result<Void> attribRemove(AuthzTrans trans, String ns, String key) {\r
- try {\r
- getSession(trans).execute(attribDeleteStmt(new StringBuilder(),ns,key).toString());\r
- return Result.ok();\r
- } catch (DriverException | APIException | IOException e) {\r
- reportPerhapsReset(trans,e);\r
- return Result.err(Result.ERR_Backend, CassAccess.ERR_ACCESS_MSG);\r
- }\r
- }\r
- \r
- private StringBuilder attribDeleteStmt(StringBuilder stmt, String ns, String key) {\r
- stmt.append("DELETE FROM ");\r
- stmt.append(TABLE_ATTRIB);\r
- stmt.append(" WHERE ns='");\r
- stmt.append(ns);\r
- stmt.append("' AND key='");\r
- stmt.append(key);\r
- stmt.append("';");\r
- return stmt;\r
- }\r
- \r
- private void attribDeleteAllStmt(StringBuilder stmt, Data data) {\r
- stmt.append(" DELETE FROM ");\r
- stmt.append(TABLE_ATTRIB);\r
- stmt.append(" WHERE ns='");\r
- stmt.append(data.name);\r
- stmt.append(SQSCCR);\r
- }\r
-\r
- private void attribInsertStmts(StringBuilder stmt, Data data) {\r
- // INSERT new Attrib\r
- for(Entry<String,String> es : data.attrib(false).entrySet() ) {\r
- stmt.append(" ");\r
- attribInsertStmt(stmt,data.name,es.getKey(),es.getValue());\r
- }\r
- }\r
-\r
- /**\r
- * Add description to Namespace\r
- * @param trans\r
- * @param ns\r
- * @param description\r
- * @return\r
- */\r
- public Result<Void> addDescription(AuthzTrans trans, String ns, String description) {\r
- try {\r
- getSession(trans).execute(UPDATE_SP + TABLE + " SET description = '" \r
- + description + "' WHERE name = '" + ns + "';");\r
- } catch (DriverException | APIException | IOException e) {\r
- reportPerhapsReset(trans,e);\r
- return Result.err(Result.ERR_Backend, CassAccess.ERR_ACCESS_MSG);\r
- }\r
-\r
- Data data = new Data();\r
- data.name=ns;\r
- wasModified(trans, CRUD.update, data, "Added description " + description + " to namespace " + ns, null );\r
- return Result.ok();\r
- }\r
-\r
- public Result<List<Data>> getChildren(AuthzTrans trans, String parent) {\r
- return psNS.read(trans, R_TEXT, new Object[]{parent});\r
- }\r
- \r
-\r
- /**\r
- * Log Modification statements to History\r
- * \r
- * @param modified which CRUD action was done\r
- * @param data entity data that needs a log entry\r
- * @param overrideMessage if this is specified, we use it rather than crafting a history message based on data\r
- */\r
- @Override\r
- protected void wasModified(AuthzTrans trans, CRUD modified, Data data, String ... override) {\r
- boolean memo = override.length>0 && override[0]!=null;\r
- boolean subject = override.length>1 && override[1]!=null;\r
-\r
- //TODO Must log history\r
- HistoryDAO.Data hd = HistoryDAO.newInitedData();\r
- hd.user = trans.user();\r
- hd.action = modified.name();\r
- hd.target = TABLE;\r
- hd.subject = subject ? override[1] : data.name;\r
- hd.memo = memo ? override[0] : (data.name + " was " + modified.name() + 'd' );\r
- if(modified==CRUD.delete) {\r
- try {\r
- hd.reconstruct = data.bytify();\r
- } catch (IOException e) {\r
- trans.error().log(e,"Could not serialize NsDAO.Data");\r
- }\r
- }\r
-\r
- if(historyDAO.create(trans, hd).status!=Status.OK) {\r
- trans.error().log("Cannot log to History");\r
- }\r
- if(infoDAO.touch(trans, TABLE,data.invalidate(cache)).notOK()) {\r
- trans.error().log("Cannot touch CacheInfo");\r
- }\r
- }\r
-\r
-}\r
Code Review / aaf / authz.git / blobdiff