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

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

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

ResultSet.unwrap介绍

暂无

代码示例

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

public ResultSet getNativeResultSet(ResultSet rs) throws SQLException {
    return (ResultSet) rs.unwrap(ResultSet.class);
  }
}

代码示例来源:origin: requery/requery

@Override
public <T> T unwrap(Class<T> iface) throws SQLException {
  return results.unwrap(iface);
}

代码示例来源:origin: querydsl/querydsl

@Override
public <T> T unwrap(Class<T> iface) throws SQLException {
  return rs.unwrap(iface);
}

代码示例来源:origin: codingapi/tx-lcn

@Override
public <T> T unwrap(Class<T> iface) throws SQLException {
 return delegate.unwrap(iface);
}

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

public static ROWID getROWID(ResultSet rs, int columnIndex) throws SQLException {
  OracleResultSet oracleResultSet = rs.unwrap(OracleResultSet.class);
  return oracleResultSet.getROWID(columnIndex);
}

代码示例来源:origin: com.zaxxer/HikariCP

/** {@inheritDoc} */
  @Override
  @SuppressWarnings("unchecked")
  public final <T> T unwrap(Class<T> iface) throws SQLException
  {
   if (iface.isInstance(delegate)) {
     return (T) delegate;
   }
   else if (delegate != null) {
     return delegate.unwrap(iface);
   }

   throw new SQLException("Wrapped ResultSet is not an instance of " + iface);
  }
}

代码示例来源:origin: prestodb/presto

protected long getProcessedLinesCount(String sqlStatement, QueryResult queryResult)
      throws SQLException
  {
    String queryId;
    if (queryResult.getJdbcResultSet().isPresent() && queryResult.getJdbcResultSet().get().isWrapperFor(PrestoResultSet.class)) {
      // if PrestoResult is available, just unwrap it from ResultSet and extract query id
      queryId = queryResult.getJdbcResultSet().get().unwrap(PrestoResultSet.class).getQueryId();
    }
    else {
      // if there is no ResultSet (UPDATE statements), try to find it in system.runtime.queries table
      queryId = (String) query(format("select query_id from system.runtime.queries where query = '%s'", sqlStatement)).row(0).get(0);
    }
    return queryStatsClient.getQueryStats(queryId).get().getRawInputPositions();
  }
}

代码示例来源:origin: prestodb/presto

private static void assertConnectionSource(Connection connection, String expectedSource)
      throws SQLException
  {
    String queryId;
    try (Statement statement = connection.createStatement();
        ResultSet rs = statement.executeQuery("SELECT 123")) {
      queryId = rs.unwrap(PrestoResultSet.class).getQueryId();
    }

    try (PreparedStatement statement = connection.prepareStatement(
        "SELECT source FROM system.runtime.queries WHERE query_id = ?")) {
      statement.setString(1, queryId);
      try (ResultSet rs = statement.executeQuery()) {
        assertTrue(rs.next());
        assertThat(rs.getString("source")).isEqualTo(expectedSource);
        assertFalse(rs.next());
      }
    }
  }
}

代码示例来源:origin: prestodb/presto

Statement statement = connection.createStatement();
  ResultSet resultSet = statement.executeQuery("SELECT * FROM slow_test_table")) {
queryId.set(resultSet.unwrap(PrestoResultSet.class).getQueryId());
queryStarted.countDown();
try {

代码示例来源:origin: prestodb/presto

queryId.set(resultSet.unwrap(PrestoResultSet.class).getQueryId());
queryStarted.countDown();
resultSet.next();

代码示例来源:origin: prestodb/presto

queryId.set(resultSet.unwrap(PrestoResultSet.class).getQueryId());
queryStarted.countDown();
resultSet.next();

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

Statement s = conn.createStatement();
ResultSet r = s.executeQuery(sql);
sb.append(String.format("QueryId: %s\n", r.unwrap(DrillResultSet.class).getQueryId()));
boolean first = true;
while (r.next()) {

代码示例来源:origin: p6spy/p6spy

@Override
public <T> T unwrap(Class<T> iface) throws SQLException {
 return delegate.unwrap(iface);
}

代码示例来源:origin: Meituan-Dianping/Zebra

@Override
public <T> T unwrap(Class<T> iface) throws SQLException {
  return innerResultSet.unwrap(iface);
}

代码示例来源:origin: Meituan-Dianping/Zebra

@Override
public <T> T unwrap(Class<T> iface) throws SQLException {
  return innerResultSet.unwrap(iface);
}

代码示例来源:origin: com.alibaba/druid

public ResultSet getNativeResultSet(ResultSet rs) throws SQLException {
    return (ResultSet) rs.unwrap(ResultSet.class);
  }
}

代码示例来源:origin: apache/phoenix

@Override
public <T> T unwrap(Class<T> iface) throws SQLException {
  return rs.unwrap(iface);
}

代码示例来源:origin: apache/phoenix

/**
 * Reset the read metrics collected in the result set.
 * 
 * @see {@link #getRequestReadMetrics(ResultSet)} {@link #getOverAllReadRequestMetrics(ResultSet)}
 * @param rs
 * @throws SQLException
 */
public static void resetMetrics(ResultSet rs) throws SQLException {
  PhoenixResultSet prs = rs.unwrap(PhoenixResultSet.class);
  prs.resetMetrics();
}

代码示例来源:origin: apache/phoenix

private static void assertQualifierRangesNotPresent(ResultSet rs) throws SQLException {
    Scan scan = rs.unwrap(PhoenixResultSet.class).getStatement().getQueryPlan().getContext().getScan();
    assertNull(scan.getAttribute(MIN_QUALIFIER));
    assertNull(scan.getAttribute(MAX_QUALIFIER));
  }
}

代码示例来源:origin: apache/phoenix

private static void assertQualifierRanges(ResultSet rs, int minQualifier, int maxQualifier) throws SQLException {
  Scan scan = rs.unwrap(PhoenixResultSet.class).getStatement().getQueryPlan().getContext().getScan();
  assertNotNull(scan.getAttribute(MIN_QUALIFIER));
  assertNotNull(scan.getAttribute(MAX_QUALIFIER));
  assertEquals(minQualifier, Bytes.toInt(scan.getAttribute(MIN_QUALIFIER)));
  assertEquals(maxQualifier, Bytes.toInt(scan.getAttribute(MAX_QUALIFIER)));
}

相关文章

微信公众号

最新文章

更多

ResultSet类方法