Merge "Update junits"

diff --combined music-core/src/main/java/org/onap/music/lockingservice/cassandra/CassaLockStore.java
index 6a68b81,cb6816e..e953334
--- 1/music-core/src/main/java/org/onap/music/lockingservice/cassandra/CassaLockStore.java
--- 2/music-core/src/main/java/org/onap/music/lockingservice/cassandra/CassaLockStore.java
+++ b/music-core/src/main/java/org/onap/music/lockingservice/cassandra/CassaLockStore.java
@@@ -129,7 -129,7 +129,7 @@@ public class CassaLockStore 
          table = table_prepend_name+table;
          String tabQuery = "CREATE TABLE IF NOT EXISTS "+keyspace+"."+table
                  + " ( key text, lockReference bigint, createTime text, acquireTime text, guard bigint static, "
-                 + "lockType text, owner text, PRIMARY KEY ((key), lockReference) ) "
+                 + "lockType text, leasePeriodTime bigint, owner text, PRIMARY KEY ((key), lockReference) ) "
                  + "WITH CLUSTERING ORDER BY (lockReference ASC);";
          PreparedQueryObject queryObject = new PreparedQueryObject();
          
@@@ -478,7 -478,7 +478,7 @@@
          queryObject.appendQueryString(" WHERE lockType = ? ALLOW FILTERING");
          queryObject.addValue(LockType.WRITE);
  
 -        DeadlockDetectionUtil ddu = new DeadlockDetectionUtil();
 +        DeadlockDetectionUtil ddu = getDeadlockDetectionUtil();
  
          ResultSet rs = dsHandle.executeLocalQuorumConsistencyGet(queryObject);
          logger.debug("rs has " + rs.getAvailableWithoutFetching() + (rs.isFullyFetched()?"":" (or more!)") );
@@@ -493,14 -493,6 +493,14 @@@
          return deadlock;
      }
  
 +    /**
 +     * This is used for testing purpose
 +     * @return new DeadlockDetectionUtil object
 +     */
 +    DeadlockDetectionUtil getDeadlockDetectionUtil() {
 +      return new DeadlockDetectionUtil();
 +    }
 +    
      public List<String> getAllLocksForOwner(String ownerId, String keyspace, String table) throws MusicServiceException, MusicQueryException {
          List<String> toRet = new ArrayList<String>();
          String lockTable = table_prepend_name + table;