diff options
| author |   Arthur Martella <arthur.martella.1@att.com> | 2019-09-13 15:59:26 -0400 |
|---|---|---|
| committer | Arthur Martella <arthur.martella.1@att.com> | 2019-09-16 14:24:40 -0400 |
| commit | ea39a71e28f2772da7d467a410d43a7ddd8d163d (patch) | |
| tree | 22c89e9b7abc41c7a69623b79a47eccf815e4947 /src/main/java/org/onap/music/datastore | |
| parent | 4fe3f08aa1c93a1fc81a78544031ef747a747098 (diff) | |
Deadlock detection by owner
Issue-ID: MUSIC-502
Signed-off-by: Martella, Arthur <arthur.martella.1@att.com>
Change-Id: Iec20cfeec96d7031c691055ffba2f65c34854adf
Diffstat (limited to 'src/main/java/org/onap/music/datastore')
| -rw-r--r-- | src/main/java/org/onap/music/datastore/PreparedQueryObject.java | 23 |
1 files changed, 22 insertions, 1 deletions
diff --git a/src/main/java/org/onap/music/datastore/PreparedQueryObject.java b/src/main/java/org/onap/music/datastore/PreparedQueryObject.java index d65096a7..fdac50be 100644 --- a/src/main/java/org/onap/music/datastore/PreparedQueryObject.java +++ b/src/main/java/org/onap/music/datastore/PreparedQueryObject.java @@ -89,7 +89,28 @@ public class PreparedQueryObject { } public String getOperation() { - return operation; + if (operation!=null) return operation; + if (query.length()==0) return null; + String queryStr = query.toString().toLowerCase(); + String firstOp = null; + int firstOpChar = query.length(); + if (queryStr.indexOf("insert")>-1 && queryStr.indexOf("insert")<firstOpChar) { + firstOp = "insert"; + firstOpChar = queryStr.indexOf("insert"); + } + if (queryStr.indexOf("update")>-1 && queryStr.indexOf("update")<firstOpChar) { + firstOp = "update"; + firstOpChar = queryStr.indexOf("update"); + } + if (queryStr.indexOf("delete")>-1 && queryStr.indexOf("delete")<firstOpChar) { + firstOp = "delete"; + firstOpChar = queryStr.indexOf("delete"); + } + if (queryStr.indexOf("select")>-1 && queryStr.indexOf("select")<firstOpChar) { + firstOp = "select"; + firstOpChar = queryStr.indexOf("select"); + } + return firstOp; } public void setOperation(String operation) { |