Executarea interogărilor SQL de bază

Interogarea unei baze de date PostgreSQL în Java

Miller Trujillo

Staff Software Engineer

Instrucțiuni în JDBC

Utilizați executeQuery() pentru instrucțiuni SELECT
Utilizați executeUpdate() pentru INSERT, UPDATE, DELETE

Instrucțiunea ca mesager

Crearea unei instrucțiuni

String sql = "SELECT book_id, title, publication_year FROM books";

try (Connection conn = DriverManager.getConnection(url, user, password);
     Statement stmt = conn.createStatement();
     ResultSet rs = stmt.executeQuery(sql)) {

Citirea rezultatelor cu ResultSet

String sql = "SELECT book_id, title, publication_year FROM books";
try (Connection conn = DriverManager.getConnection(url, user, password);
     Statement stmt = conn.createStatement();
     ResultSet rs = stmt.executeQuery(sql)) {

  while (rs.next()) {

    int id = rs.getInt("book_id");
    String title = rs.getString("title");
    int year = rs.getInt("publication_year");
    System.out.println(id + " | " + title + " (" + year + ")");}}

1 | Effective Java (2018)
2 | Clean Code (2008)
...

Gestionarea excepțiilor

try {
    Statement stmt = conn.createStatement();

    stmt.executeQuery("SELECT * FROM unknown_table");

} catch (SQLException e) {

    System.err.println("Error: " + e.getMessage());
    System.err.println("SQLState: " + e.getSQLState()); 
}

Error: ERROR: relation "unknown_table" does not exist
  Position: 15
SQLState: 42P01

Recapitulare

Statement trimite comenzi SQL către baza de date
ResultSet stochează rezultatele; iterați cu next()
Metode getter: getInt(), getString(), getDate()
executeQuery() pentru SELECT, executeUpdate() pentru modificări
Gestionați erorile cu SQLException

Recapitulare

Să exersăm!

Interogarea unei baze de date PostgreSQL în Java