JDBC - 更新結果集示例

上一頁
下一頁

以下是示例，它使用了結果集教程中描述的ResultSet.CONCUR_UPDATABLE和ResultSet.TYPE_SCROLL_INSENSITIVE。本示例將解釋在表上執行INSERT、UPDATE和DELETE操作。

需要注意的是，您正在使用的表應正確設定主鍵。

刪除表並按如下方式重新建立表Employees：

mysql> use TUTORIALSPOINT;
mysql> drop table Employees;
Query OK, 0 rows affected (0.08 sec)
mysql> create table Employees
    -> (
    -> id int primary key auto_increment,
    -> age int not null,
    -> first varchar (255),
    -> last varchar (255)
    -> );
Query OK, 0 rows affected (0.08 sec)
mysql>

建立資料記錄

最後，您按如下方式在Employee表中建立一些記錄：

mysql> INSERT INTO Employees(AGE, FIRST, LAST) VALUES (18, 'Zara', 'Ali');
Query OK, 1 row affected (0.05 sec)

mysql> INSERT INTO Employees(AGE, FIRST, LAST) VALUES (25, 'Mahnaz', 'Fatma');
Query OK, 1 row affected (0.00 sec)

mysql> INSERT INTO Employees(AGE, FIRST, LAST) VALUES (30, 'Zaid', 'Khan');
Query OK, 1 row affected (0.00 sec)

mysql> INSERT INTO Employees(AGE, FIRST, LAST) VALUES (28, 'Sumit', 'Mittal');
Query OK, 1 row affected (0.00 sec)

mysql>

使用ResultSet示例更新和插入記錄

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

我們定義了一個printResultSet()方法，用於列印所有記錄。在主方法中，我們使用updateDouble()方法更新所有記錄的年齡，並使用updateRow()更新記錄。類似地，我們使用moveToInsertRow()標記結果集以插入記錄。然後，使用updateString()和updateInt()方法新增新值，然後使用insertRow()方法提交更改，從而將記錄插入資料庫。現在，使用printResultSet()再次列印所有記錄。

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

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class ResultSetExample {
   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 printResultSet(ResultSet rs) throws SQLException{
      // Ensure we start with first row
      rs.beforeFirst();
      while(rs.next()){
         // Display values
         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"));
      }
      System.out.println();
   }

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

         System.out.println("List result set for reference....");
         printResultSet(rs);

         // Loop through result set and add 5 in age
         // Move to Before first position so while-loop works properly
         rs.beforeFirst();
         //STEP 7: Extract data from result set
         while(rs.next()){
            // Retrieve by column name
            int newAge = rs.getInt("age") + 5;
            rs.updateDouble( "age", newAge );
            rs.updateRow();
         }
         System.out.println("List result set showing new ages...");
         printResultSet(rs);

         // Insert a record into the table.
         // Move to insert row and add column data with updateXXX()
         System.out.println("Inserting a new record...");
         rs.moveToInsertRow();
         rs.updateString("first","John");
         rs.updateString("last","Paul");
         rs.updateInt("age",40);
         // Commit row
         rs.insertRow();

         System.out.println("List result set showing new set...");
         printResultSet(rs);	

      } catch (SQLException e) {
         e.printStackTrace();
      } 
   }
}

輸出

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

C:\>javac ResultSetExample.java
C:\>

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

C:\>java ResultSetExample
List result set for reference....
ID: 1, Age: 18, First: Zara, Last: Ali
ID: 2, Age: 25, First: Mahnaz, Last: Fatma
ID: 3, Age: 30, First: Zaid, Last: Khan
ID: 4, Age: 28, First: Sumit, Last: Mittal

List result set showing new ages...
ID: 1, Age: 23, First: Zara, Last: Ali
ID: 2, Age: 30, First: Mahnaz, Last: Fatma
ID: 3, Age: 35, First: Zaid, Last: Khan
ID: 4, Age: 33, First: Sumit, Last: Mittal

Inserting a new record...
List result set showing new set...
ID: 1, Age: 23, First: Zara, Last: Ali
ID: 2, Age: 30, First: Mahnaz, Last: Fatma
ID: 3, Age: 35, First: Zaid, Last: Khan
ID: 4, Age: 33, First: Sumit, Last: Mittal
ID: 5, Age: 40, First: John, Last: Paul
C:\>

使用ResultSet示例插入和刪除記錄

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

我們定義了一個printResultSet()方法，用於列印所有記錄。在主方法中，我們使用moveToInsertRow()標記結果集以插入記錄。然後，使用updateString()和updateInt()方法新增新值，然後使用insertRow()方法提交更改，從而將記錄插入資料庫。現在，使用printResultSet()列印所有記錄。現在，使用ResultSet.last()方法移動到最後一條記錄，並使用ResultSet.deleteRow()方法刪除它。然後，使用printResultSet()方法列印所有記錄。

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

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.PreparedStatement;

public class ResultSetExample {
   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 printResultSet(ResultSet rs) throws SQLException{
      // Ensure we start with first row
      rs.beforeFirst();
      while(rs.next()){
         // Display values
         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"));
      }
      System.out.println("----------------------------");
   }

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

         System.out.println("Inserting a new record...");
         rs.moveToInsertRow();
         rs.updateString("first","Manoj");
         rs.updateString("last","Jain");
         rs.updateInt("age",40);
         // The code below will insert the row in database
         rs.insertRow();

         System.out.println("List result set showing added row.");
         printResultSet(rs);
         // Deleting the added row.
         rs.last();
         rs.deleteRow();

         System.out.println("List result set showing row after deletion.");

         printResultSet(rs);

      } catch (SQLException e) {
         e.printStackTrace();
      } 
   }
}

輸出

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

C:\>javac ResultSetExample.java
C:\>

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

C:\>java ResultSetExample
Inserting a new record...
List result set showing added row.
ID: 1, Age: 18, First: Zara, Last: Ali
ID: 2, Age: 25, First: Mahnaz, Last: Fatma
ID: 3, Age: 30, First: Zaid, Last: Khan
ID: 4, Age: 28, First: Sumit, Last: Mittal
ID: 6, Age: 40, First: Manoj, Last: Jain
----------------------------
List result set showing row after deletion.
ID: 1, Age: 18, First: Zara, Last: Ali
ID: 2, Age: 25, First: Mahnaz, Last: Fatma
ID: 3, Age: 30, First: Zaid, Last: Khan
ID: 4, Age: 28, First: Sumit, Last: Mittal
----------------------------

C:\>
jdbc-result-sets.htm
列印頁面
上一頁
下一頁
廣告