Create even table automatically

Author: LEDfan

src/main/java/eu/openanalytics/containerproxy/stat/impl/JDBCCollector.java

@@ -24,6 +24,7 @@
 import java.sql.Connection;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
+import java.sql.Statement;
 import java.sql.Timestamp;
 
 import org.springframework.core.env.Environment;
@@ -63,7 +64,7 @@ public class JDBCCollector extends AbstractDbCollector {
 	private Environment environment;
 
 	@PostConstruct
-	public void init() {
+	public void init() throws IOException {
 		String baseURL = environment.getProperty("proxy.usage-stats-url");
 		String username = environment.getProperty("proxy.usage-stats-username", "monetdb");
 		String password = environment.getProperty("proxy.usage-stats-password", "monetdb");
@@ -96,7 +97,29 @@ public void init() {
 		if (maximumPoolSize != null) {
 			ds.setMaximumPoolSize(maximumPoolSize);
 		}
-		
+
+		// create table if not already exists
+		try (Connection con = ds.getConnection()) {
+			Statement statement = con.createStatement();
+			if (con.getMetaData().getDatabaseProductName().equals("Microsoft SQL Server")) {
+				statement.execute(
+						"IF OBJECT_ID('event', 'U') IS NULL" +
+								" create table event(" +
+								" event_time datetime," +
+								" username varchar(128)," +
+								" type varchar(128)," +
+								" data text)");
+			} else {
+				statement.execute(
+						"create table if not exists event(" +
+								" event_time timestamp," +
+								" username varchar(128)," +
+								" type varchar(128)," +
+								" data text)");
+			}
+		} catch (SQLException e) {
+			throw new IOException("Exception while logging stats", e);
+		}
 	}
 
 	@Override