Как создать метод из SQL запроса?

Question

[avgwowenjoyer]

Данный запрос в PostrgreSQL возвращает true, если такая запись в БД есть и false - если нет:

SELECT count(*) <> 0 FROM customers
WHERE name = 'Bob' AND purchase = 'bike'

Как создать такой метод, возвращающий boolean, в Java?

Answer 1

[сергей кузьмин]

то же самое почти что:

ResultSet resultSet = statement.executeQuery("SELECT count(*) as cnt FROM customers WHERE name = 'Bob' AND purchase = 'bike'");
  resultSet.next(); // not first() with PGSL JDBC it is forward only cursor
  final int cnt = resultSet.getInt(1);   
  System.out.println("cnt: " + cnt);

учтите что можно конечно исходный SQL запрос выполнит через JDBC но его синтаксис не является стандартным SQL это какое то постгрес расширение:

String query = "SELECT count(*) <> 0 FROM accounts WHERE username = 'bob';";
              System.out.println("Executing count query: " + query);
              ResultSet resultSet = connection.createStatement().executeQuery(query);
              resultSet.next();
              final boolean status = resultSet.getBoolean(1);
              System.out.println("status: " + status);

Answer 2

[Орхан Гасанлы]

Ну пожалуй, вам стоило бы уточнить работаете ли вы с jdbc или с Spring JDBC, Spring JPA, Hibernate и т.д.
В Spring есть такая штука, как exists*
Например,

existsCustomerByNameAndPurchase(String name, String purchase);

Подробнее: https://www.baeldung.com/spring-data-exists-query
Ну а если jdbc, то в чем проблема? Выполнили SQL запрос. Проверили кол-во записей. Если больше 0, то значит true, если 0 - false

Comments

[avgwowenjoyer]

Здравствуйте, Орхан Гасанлы!

Я только недавно начал изучать sql в java, до этого использовал только sqlit3 в python, поэтому смотрю различные гайды

Сейчас в моём проекте есть класс:

import java.sql.*;

public class PostgreSQL {

private static Statement statement;

    static {
        try {
            Connection connection = DriverManager.getConnection(
                    "url",
                    "user",
                    "password");
            statement = connection.createStatement();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

public static void insertNew(String name, String purchase) throws SQLException {
        statement.executeUpdate(String.format("""
                        INSERT INTO customers(
                        name, purchase)
                        VALUES ( '%s', '%s');
                """, name, purchase));
    }
}

Метод insertNew работает (добавляет запись в БД), хотелось бы создать метод, речь о котором идёт в вопросе

[сергей кузьмин]

то же самое почти что:

ResultSet resultSet = statement.executeQuery("SELECT count(*) as cnt FROM customers
WHERE name = 'Bob' AND purchase = 'bike'");
              resultSet.first();
              final int cnt = resultSet.getInt(1);   
              System.out.println("cnt: " + cnt);

[avgwowenjoyer]

сергей кузьмин, не совсем понял, что значит getRows(resultSet) в Вашем примере

[сергей кузьмин]

avgwowenjoyer, поправил на

resultSet.first();
              final int cnt = resultSet.getInt(1);
              System.out.println("cnt: " + cnt);

если помогло - я положу в ответы вы отметите решением

[avgwowenjoyer]

сергей кузьмин,
org.postgresql.util.PSQLException: Operation requires a scrollable ResultSet, but this ResultSet is FORWARD_ONLY.
Это на строчку resultSet.first();

[сергей кузьмин]

avgwowenjoyer, закомментируйте
точнее замените на resultSet.next() - инересная особенность постгреса

[avgwowenjoyer]

сергей кузьмин, вроде работает, спасибо!)

Продублируйте в ответы, чтобы я отметил решением

[сергей кузьмин]

... А не знаете, как вставлять конкретные величины?
То есть чтобы вместо '?' из примера ниже подставлялись name... -

import java.sql.PreparedStatement
String sql = "INSERT INTO survey (register) VALUES(?)";
PreparedStatement preparedStatement = conn.prepareStatement(sql);
                  preparedStatement.setInt(1, 12);
                  preparedStatement.setString(2, "test");
                  preparedStatement.executeUpdate();