Change methods' signatures

Author: psolomin

vertx-pg-client/src/main/java/examples/PgClientExamples.java

@@ -19,8 +19,6 @@
 
 import io.vertx.core.Future;
 import io.vertx.core.Vertx;
-import io.vertx.core.buffer.Buffer;
-import io.vertx.core.buffer.impl.BufferImpl;
 import io.vertx.core.json.JsonObject;
 import io.vertx.core.net.PemTrustOptions;
 import io.vertx.docgen.Source;
@@ -738,7 +736,7 @@ public void batchReturning(SqlClient client) {
   public void importDataToDb(Vertx vertx, PgConnection client) {
     vertx.fileSystem().readFile("path/to/file")
       .flatMap(bufferAsyncResult -> {
-          return client.copyFrom(
+          return client.copyFromBytes(
             "COPY my_table FROM STDIN (FORMAT csv, HEADER)",
             bufferAsyncResult
           ).execute();
@@ -749,12 +747,10 @@ public void importDataToDb(Vertx vertx, PgConnection client) {
   }
 
   public void exportDataFromDb(Vertx vertx, PgConnection client) {
-    Buffer buffer = new BufferImpl();
     String path = "path/to/file";
-    client.copyTo("COPY my_table TO STDOUT (FORMAT csv, HEADER)", buffer)
-      .andThen(res -> {
-        vertx.fileSystem().writeFile("path/to/file.csv", buffer);
-      }).onSuccess(res -> System.out.println("Data exported to " + path));
+    client.copyToBytes("COPY my_table TO STDOUT (FORMAT csv, HEADER)").execute()
+      .flatMap(buffer -> vertx.fileSystem().writeFile("path/to/file.csv", buffer))
+      .onSuccess(res -> System.out.println("Data exported to " + path));
   }
 
   public void pgBouncer(PgConnectOptions connectOptions) {

vertx-pg-client/src/main/java/io/vertx/pgclient/PgConnection.java

@@ -110,7 +110,7 @@ static Future<PgConnection> connect(Vertx vertx, String connectionUri) {
    * @param from byte stream data will be fetched from
    * @return result set with single field {@code rowsWritten}
    */
-  Query<RowSet<Row>> copyFrom(String sql, Buffer from);
+  Query<RowSet<Row>> copyFromBytes(String sql, Buffer from);
 
   /**
    * Exports data from a database with decoding.
@@ -120,18 +120,17 @@ static Future<PgConnection> connect(Vertx vertx, String connectionUri) {
    * @param sql COPY command (example {@code COPY my_table TO STDOUT (FORMAT binary)})
    * @return decoded records
    */
-  Query<RowSet<Row>> copyTo(String sql);
+  Query<RowSet<Row>> copyToRows(String sql);
 
   /**
    * Exports data from a database as-is, without decoding.
    *
    * <p>Use this method when exporting opaque bytes, e.g. to a CSV file.
    *
    * @param sql COPY command (example {@code COPY my_table TO STDOUT (FORMAT csv)})
-   * @param to bytes container data will be written to
-   * @return async result
+   * @return async result of bytes container data will be written to
    */
-  Future<Void> copyTo(String sql, Buffer to);
+  Query<Buffer> copyToBytes(String sql);
 
   /**
    * Send a request cancellation message to tell the server to cancel processing request in this connection.

vertx-pg-client/src/main/java/io/vertx/pgclient/impl/PgConnectionImpl.java

@@ -112,18 +112,18 @@ public PgConnection noticeHandler(Handler<PgNotice> handler) {
   }
 
   @Override
-  public Query<RowSet<Row>> copyFrom(String sql, Buffer from) {
+  public Query<RowSet<Row>> copyFromBytes(String sql, Buffer from) {
     return null;
   }
 
   @Override
-  public Query<RowSet<Row>> copyTo(String sql) {
+  public Query<RowSet<Row>> copyToRows(String sql) {
     return null;
   }
 
   @Override
-  public Future<Void> copyTo(String sql, Buffer to) {
-    return Future.succeededFuture();
+  public Query<Buffer> copyToBytes(String sql) {
+    return null;
   }
 
   @Override

vertx-pg-client/src/test/java/io/vertx/pgclient/PgConnectionCopyTest.java

@@ -18,7 +18,7 @@ public void testCopyToRows(TestContext ctx) {
       deleteFromTestTable(ctx, conn, () -> {
         insertIntoTestTable(ctx, conn, 10, () -> {
           PgConnection pgConn = (PgConnection) conn;
-          pgConn.copyTo("COPY my_table TO STDOUT (FORMAT binary)")
+          pgConn.copyToRows("COPY my_table TO STDOUT (FORMAT binary)")
             .execute()
             .onComplete(ctx.asyncAssertSuccess(result -> {
                 for (int i = 0; i < 2; i++) {