การรันคิวรี SQL เบื้องต้น

การคิวรีฐานข้อมูล PostgreSQL ด้วย Java

Miller Trujillo

Staff Software Engineer

Statement ใน JDBC

ใช้ executeQuery() สำหรับคำสั่ง SELECT
ใช้ executeUpdate() สำหรับ INSERT, UPDATE, DELETE

Statement ทำหน้าที่เป็นตัวกลาง

การสร้าง Statement

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)) {

การอ่านผลลัพธ์ด้วย 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)
...

การจัดการข้อผิดพลาด

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

สรุป

Statement ส่งคำสั่ง SQL ไปยังฐานข้อมูล
ResultSet เก็บผลลัพธ์ของคิวรี วนซ้ำด้วย next()
เมธอดดึงค่า: getInt(), getString(), getDate()
executeQuery() สำหรับ SELECT และ executeUpdate() สำหรับการแก้ไขข้อมูล
จัดการข้อผิดพลาดด้วย SQLException

สรุป

มาฝึกกันเถอะ!

การคิวรีฐานข้อมูล PostgreSQL ด้วย Java