clickhouse-jdbc-test.java

clickhouse-jdbc-test.java

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;


class JavaConnectorTest {
    private static final String CREATE_TABLE_SQL = "CREATE TABLE IF NOT EXISTS default.test1 (age Int32, name String) Engine = Memory";
    private static final String INSERT_SQL = "INSERT INTO default.test1 VALUES(33, 'jdbc'),(44, 'ck')";
    private static final String SELECT_SQL = "SELECT * FROM default.test1";
    private static final String SELECT_NUMBER_SQL = "SELECT * FROM system.numbers LIMIT 13";
    private static final String DROP_TABLE_SQL = "DROP TABLE default.test1";

    public static void main(String[] args) {
        String jdbcUrl = "jdbc:mysql://127.0.0.1:9004/default?maxAllowedPacket=67108864&useSSL=false";
        String username = "default";
        String password = "";

        Connection conn = null;
        Statement stmt = null;

        try {
            conn = DriverManager.getConnection(jdbcUrl, username, password);
            stmt = conn.createStatement();
            stmt.executeUpdate(CREATE_TABLE_SQL);
            System.out.println("Table created");

            stmt.executeUpdate(INSERT_SQL);
            System.out.println("Insert rows");

            ResultSet rs = stmt.executeQuery(SELECT_SQL);
            while (rs.next()) {
                System.out.print(rs.getString(1));
                System.out.print(rs.getString(2));
                System.out.println();
            }

            stmt.executeUpdate(DROP_TABLE_SQL);

            rs = stmt.executeQuery(SELECT_NUMBER_SQL);
            while (rs.next()) {
                System.out.print(rs.getString(1));
                System.out.println();
            }

            stmt.close();
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}