java.sql.ResultSet.isClosed()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(10.2k)|赞(0)|评价(0)|浏览(411)

本文整理了Java中java.sql.ResultSet.isClosed方法的一些代码示例，展示了ResultSet.isClosed的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ResultSet.isClosed方法的具体详情如下：
包路径：java.sql.ResultSet
类名称：ResultSet
方法名：isClosed

ResultSet.isClosed介绍

[英]Returns true if this result set has been closed, false otherwise.
[中]如果此结果集已关闭，则返回true，否则返回false。

代码示例

代码示例来源：origin: alibaba/druid

protected void clearResultSet() {
  if (resultSetTrace == null) {
    return;
  }
  for (ResultSet rs : resultSetTrace) {
    try {
      if (!rs.isClosed()) {
        rs.close();
      }
    } catch (SQLException ex) {
      LOG.error("clearResultSet error", ex);
    }
  }
  resultSetTrace.clear();
}

代码示例来源：origin: apache/ignite

/**
 * @throws Exception If failed.
 */
@org.junit.Test
public void testCloseResultSet0() throws Exception {
  ResultSet rs0 = stmt.executeQuery(SQL);
  ResultSet rs1 = stmt.executeQuery(SQL);
  ResultSet rs2 = stmt.executeQuery(SQL);
  assert rs0.isClosed() : "ResultSet must be implicitly closed after re-execute statement";
  assert rs1.isClosed() : "ResultSet must be implicitly closed after re-execute statement";
  assert !rs2.isClosed() : "Last result set must be available";
  stmt.close();
  assert rs2.isClosed() : "ResultSet must be explicitly closed after close statement";
}

代码示例来源：origin: apache/ignite

/**
 * @throws Exception If failed.
 */
@org.junit.Test
public void testClose() throws Exception {
  String sqlText = "select * from test";
  ResultSet rs = stmt.executeQuery(sqlText);
  assertTrue(rs.next());
  assertFalse(rs.isClosed());
  assertFalse(stmt.isClosed());
  stmt.close();
  stmt.close(); // Closing closed is ok
  assertTrue(stmt.isClosed());
  // Current result set must be closed
  assertTrue(rs.isClosed());
}

代码示例来源：origin: apache/jena

/**
 * Get type info and check the nullable column (regression for an issue
 * encountered during debugging)
 * 
 * @throws SQLException
 */
@Test
public void metadata_type_info() throws SQLException {
  JenaConnection conn = this.getConnection();
  DatabaseMetaData metadata = conn.getMetaData();
  ResultSet typeInfo = metadata.getTypeInfo();
  while (typeInfo.next()) {
    typeInfo.getShort("NULLABLE");
  }
  Assert.assertTrue(typeInfo.isAfterLast());
  typeInfo.close();
  Assert.assertTrue(typeInfo.isClosed());
  conn.close();
  Assert.assertTrue(typeInfo.isClosed());
}

代码示例来源：origin: apache/ignite

/**
 * @throws Exception If failed.
 */
@org.junit.Test
public void testCloseOnCompletionBeforeQuery() throws Exception {
  assert !stmt.isCloseOnCompletion() : "Invalid default closeOnCompletion";
  ResultSet rs0 = stmt.executeQuery(SQL);
  ResultSet rs1 = stmt.executeQuery(SQL);
  assert rs0.isClosed() : "Result set must be closed implicitly";
  assert !stmt.isClosed() : "Statement must not be closed";
  rs1.close();
  assert !stmt.isClosed() : "Statement must not be closed";
  stmt.closeOnCompletion();
  ResultSet rs2 = stmt.executeQuery(SQL);
  assert stmt.isCloseOnCompletion() : "Invalid closeOnCompletion";
  rs2.close();
  assert stmt.isClosed() : "Statement must be closed";
}

代码示例来源：origin: apache/ignite

assertTrue(rs0.next());
assertEquals(1, rs0.getInt(1));
assertFalse(rs0.isClosed());
assertTrue(rs0.isClosed());
assertTrue(stmt0.isClosed());
assertTrue(rs1.next());
assertEquals(1, rs1.getInt(1));

代码示例来源：origin: apache/drill

resultSetToCloseOnStmtToClose.next();
final ResultSet resultSetToCloseOnStmtToKeep =
  plainStmtToKeep.executeQuery("VALUES 'plain Statement query'");
