package nl.astraeus.jdbc.example;

import java.sql.*;

/**
 * User: rnentjes
 * Date: 4/12/12
 * Time: 7:32 PM
 */
public class JdbcStatisticsExample {


    public static void main(String [] args) throws Exception {
        Class.forName("org.h2.Driver");
        Class.forName("nl.astraeus.jdbc.Driver");

        new JdbcStatisticsExample();
    }

    public JdbcStatisticsExample() throws Exception {
        Connection conn = DriverManager.getConnection("jdbc:stat:jdbc:h2:mem:test");

        Statement statement = null;

        statement = conn.createStatement();
        statement.execute("CREATE TABLE TEST(ID INT PRIMARY KEY, NAME VARCHAR(255))");
        statement.close();

        boolean running = true;
        int count = 1;
        PreparedStatement ps = null;

        while (running) {
            Thread.sleep(10);

            String TableName = "TEST"+(System.nanoTime() % 1000);

            try {
                ps = conn.prepareStatement("SELECT COUNT(*) FROM "+TableName);
                ResultSet rs = ps.executeQuery();
            } catch (SQLException e) {
                statement = conn.createStatement();
                statement.execute("CREATE TABLE "+TableName+" (ID INT PRIMARY KEY, NAME VARCHAR(255))");
                statement.close();
            } finally {
                if (ps!=null) {
                    ps.close();
                }
            }

            ps = conn.prepareStatement("INSERT INTO "+TableName+" VALUES (?, ?)");

            ps.setInt(1, count++);
            ps.setString(2, "String  "+System.currentTimeMillis());

            ps.execute();
            ps.close();

            Thread.sleep(10);

            ps = conn.prepareStatement("SELECT * FROM "+TableName);
            ResultSet rs = ps.executeQuery();
            statement.close();
        }

        conn.close();
    }
}