ba150d5108b80b1f11dc1018f42e1018d28bd58c
[ccsdk/features.git] /
1 /*\r
2  * Copyright © 2017-2018 AT&T Intellectual Property.\r
3  * Modifications Copyright © 2018 IBM.\r
4  * \r
5  * Licensed under the Apache License, Version 2.0 (the "License");\r
6  * you may not use this file except in compliance with the License.\r
7  * You may obtain a copy of the License at\r
8  * \r
9  * http://www.apache.org/licenses/LICENSE-2.0\r
10  * \r
11  * Unless required by applicable law or agreed to in writing, software\r
12  * distributed under the License is distributed on an "AS IS" BASIS,\r
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
14  * See the License for the specific language governing permissions and\r
15  * limitations under the License.\r
16  */\r
17 \r
18 package org.onap.ccsdk.config.data.adaptor.dao;\r
19 \r
20 import java.util.HashMap;\r
21 import java.util.List;\r
22 import java.util.Map;\r
23 import org.junit.Assert;\r
24 import org.junit.Before;\r
25 import org.junit.FixMethodOrder;\r
26 import org.junit.Test;\r
27 import org.junit.runner.RunWith;\r
28 import org.junit.runners.MethodSorters;\r
29 import org.onap.ccsdk.config.data.adaptor.DataAdaptorConstants;\r
30 import org.onap.ccsdk.config.data.adaptor.domain.TransactionLog;\r
31 import org.springframework.beans.factory.annotation.Autowired;\r
32 import org.springframework.test.context.ContextConfiguration;\r
33 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;\r
34 import com.att.eelf.configuration.EELFLogger;\r
35 import com.att.eelf.configuration.EELFManager;\r
36 \r
37 @RunWith(SpringJUnit4ClassRunner.class)\r
38 @ContextConfiguration(locations = {"classpath:test-context-h2db.xml"})\r
39 @FixMethodOrder(MethodSorters.NAME_ASCENDING)\r
40 public class ConfigTransactionLogDaoTest {\r
41     private static EELFLogger logger = EELFManager.getInstance().getLogger(ConfigTransactionLogDaoTest.class);\r
42 \r
43     @Autowired\r
44     private TransactionLogDao transactionLogDao;\r
45 \r
46     @Autowired\r
47     private NamedQueryExecutorDao namedQueryExecutorDao;\r
48 \r
49     @Before\r
50     public void initialise() {\r
51 \r
52     }\r
53 \r
54     @Test\r
55     public void testQueryExecution() throws Exception {\r
56         String requestId = "12345";\r
57 \r
58         transactionLogDao\r
59                 .save(new TransactionLog(requestId, DataAdaptorConstants.LOG_MESSAGE_TYPE_LOG, "Received Request"));\r
60 \r
61         List<TransactionLog> result = transactionLogDao.getTransactionsByRequestId(requestId);\r
62         logger.info("DB ArtifactReference :" + result);\r
63         Assert.assertNotNull("Failed to get Query Result", result);\r
64 \r
65         List<TransactionLog> result2 =\r
66                 transactionLogDao.getTransactionsByRequestId(requestId, DataAdaptorConstants.LOG_MESSAGE_TYPE_LOG);\r
67         logger.info("DB ArtifactReference :" + result2);\r
68         Assert.assertNotNull("Failed to get Query Result", result2);\r
69 \r
70         String namedsql = "SELECT * FROM CONFIG_TRANSACTION_LOG WHERE request_id = :request_id";\r
71         Map<String, Object> parameters = new HashMap<>();\r
72         parameters.put("request_id", "12345");\r
73         List<Map<String, Object>> namedresult = namedQueryExecutorDao.query(namedsql, parameters);\r
74         logger.info("DB ArtifactReference :" + namedresult);\r
75         Assert.assertNotNull("Failed to get Query Result", namedresult);\r
76 \r
77     }\r
78 \r
79 }\r