8.2. Eclipse Vert.x JDBC 客户端的更改

在 Eclipse Vert.x 4 中，您可以使用 JDBC 客户端 API 创建池。在早期版本中，您只能创建客户端。您不能创建池。

以下示例演示了如何在 Eclipse Vert.x 3.x 中创建客户端。

// 3.x
SQLClient client = JDBCClient.create(vertx, jsonConfig);

以下示例演示了如何在 Eclipse Vert.x 4 中创建池。

// 4.x
JDBCPool pool = JDBCPool.pool(vertx, jsonConfig);

池允许您执行简单的查询。您不需要管理简单查询的连接。但是，对于复杂的查询或多个查询，您必须管理您的连接。

以下示例演示了如何管理 Eclipse Vert.x 3.x 中的查询的连接。

// 3.x
client.getConnection(res -> {
  if (res.succeeded()) {
    SQLConnection connection = res.result();
    // Important, do not forget to return the connection
    connection.close();
  } else {
    // Failed to get connection
  }
});

以下示例演示了如何管理 Eclipse Vert.x 4 中的查询连接。

// 4.x
pool
  .getConnection()
  .onFailure(e -> {
    // Failed to get a connection
  })
  .onSuccess(conn -> {
    // Important, do not forget to return the connection
    conn.close();
  });

您可以使用 jsonConfig 进行配置。但是，使用 jsonConfig 有时可能会导致错误。为避免这些错误，JDBC 客户端引入了 Typesafe Config。

以下示例显示了 Typesafe Config 的基本结构。

// 4.x ONLY!!!
JDBCPool pool = JDBCPool.pool(
      vertx,
      // configure the connection
      new JDBCConnectOptions()
        // H2 connection string
        .setJdbcUrl("jdbc:h2:~/test")
        // username
        .setUser("sa")
        // password
        .setPassword(""),
      // configure the pool
      new PoolOptions()
        .setMaxSize(16)
    );

本节演示了如何在 JDBC 客户端中运行查询。

// 3.x
client.query("SELECT * FROM user WHERE emp_id > ?", new JsonArray().add(1000), res -> {
  if (res.succeeded()) {
    ResultSet rs = res2.result();
    // You can use these results in your application
  }
});

// 4.x
pool
  .preparedQuery("SELECT * FROM user WHERE emp_id > ?")
  // the emp id to look up
  .execute(Tuple.of(1000))
  .onSuccess(rows -> {
    for (Row row : rows) {
      System.out.println(row.getString("FIRST_NAME"));
    }
  });

pool
  .getConnection()
  .onFailure(e -> {
    // Failed to get a connection
  })
  .onSuccess(conn -> {
    conn
      .query("SELECT * FROM user")
      .execute()
      .onFailure(e -> {
        // Handle the failure
        // Important, do not forget to return the connection
        conn.close();
      })
      .onSuccess(rows -> {
        for (Row row : rows) {
          System.out.println(row.getString("FIRST_NAME"));
        }
        // Important, do not forget to return the connection
        conn.close();
      });
  });

存储的步骤在 JDBC 客户端中受到支持。

以下示例演示了如何在 Eclipse Vert.x 3.x 中传递 IN 参数。

// 3.x
connection.callWithParams(
  "{ call new_customer(?, ?) }",
  new JsonArray().add("John").add("Doe"),
  null,
  res -> {
    if (res.succeeded()) {
      // Success!
    } else {
      // Failed!
    }
  });

以下示例演示了如何在 Eclipse Vert.x 4 中传递 IN 参数。

// 4.x
client
  .preparedQuery("{call new_customer(?, ?)}")
  .execute(Tuple.of("Paulo", "Lopes"))
  .onSuccess(rows -> {
    ...
  });

在 Eclipse Vert.x 3.x 中，由于可用类型，将 IN 和 OUT 参数结合使用的支持会非常有限。在 Eclipse Vert.x 4 中，池是安全的，可以处理 IN 和 OUT 参数的组合。您还可以在应用程序中使用 INOUT 参数。

以下示例显示了在 Eclipse Vert.x 3.x 中处理参数。

// 3.x
connection.callWithParams(
  "{ call customer_lastname(?, ?) }",
  new JsonArray().add("John"),
  new JsonArray().addNull().add("VARCHAR"),
  res -> {
    if (res.succeeded()) {
      ResultSet result = res.result();
    } else {
      // Failed!
    }
});

以下示例显示了在 Eclipse Vert.x 4 中处理参数。

// 4.x
client
  .preparedQuery("{call customer_lastname(?, ?)}")
  .execute(Tuple.of("John", SqlOutParam.OUT(JDBCType.VARCHAR)))
  .onSuccess(rows -> {
    ...
  });

在 JDBC 客户端中，数据类型已更新。