resultSetToCloseOnStmtToKeep.next();
plainStmtToClose.close();
preparedStmtToClose.close();
resultSetToCloseOnStmtToClose.close();
resultSetToCloseOnStmtToKeep.close();
assertTrue("Test setup error", closedPlainStmtOfOpenConn.isClosed());
assertTrue("Test setup error", closedPreparedStmtOfOpenConn.isClosed());
assertTrue("Test setup error", closedResultSetOfClosedStmt.isClosed());
assertTrue("Test setup error", closedResultSetOfOpenStmt.isClosed());

代码示例来源：origin: org.apache.calcite.avatica/avatica-core

@Test public void testCommonCursorStates() throws SQLException {
 final ResultSet resultSet = getResultSet();
 // right after statement execution, result set is before first row
 assertTrue(resultSet.isBeforeFirst());
 // checking that return values of next and isAfterLast are coherent
 for (int c = 0; c < 3 && !resultSet.isAfterLast(); ++c) {
  assertTrue(resultSet.next() != resultSet.isAfterLast());
 }
 // result set is not closed yet, despite fully consumed
 assertFalse(resultSet.isClosed());
 resultSet.close();
 // result set is now closed
 assertTrue(resultSet.isClosed());
 // once closed, next should fail
 thrown.expect(SQLException.class);
 resultSet.next();
}

代码示例来源：origin: apache/ignite

/**
 * @throws Exception If failed.
 */
@org.junit.Test
public void testCloseResultSet1() throws Exception {
  stmt.execute(SQL);
  ResultSet rs = stmt.getResultSet();
  stmt.close();
  assert rs.isClosed() : "ResultSet must be explicitly closed after close statement";
}

代码示例来源：origin: apache/ignite

/**
 * @throws Exception If failed.
 */
@org.junit.Test
public void testCloseOnCompletionAfterQuery() throws Exception {
  assert !stmt.isCloseOnCompletion() : "Invalid default closeOnCompletion";
  ResultSet rs0 = stmt.executeQuery(SQL);
  ResultSet rs1 = stmt.executeQuery(SQL);
  assert rs0.isClosed() : "Result set must be closed implicitly";
  assert !stmt.isClosed() : "Statement must not be closed";
  rs1.close();
  assert !stmt.isClosed() : "Statement must not be closed";
  ResultSet rs2 = stmt.executeQuery(SQL);
  stmt.closeOnCompletion();
  assert stmt.isCloseOnCompletion() : "Invalid closeOnCompletion";
  rs2.close();
  assert stmt.isClosed() : "Statement must be closed";
}

代码示例来源：origin: org.vibur/vibur-dbcp

@Test
  public void testResultSetIsImplicitlyClosed() throws SQLException {
    DataSource ds = createDataSourceNoStatementsCache();
    ResultSet resultSet;

    try (Connection connection = ds.getConnection();
       Statement statement = connection.createStatement()) {

      resultSet = statement.executeQuery("select * from actor where first_name = 'CHRISTIAN'");
      assertTrue(resultSet.next());

      assertFalse(resultSet.isClosed());
      assertFalse(resultSet.unwrap(ResultSet.class).isClosed());

    } // the statement is closed here

    assertTrue(resultSet.isClosed());
    assertTrue(resultSet.unwrap(ResultSet.class).isClosed());
  }
}

代码示例来源：origin: apache/hive

/**
 * Close the ResultSet.
 * @param rs may be {@code null}
 */
private static void close(ResultSet rs) {
 try {
  if (rs != null && !rs.isClosed()) {
   rs.close();
  }
 } catch(SQLException ex) {
  LOG.warn("Failed to close result set " + ex.getMessage());
 }
}

代码示例来源：origin: apache/ignite

assertTrue(rs0.next());
assertEquals(1, rs0.getInt(1));
assertFalse(rs0.isClosed());
assertTrue(rs0.isClosed());
assertTrue(stmt0.isClosed());
assertTrue(rs1.next());
assertEquals(1, rs1.getInt(1));

代码示例来源：origin: apache/calcite-avatica

@Test public void testCommonCursorStates() throws SQLException {
 final ResultSet resultSet = getResultSet();
 // right after statement execution, result set is before first row
 assertTrue(resultSet.isBeforeFirst());
 // checking that return values of next and isAfterLast are coherent
 for (int c = 0; c < 3 && !resultSet.isAfterLast(); ++c) {
  assertTrue(resultSet.next() != resultSet.isAfterLast());
 }
 // result set is not closed yet, despite fully consumed
 assertFalse(resultSet.isClosed());
 resultSet.close();
 // result set is now closed
 assertTrue(resultSet.isClosed());
 // once closed, next should fail
 thrown.expect(SQLException.class);
 resultSet.next();
}

