Added audit4j Database Handler

Author: janithb

pom.xml

@@ -0,0 +1,58 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<groupId>org.audit4j.handler-db</groupId>
+	<artifactId>audit4j-handler-db</artifactId>
+	<packaging>jar</packaging>
+	<version>2.0-SNAPSHOT</version>
+	<name>Audit4j - Database Handler</name>
+	<url>http://maven.apache.org</url>
+
+	<properties>
+		<slf4j.version>1.7.5</slf4j.version>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>junit</groupId>
+			<artifactId>junit</artifactId>
+			<version>4.11</version>
+		</dependency>
+		<dependency>
+			<groupId>org.slf4j</groupId>
+			<artifactId>slf4j-api</artifactId>
+			<version>1.7.6</version>
+		</dependency>
+		<dependency>
+			<groupId>c3p0</groupId>
+			<artifactId>c3p0</artifactId>
+			<version>0.9.1</version>
+		</dependency>
+		<dependency>
+			<groupId>org.hsqldb</groupId>
+			<artifactId>hsqldb</artifactId>
+			<version>2.3.2</version>
+		</dependency>
+	</dependencies>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-compiler-plugin</artifactId>
+			</plugin>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-eclipse-plugin</artifactId>
+			</plugin>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-jar-plugin</artifactId>
+			</plugin>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-surefire-plugin</artifactId>
+			</plugin>
+		</plugins>
+	</build>
+</project>

src/main/java/org/audit4j/handler/db/AuditBaseDao.java

@@ -0,0 +1,40 @@
+/*
+ * Copyright 2014 Janith Bandara, This source is a part of Audit4j - 
+ * An open-source audit platform for Enterprise java platform.
+ * http://mechanizedspace.com/audit4j
+ * http://audit4j.org
+ *
+ * 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.
+ */
+
+package org.audit4j.handler.db;
+
+import java.sql.Connection;
+
+/**
+ * The Class AuditBaseDao.
+ *
+ * @author <a href="mailto:[email protected]">Janith Bandara</a>
+ */
+class AuditBaseDao {
+
+	/**
+	 * Gets the connection.
+	 *
+	 * @return the connection
+	 */
+	protected Connection getConnection() {
+		ConnectionFactory factory = ConnectionFactory.getInstance();
+		return factory.getConnection();
+	}
+}

src/main/java/org/audit4j/handler/db/AuditLogDao.java

@@ -0,0 +1,49 @@
+/*
+ * Copyright 2014 Janith Bandara, This source is a part of Audit4j - 
+ * An open-source audit platform for Enterprise java platform.
+ * http://mechanizedspace.com/audit4j
+ * http://audit4j.org
+ *
+ * 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.
+ */
+
+package org.audit4j.handler.db;
+
+import java.sql.SQLException;
+
+import org.audit4j.core.dto.AuditEvent;
+
+/**
+ * The Interface AuditLogDao.
+ *
+ * @author <a href="mailto:[email protected]">Janith Bandara</a>
+ */
+interface AuditLogDao {
+
+	/**
+	 * Write event.
+	 *
+	 * @param event the event
+	 * @return true, if successful
+	 * @throws SQLException the sQL exception
+	 */
+	boolean writeEvent(AuditEvent event) throws SQLException;
+	
+	/**
+	 * Creates the audit table if not exist.
+	 *
+	 * @return true, if successful
+	 * @throws SQLException the sQL exception
+	 */
+	boolean createAuditTableIFNotExist() throws SQLException;
+}

src/main/java/org/audit4j/handler/db/AuditLogDaoImpl.java

@@ -0,0 +1,81 @@
+/*
+ * Copyright 2014 Janith Bandara, This source is a part of Audit4j - 
+ * An open-source audit platform for Enterprise java platform.
+ * http://mechanizedspace.com/audit4j
+ * http://audit4j.org
+ *
+ * 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.
+ */
+
+package org.audit4j.handler.db;
+
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+
+import org.audit4j.core.dto.AuditEvent;
+import org.audit4j.core.dto.Element;
+
+/**
+ * The Class HSQLAuditLogDao.
+ * 
+ * @author <a href="mailto:[email protected]">Janith Bandara</a>
+ */
+class AuditLogDaoImpl extends AuditBaseDao implements AuditLogDao {
+
+    /*
+     * (non-Javadoc)
+     * 
+     * @see
+     * org.audit4j.core.handler.db.AuditLogDao#createEvent(org.audit4j.core.
+     * dto.AuditEvent)
+     */
+    @Override
+    public boolean writeEvent(AuditEvent event) throws SQLException {
+
+        StringBuffer elements = new StringBuffer();
+
+        for (Element element : event.getEventElements()) {
+            elements.append(element.getName() + " " + element.getType() + ":" + element.getValue() + ", ");
+        }
+        StringBuffer query = new StringBuffer();
+        query.append("insert into audit(auditId, uuid, timestamp, actor, origin, action, elements) ").append(
+                "values (?, ?, ?, ?, ?, ?, ?)");
+
+        PreparedStatement statement = getConnection().prepareStatement(query.toString());
+        statement.setInt(1, event.getAuditId());
+        statement.setString(2, event.getUuid().toString());
+        statement.setString(3, event.getTimestamp().toString());
+        statement.setString(4, event.getActor());
+        statement.setString(5, event.getOrigin());
+        statement.setString(6, event.getAction());
+        statement.setString(7, elements.toString());
+        return statement.execute();
+    }
+
+    @Override
+    public boolean createAuditTableIFNotExist() throws SQLException {
+        StringBuffer query = new StringBuffer("create table if not exists audit (");
+        query.append("auditId INT NOT NULL,");
+        query.append("uuid char(60) NOT NULL,");
+        query.append("timestamp varchar(100) NOT NULL,");
+        query.append("actor varchar(200) NOT NULL,");
+        query.append("origin varchar(200),");
+        query.append("action varchar(200) NOT NULL,");
+        query.append("elements varchar(20000)");
+        query.append(");");
+
+        getConnection().prepareStatement(query.toString()).execute();
+        return true;
+    }
+
+}

