package com.example;

import org.postgresql.pljava.annotation.Function;

import java.sql.*;
import java.util.logging.Logger;

public class Threads {
    Worker worker = new Worker();

    @Function (
            schema = "javatest",
            name = "java_simpleThread",
    )
    public static void testThread() {
        try {
            Threads threads = new Threads();
            // Uncomment to make it work
            // threads.test();

            threads.worker.start();
            threads.worker.join();

        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    public void test() {
        PreparedStatement ps = null;
        Connection connection = null;
        ResultSet rs = null;

        try {
            Class.forName("org.postgresql.Driver");
            connection = DriverManager.getConnection("jdbc:postgresql://127.0.0.1:5432/sample", "user", "pass");

            ps = connection.prepareStatement("SELECT NOW();");
            rs = ps.executeQuery();

            if (rs.next()) {
                Logger.getAnonymousLogger().info("Now: " + rs.getString(1) + " Thread: " + Thread.currentThread().getName());
            }

        } catch (SQLException | ClassNotFoundException e) {
            throw new RuntimeException(e);
        } finally {
            if (rs != null) {
                try {
                    rs.close();
                } catch (SQLException e) {}
            }
            if (ps != null) {
                try {
                    ps.close();
                } catch (SQLException e) {}
            }
            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {}
            }
        }
    }

    private class Worker extends Thread {
        @Override
        public void run() {
            test();
        }
    }
}