JDBC - 示例程式碼

上一頁
下一頁

本章提供了一個如何建立簡單 JDBC 應用程式的示例。它將向您展示如何開啟資料庫連線、執行 SQL 查詢以及顯示結果。

本模板示例中提到的所有步驟將在本教程的後續章節中進行解釋。

建立 JDBC 應用程式

構建 JDBC 應用程式涉及以下六個步驟：

  • 匯入包 - 需要包含用於資料庫程式設計的 JDBC 類所在的包。大多數情況下，使用import java.sql.*就足夠了。

  • 開啟連線 - 需要使用DriverManager.getConnection()方法建立一個 Connection 物件，該物件表示與資料庫的物理連線。

  • 執行查詢 - 需要使用 Statement 型別的物件來構建和提交 SQL 語句到資料庫。

  • 從結果集中提取資料 - 需要使用適當的ResultSet.getXXX()方法從結果集中檢索資料。

  • 清理環境 - 需要顯式地關閉所有資料庫資源，而不是依賴 JVM 的垃圾回收。

選擇記錄的示例程式碼

此示例可以作為模板，供您將來建立自己的 JDBC 應用程式時參考。

此示例程式碼是基於上一章中完成的環境和資料庫設定編寫的。

在此示例中，我們有四個靜態字串，分別包含資料庫連線 URL、使用者名稱、密碼和 SELECT 查詢。現在使用 DriverManager.getConnection() 方法，我們準備了一個數據庫連線。連線準備就緒後，我們使用 connection.createStatement() 方法建立了一個 Statement 物件，然後使用 statement.executeQuery() 執行 SELECT 查詢並將結果儲存在結果集中。現在迭代結果集並列印每個記錄。

將以下示例複製並貼上到 SelectExample.java 中，編譯並執行如下：

import java.sql.*;

public class SelectExample {
   static final String DB_URL = "jdbc:mysql:///TUTORIALSPOINT";
   static final String USER = "guest";
   static final String PASS = "guest123";
   static final String QUERY = "SELECT id, first, last, age FROM Employees";

   public static void main(String[] args) {
      // Open a connection
      try(Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
         Statement stmt = conn.createStatement();
         ResultSet rs = stmt.executeQuery(QUERY);) {
         // Extract data from result set
         while (rs.next()) {
            // Retrieve by column name
            System.out.print("ID: " + rs.getInt("id"));
            System.out.print(", Age: " + rs.getInt("age"));
            System.out.print(", First: " + rs.getString("first"));
            System.out.println(", Last: " + rs.getString("last"));
         }
      } catch (SQLException e) {
         e.printStackTrace();
      } 
   }
}

輸出

現在讓我們按如下方式編譯上述示例：

C:\>javac SelectExample.java
C:\>

執行SelectExample時，它會產生以下結果：

C:\>java SelectExample
Connecting to database...
Creating statement...
ID: 100, Age: 18, First: Zara, Last: Ali
ID: 101, Age: 25, First: Mahnaz, Last: Fatma
ID: 102, Age: 30, First: Zaid, Last: Khan
ID: 103, Age: 28, First: Sumit, Last: Mittal
C:\>

更新記錄的示例程式碼

在此示例中，我們有五個靜態字串，分別包含資料庫連線 URL、使用者名稱、密碼、UPDATE 查詢和 SELECT 查詢。現在使用 DriverManager.getConnection() 方法，我們準備了一個數據庫連線。連線準備就緒後，我們使用 connection.createStatement() 方法建立了一個 Statement 物件。現在使用 statement.executeUpdate() 執行更新查詢。最後使用 statement.executeQuery() 執行 SELECT 查詢並將結果儲存在結果集中。現在迭代結果集並列印每個記錄以檢查更新的內容。

將以下示例複製並貼上到 UpdateExample.java 中，編譯並執行如下：

import java.sql. *;

public class UpdateExample {
   static final String DB_URL = "jdbc: mysql:///TUTORIALSPOINT";
   static final String USER = "guest";
   static final String PASS = "guest123";
   static final String QUERY1 = "UPDATE Employees SET age=20 where id=100";
   static final String QUERY2= "SELECT id, first, last, age FROM Employees";

   public static void main (String [] args) {
      // Open a connection
      try (Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
         Statement stmt = conn.createStatement();
      ) {

         stmt.executeUpdate(QUERY1);
         ResultSet rs=stmt.executeQuery(QUERY2);
         // Extract data from result set
         while (rs.next()) {
            // Retrieve by column name   
            System.out.print("ID: " + rs.getInt("id"));
            System.out.print(", Age: " + rs.getInt("age"));
            System.out.print(", First: " + rs.getString("first"));
            System.out.println(", Last: " + rs.getString("last"));
         }
      } catch (SQLException e) {
         e.printStackTrace();
      } 
   }
}

輸出

現在讓我們按如下方式編譯上述示例：

C:\>javac UpdateExample.java
C:\>

執行UpdateExample時，它會產生以下結果：

C:\>java UpdateExample
ID: 100, Age: 20, First: Zara, Last: Ali
ID: 101, Age: 25, First: Mahnaz, Last: Fatma
ID: 102, Age: 30, First: Zaid, Last: Khan
ID: 103, Age: 28, First: Sumit, Last: Mittal

C:\>

刪除記錄的示例程式碼

在此示例中，我們有五個靜態字串，分別包含資料庫連線 URL、使用者名稱、密碼、DELETE 查詢和 SELECT 查詢。現在使用 DriverManager.getConnection() 方法，我們準備了一個數據庫連線。連線準備就緒後，我們使用 connection.createStatement() 方法建立了一個 Statement 物件。現在使用 statement.executeUpdate() 執行刪除查詢。最後使用 statement.executeQuery() 執行 SELECT 查詢並將結果儲存在結果集中。現在迭代結果集並列印每個記錄以檢查刪除的內容。

將以下示例複製並貼上到 DeleteExample.java 中，編譯並執行如下：

import java.sql. *;

public class DeleteExample {
   static final String DB_URL = "jdbc: mysql:///TUTORIALSPOINT";
   static final String USER = "guest";
   static final String PASS = "guest123";
   static final String QUERY1 = "DELETE from Employees where id=100";
   static final String QUERY2= "SELECT id, first, last, age FROM Employees";

   public static void main (String [] args) {
      // Open a connection
      try (Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
         Statement stmt = conn.createStatement();
      ) {

         stmt.executeUpdate(QUERY1);
         ResultSet rs=stmt.executeQuery(QUERY2);
         // Extract data from result set
         while (rs.next()) {
            // Retrieve by column name   
            System.out.print("ID: " + rs.getInt("id"));
            System.out.print(", Age: " + rs.getInt("age"));
            System.out.print(", First: " + rs.getString("first"));
            System.out.println(", Last: " + rs.getString("last"));
         }
      } catch (SQLException e) {
         e.printStackTrace();
      } 
   }
}

輸出

現在讓我們按如下方式編譯上述示例：

C:\>javac DeleteExample.java
C:\>

執行DeleteExample時，它會產生以下結果：

C:\>java DeleteExample
ID: 101, Age: 25, First: Mahnaz, Last: Fatma
ID: 102, Age: 30, First: Zaid, Last: Khan
ID: 103, Age: 28, First: Sumit, Last: Mittal

C:\>
列印頁面
上一頁
下一頁
廣告

© . All rights reserved.