ac6b336ca2440644e75e3f5e5d305d6a973c2d89
[dmaap/dbcapi.git] / src / test / java / org / onap / dmaap / dbcapi / aaf / database / TableHandlerTest.java
1 /*-
2  * ============LICENSE_START=======================================================
3  * org.onap.dmaap
4  * ================================================================================
5  * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
6  * ================================================================================
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  * 
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  * 
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ============LICENSE_END=========================================================
19  */
20 package org.onap.dmaap.dbcapi.aaf.database;
21
22 import org.onap.dmaap.dbcapi.model.*;
23 import org.onap.dmaap.dbcapi.testframework.ReflectionHarness;
24
25 import static org.junit.Assert.*;
26
27 import org.junit.After;
28 import org.junit.Before;
29 import org.junit.Test;
30 import java.util.*;
31 import java.sql.*;
32
33 public class TableHandlerTest {
34
35         private static final String  fmt = "%24s: %s%n";
36
37         ReflectionHarness rh = new ReflectionHarness();
38
39    private static class TopicReplicationTypeHandler implements DBFieldHandler.SqlOp {
40         public Object get(ResultSet rs, int index) throws Exception {
41             int val = rs.getInt(index);
42
43             return (ReplicationType.valueOf(val));
44         }
45         public void set(PreparedStatement ps, int index, Object val) throws Exception {
46             if (val == null) {
47                 ps.setInt(index, 0);
48                 return;
49             }
50             @SuppressWarnings("unchecked")
51             ReplicationType rep = (ReplicationType) val;
52             ps.setInt(index, rep.getValue());
53         }
54     }
55
56
57
58         @Before
59         public void setUp() throws Exception {
60         }
61
62         @After
63         public void tearDown() throws Exception {
64         }
65
66
67         @Test
68         public void test1() {
69
70
71                 //rh.reflect( "org.onap.dmaap.dbcapi.aaf.client.MrTopicConnection", "get", "idNotSet@namespaceNotSet:pwdNotSet" );      
72         
73         }
74
75         @Test
76         public void test2() {
77                 String v = "Validate";
78                 //rh.reflect( "org.onap.dmaap.dbcapi.aaf.client.MrTopicConnection", "set", v );
79
80         }
81
82         @Test
83         public void test3() {
84                 TableHandler.setSpecialCase("topic", "replication_case", new TopicReplicationTypeHandler());
85
86                 try {
87                 ConnectionFactory cf = new ConnectionFactory();
88                 TableHandler th = new TableHandler( cf, TopicReplicationTypeHandler.class, "foo", "bar" );
89                 } catch (Exception e ) {
90                 }
91                 try {
92                 ConnectionFactory cf = new ConnectionFactory();
93                 TableHandler th = new TableHandler( TopicReplicationTypeHandler.class, "foo", "bar" );
94                 th.getSpecialCase( "foo", "bar" );
95                 } catch (Exception e ) {
96                 }
97
98         }
99
100
101
102 }
103