X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=auth%2Fauth-cass%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Faaf%2Fauth%2Fdao%2Fcass%2FFutureDAO.java;h=7831815f528218140291b97df8bfa862f058707e;hb=a174f8ddbc5eb78a648fb68b33ef18cb64d81fda;hp=96cbf28a4d439f6af4c791347bc57d4f729192d0;hpb=c2445ee11b66efebdd5efe92fddf9526926c736e;p=aaf%2Fauthz.git diff --git a/auth/auth-cass/src/main/java/org/onap/aaf/auth/dao/cass/FutureDAO.java b/auth/auth-cass/src/main/java/org/onap/aaf/auth/dao/cass/FutureDAO.java index 96cbf28a..7831815f 100644 --- a/auth/auth-cass/src/main/java/org/onap/aaf/auth/dao/cass/FutureDAO.java +++ b/auth/auth-cass/src/main/java/org/onap/aaf/auth/dao/cass/FutureDAO.java @@ -29,7 +29,6 @@ import java.util.List; import java.util.UUID; import org.onap.aaf.auth.dao.CassDAOImpl; -import org.onap.aaf.auth.dao.DAOException; import org.onap.aaf.auth.dao.Loader; import org.onap.aaf.auth.env.AuthzTrans; import org.onap.aaf.auth.layer.Result; @@ -66,11 +65,13 @@ public class FutureDAO extends CassDAOImpl { public static class Data { public UUID id; - public String target; - public String memo; - public Date start; - public Date expires; - public ByteBuffer construct; // this is a blob in cassandra + public String target; + public String memo; + public Date start; + public Date expires; + public String target_key; + public Date target_date; + public ByteBuffer construct; // this is a blob in cassandra } private static class FLoader extends Loader { @@ -84,12 +85,14 @@ public class FutureDAO extends CassDAOImpl { @Override public Data load(Data data, Row row) { - data.id = row.getUUID(0); - data.target = row.getString(1); - data.memo = row.getString(2); - data.start = row.getTimestamp(3); - data.expires = row.getTimestamp(4); - data.construct = row.getBytes(5); + data.id = row.getUUID(0); + data.target = row.getString(1); + data.memo = row.getString(2); + data.start = row.getTimestamp(3); + data.expires = row.getTimestamp(4); + data.construct = row.getBytes(5); + data.target_key = row.getString(6); + data.target_date = row.getTimestamp(7); return data; } @@ -107,6 +110,8 @@ public class FutureDAO extends CassDAOImpl { obj[++idx] = data.start; obj[++idx] = data.expires; obj[++idx] = data.construct; + obj[++idx] = data.target_key; + obj[++idx] = data.target_date; } } @@ -125,8 +130,6 @@ public class FutureDAO extends CassDAOImpl { obj[++idx]=data.target; } },readConsistency); - - } public Result> readByStartAndTarget(AuthzTrans trans, Date start, String target) { @@ -136,7 +139,7 @@ public class FutureDAO extends CassDAOImpl { /** * Override create to add secondary ID to Subject in History, and create Data.ID, if it is null */ - public Result create(AuthzTrans trans, FutureDAO.Data data, String id) { + public Result create(AuthzTrans trans, FutureDAO.Data data, String id) { // If ID is not set (typical), create one. if (data.id==null) { StringBuilder sb = new StringBuilder(trans.user());