32438410f8631583ec43249209227611238c711c
[ccsdk/features.git] /
1 /*
2  * ============LICENSE_START=======================================================
3  * ONAP : ccsdk features
4  * ================================================================================
5  * Copyright (C) 2020 highstreet technologies GmbH Intellectual Property.
6  * All rights reserved.
7  * ================================================================================
8  * Licensed under the Apache License, Version 2.0 (the "License");
9  * you may not use this file except in compliance with the License.
10  * You may obtain a copy of the License at
11  *
12  *     http://www.apache.org/licenses/LICENSE-2.0
13  *
14  * Unless required by applicable law or agreed to in writing, software
15  * distributed under the License is distributed on an "AS IS" BASIS,
16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17  * See the License for the specific language governing permissions and
18  * limitations under the License.
19  * ============LICENSE_END=========================================================
20  *
21  */
22 package org.onap.ccsdk.features.sdnr.wt.dataprovider.setup;
23
24 import static org.junit.Assert.assertEquals;
25 import static org.junit.Assert.assertTrue;
26 import static org.junit.Assert.fail;
27
28 import org.junit.Test;
29 import org.onap.ccsdk.features.sdnr.wt.common.database.config.HostInfo;
30 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.DataMigrationReport;
31 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.Release;
32
33 /**
34  * @author Michael Dürre
35  *
36  */
37 public class TestMigrationProvider {
38
39     private static final String FRANKFURT_BACKUP_FILE = "src/test/resources/test2.bak.json";
40     public static HostInfo[] hosts = new HostInfo[] {new HostInfo("localhost", Integer
41             .valueOf(System.getProperty("databaseport") != null ? System.getProperty("databaseport") : "49200"))};
42
43     @Test
44     public void testCreateImport() throws Exception {
45         DataMigrationProviderImpl provider = new DataMigrationProviderImpl(hosts, null, null, true, 5000);
46
47         try {
48
49
50             //create el alto db infrastructure
51             if (!provider.initDatabase(null, 5, 1, "", true, 10000)) {
52                 fail("unable to init database");
53             }
54             //import data into database
55             DataMigrationReport report = provider.importData(FRANKFURT_BACKUP_FILE, false, Release.FRANKFURT_R2);
56             assertTrue(report.completed());
57             assertEquals(Release.FRANKFURT_R2, provider.autoDetectRelease());
58         } catch (Exception e) {
59             fail(e.getMessage());
60         }
61     }
62 }