diff options
| author |   Thomas Nelson Jr (arthurdent3) <tn1381@att.com> | 2018-02-23 15:14:24 -0500 |
|---|---|---|
| committer | Thomas Nelson Jr (arthurdent3) <tn1381@att.com> | 2018-02-23 15:29:08 -0500 |
| commit | b6a14a0dc52c9ed43b035aff79831fc32fd52fe3 (patch) | |
| tree | 400ba474c44d779632406d3d998e65038816eed1 /src/main/java/org/onap/music/datastore/MusicDataStore.java | |
| parent | 3acbae6bf3be04f352bfaac340b8303064a2f7c4 (diff) | |
Changes related to Authentication and Atomic
Authentication Fixes
Atomic with delete added.
Issue-ID: MUSIC-38,MUSIC-39
Change-Id: Ide2974a42ff8618d8a94ef7e8a1b0abde3630550
Signed-off-by: Thomas Nelson Jr (arthurdent3) <tn1381@att.com>
Diffstat (limited to 'src/main/java/org/onap/music/datastore/MusicDataStore.java')
| -rw-r--r-- | src/main/java/org/onap/music/datastore/MusicDataStore.java | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/main/java/org/onap/music/datastore/MusicDataStore.java b/src/main/java/org/onap/music/datastore/MusicDataStore.java index 6ced1e48..e1ae5b08 100644 --- a/src/main/java/org/onap/music/datastore/MusicDataStore.java +++ b/src/main/java/org/onap/music/datastore/MusicDataStore.java @@ -45,6 +45,7 @@ import com.datastax.driver.core.ResultSet; import com.datastax.driver.core.Row; import com.datastax.driver.core.Session; import com.datastax.driver.core.TableMetadata; +import com.datastax.driver.core.exceptions.AlreadyExistsException; import com.datastax.driver.core.exceptions.NoHostAvailableException; /** @@ -322,7 +323,12 @@ public class MusicDataStore { ResultSet rs = session.execute(preparedInsert.bind(queryObject.getValues().toArray())); result = rs.wasApplied(); - } catch (Exception e) { + } + catch (AlreadyExistsException ae) { + logger.error(EELFLoggerDelegate.errorLogger, "Executing Session Failure for Request = " + + "[" + queryObject.getQuery() + "]" + " Reason = " + ae.getMessage()); + } + catch (Exception e) { logger.error(EELFLoggerDelegate.errorLogger, "Executing Session Failure for Request = " + "[" + queryObject.getQuery() + "]" + " Reason = " + e.getMessage()); throw new MusicServiceException("Executing Session Failure for Request = " + "[" |