X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Forg%2Fonap%2Fmusic%2Funittests%2FTestMusicCore.java;h=3355e4cd727a3dec71e534235cd9b78cd40f86db;hb=f327e0cb4a14ff8d4f85e5ae9da5986b8c87ab8c;hp=2deb3496f70d4349a4abdfd36421af2ba1fa42c2;hpb=168c54c6e774563910a3ed5a7480ea63cd3fe572;p=music.git diff --git a/src/test/java/org/onap/music/unittests/TestMusicCore.java b/src/test/java/org/onap/music/unittests/TestMusicCore.java index 2deb3496..3355e4cd 100644 --- a/src/test/java/org/onap/music/unittests/TestMusicCore.java +++ b/src/test/java/org/onap/music/unittests/TestMusicCore.java @@ -1,440 +1,463 @@ -/* - * ============LICENSE_START========================================== - * org.onap.music - * =================================================================== - * Copyright (c) 2017 AT&T Intellectual Property - * =================================================================== - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * ============LICENSE_END============================================= - * ==================================================================== - */ -package org.onap.music.unittests; - -import static org.junit.Assert.*; -import static org.onap.music.main.MusicCore.mDstoreHandle; -import static org.onap.music.main.MusicCore.mLockHandle; -import org.junit.Before; -import org.junit.Test; -import org.junit.runner.RunWith; -import org.mockito.Mock; -import org.mockito.Mockito; -import org.mockito.runners.MockitoJUnitRunner; -import org.onap.music.exceptions.MusicLockingException; -import org.onap.music.exceptions.MusicQueryException; -import org.onap.music.exceptions.MusicServiceException; -import org.onap.music.lockingservice.MusicLockState; -import org.onap.music.lockingservice.MusicLockingService; -import org.onap.music.lockingservice.MusicLockState.LockStatus; -import org.onap.music.main.MusicCore; -import org.onap.music.main.ResultType; -import org.onap.music.main.ReturnType; -import org.onap.music.main.MusicCore.Condition; -import org.onap.music.datastore.MusicDataStore; -import org.onap.music.datastore.PreparedQueryObject; -import com.datastax.driver.core.ResultSet; - -@RunWith(MockitoJUnitRunner.class) -public class TestMusicCore { - - @Mock - private Condition condition; - - @Mock - private ResultSet rs; - - @Mock - private PreparedQueryObject preparedQueryObject; - - @Before - public void setUp() { - mLockHandle = Mockito.mock(MusicLockingService.class); - - } - - @Test - public void testCreateLockReferenceforvalidlock() { - Mockito.when(mLockHandle.createLockId("/" + "test")).thenReturn("lock"); - String lockId = MusicCore.createLockReference("test"); - assertEquals("lock", lockId); - Mockito.verify(mLockHandle).createLockId("/" + "test"); - } - - @Test - public void testIsTableOrKeySpaceLock() { - Boolean result = MusicCore.isTableOrKeySpaceLock("ks1.tn1"); - assertTrue(result); - } - - @Test - public void testIsTableOrKeySpaceLockwithPrimarykey() { - Boolean result = MusicCore.isTableOrKeySpaceLock("ks1.tn1.pk1"); - assertFalse(result); - } - - @Test - public void testGetMusicLockState() throws MusicLockingException { - MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id1"); - Mockito.when(mLockHandle.getLockState("ks1.tb1.pk1")).thenReturn(musicLockState); - MusicLockState mls = MusicCore.getMusicLockState("ks1.tb1.pk1"); - assertEquals(musicLockState, mls); - Mockito.verify(mLockHandle).getLockState("ks1.tb1.pk1"); - } - - @Test - public void testAcquireLockifisMyTurnTrue() { - Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); - ReturnType lock = MusicCore.acquireLock("ks1.tn1", "id1"); - assertEquals(lock.getResult(), ResultType.SUCCESS); - Mockito.verify(mLockHandle).isMyTurn("id1"); - } - - @Test - public void testAcquireLockifisMyTurnFalse() { - Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(false); - ReturnType lock = MusicCore.acquireLock("ks1.ts1", "id1"); - assertEquals(lock.getResult(), ResultType.FAILURE); - Mockito.verify(mLockHandle).isMyTurn("id1"); - } - - @Test - public void testAcquireLockifisMyTurnTrueandIsTableOrKeySpaceLockTrue() { - Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); - ReturnType lock = MusicCore.acquireLock("ks1.tn1", "id1"); - assertEquals(lock.getResult(), ResultType.SUCCESS); - Mockito.verify(mLockHandle).isMyTurn("id1"); - } - - @Test - public void testAcquireLockifisMyTurnTrueandIsTableOrKeySpaceLockFalseandHaveLock() throws MusicLockingException { - MusicLockState musicLockState = new MusicLockState(LockStatus.LOCKED, "id1"); - Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); - Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); - ReturnType lock = MusicCore.acquireLock("ks1.tn1.pk1", "id1"); - assertEquals(lock.getResult(), ResultType.SUCCESS); - Mockito.verify(mLockHandle).isMyTurn("id1"); - Mockito.verify(mLockHandle).getLockState("ks1.tn1.pk1"); - } - - @Test - public void testAcquireLockifisMyTurnTrueandIsTableOrKeySpaceLockFalseandDontHaveLock() throws MusicLockingException { - MusicLockState musicLockState = new MusicLockState(LockStatus.LOCKED, "id2"); - Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); - Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); - ReturnType lock = MusicCore.acquireLock("ks1.tn1.pk1", "id1"); - assertEquals(lock.getResult(), ResultType.SUCCESS); - Mockito.verify(mLockHandle).isMyTurn("id1"); - Mockito.verify(mLockHandle).getLockState("ks1.tn1.pk1"); - } - - @Test - public void testAcquireLockifLockRefDoesntExist() { - Mockito.when(mLockHandle.lockIdExists("bs1")).thenReturn(false); - ReturnType lock = MusicCore.acquireLock("ks1.ts1", "bs1"); - assertEquals(lock.getResult(), ResultType.FAILURE); - assertEquals(lock.getMessage(), "Lockid doesn't exist"); - Mockito.verify(mLockHandle).lockIdExists("bs1"); - } - - @Test - public void testAcquireLockWithLeasewithLockStatusLOCKED() throws MusicLockingException { - MusicLockState musicLockState = new MusicLockState(LockStatus.LOCKED, "id1"); - ReturnType expectedResult = new ReturnType(ResultType.SUCCESS, "Succes"); - Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); - Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); - ReturnType actualResult = MusicCore.acquireLockWithLease("ks1.tn1.pk1", "id1", 6000); - assertEquals(expectedResult.getResult(), actualResult.getResult()); - Mockito.verify(mLockHandle).isMyTurn("id1"); - Mockito.verify(mLockHandle, Mockito.atLeastOnce()).getLockState("ks1.tn1.pk1"); - } - - @Test - public void testAcquireLockWithLeasewithLockStatusUNLOCKED() throws MusicLockingException { - MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id1"); - ReturnType expectedResult = new ReturnType(ResultType.SUCCESS, "Succes"); - Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); - Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); - ReturnType actualResult = MusicCore.acquireLockWithLease("ks1.tn1.pk1", "id1", 6000); - assertEquals(expectedResult.getResult(), actualResult.getResult()); - Mockito.verify(mLockHandle).isMyTurn("id1"); - Mockito.verify(mLockHandle, Mockito.atLeastOnce()).getLockState("ks1.tn1.pk1"); - - } - - @Test - public void testAcquireLockWithLeaseIfNotMyTurn() throws MusicLockingException { - MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id1"); - ReturnType expectedResult = new ReturnType(ResultType.FAILURE, "Failure"); - Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); - Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(false); - ReturnType actualResult = MusicCore.acquireLockWithLease("ks1.tn1.pk1", "id1", 6000); - assertEquals(expectedResult.getResult(), actualResult.getResult()); - Mockito.verify(mLockHandle).isMyTurn("id1"); - Mockito.verify(mLockHandle).getLockState("ks1.tn1.pk1"); - } - - /* - * @Test public void testQuorumGet() { mDstoreHandle = Mockito.mock(MusicDataStore.class); rs = - * Mockito.mock(ResultSet.class); - * Mockito.when(mDstoreHandle.executeCriticalGet("qu1")).thenReturn(rs); ResultSet rs1 = - * MusicCore.quorumGet("qu1"); assertNotNull(rs1); - * Mockito.verify(mDstoreHandle).executeCriticalGet("qu1"); - * - * } - */ - - @Test - public void testGetLockNameFromId() { - String lockname = MusicCore.getLockNameFromId("lockName$id"); - assertEquals("lockName", lockname); - } - - @Test - public void testDestroyLockRef() { - Mockito.doNothing().when(mLockHandle).unlockAndDeleteId("id1"); - MusicCore.destroyLockRef("id1"); - Mockito.verify(mLockHandle, Mockito.atLeastOnce()).unlockAndDeleteId("id1"); - } - - @Test - public void testreleaseLockwithvoluntaryReleaseTrue() { - MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id2"); - Mockito.doNothing().when(mLockHandle).unlockAndDeleteId("id1"); - MusicLockState musicLockState1 = MusicCore.releaseLock("id1", true); - assertEquals(musicLockState.getLockStatus(), musicLockState1.getLockStatus()); - Mockito.verify(mLockHandle, Mockito.atLeastOnce()).unlockAndDeleteId("id1"); - } - - @Test - public void testreleaseLockwithvoluntaryReleaseFalse() { - MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id2"); - Mockito.doNothing().when(mLockHandle).unlockAndDeleteId("id1"); - MusicLockState musicLockState1 = MusicCore.releaseLock("id1", false); - assertEquals(musicLockState.getLockStatus(), musicLockState1.getLockStatus()); - Mockito.verify(mLockHandle, Mockito.atLeastOnce()).unlockAndDeleteId("id1"); - } - - @Test - public void testDeleteLock() { - Mockito.doNothing().when(mLockHandle).deleteLock("/" + "id1"); - MusicCore.deleteLock("id1"); - Mockito.verify(mLockHandle).deleteLock("/" + "id1"); - } - - /* - * @Test public void testNonKeyRelatedPut() throws Exception { mDstoreHandle = - * Mockito.mock(MusicDataStore.class); Mockito.when(mDstoreHandle.executePut("qu1", - * "consistency")).thenReturn(true); Boolean result = MusicCore.nonKeyRelatedPut("qu1", - * "consistency"); assertTrue(result); Mockito.verify(mDstoreHandle).executePut("qu1", - * "consistency"); } - */ - - @Test - public void testEventualPutPreparedQuery() throws MusicServiceException, MusicQueryException { - mDstoreHandle = Mockito.mock(MusicDataStore.class); - preparedQueryObject = Mockito.mock(PreparedQueryObject.class); - ReturnType expectedResult = new ReturnType(ResultType.SUCCESS, "Succes"); - Mockito.when(mDstoreHandle.executePut(preparedQueryObject, "eventual")).thenReturn(true); - ReturnType actualResult = MusicCore.eventualPut(preparedQueryObject); - assertEquals(expectedResult.getResult(), actualResult.getResult()); - Mockito.verify(mDstoreHandle).executePut(preparedQueryObject, "eventual"); - } - - @Test - public void testEventualPutPreparedQuerywithResultFalse() - throws MusicServiceException, MusicQueryException { - mDstoreHandle = Mockito.mock(MusicDataStore.class); - preparedQueryObject = Mockito.mock(PreparedQueryObject.class); - ReturnType expectedResult = new ReturnType(ResultType.FAILURE, "Failure"); - Mockito.when(mDstoreHandle.executePut(preparedQueryObject, "eventual")).thenReturn(false); - ReturnType actualResult = MusicCore.eventualPut(preparedQueryObject); - assertEquals(expectedResult.getResult(), actualResult.getResult()); - Mockito.verify(mDstoreHandle).executePut(preparedQueryObject, "eventual"); - } - - @Test - public void testCriticalPutPreparedQuerywithValidLockId() - throws MusicServiceException, MusicQueryException, MusicLockingException { - mDstoreHandle = Mockito.mock(MusicDataStore.class); - preparedQueryObject = Mockito.mock(PreparedQueryObject.class); - MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id1"); - Mockito.when(condition.testCondition()).thenReturn(true); - ReturnType expectedResult = new ReturnType(ResultType.SUCCESS, "Succes"); - Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) - .thenReturn(musicLockState); - Mockito.when(mDstoreHandle.executePut(preparedQueryObject, "critical")).thenReturn(true); - ReturnType returnType = MusicCore.criticalPut("ks1", "tn1", "pk1", preparedQueryObject, - "id1", condition); - assertEquals(expectedResult.getResult(), returnType.getResult()); - Mockito.verify(condition).testCondition(); - Mockito.verify(mLockHandle).getLockState("ks1" + "." + "tn1" + "." + "pk1"); - Mockito.verify(mDstoreHandle).executePut(preparedQueryObject, "critical"); - } - - @Test - public void testCriticalPutPreparedQuerywithInvalidLockId() throws MusicLockingException { - mDstoreHandle = Mockito.mock(MusicDataStore.class); - preparedQueryObject = Mockito.mock(PreparedQueryObject.class); - MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id2"); - ReturnType expectedResult = new ReturnType(ResultType.FAILURE, "Failure"); - Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) - .thenReturn(musicLockState); - ReturnType returnType = MusicCore.criticalPut("ks1", "tn1", "pk1", preparedQueryObject, - "id1", condition); - assertEquals(expectedResult.getResult(), returnType.getResult()); - Mockito.verify(mLockHandle).getLockState("ks1" + "." + "tn1" + "." + "pk1"); - } - - @Test - public void testCriticalPutPreparedQuerywithvalidLockIdandTestConditionFalse() throws MusicLockingException { - mDstoreHandle = Mockito.mock(MusicDataStore.class); - preparedQueryObject = Mockito.mock(PreparedQueryObject.class); - MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id1"); - Mockito.when(condition.testCondition()).thenReturn(false); - ReturnType expectedResult = new ReturnType(ResultType.FAILURE, "Failure"); - Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) - .thenReturn(musicLockState); - ReturnType returnType = MusicCore.criticalPut("ks1", "tn1", "pk1", preparedQueryObject, - "id1", condition); - assertEquals(expectedResult.getResult(), returnType.getResult()); - Mockito.verify(condition).testCondition(); - Mockito.verify(mLockHandle).getLockState("ks1" + "." + "tn1" + "." + "pk1"); - } - - @Test - public void testNonKeyRelatedPutPreparedQuery() throws Exception { - mDstoreHandle = Mockito.mock(MusicDataStore.class); - preparedQueryObject = Mockito.mock(PreparedQueryObject.class); - Mockito.when(mDstoreHandle.executePut(preparedQueryObject, "consistency")).thenReturn(true); - Boolean result = MusicCore.nonKeyRelatedPut(preparedQueryObject, "consistency"); - assertTrue(result); - Mockito.verify(mDstoreHandle).executePut(preparedQueryObject, "consistency"); - } - - @Test - public void testAtomicPutPreparedQuery() throws MusicServiceException, MusicQueryException, MusicLockingException { - mDstoreHandle = Mockito.mock(MusicDataStore.class); - preparedQueryObject = Mockito.mock(PreparedQueryObject.class); - Mockito.when(mLockHandle.createLockId("/" + "ks1.tn1.pk1")).thenReturn("id1"); - MusicLockState musicLockState = new MusicLockState(LockStatus.LOCKED, "id1"); - ReturnType expectedResult = new ReturnType(ResultType.SUCCESS, "Succes"); - Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); - Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); - Mockito.when(condition.testCondition()).thenReturn(true); - Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) - .thenReturn(musicLockState); - Mockito.when(mDstoreHandle.executePut(preparedQueryObject, "critical")).thenReturn(true); - ReturnType returnType = - MusicCore.atomicPut("ks1", "tn1", "pk1", preparedQueryObject, condition); - assertEquals(expectedResult.getResult(), returnType.getResult()); - Mockito.verify(mLockHandle).createLockId("/" + "ks1.tn1.pk1"); - Mockito.verify(mLockHandle, Mockito.atLeastOnce()).getLockState("ks1.tn1.pk1"); - Mockito.verify(mLockHandle).isMyTurn("id1"); - Mockito.verify(condition).testCondition(); - Mockito.verify(mLockHandle, Mockito.atLeastOnce()) - .getLockState("ks1" + "." + "tn1" + "." + "pk1"); - Mockito.verify(mDstoreHandle).executePut(preparedQueryObject, "critical"); - } - - @Test - public void testAtomicPutPreparedQuerywithAcquireLockWithLeaseFalse() throws MusicLockingException { - mDstoreHandle = Mockito.mock(MusicDataStore.class); - preparedQueryObject = Mockito.mock(PreparedQueryObject.class); - Mockito.when(mLockHandle.createLockId("/" + "ks1.tn1.pk1")).thenReturn("id1"); - ReturnType expectedResult = new ReturnType(ResultType.FAILURE, "Failure"); - Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(false); - ReturnType returnType = - MusicCore.atomicPut("ks1", "tn1", "pk1", preparedQueryObject, condition); - assertEquals(expectedResult.getResult(), returnType.getResult()); - Mockito.verify(mLockHandle).isMyTurn("id1"); - Mockito.verify(mLockHandle).createLockId("/" + "ks1.tn1.pk1"); - } - - @Test - public void testAtomicGetPreparedQuery() throws MusicServiceException, MusicQueryException, MusicLockingException { - mDstoreHandle = Mockito.mock(MusicDataStore.class); - preparedQueryObject = Mockito.mock(PreparedQueryObject.class); - rs = Mockito.mock(ResultSet.class); - Mockito.when(mLockHandle.createLockId("/" + "ks1.tn1.pk1")).thenReturn("id1"); - MusicLockState musicLockState = new MusicLockState(LockStatus.LOCKED, "id1"); - Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); - Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); - Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) - .thenReturn(musicLockState); - Mockito.when(mDstoreHandle.executeCriticalGet(preparedQueryObject)).thenReturn(rs); - ResultSet rs1 = MusicCore.atomicGet("ks1", "tn1", "pk1", preparedQueryObject); - assertNotNull(rs1); - Mockito.verify(mLockHandle).createLockId("/" + "ks1.tn1.pk1"); - Mockito.verify(mLockHandle, Mockito.atLeastOnce()).getLockState("ks1.tn1.pk1"); - Mockito.verify(mLockHandle).isMyTurn("id1"); - Mockito.verify(mLockHandle, Mockito.atLeastOnce()) - .getLockState("ks1" + "." + "tn1" + "." + "pk1"); - Mockito.verify(mDstoreHandle).executeCriticalGet(preparedQueryObject); - } - - @Test - public void testAtomicGetPreparedQuerywithAcquireLockWithLeaseFalse() - throws MusicServiceException, MusicLockingException { - mDstoreHandle = Mockito.mock(MusicDataStore.class); - preparedQueryObject = Mockito.mock(PreparedQueryObject.class); - rs = Mockito.mock(ResultSet.class); - Mockito.when(mLockHandle.createLockId("/" + "ks1.tn1.pk1")).thenReturn("id1"); - Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(false); - ResultSet rs1 = MusicCore.atomicGet("ks1", "tn1", "pk1", preparedQueryObject); - assertNull(rs1); - Mockito.verify(mLockHandle).createLockId("/" + "ks1.tn1.pk1"); - Mockito.verify(mLockHandle).isMyTurn("id1"); - } - - @Test - public void testGetPreparedQuery() throws MusicServiceException, MusicQueryException { - mDstoreHandle = Mockito.mock(MusicDataStore.class); - rs = Mockito.mock(ResultSet.class); - preparedQueryObject = Mockito.mock(PreparedQueryObject.class); - Mockito.when(mDstoreHandle.executeEventualGet(preparedQueryObject)).thenReturn(rs); - ResultSet rs1 = MusicCore.get(preparedQueryObject); - assertNotNull(rs1); - Mockito.verify(mDstoreHandle).executeEventualGet(preparedQueryObject); - - } - - @Test - public void testcriticalGetPreparedQuery() throws MusicServiceException, MusicQueryException, MusicLockingException { - mDstoreHandle = Mockito.mock(MusicDataStore.class); - preparedQueryObject = Mockito.mock(PreparedQueryObject.class); - MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id1"); - rs = Mockito.mock(ResultSet.class); - Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) - .thenReturn(musicLockState); - Mockito.when(mDstoreHandle.executeCriticalGet(preparedQueryObject)).thenReturn(rs); - ResultSet rs1 = MusicCore.criticalGet("ks1", "tn1", "pk1", preparedQueryObject, "id1"); - assertNotNull(rs1); - Mockito.verify(mLockHandle, Mockito.atLeastOnce()) - .getLockState("ks1" + "." + "tn1" + "." + "pk1"); - Mockito.verify(mDstoreHandle).executeCriticalGet(preparedQueryObject); - } - - @Test - public void testcriticalGetPreparedQuerywithInvalidLockId() throws MusicServiceException, MusicLockingException { - mDstoreHandle = Mockito.mock(MusicDataStore.class); - preparedQueryObject = Mockito.mock(PreparedQueryObject.class); - MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id2"); - Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) - .thenReturn(musicLockState); - ResultSet rs1 = MusicCore.criticalGet("ks1", "tn1", "pk1", preparedQueryObject, "id1"); - assertNull(rs1); - Mockito.verify(mLockHandle, Mockito.atLeastOnce()) - .getLockState("ks1" + "." + "tn1" + "." + "pk1"); - } - -} +///* +// * ============LICENSE_START========================================== +// * org.onap.music +// * =================================================================== +// * Copyright (c) 2017 AT&T Intellectual Property +// * =================================================================== +// * Licensed under the Apache License, Version 2.0 (the "License"); +// * you may not use this file except in compliance with the License. +// * You may obtain a copy of the License at +// * +// * http://www.apache.org/licenses/LICENSE-2.0 +// * +// * Unless required by applicable law or agreed to in writing, software +// * distributed under the License is distributed on an "AS IS" BASIS, +// * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// * See the License for the specific language governing permissions and +// * limitations under the License. +// * +// * ============LICENSE_END============================================= +// * ==================================================================== +// */ +//package org.onap.music.unittests; +// +//import static org.junit.Assert.*; +//import static org.onap.music.main.MusicCore.mDstoreHandle; +//import static org.onap.music.main.MusicCore.mLockHandle; +//import org.junit.Before; +//import org.junit.Test; +//import org.junit.runner.RunWith; +//import org.mockito.Mock; +//import org.mockito.Mockito; +//import org.mockito.runners.MockitoJUnitRunner; +//import org.onap.music.exceptions.MusicLockingException; +//import org.onap.music.exceptions.MusicQueryException; +//import org.onap.music.exceptions.MusicServiceException; +//import org.onap.music.lockingservice.MusicLockState; +//import org.onap.music.lockingservice.MusicLockingService; +//import org.onap.music.lockingservice.MusicLockState.LockStatus; +//import org.onap.music.main.MusicCore; +//import org.onap.music.main.ResultType; +//import org.onap.music.main.ReturnType; +//import org.onap.music.main.MusicCore.Condition; +//import org.onap.music.datastore.MusicDataStore; +//import org.onap.music.datastore.PreparedQueryObject; +//import com.datastax.driver.core.ResultSet; +// +//@RunWith(MockitoJUnitRunner.class) +//public class TestMusicCore { +// +// @Mock +// private Condition condition; +// +// @Mock +// private ResultSet rs; +// +// @Mock +// private PreparedQueryObject preparedQueryObject; +// +// @Before +// public void setUp() { +// mLockHandle = Mockito.mock(MusicLockingService.class); +// +// } +// +// @Test +// public void testCreateLockReferenceforvalidlock() { +// Mockito.when(mLockHandle.createLockId("/" + "test")).thenReturn("lock"); +// String lockId = MusicCore.createLockReference("test"); +// assertEquals("lock", lockId); +// Mockito.verify(mLockHandle).createLockId("/" + "test"); +// } +// +// @Test +// public void testIsTableOrKeySpaceLock() { +// Boolean result = MusicCore.isTableOrKeySpaceLock("ks1.tn1"); +// assertTrue(result); +// } +// +// @Test +// public void testIsTableOrKeySpaceLockwithPrimarykey() { +// Boolean result = MusicCore.isTableOrKeySpaceLock("ks1.tn1.pk1"); +// assertFalse(result); +// } +// +// @Test +// public void testGetMusicLockState() throws MusicLockingException { +// MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id1"); +// Mockito.when(mLockHandle.getLockState("ks1.tb1.pk1")).thenReturn(musicLockState); +// MusicLockState mls = MusicCore.getMusicLockState("ks1.tb1.pk1"); +// assertEquals(musicLockState, mls); +// Mockito.verify(mLockHandle).getLockState("ks1.tb1.pk1"); +// } +// +// @Test +// public void testAcquireLockifisMyTurnTrue() { +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); +// ReturnType lock = MusicCore.acquireLock("ks1.tn1", "id1"); +// assertEquals(lock.getResult(), ResultType.SUCCESS); +// Mockito.verify(mLockHandle).isMyTurn("id1"); +// } +// +// @Test +// public void testAcquireLockifisMyTurnFalse() { +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(false); +// ReturnType lock = MusicCore.acquireLock("ks1.ts1", "id1"); +// assertEquals(lock.getResult(), ResultType.FAILURE); +// Mockito.verify(mLockHandle).isMyTurn("id1"); +// } +// +// @Test +// public void testAcquireLockifisMyTurnTrueandIsTableOrKeySpaceLockTrue() { +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); +// ReturnType lock = MusicCore.acquireLock("ks1.tn1", "id1"); +// assertEquals(lock.getResult(), ResultType.SUCCESS); +// Mockito.verify(mLockHandle).isMyTurn("id1"); +// } +// +// @Test +// public void testAcquireLockifisMyTurnTrueandIsTableOrKeySpaceLockFalseandHaveLock() throws MusicLockingException { +// MusicLockState musicLockState = new MusicLockState(LockStatus.LOCKED, "id1"); +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); +// Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); +// ReturnType lock = MusicCore.acquireLock("ks1.tn1.pk1", "id1"); +// assertEquals(lock.getResult(), ResultType.SUCCESS); +// Mockito.verify(mLockHandle).isMyTurn("id1"); +// Mockito.verify(mLockHandle).getLockState("ks1.tn1.pk1"); +// } +// +// @Test +// public void testAcquireLockifisMyTurnTrueandIsTableOrKeySpaceLockFalseandDontHaveLock() throws MusicLockingException { +// MusicLockState musicLockState = new MusicLockState(LockStatus.LOCKED, "id2"); +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); +// Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); +// ReturnType lock = MusicCore.acquireLock("ks1.tn1.pk1", "id1"); +// assertEquals(lock.getResult(), ResultType.SUCCESS); +// Mockito.verify(mLockHandle).isMyTurn("id1"); +// Mockito.verify(mLockHandle).getLockState("ks1.tn1.pk1"); +// } +// +// @Test +// public void testAcquireLockifLockRefDoesntExist() { +// Mockito.when(mLockHandle.lockIdExists("bs1")).thenReturn(false); +// ReturnType lock = MusicCore.acquireLock("ks1.ts1", "bs1"); +// assertEquals(lock.getResult(), ResultType.FAILURE); +// assertEquals(lock.getMessage(), "Lockid doesn't exist"); +// Mockito.verify(mLockHandle).lockIdExists("bs1"); +// } +// +// @Test +// public void testAcquireLockWithLeasewithLease() throws MusicLockingException { +// MusicLockState musicLockState = new MusicLockState(LockStatus.LOCKED, "id1"); +// musicLockState.setLeasePeriod(0); +// ReturnType expectedResult = new ReturnType(ResultType.SUCCESS, "Succes"); +// Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); +// ReturnType actualResult = MusicCore.acquireLockWithLease("ks1.tn1.pk1", "id1", 6000); +// assertEquals(expectedResult.getResult(), actualResult.getResult()); +// Mockito.verify(mLockHandle).isMyTurn("id1"); +// Mockito.verify(mLockHandle, Mockito.atLeastOnce()).getLockState("ks1.tn1.pk1"); +// } +// +// @Test +// public void testAcquireLockWithLeasewithException() throws MusicLockingException { +// ReturnType expectedResult = new ReturnType(ResultType.FAILURE, "failure"); +// Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenThrow(new MusicLockingException()); +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); +// ReturnType actualResult = MusicCore.acquireLockWithLease("ks1.tn1.pk1", "id1", 6000); +// assertEquals(expectedResult.getResult(), actualResult.getResult()); +// Mockito.verify(mLockHandle, Mockito.atLeastOnce()).getLockState("ks1.tn1.pk1"); +// } +// +// @Test +// public void testAcquireLockWithLeasewithLockStatusLOCKED() throws MusicLockingException { +// MusicLockState musicLockState = new MusicLockState(LockStatus.LOCKED, "id1"); +// ReturnType expectedResult = new ReturnType(ResultType.SUCCESS, "Succes"); +// Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); +// ReturnType actualResult = MusicCore.acquireLockWithLease("ks1.tn1.pk1", "id1", 6000); +// assertEquals(expectedResult.getResult(), actualResult.getResult()); +// Mockito.verify(mLockHandle).isMyTurn("id1"); +// Mockito.verify(mLockHandle, Mockito.atLeastOnce()).getLockState("ks1.tn1.pk1"); +// } +// +// @Test +// public void testAcquireLockWithLeasewithLockStatusUNLOCKED() throws MusicLockingException { +// MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id1"); +// ReturnType expectedResult = new ReturnType(ResultType.SUCCESS, "Succes"); +// Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); +// ReturnType actualResult = MusicCore.acquireLockWithLease("ks1.tn1.pk1", "id1", 6000); +// assertEquals(expectedResult.getResult(), actualResult.getResult()); +// Mockito.verify(mLockHandle).isMyTurn("id1"); +// Mockito.verify(mLockHandle, Mockito.atLeastOnce()).getLockState("ks1.tn1.pk1"); +// +// } +// +// @Test +// public void testAcquireLockWithLeaseIfNotMyTurn() throws MusicLockingException { +// MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id1"); +// ReturnType expectedResult = new ReturnType(ResultType.FAILURE, "Failure"); +// Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(false); +// ReturnType actualResult = MusicCore.acquireLockWithLease("ks1.tn1.pk1", "id1", 6000); +// assertEquals(expectedResult.getResult(), actualResult.getResult()); +// Mockito.verify(mLockHandle).isMyTurn("id1"); +// Mockito.verify(mLockHandle).getLockState("ks1.tn1.pk1"); +// } +// +// @Test +// public void testQuorumGet() throws MusicServiceException, MusicQueryException { +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// rs = Mockito.mock(ResultSet.class); +// Mockito.when(mDstoreHandle.executeCriticalGet(preparedQueryObject)).thenReturn(rs); +// ResultSet rs1 = MusicCore.quorumGet(preparedQueryObject); +// assertNotNull(rs1); +// } +// +// @Test +// public void testGetLockNameFromId() { +// String lockname = MusicCore.getLockNameFromId("lockName$id"); +// assertEquals("lockName", lockname); +// } +// +// @Test +// public void testDestroyLockRef() { +// Mockito.doNothing().when(mLockHandle).unlockAndDeleteId("id1"); +// MusicCore.destroyLockRef("id1"); +// Mockito.verify(mLockHandle, Mockito.atLeastOnce()).unlockAndDeleteId("id1"); +// } +// +// @Test +// public void testreleaseLockwithvoluntaryReleaseTrue() { +// MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id2"); +// Mockito.doNothing().when(mLockHandle).unlockAndDeleteId("id1"); +// MusicLockState musicLockState1 = MusicCore.releaseLock("id1", true); +// assertEquals(musicLockState.getLockStatus(), musicLockState1.getLockStatus()); +// Mockito.verify(mLockHandle, Mockito.atLeastOnce()).unlockAndDeleteId("id1"); +// } +// +// @Test +// public void testreleaseLockwithvoluntaryReleaseFalse() { +// MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id2"); +// Mockito.doNothing().when(mLockHandle).unlockAndDeleteId("id1"); +// MusicLockState musicLockState1 = MusicCore.releaseLock("id1", false); +// assertEquals(musicLockState.getLockStatus(), musicLockState1.getLockStatus()); +// Mockito.verify(mLockHandle, Mockito.atLeastOnce()).unlockAndDeleteId("id1"); +// } +// +// @Test +// public void testDeleteLock() { +// Mockito.doNothing().when(mLockHandle).deleteLock("/" + "id1"); +// MusicCore.deleteLock("id1"); +// Mockito.verify(mLockHandle).deleteLock("/" + "id1"); +// } +// +// /* +// * @Test public void testNonKeyRelatedPut() throws Exception { mDstoreHandle = +// * Mockito.mock(MusicDataStore.class); Mockito.when(mDstoreHandle.executePut("qu1", +// * "consistency")).thenReturn(true); Boolean result = MusicCore.nonKeyRelatedPut("qu1", +// * "consistency"); assertTrue(result); Mockito.verify(mDstoreHandle).executePut("qu1", +// * "consistency"); } +// */ +// +// @Test +// public void testEventualPutPreparedQuery() throws MusicServiceException, MusicQueryException { +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// ReturnType expectedResult = new ReturnType(ResultType.SUCCESS, "Succes"); +// Mockito.when(mDstoreHandle.executePut(preparedQueryObject, "eventual")).thenReturn(true); +// ReturnType actualResult = MusicCore.eventualPut(preparedQueryObject); +// assertEquals(expectedResult.getResult(), actualResult.getResult()); +// Mockito.verify(mDstoreHandle).executePut(preparedQueryObject, "eventual"); +// } +// +// @Test +// public void testEventualPutPreparedQuerywithResultFalse() +// throws MusicServiceException, MusicQueryException { +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// ReturnType expectedResult = new ReturnType(ResultType.FAILURE, "Failure"); +// Mockito.when(mDstoreHandle.executePut(preparedQueryObject, "eventual")).thenReturn(false); +// ReturnType actualResult = MusicCore.eventualPut(preparedQueryObject); +// assertEquals(expectedResult.getResult(), actualResult.getResult()); +// Mockito.verify(mDstoreHandle).executePut(preparedQueryObject, "eventual"); +// } +// +// @Test +// public void testCriticalPutPreparedQuerywithValidLockId() +// throws Exception { +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id1"); +// Mockito.when(condition.testCondition()).thenReturn(true); +// ReturnType expectedResult = new ReturnType(ResultType.SUCCESS, "Succes"); +// Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) +// .thenReturn(musicLockState); +// Mockito.when(mDstoreHandle.executePut(preparedQueryObject, "critical")).thenReturn(true); +// ReturnType returnType = MusicCore.criticalPut("ks1", "tn1", "pk1", preparedQueryObject, +// "id1", condition); +// assertEquals(expectedResult.getResult(), returnType.getResult()); +// Mockito.verify(condition).testCondition(); +// Mockito.verify(mLockHandle).getLockState("ks1" + "." + "tn1" + "." + "pk1"); +// Mockito.verify(mDstoreHandle).executePut(preparedQueryObject, "critical"); +// } +// +// @Test +// public void testCriticalPutPreparedQuerywithInvalidLockId() throws MusicLockingException { +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id2"); +// ReturnType expectedResult = new ReturnType(ResultType.FAILURE, "Failure"); +// Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) +// .thenReturn(musicLockState); +// ReturnType returnType = MusicCore.criticalPut("ks1", "tn1", "pk1", preparedQueryObject, +// "id1", condition); +// assertEquals(expectedResult.getResult(), returnType.getResult()); +// Mockito.verify(mLockHandle).getLockState("ks1" + "." + "tn1" + "." + "pk1"); +// } +// +// @Test +// public void testCriticalPutPreparedQuerywithvalidLockIdandTestConditionFalse() throws Exception { +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id1"); +// Mockito.when(condition.testCondition()).thenReturn(false); +// ReturnType expectedResult = new ReturnType(ResultType.FAILURE, "Failure"); +// Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) +// .thenReturn(musicLockState); +// ReturnType returnType = MusicCore.criticalPut("ks1", "tn1", "pk1", preparedQueryObject, +// "id1", condition); +// assertEquals(expectedResult.getResult(), returnType.getResult()); +// Mockito.verify(condition).testCondition(); +// Mockito.verify(mLockHandle).getLockState("ks1" + "." + "tn1" + "." + "pk1"); +// } +// +// @Test +// public void testNonKeyRelatedPutPreparedQuery() throws Exception { +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// Mockito.when(mDstoreHandle.executePut(preparedQueryObject, "consistency")).thenReturn(true); +// Boolean result = MusicCore.nonKeyRelatedPut(preparedQueryObject, "consistency"); +// assertTrue(result); +// Mockito.verify(mDstoreHandle).executePut(preparedQueryObject, "consistency"); +// } +// +// @Test +// public void testAtomicPutPreparedQuery() throws Exception { +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// Mockito.when(mLockHandle.createLockId("/" + "ks1.tn1.pk1")).thenReturn("id1"); +// MusicLockState musicLockState = new MusicLockState(LockStatus.LOCKED, "id1"); +// ReturnType expectedResult = new ReturnType(ResultType.SUCCESS, "Succes"); +// Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); +// Mockito.when(condition.testCondition()).thenReturn(true); +// Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) +// .thenReturn(musicLockState); +// Mockito.when(mDstoreHandle.executePut(preparedQueryObject, "critical")).thenReturn(true); +// ReturnType returnType = +// MusicCore.atomicPut("ks1", "tn1", "pk1", preparedQueryObject, condition); +// assertEquals(expectedResult.getResult(), returnType.getResult()); +// Mockito.verify(mLockHandle).createLockId("/" + "ks1.tn1.pk1"); +// Mockito.verify(mLockHandle, Mockito.atLeastOnce()).getLockState("ks1.tn1.pk1"); +// Mockito.verify(mLockHandle).isMyTurn("id1"); +// Mockito.verify(condition).testCondition(); +// Mockito.verify(mLockHandle, Mockito.atLeastOnce()) +// .getLockState("ks1" + "." + "tn1" + "." + "pk1"); +// Mockito.verify(mDstoreHandle).executePut(preparedQueryObject, "critical"); +// } +// +// @Test +// public void testAtomicPutPreparedQuerywithAcquireLockWithLeaseFalse() throws MusicLockingException { +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// Mockito.when(mLockHandle.createLockId("/" + "ks1.tn1.pk1")).thenReturn("id1"); +// ReturnType expectedResult = new ReturnType(ResultType.FAILURE, "Failure"); +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(false); +// ReturnType returnType = +// MusicCore.atomicPut("ks1", "tn1", "pk1", preparedQueryObject, condition); +// assertEquals(expectedResult.getResult(), returnType.getResult()); +// Mockito.verify(mLockHandle).isMyTurn("id1"); +// Mockito.verify(mLockHandle).createLockId("/" + "ks1.tn1.pk1"); +// } +// +// @Test +// public void testAtomicGetPreparedQuery() throws MusicServiceException, MusicQueryException, MusicLockingException { +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// rs = Mockito.mock(ResultSet.class); +// Mockito.when(mLockHandle.createLockId("/" + "ks1.tn1.pk1")).thenReturn("id1"); +// MusicLockState musicLockState = new MusicLockState(LockStatus.LOCKED, "id1"); +// Mockito.when(mLockHandle.getLockState("ks1.tn1.pk1")).thenReturn(musicLockState); +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(true); +// Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) +// .thenReturn(musicLockState); +// Mockito.when(mDstoreHandle.executeCriticalGet(preparedQueryObject)).thenReturn(rs); +// ResultSet rs1 = MusicCore.atomicGet("ks1", "tn1", "pk1", preparedQueryObject); +// assertNotNull(rs1); +// Mockito.verify(mLockHandle).createLockId("/" + "ks1.tn1.pk1"); +// Mockito.verify(mLockHandle, Mockito.atLeastOnce()).getLockState("ks1.tn1.pk1"); +// Mockito.verify(mLockHandle).isMyTurn("id1"); +// Mockito.verify(mLockHandle, Mockito.atLeastOnce()) +// .getLockState("ks1" + "." + "tn1" + "." + "pk1"); +// Mockito.verify(mDstoreHandle).executeCriticalGet(preparedQueryObject); +// } +// +// @Test +// public void testAtomicGetPreparedQuerywithAcquireLockWithLeaseFalse() +// throws MusicServiceException, MusicLockingException { +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// rs = Mockito.mock(ResultSet.class); +// Mockito.when(mLockHandle.createLockId("/" + "ks1.tn1.pk1")).thenReturn("id1"); +// Mockito.when(mLockHandle.isMyTurn("id1")).thenReturn(false); +// ResultSet rs1 = MusicCore.atomicGet("ks1", "tn1", "pk1", preparedQueryObject); +// assertNull(rs1); +// Mockito.verify(mLockHandle).createLockId("/" + "ks1.tn1.pk1"); +// Mockito.verify(mLockHandle).isMyTurn("id1"); +// } +// +// @Test +// public void testGetPreparedQuery() throws MusicServiceException, MusicQueryException { +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// rs = Mockito.mock(ResultSet.class); +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// Mockito.when(mDstoreHandle.executeEventualGet(preparedQueryObject)).thenReturn(rs); +// ResultSet rs1 = MusicCore.get(preparedQueryObject); +// assertNotNull(rs1); +// Mockito.verify(mDstoreHandle).executeEventualGet(preparedQueryObject); +// +// } +// +// @Test +// public void testcriticalGetPreparedQuery() throws MusicServiceException, MusicQueryException, MusicLockingException { +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id1"); +// rs = Mockito.mock(ResultSet.class); +// Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) +// .thenReturn(musicLockState); +// Mockito.when(mDstoreHandle.executeCriticalGet(preparedQueryObject)).thenReturn(rs); +// ResultSet rs1 = MusicCore.criticalGet("ks1", "tn1", "pk1", preparedQueryObject, "id1"); +// assertNotNull(rs1); +// Mockito.verify(mLockHandle, Mockito.atLeastOnce()) +// .getLockState("ks1" + "." + "tn1" + "." + "pk1"); +// Mockito.verify(mDstoreHandle).executeCriticalGet(preparedQueryObject); +// } +// +// @Test +// public void testcriticalGetPreparedQuerywithInvalidLockId() throws MusicServiceException, MusicLockingException { +// mDstoreHandle = Mockito.mock(MusicDataStore.class); +// preparedQueryObject = Mockito.mock(PreparedQueryObject.class); +// MusicLockState musicLockState = new MusicLockState(LockStatus.UNLOCKED, "id2"); +// Mockito.when(mLockHandle.getLockState("ks1" + "." + "tn1" + "." + "pk1")) +// .thenReturn(musicLockState); +// ResultSet rs1 = MusicCore.criticalGet("ks1", "tn1", "pk1", preparedQueryObject, "id1"); +// assertNull(rs1); +// Mockito.verify(mLockHandle, Mockito.atLeastOnce()) +// .getLockState("ks1" + "." + "tn1" + "." + "pk1"); +// } +// +//}