gerrit.onap Code Review - so.git/blob

   1 /*-\r
   2  * ============LICENSE_START=======================================================\r
   3  * ONAP - SO\r
   4  * ================================================================================\r
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.\r
   6  * ================================================================================\r
   7  * Licensed under the Apache License, Version 2.0 (the "License");\r
   8  * you may not use this file except in compliance with the License.\r
   9  * You may obtain a copy of the License at\r
  10  * \r
  11  *      http://www.apache.org/licenses/LICENSE-2.0\r
  12  * \r
  13  * Unless required by applicable law or agreed to in writing, software\r
  14  * distributed under the License is distributed on an "AS IS" BASIS,\r
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  16  * See the License for the specific language governing permissions and\r
  17  * limitations under the License.\r
  18  * ============LICENSE_END=========================================================\r
  19  */\r
  20 \r
  21 package org.openecomp.camunda.bpmn.plugin.urnmap.resources;\r
  22 \r
  23 import java.util.List;\r
  24 import java.util.StringTokenizer;\r
  25 \r
  26 import javax.ws.rs.GET;\r
  27 import javax.ws.rs.POST;\r
  28 import javax.ws.rs.PUT;\r
  29 \r
  30 import org.slf4j.Logger;\r
  31 import org.slf4j.LoggerFactory;\r
  32 \r
  33 import org.camunda.bpm.cockpit.db.QueryParameters;\r
  34 import org.camunda.bpm.cockpit.plugin.resource.AbstractPluginResource;\r
  35 import org.camunda.bpm.cockpit.db.CommandExecutor;\r
  36 import org.openecomp.camunda.bpmn.plugin.urnmap.db.*;\r
  37 \r
  38 public class ProcessInstanceResource extends AbstractPluginResource {\r
  39 \r
  40   private static final Logger log = LoggerFactory.getLogger(ProcessInstanceResource.class);\r
  41 \r
  42   public ProcessInstanceResource(String engineName) {\r
  43     super(engineName);\r
  44   }\r
  45 \r
  46   @GET\r
  47   public List<URNData> getUrnDataMap() {    \r
  48     List<URNData> list = getQueryService()\r
  49             .executeQuery(\r
  50                     "cockpit.urnMap.retrieveUrnKeyValuePair",\r
  51                     new QueryParameters<URNData>());\r
  52     \r
  53     log.info("urnmap-plugin project - Results Retrieved: ");\r
  54     log.info("URNName: " + "            " + "URNValue: " );\r
  55     for(URNData d: list)\r
  56     {\r
  57         log.info(  d.getURNName() + "           "  + d.getURNValue());\r
  58     }\r
  59    \r
  60     return list;\r
  61   }\r
  62   \r
  63   @PUT\r
  64   //public void insertNewRow(String key_, String value_) \r
  65   public void insertNewRow(String temp) \r
  66    {  \r
  67          log.info("AddNewRow: XXXXXXXXXXXXXXXXX ---> " + temp);\r
  68          StringTokenizer st = new StringTokenizer(temp, "|");\r
  69          String key_ = "";\r
  70          String value_ = "";\r
  71          \r
  72          while(st.hasMoreTokens()) { \r
  73                   key_ = st.nextToken(); \r
  74                   value_ = st.nextToken(); \r
  75                  System.out.println(key_ + "\t" + value_); \r
  76                  } \r
  77                          \r
  78           log.info("AddNewRow: XXXXXXXXXXXXXXXXX ---> key: " + key_ + " , Value: " + value_);\r
  79           URNData nRow = new URNData();\r
  80           nRow.setVer_("1");     \r
  81           nRow.setURNName(key_);\r
  82           nRow.setURNValue(value_);\r
  83           \r
  84          getQueryService().executeQuery("cockpit.urnMap.insertNewRow", nRow, URNData.class);\r
  85          \r
  86          log.info("AddNewRow: XXXXXX    END   XXXXXXXXXXX");\r
  87    }\r
  88   \r
  89   @POST\r
  90  // public void getPersistData(List<URNData > myList) {  \r
  91   public void getPersistData(URNData d) {  \r
  92           \r
  93           log.info("getPersistData:  UrnName: " + d.getURNName() + " , URNValue: " + d.getURNValue() );\r
  94             \r
  95                 getQueryService().executeQuery("cockpit.urnMap.persistURNData", d, URNData.class);\r
  96                 //getQueryService().executeQuery("cockpit.sample.persistURNData", d, ProcessInstanceCountDto.class);\r
  97              \r
  98                     \r
  99             log.info("XXXXXXXXXX - END - XXXXXXXXXXXXXXX");\r
 100         }\r
 101 }\r