如何在 JDBC 中向 ResultSet 插入行?

jdbcjava 8programmingobject oriented programming

您可以将表的内容检索为 ResultSet,并直接向其中插入新行。为此,首先需要确保您的 ResultSet 可更新。

  • ResultSet 接口的 moveToInsertRow() 方法会将光标导航到需要插入下一条记录的位置。因此,使用此方法将光标移动到相应位置以插入一行。

  • ResultSet 接口的 updateXXX() 方法允许您在 ResultSet 对象中插入/更新值。

    使用这些方法向新行添加值,例如,如果您需要在第一列插入一个整数值,在第二列插入一个字符串值,则可以使用 updateInt() 和 updateString() 方法,如下所示:

rs.updateInt(1, integerValue);
rs.updateString(2, "stringValue");
  • insertRow() 方法将行插入到 ResultSet 和表中。

    因此,使用此方法将上面创建的行插入到结果集对象和表中。

示例

假设数据库中有一个名为 Employees 的表,其内容如下:

+----+---------+--------+----------------+
| Id | Name    | Salary | Location       |
+----+---------+--------+----------------+
| 1  | Amit    | 3000   | Hyderabad      |
| 2  | Kalyan  | 4000   | Vishakhapatnam |
| 3  | Renuka  | 6000   | Delhi          |
| 4  | Archana | 96000  | Mumbai         |
| 5  | Sumith  | 11000  | Hyderabad      |
| 6  | Rama    | 11000  | Goa            |
+----+---------+--------+----------------+

以下示例将该表的内容作为 ResultSet 对象检索,并将新记录插入到 ResultSet 和表中。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class InsertRowToResultSet {
   public static void main(String[] args) throws Exception {
      //注册驱动程序
      DriverManager.registerDriver(new com.mysql.jdbc.Driver());
      //获取连接
      String url = "jdbc:mysql://localhost/testdb";
      Connection con = DriverManager.getConnection(url, "root", "password");
      //创建 Statement 对象
      Statement stmt = con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
      //检索数据
      ResultSet rs = stmt.executeQuery("select * from Employees");
      //打印结果集的内容
      System.out.println("Contents of the Result Set");
      while(rs.next()) {
         System.out.print("ID: " + rs.getInt("id"));
         System.out.print(", Salary: " + rs.getInt("Salary"));
         System.out.print(", Name: " + rs.getString("Name"));
         System.out.println(", Location: " + rs.getString("Location"));
      }
      System.out.println();
      rs.moveToInsertRow();
      rs.updateInt(1, 7);
      rs.updateString(2, "Santosh");
      rs.updateInt(3, 96000);
      rs.updateString(4, "Mumbai");
      rs.insertRow();

      //再次检索结果集的内容
      System.out.println("Contents of the ResultSet after inserting another row in to it");
      rs.beforeFirst();
      while(rs.next()) {
         System.out.print("ID: " + rs.getInt("id"));
         System.out.print(", Salary: " + rs.getInt("Salary"));
         System.out.print(", Name: " + rs.getString("Name"));
         System.out.println(", Location: " + rs.getString("Location"));
      }
   }
}

输出

Contents of the Result Set
ID: 1, Salary: 3000, Name: Amit, Location: Hyderabad
ID: 2, Salary: 4000, Name: Kalyan, Location: Vishakhapatnam
ID: 3, Salary: 6000, Name: Renuka, Location: Delhi
ID: 4, Salary: 96000, Name: Archana, Location: Mumbai
ID: 5, Salary: 11000, Name: Sumith, Location: Hyderabad
ID: 6, Salary: 11000, Name: Rama, Location: Goa

Contents of the ResultSet after inserting another row in to it
ID: 1, Salary: 3000, Name: Amit, Location: Hyderabad
ID: 2, Salary: 4000, Name: Kalyan, Location: Vishakhapatnam
ID: 3, Salary: 6000, Name: Renuka, Location: Delhi
ID: 4, Salary: 96000, Name: Archana, Location: Mumbai
ID: 5, Salary: 11000, Name: Sumith, Location: Hyderabad
ID: 6, Salary: 11000, Name: Rama, Location: Goa
ID: 7, Salary: 96000, Name: Santosh, Location: Mumbai

相关文章