moved H2DAO from para-server to here

Erudika · Mar 14, 2018 · 68a19f8 · 68a19f8
1 parent 569cd36
commit 68a19f8
Show file tree

Hide file tree

Showing 5 changed files with 748 additions and 8 deletions.
diff --git a/pom.xml b/pom.xml
@@ -80,6 +80,13 @@
 			<version>2.7.4</version>
 		</dependency>
 
+		<!-- H2 DB -->
+		<dependency>
+			<groupId>com.h2database</groupId>
+			<artifactId>h2</artifactId>
+			<version>1.4.196</version>
+		</dependency>
+
 		<!-- TESTING -->
 		<dependency>
 			<groupId>org.mockito</groupId>
@@ -105,12 +112,6 @@
 			<version>1.2</version>
 			<scope>test</scope>
 		</dependency>
-		<dependency>
-			<groupId>com.h2database</groupId>
-			<artifactId>h2</artifactId>
-			<version>1.4.196</version>
-			<scope>test</scope>
-		</dependency>
 	</dependencies>
 
 	<build>
@@ -168,7 +169,7 @@
 			<plugin>
 				<groupId>org.apache.maven.plugins</groupId>
 				<artifactId>maven-checkstyle-plugin</artifactId>
-				<version>2.17</version>
+				<version>3.0.0</version>
 				<executions>
 					<execution>
 						<id>validate-core</id>

diff --git a/src/main/java/com/erudika/para/persistence/H2DAO.java b/src/main/java/com/erudika/para/persistence/H2DAO.java
@@ -0,0 +1,192 @@
+/*
+ * Copyright 2013-2018 Erudika. https://erudika.com
+ *
+ * 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.
+ *
+ * For issues and patches go to: https://github.com/erudika
+ */
+package com.erudika.para.persistence;
+
+import com.erudika.para.AppCreatedListener;
+import com.erudika.para.AppDeletedListener;
+import com.erudika.para.core.App;
+import com.erudika.para.core.ParaObject;
+import com.erudika.para.utils.Config;
+import com.erudika.para.utils.Pager;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import javax.inject.Singleton;
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Fake DAO for in-memory persistence.
+ * Used for testing and development without a database.
+ * @author Alex Bogdanovski [alex@erudika.com]
+ */
+@Singleton
+public class H2DAO implements DAO {
+
+	private static final Logger logger = LoggerFactory.getLogger(H2DAO.class);
+
+	/**
+	 * Default constructor.
+	 */
+	public H2DAO() {
+		// set up automatic table creation and deletion
+		App.addAppCreatedListener(new AppCreatedListener() {
+			public void onAppCreated(App app) {
+				if (app != null) {
+					H2Utils.createTable(app.getAppIdentifier());
+				}
+			}
+		});
+		App.addAppDeletedListener(new AppDeletedListener() {
+			public void onAppDeleted(App app) {
+				if (app != null) {
+					H2Utils.deleteTable(app.getAppIdentifier());
+				}
+			}
+		});
+	}
+
+	@Override
+	public <P extends ParaObject> String create(String appid, P object) {
+		if (object == null) {
+			return null;
+		}
+		H2Utils.createRows(appid, Collections.singletonList(object));
+		logger.debug("DAO.create() {}", object.getId());
+		return object.getId();
+	}
+
+	@Override
+	@SuppressWarnings("unchecked")
+	public <P extends ParaObject> P read(String appid, String key) {
+		if (key == null || StringUtils.isBlank(appid)) {
+			return null;
+		}
+		Map<String, P> results = H2Utils.readRows(appid, Collections.singletonList(key));
+		P object = results.get(key);
+		logger.debug("DAO.read() {} -> {}", key, object);
+		return object;
+	}
+
+	@Override
+	public <P extends ParaObject> void update(String appid, P object) {
+		if (object != null && !StringUtils.isBlank(appid)) {
+			H2Utils.updateRows(appid, Collections.singletonList(object));
+			logger.debug("DAO.update() {}", object.getId());
+		}
+	}
+
+	@Override
+	public <P extends ParaObject> void delete(String appid, P object) {
+		if (object != null && !StringUtils.isBlank(appid)) {
+			H2Utils.deleteRows(appid, Collections.singletonList(object));
+			logger.debug("DAO.delete() {}", object.getId());
+		}
+	}
+
+	@Override
+	public <P extends ParaObject> void createAll(String appid, List<P> objects) {
+		if (StringUtils.isBlank(appid) || objects == null) {
+			return;
+		}
+		H2Utils.createRows(appid, objects);
+		logger.debug("DAO.createAll() {}", objects.size());
+	}
+
+	@Override
+	@SuppressWarnings("unchecked")
+	public <P extends ParaObject> Map<String, P> readAll(String appid, List<String> keys, boolean getAllColumns) {
+		if (keys == null || StringUtils.isBlank(appid)) {
+			return Collections.emptyMap();
+		}
+		Map<String, P> results = H2Utils.readRows(appid, keys);
+		logger.debug("DAO.readAll() {}", results.size());
+		return results;
+	}
+
+	@Override
+	@SuppressWarnings("unchecked")
+	public <P extends ParaObject> List<P> readPage(String appid, Pager pager) {
+		return H2Utils.scanRows(appid, pager);
+	}
+
+	@Override
+	public <P extends ParaObject> void updateAll(String appid, List<P> objects) {
+		if (!StringUtils.isBlank(appid) && objects != null) {
+			H2Utils.updateRows(appid, objects);
+			logger.debug("DAO.updateAll() {}", objects.size());
+		}
+	}
+
+	@Override
+	public <P extends ParaObject> void deleteAll(String appid, List<P> objects) {
+		if (!StringUtils.isBlank(appid) && objects != null) {
+			H2Utils.deleteRows(appid, objects);
+			logger.debug("DAO.deleteAll() {}", objects.size());
+		}
+	}
+
+	////////////////////////////////////////////////////////////////////
+
+	@Override
+	public <P extends ParaObject> String create(P object) {
+		return create(Config.getRootAppIdentifier(), object);
+	}
+
+	@Override
+	public <P extends ParaObject> P read(String key) {
+		return read(Config.getRootAppIdentifier(), key);
+	}
+
+	@Override
+	public <P extends ParaObject> void update(P object) {
+		update(Config.getRootAppIdentifier(), object);
+	}
+
+	@Override
+	public <P extends ParaObject> void delete(P object) {
+		delete(Config.getRootAppIdentifier(), object);
+	}
+
+	@Override
+	public <P extends ParaObject> void createAll(List<P> objects) {
+		createAll(Config.getRootAppIdentifier(), objects);
+	}
+
+	@Override
+	public <P extends ParaObject> Map<String, P> readAll(List<String> keys, boolean getAllColumns) {
+		return readAll(Config.getRootAppIdentifier(), keys, getAllColumns);
+	}
+
+	@Override
+	public <P extends ParaObject> List<P> readPage(Pager pager) {
+		return readPage(Config.getRootAppIdentifier(), pager);
+	}
+
+	@Override
+	public <P extends ParaObject> void updateAll(List<P> objects) {
+		updateAll(Config.getRootAppIdentifier(), objects);
+	}
+
+	@Override
+	public <P extends ParaObject> void deleteAll(List<P> objects) {
+		deleteAll(Config.getRootAppIdentifier(), objects);
+	}
+
+}