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

ResultSet.getResults介绍

[英]Get the results
[中]得到结果

代码示例

代码示例来源：origin: vert-x3/vertx-examples

results.addAll(rs.result().getResults().stream().map(JsonArray::encode).collect(Collectors.toList()));

代码示例来源：origin: vert-x3/vertx-examples

for (JsonArray line : rs.result().getResults()) {
 System.out.println(line.encode());

代码示例来源：origin: vert-x3/vertx-examples

for (JsonArray line : rs.result().getResults()) {
 System.out.println(line.encode());

代码示例来源：origin: vert-x3/vertx-examples

for (JsonArray line : rs.getResults()) {
 System.out.println(line.encode());

代码示例来源：origin: vert-x3/vertx-examples

for (JsonArray line : rs.getResults()) {
 System.out.println(line.encode());

代码示例来源：origin: vert-x3/vertx-examples

@Override
@Suspendable
public void start() throws Exception {
 JsonObject config = new JsonObject().put("url", "jdbc:hsqldb:mem:test?shutdown=true")
  .put("driver_class", "org.hsqldb.jdbcDriver");
 JDBCClient jdbc = JDBCClient.createShared(vertx, config);
 // Get a connection
 try (SQLConnection conn = awaitResult(jdbc::getConnection)) {
  // Create a table
  Void v = awaitResult(h -> conn.execute("CREATE TABLE test(col VARCHAR(20))", h));
  // Insert some stuff
  for (int i = 0; i < 10; i++) {
   int ii = i;
   UpdateResult res = awaitResult(h -> conn.update("INSERT INTO test (col) VALUES ('val" + ii + "')", h));
   System.out.println("Rows updated: " + res.getUpdated());
  }
  // Select the results
  ResultSet res = awaitResult(h -> conn.query("SELECT * FROM test", h));
  System.out.println("Selected " + res.getNumRows() + " results");
  res.getResults().forEach(System.out::println);
 }
}

代码示例来源：origin: apiman/apiman

public VertxJdbcResultSet(ResultSet resultSet) {
  this.resultSet = resultSet;
  rows = resultSet.getResults();
}

代码示例来源：origin: com.jporm/jpo-rx-vertx3

@Override
public boolean getBoolean(final int columnIndex) {
  return orDefault(resultSet.getResults().get(position).getBoolean(columnIndex), false);
}

代码示例来源：origin: de.braintags/vertx-pojo-mapper-mysql

private static int getCount(ResultSet set) {
  List<JsonArray> results = set.getResults();
  if (results.isEmpty())
   throw new SqlException("uncorrect result found");
  JsonArray array = results.get(0);
  if (array.isEmpty())
   throw new SqlException("uncorrect result found");
  return array.getInteger(0);
 }
}

代码示例来源：origin: vert-x3/vertx-rx

protected Observable<String> uniqueNames(SQLConnection conn) {
 return conn.rxQuery(UNIQUE_NAMES_SQL)
  .flatMapObservable(resultSet -> Observable.from(resultSet.getResults()))
  .map(row -> row.getString(0));
}

代码示例来源：origin: io.vertx/vertx-jdbc-client

@Test
public void testBlob() {
 String sql = "SELECT b FROM blob_table";
 connection().query(sql, onSuccess(resultSet -> {
  assertNotNull(resultSet);
  assertEquals(1, resultSet.getResults().size());
  assertNotNull(resultSet.getResults().get(0).getBinary(0));
  testComplete();
 }));
 await();
}

代码示例来源：origin: io.vertx/vertx-jdbc-client

@Test
public void testClob() {
 String sql = "SELECT c FROM blob_table";
 connection().query(sql, onSuccess(resultSet -> {
  assertNotNull(resultSet);
  assertEquals(1, resultSet.getResults().size());
  assertNotNull(resultSet.getResults().get(0).getString(0));
  testComplete();
 }));
 await();
}

代码示例来源：origin: io.vertx/vertx-jdbc-client

@Test
public void testArray() {
 String sql = "SELECT a FROM blob_table";
 connection().query(sql, onSuccess(resultSet -> {
  assertNotNull(resultSet);
  assertEquals(1, resultSet.getResults().size());
  assertNotNull(resultSet.getResults().get(0).getJsonArray(0));
  testComplete();
 }));
 await();
}

代码示例来源：origin: io.vertx/vertx-jdbc-client

@Test
public void testCustom() {
 String sql = "SELECT u FROM t";
 connection().query(sql, onSuccess(resultSet -> {
  assertNotNull(resultSet);
  assertEquals(1, resultSet.getResults().size());
  // we expect a String since UUID will be converted with the fallback mode
  assertNotNull(resultSet.getResults().get(0).getString(0));
  testComplete();
 }));
 await();
}

代码示例来源：origin: io.vertx/vertx-jdbc-client

@Test
public void testStoredProcedure4() {
 client.callWithParams("{call times2(?)}", new JsonArray().add(2), new JsonArray().add("INTEGER"), onSuccess(resultSet -> {
  assertNotNull(resultSet);
  assertEquals(0, resultSet.getResults().size());
  assertEquals(new Integer(4), resultSet.getOutput().getInteger(0));
  testComplete();
 }));
 await();
}

代码示例来源：origin: io.vertx/vertx-rx-java2

protected Flowable<String> uniqueNames(SQLConnection conn) {
 return conn.rxQuery(UNIQUE_NAMES_SQL)
  .flatMapPublisher(resultSet -> Flowable.fromIterable(resultSet.getResults()))
  .map(row -> row.getString(0));
}

代码示例来源：origin: io.vertx/vertx-jdbc-client

@Test
public void testStoredProcedure3() {
 connection().callWithParams("{call times2(?)}", new JsonArray().add(2), new JsonArray().add("INTEGER"), onSuccess(resultSet -> {
  assertNotNull(resultSet);
  assertEquals(0, resultSet.getResults().size());
  assertEquals(new Integer(4), resultSet.getOutput().getInteger(0));
  testComplete();
 }));
 await();
}

代码示例来源：origin: io.vertx/vertx-jdbc-client

@Test
public void testStoredProcedure6() {
 client.callWithParams("{call an_hour_before()}", null, null, onSuccess(resultSet -> {
  assertNotNull(resultSet);
  assertEquals(1, resultSet.getResults().size());
  testComplete();
 }));
 await();
}

代码示例来源：origin: io.vertx/vertx-jdbc-client

@Test
public void testStoredProcedure2() {
 connection().callWithParams("{call an_hour_before()}", null, null, onSuccess(resultSet -> {
  assertNotNull(resultSet);
  assertEquals(1, resultSet.getResults().size());
  testComplete();
 }));
 await();
}

代码示例来源：origin: io.vertx/vertx-jdbc-client

@Test
public void testStoredProcedure1() {
 connection().callWithParams("{call customer_lastname(?, ?)}", new JsonArray().add("Paulo"), new JsonArray().addNull().add("VARCHAR"), onSuccess(resultSet -> {
  assertNotNull(resultSet);
  assertEquals(0, resultSet.getResults().size());
  assertEquals("Lopes", resultSet.getOutput().getString(1));
  testComplete();
 }));
 await();
}