代码示例来源：origin: apache/ignite

/**
 * @throws Exception If failed.
 */
@org.junit.Test
public void testCloseResultSetByConnectionClose() throws Exception {
  ResultSet rs = stmt.executeQuery(SQL);
  conn.close();
  assert stmt.isClosed() : "Statement must be implicitly closed after close connection";
  assert rs.isClosed() : "ResultSet must be implicitly closed after close connection";
}

代码示例来源：origin: apache/jena

/**
 * Tests movement through SELECT results
 * 
 * @throws SQLException
 */
@Test
public void results_select_movement_04() throws SQLException {
  ResultSet rset = this.createResults(ds, "SELECT * { ?s ?p ?o . } LIMIT 1", ResultSet.TYPE_FORWARD_ONLY);
  Assert.assertEquals(ResultSet.TYPE_FORWARD_ONLY, rset.getType());
  Assert.assertNotNull(rset);
  Assert.assertFalse(rset.isClosed());
  Assert.assertTrue(rset.isBeforeFirst());
  Assert.assertFalse(rset.isLast());
  // Can move forwards to after last row
  rset.afterLast();
  Assert.assertTrue(rset.isAfterLast());
  rset.close();
  Assert.assertTrue(rset.isClosed());
}

代码示例来源：origin: jeremylong/DependencyCheck

/**
   * Closes the result set capturing and ignoring any SQLExceptions that
   * occur.
   *
   * @param rs a ResultSet to close
   */
  public static void closeResultSet(ResultSet rs) {
    try {
      if (rs != null && !rs.isClosed()) {
        rs.close();
      }
    } catch (SQLException ex) {
      LOGGER.trace(rs.toString(), ex);
    }
  }
}

代码示例来源：origin: apache/drill

@BeforeClass
public static void setUpObjects() throws Exception {
 // (Note: Can't use JdbcTest's connect(...) for this test class.)
 connection = connect();
 plainStatement = connection.createStatement();
 preparedStatement =
   connection.prepareStatement("VALUES 'PreparedStatement query'");
 try {
  connection.prepareCall("VALUES 'CallableStatement query'");
  fail("Test seems to be out of date.  Was prepareCall(...) implemented?");
 }
 catch (SQLException | UnsupportedOperationException e) {
  // Expected.
 }
 connection.createArrayOf("INTEGER", new Object[0]);
 resultSet = plainStatement.executeQuery("VALUES 'plain Statement query'");
 resultSet.next();
 resultSetMetaData = resultSet.getMetaData();
 databaseMetaData = connection.getMetaData();
 // Self-check that member variables are set:
 assertFalse("Test setup error", connection.isClosed());
 assertFalse("Test setup error", plainStatement.isClosed());
 assertFalse("Test setup error", preparedStatement.isClosed());
 assertFalse("Test setup error", resultSet.isClosed());
 // (No ResultSetMetaData.isClosed() or DatabaseMetaData.isClosed():)
 assertNotNull("Test setup error", resultSetMetaData);
 assertNotNull("Test setup error", databaseMetaData);
}

代码示例来源：origin: apache/jena

/**
 * Test ASK results with a false result
 * 
 * @throws SQLException
 */
@Test
public void results_ask_false() throws SQLException {
  ResultSet rset = this.createResults(AbstractResultSetTests.empty, "ASK { FILTER(false) }");
  Assert.assertNotNull(rset);
  Assert.assertFalse(rset.isClosed());
  Assert.assertTrue(rset.isBeforeFirst());
  // Try to move to the result row
  Assert.assertTrue(rset.next());
  // Check the boolean return value
  Assert.assertFalse(rset.getBoolean(AskResultsMetadata.COLUMN_LABEL_ASK));
  // Check no further rows
  Assert.assertFalse(rset.next());
  Assert.assertTrue(rset.isAfterLast());
  // Close and clean up
  rset.close();
  Assert.assertTrue(rset.isClosed());
}

代码示例来源：origin: apache/drill

@Test
public void testClosedResultSet_isClosed_returnsTrue() throws SQLException {
 assertThat(closedResultSetOfOpenStmt.isClosed(), equalTo(true));
}

内容来源于网络，如有侵权，请联系作者删除！

resultset

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    ResultSet类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com