/*
 * Copyright (c) 2011-2018 Contributors to the Eclipse Foundation
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License 2.0 which is available at
 * http://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0
 * which is available at https://www.apache.org/licenses/LICENSE-2.0.
 *
 * SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
 */

package examples;

import io.vertx.ext.sql.ResultSet;
import io.vertx.reactivex.ext.sql.SQLClient;
import io.vertx.reactivex.ext.sql.SQLClientHelper;
import io.vertx.reactivex.ext.sql.SQLConnection;

Author:
Thomas Segismont/**
 * @author Thomas Segismont
 */
public class RxifiedSQLExamples {

  public void inTransactionTransformer(SQLConnection conn) {
    conn.rxExecute("... insert into album ...")
      .andThen(conn.rxExecute("... insert into tracks ..."))
      .compose(SQLClientHelper.txCompletableTransformer(conn)) // <1>
      .andThen(conn.rxQuery("... select from album, tracks ...").map(ResultSet::getResults))
      .subscribe(rows -> {
        // send to client
      }, throwable -> {
        // handle error
      });
  }

  public void inTransactionSingle(SQLClient sqlClient) {
    SQLClientHelper.inTransactionSingle(sqlClient, conn -> {
      return conn.rxExecute("... insert into album ...")
        .andThen(conn.rxExecute("... insert into tracks ..."))
        .andThen(conn.rxQuery("... select from album, tracks ...").map(ResultSet::getResults)); // <1>
    }).subscribe(rows -> {
      // send to client
    }, throwable -> {
      // handle error
    });
  }

  private RxifiedSQLExamples() {
    // Examples
  }
}