From 9be1e1d86e54070f4feeef731b3f15bbf5d67db9 Mon Sep 17 00:00:00 2001
From: Robin Kupper <robbzkupper@web.de>
Date: Sat, 23 Jul 2011 23:51:31 +0200
Subject: [PATCH] Added getBlockChanges api

---
 src/de/diddiz/LogBlock/LogBlock.java | 25 +++++++++++++++++++++++++
 1 file changed, 25 insertions(+)

diff --git a/src/de/diddiz/LogBlock/LogBlock.java b/src/de/diddiz/LogBlock/LogBlock.java
index 33498eb..6b8ebd1 100644
--- a/src/de/diddiz/LogBlock/LogBlock.java
+++ b/src/de/diddiz/LogBlock/LogBlock.java
@@ -7,8 +7,12 @@ import java.io.FileNotFoundException;
 import java.io.FileReader;
 import java.net.URL;
 import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
 import java.sql.Statement;
+import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 import java.util.Timer;
 import java.util.logging.Level;
@@ -259,4 +263,25 @@ public class LogBlock extends JavaPlugin
 		}
 		return session;
 	}
+
+	public List<BlockChange> getBlockChanges(QueryParams params) throws SQLException {
+		final Connection conn = getConnection();
+		Statement state = null;
+		ResultSet rs = null;
+		if (conn == null)
+			throw new SQLException("No connection");
+		try {
+			params.getLookupQuery();
+			state = conn.createStatement();
+			rs = state.executeQuery(params.getLookupQuery());
+			final List<BlockChange> blockchanges = new ArrayList<BlockChange>();
+			while (rs.next())
+				blockchanges.add(new BlockChange(rs, params.coords));
+			return blockchanges;
+		} finally {
+			if (state != null)
+				state.close();
+			conn.close();
+		}
+	}
 }