src/main/java/org/audit4j/handler/db/ConnectionFactory.java

@@ -0,0 +1,154 @@
+/*
+ * Copyright 2014 Janith Bandara, This source is a part of Audit4j - 
+ * An open-source audit platform for Enterprise java platform.
+ * http://mechanizedspace.com/audit4j
+ * http://audit4j.org
+ *
+ * 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.
+ */
+
+package org.audit4j.handler.db;
+
+import java.beans.PropertyVetoException;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+
+import org.audit4j.core.exception.InitializationException;
+
+import com.mchange.v2.c3p0.ComboPooledDataSource;
+
+/**
+ * A factory for creating Connection objects.
+ */
+final class ConnectionFactory {
+
+	static final String SINGLE_CONNECTION = "single";
+	
+	static final String POOLED_CONNECTION = "pooled";
+	
+	/** The db_driver. */
+	private String driver = "org.hsqldb.jdbcDriver";
+
+	/** The db_url. */
+	private String url = "jdbc:hsqldb:hsql://localhost/audit4j";
+
+	/** The db_user. */
+	private String user = "audit4juser";
+
+	/** The db_password. */
+	private String password = "audit4jpassword";
+	
+
+	private String connectionType;
+	
+
+	/**
+	 * Instantiates a new connection factory.
+	 */
+	private ConnectionFactory() {
+	}
+
+	/** The instance. */
+	private static ConnectionFactory instance;
+
+	private static ComboPooledDataSource cpds;
+
+	/**
+	 * Gets the connection.
+	 * 
+	 * @return the connection
+	 * 
+	 * @deprecated please use getPooledConnection() instead.
+	 */
+	@Deprecated
+	Connection getSingleConnection() {
+		Connection connection = null;
+		try {
+			Class.forName(driver);
+			connection = DriverManager.getConnection(url, user, password);
+		} catch (SQLException e) {
+			throw new InitializationException("Could not initialize the connection", e);
+		} catch (ClassNotFoundException e) {
+			throw new InitializationException("Could not find the driver class", e);
+		}
+		return connection;
+	}
+
+	Connection getConnection() {
+		if (SINGLE_CONNECTION.equals(connectionType)) {
+			return getSingleConnection();
+		} else {
+			try {
+				return  cpds.getConnection();
+			} catch (SQLException e) {
+				throw new InitializationException("Could not obtain the db connection", e);
+			}
+		}
+	}
+
+	
+
+	/**
+	 * Inits the.
+	 * 
+	 * @return true, if successful
+	 * @throws SQLException
+	 */
+	boolean init() {
+		try {
+			cpds = new ComboPooledDataSource();
+			cpds.setDriverClass(this.driver);
+
+			cpds.setJdbcUrl(this.url);
+			cpds.setUser(this.user);
+			cpds.setPassword(this.password);
+
+		} catch (PropertyVetoException e) {
+			throw new InitializationException("Couldn't initialize c3p0 object pool", e);
+		}
+		return Boolean.TRUE;
+	}
+
+	void setDriver(String driver) {
+		this.driver = driver;
+	}
+
+	void setUrl(String url) {
+		this.url = url;
+	}
+
+	void setUser(String user) {
+		this.user = user;
+	}
+
+	void setPassword(String password) {
+		this.password = password;
+	}
+
+	void setConnectionType(String connectionType) {
+		this.connectionType = connectionType;
+	}
+
+	/**
+	 * Gets the single instance of ConnectionFactory.
+	 * 
+	 * @return single instance of ConnectionFactory
+	 */
+	static ConnectionFactory getInstance() {
+		if (instance == null) {
+			instance = new ConnectionFactory();
+		}
+		return instance;
+	}
+}