Modularized mdbc build

The mdbc pom should inherit from oparent.

The top-level pom should not build the jar directly.
It should be a parent pom for mdbc submodules.

The first submodule will be called mdbc-server.

Note: the "mdbc" jar will now be called "mdbc-server".

Change-Id: I4456e659b7494641e5b3cefd540eb62a149b79a4
Issue-ID: MUSIC-175
Signed-off-by: Rob Daugherty <rd472p@att.com>

3 files changed, 376 insertions, 0 deletions

diff --git a/mdbc-server/src/test/java/org/openecomp/sdnc/sli/resource/dblib/CachedDataSource.java b/mdbc-server/src/test/java/org/openecomp/sdnc/sli/resource/dblib/CachedDataSource.java
new file mode 100755
index 0000000..ecac610
--- /dev/null
+++ b/mdbc-server/src/test/java/org/openecomp/sdnc/sli/resource/dblib/CachedDataSource.java
@@ -0,0 +1,26 @@
+/*
+ * ============LICENSE_START====================================================
+ * org.onap.music.mdbc
+ * =============================================================================
+ * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
+ * =============================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END======================================================
+ */
+package org.openecomp.sdnc.sli.resource.dblib;
+
+public class CachedDataSource {
+	public String getDbConnectionName() {
+		return "name";
+	}
+}
diff --git a/mdbc-server/src/test/java/org/openecomp/sdnc/sli/resource/dblib/DBResourceManager.java b/mdbc-server/src/test/java/org/openecomp/sdnc/sli/resource/dblib/DBResourceManager.java
new file mode 100755
index 0000000..43d4cdf
--- /dev/null
+++ b/mdbc-server/src/test/java/org/openecomp/sdnc/sli/resource/dblib/DBResourceManager.java
@@ -0,0 +1,106 @@
+/*
+ * ============LICENSE_START====================================================
+ * org.onap.music.mdbc
+ * =============================================================================
+ * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
+ * =============================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END======================================================
+ */
+package org.openecomp.sdnc.sli.resource.dblib;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.List;
+import java.util.Properties;
+import java.util.Queue;
+import java.util.concurrent.LinkedBlockingQueue;
+
+import javax.sql.rowset.CachedRowSet;
+import javax.sql.rowset.RowSetProvider;
+
+public class DBResourceManager {
+	public static final String DB_CONNECTION = "jdbc:mdbc:file:/tmp/stresstest";		// "jdbc:h2:mem:db1";
+	@SuppressWarnings("unused")
+	private Properties p;
+	private Queue<Connection> conns;
+
+	private DBResourceManager(Properties p) {
+		this.p = p;
+		this.conns = new LinkedBlockingQueue<Connection>();
+	}
+	public static DBResourceManager create(Properties props) throws Exception {
+		DBResourceManager dbmanager = new DBResourceManager(props);
+		return dbmanager;
+	}
+	public Connection getConnection() throws SQLException {
+		if (conns.size() > 0) {
+			return conns.remove();
+		} else {
+			Properties driver_info = new Properties();
+			return DriverManager.getConnection(DB_CONNECTION, driver_info);
+		}
+	}
+	public void cleanUp() {
+		try {
+			while (conns.size() > 0) {
+				Connection conn = conns.remove();
+				conn.close();
+			}
+		} catch (SQLException e) {
+		}
+	}
+	public boolean isActive() {
+		return true;
+	}
+	public boolean writeData(String statement, List<String> arguments, String preferredDS) throws SQLException {
+		Connection conn = getConnection();
+		PreparedStatement ps =  conn.prepareStatement(statement);
+        for (int i = 1; i <= arguments.size(); i++) {
+        	ps.setObject(i, arguments.get(i-1));
+        }
+        ps.executeUpdate();
+        ps.close();
+        conns.add(conn);
+		return true;
+	}
+	public CachedRowSet getData(String statement, List<String> arguments, String preferredDS) throws SQLException {
+		CachedRowSet data = null;
+		ResultSet rs = null;
+		Connection conn = null;
+		try {
+			data = RowSetProvider.newFactory().createCachedRowSet();
+			conn = getConnection();
+			PreparedStatement ps = conn.prepareStatement(statement);
+			if(arguments != null) {
+				for (int i = 0; i < arguments.size(); i++) {
+					ps.setObject(i+1, arguments.get(i));
+				}
+			}
+			rs = ps.executeQuery();
+			data.populate(rs);
+		} catch (Throwable exc) {
+			throw (SQLException)exc;
+		} finally {
+			if (conn != null)
+				conns.add(conn);
+		}
+		return data;
+	}
+	CachedDataSource findMaster() throws Exception {
+		return new CachedDataSource();
+	}
+}
diff --git a/mdbc-server/src/test/java/org/openecomp/sdnc/sli/resource/dblib/StressTest.java b/mdbc-server/src/test/java/org/openecomp/sdnc/sli/resource/dblib/StressTest.java
new file mode 100755
index 0000000..d6b5717
--- /dev/null
+++ b/mdbc-server/src/test/java/org/openecomp/sdnc/sli/resource/dblib/StressTest.java
@@ -0,0 +1,244 @@
+/*
+ * ============LICENSE_START====================================================
+ * org.onap.music.mdbc
+ * =============================================================================
+ * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
+ * =============================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END======================================================
+ */
+package org.openecomp.sdnc.sli.resource.dblib;
+
+import static org.junit.Assert.*;
+
+import java.net.URL;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.Properties;
+import java.util.Set;
+import java.util.concurrent.atomic.AtomicInteger;
+
+import javax.sql.rowset.CachedRowSet;
+
+import org.junit.After;
+import org.junit.AfterClass;
+import org.junit.Before;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.anarsoft.vmlens.concurrent.junit.ConcurrentTestRunner;
+import com.anarsoft.vmlens.concurrent.junit.ThreadCount;
+
+//@FixMethodOrder(MethodSorters.NAME_ASCENDING)
+@RunWith(ConcurrentTestRunner.class)
+public class StressTest {
+
+//	static {
+//		System.setProperty(org.slf4j.impl.SimpleLogger.DEFAULT_LOG_LEVEL_KEY, "INFO");
+//		System.setProperty(org.slf4j.impl.SimpleLogger.LOG_FILE_KEY, String.format("ComparativeAnalysisTest-%d.log", System.currentTimeMillis()));
+//	}
+	private static final Logger LOG = LoggerFactory.getLogger(StressTest.class);
+	private static Properties props;
+	private static DBResourceManager jdbcDataSource = null;
+	@SuppressWarnings("unused")
+	private static final int MAX_TREADS = 1;
+	@SuppressWarnings("unused")
+	private static final int MAX_ITERATIONS = 10;
+	
+	private final AtomicInteger  count= new AtomicInteger();
+
+	Set<Thread> runningThreads = new HashSet<Thread>();
+
+	@BeforeClass
+	public static void setUpBeforeClass() throws Exception {
+		props = new Properties();
+		URL url = StressTest.class.getResource("/dblib.properties");
+		assertNotNull(url);
+		LOG.info("Property file is: " + url.toString());
+		props.load(url.openStream());
+
+		try {
+			jdbcDataSource = DBResourceManager.create(props);
+			Connection conn = jdbcDataSource.getConnection();
+
+			// ---------------
+			// CREATE TABLE
+			String sql =
+				"CREATE TABLE IF NOT EXISTS `AIC_SITE` (" + 
+					"`name` varchar(100) DEFAULT NULL, "+
+					"`aic_site_id` varchar(100) NOT NULL, "+
+					"`vcenter_url` varchar(200) DEFAULT NULL, "+
+					"`vcenter_username` varchar(40) DEFAULT NULL, "+
+					"`vcenter_passwd` varchar(255) DEFAULT NULL, "+
+					"`city` varchar(100) DEFAULT NULL, "+
+					"`state` varchar(2) DEFAULT NULL, "+
+					"`operational_status` varchar(20) DEFAULT NULL, "+
+					"`oam_gateway_addr` varchar(20) DEFAULT '', "+
+					"PRIMARY KEY (`aic_site_id`) "+
+				") ; ";
+			Statement stmt = conn.createStatement();
+			stmt.execute(sql);
+			// ---------------
+
+			conn.close();
+		} catch (Throwable exc) {
+			LOG.error("", exc);
+		}
+		assertNotNull(jdbcDataSource);
+		if (((DBResourceManager)jdbcDataSource).isActive()){
+			LOG.warn( "DBLIB: JDBC DataSource has been initialized.");
+		} else {
+			LOG.warn( "DBLIB: JDBC DataSource did not initialize successfully.");
+		}
+	}
+
+	@AfterClass
+	public static void tearDownAfterClass() throws Exception {
+		jdbcDataSource.cleanUp();
+	}
+
+	@Before
+	public void setUp() throws Exception {
+
+	}
+
+	@After
+	public void tearDown() throws Exception {
+
+	}
+
+//	@Test
+	public void test01() {
+		LOG.info("TEST 1: Verify primary db selection");
+		checkPrimaryDatabase();
+	}
+	
+	
+	@Test
+	@ThreadCount(10)
+	public void test0X() {
+		int id = count.incrementAndGet();
+		
+		String siteid = String.format("Councurrent-tester-%02d", id);
+		for(int i=0; i<40; i++){
+			String site = String.format("%s_%04d", siteid, i);
+			insertTestData(site);
+			queryTestData(site);
+			removeTestData(site);
+			try {
+				Thread.sleep(0);
+			} catch (Exception e) {
+				LOG.warn("", e);
+			}			
+		}
+	}
+
+	private void removeTestData(String site) {
+		ArrayList<String> delete = new ArrayList<String>();
+		delete.add(site);
+		try {
+			long startTime = System.currentTimeMillis();
+			boolean success = jdbcDataSource.writeData("delete from AIC_SITE where aic_site_id=?", delete, null);
+			logRequest(site, "DELETE", startTime, System.currentTimeMillis() - startTime);
+			assertTrue(success);
+		} catch (SQLException e) {
+			LOG.warn("", e);
+			
+		}
+	}
+
+	private boolean queryTestData(String site) {
+		ArrayList<String> identifier = new ArrayList<String>();
+		identifier.add(site);
+		try {
+			int rowcount = 0;
+			long startTime = System.currentTimeMillis();
+			CachedRowSet data = jdbcDataSource.getData("select * from AIC_SITE where aic_site_id=?", identifier, null);
+			logRequest(site, "QUERY", startTime, System.currentTimeMillis() - startTime);
+			while(data.next()) {
+				rowcount ++;
+			}
+			return rowcount!=0;
+//			assertTrue(success);
+		} catch (SQLException e) {
+			LOG.warn("", e);
+			return false;
+		}
+	}
+
+
+	private void insertTestData(String site) {
+		ArrayList<String> data = new ArrayList<String>();
+		data.add(site);
+		data.add(site);
+		data.add("Sample03");
+		data.add("Sample04");
+		data.add("Sample05");
+
+		boolean success;
+		try {
+			long startTime = System.currentTimeMillis();
+			success = jdbcDataSource.writeData("insert into AIC_SITE (name, aic_site_id, vcenter_url, vcenter_username, vcenter_passwd) values (?,?,?,?,?)", data, null);
+			logRequest(site, "INSERT", startTime, System.currentTimeMillis() - startTime);
+			assertTrue(success);
+		} catch (SQLException e) {
+			LOG.warn("", e);
+		}
+	}
+
+	private void checkPrimaryDatabase() {
+		Connection conn = null;
+		PreparedStatement statement = null;
+		ResultSet rs  = null;
+		
+		try {
+			conn = jdbcDataSource.getConnection();
+			statement = conn.prepareStatement("SELECT 1 FROM DUAL");
+			rs = statement.executeQuery();
+			int value = -1;
+			while(rs.next()) {
+				value = rs.getInt(1);
+			}
+			LOG.info("Value returned is: " + value);
+			conn.close();
+		} catch (SQLException e) {
+			LOG.warn("transaction failed", e);
+		} finally {
+			try {
+				if(rs != null) 	{ rs.close();	} 
+				if(conn != null){ conn.close();	}
+				if(conn != null){ conn.close();	}
+			} catch (SQLException e) {
+				LOG.warn("transaction failed", e);
+			}
+		}
+		CachedDataSource ds = null;
+		try {
+			ds = jdbcDataSource.findMaster();
+		} catch (Throwable e) {
+			LOG.warn("", e);
+		} 
+		LOG.info("Primary DS is " + ds.getDbConnectionName());
+	}
+	private static void logRequest(String site, String command, long timestamp, long duration) {
+		LOG.info(String.format("%s|%s|%d|%d", site, command, timestamp, duration));
+	}	
+}