import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;

public class inspectDB {

        public static void runQuery(int startHeight, int endHeight) {

                Connection conn = null;

                String dbUrl = "jdbc:h2:nxt_db/nxt;DB_CLOSE_ON_EXIT=FALSE";
                dbUrl += ";DB_CLOSE_ON_EXIT=FALSE";

                try {

                        Class.forName("org.h2.Driver");

                        conn = DriverManager.getConnection(dbUrl, "sa", "sa");

                        Statement stmt = conn.createStatement();
                        // generator_public_key
                        ArrayList<String> pubgenkeys = new ArrayList<String>();
                        String stmtStr = "SELECT generator_public_key, height, timestamp, total_amount FROM block where total_amount >= 0 and height > "
                                        + startHeight + " and height < " + endHeight;
                        ResultSet selectRS = stmt.executeQuery(stmtStr);// total_amount
                        while (selectRS.next()) {
                                String a = selectRS.getString(1);
                                pubgenkeys.add(a);

                        }

                        Iterator<String> it = pubgenkeys.iterator();
                        HashMap<String, Integer> occ = new HashMap<String, Integer>();
                        while (it.hasNext()) {
                                String cur = it.next();
                                // System.out.println(cur);
                                if (occ.containsKey(cur)) {
                                        int last = occ.get(cur).intValue();
                                        occ.remove(cur);
                                        occ.put(cur, new Integer(last + 1));
                                } else
                                        occ.put(cur, 1);
                        }

                        int numBlocks = endHeight - startHeight;
                        int numAddr = occ.values().size();

                        System.out.println("startBlock  " + startHeight
                                        + " generated by # addresses : " + numAddr
                                        + " (numBlocks: " + numBlocks + ")");

                        conn.close();

                } catch (SQLException e) {
                        e.printStackTrace();
                } catch (ClassNotFoundException e) {

                        e.printStackTrace();
                } finally {
                        if (conn != null)
                                try {
                                        conn.close();
                                } catch (SQLException e) {
                                        e.printStackTrace();
                                }
                }

        }

        public static void main(String[] args) {
                int maxh = 200000;
                int step = 10000;
                for (int bh = 0; bh < maxh; bh += step) {
                        runQuery(bh, bh + step);
                }

        }
}