transaction-rx-jdbc

    @Test
    public void tt() {
        long startTime = System.currentTimeMillis();
        System.out.println("start: " + startTime);
        Observable<Integer> firstTransactionFirstPart = database.update(queryThatInsertsinTableWithPrimaryKeyA)
                .dependsOn(database.beginTransaction())
                .parameters(new Object[0])
                .count()
                .doOnCompleted(() -> System.out.println("t1 done"));
        Observable<Integer> firstTransaction2ndPart = database.update(queryThatInsertsinTableWithPrimaryKeyA)
                .dependsOn(firstTransactionFirstPart)
                .parameters(new Object[0])
                .count();
        Observable<Boolean> firstTransaction = database.commit(firstTransaction2ndPart);
        firstTransaction
                .subscribe(new Observer<Boolean>() {
                    @Override
                    public void onCompleted() {
                        System.out.println("1: " + (System.currentTimeMillis() - startTime));
                    }

                    @Override
                    public void onError(Throwable throwable) {
                        throwable.printStackTrace();
                        System.out.println("2: " + (System.currentTimeMillis() - startTime));
                    }

                    @Override
                    public void onNext(Boolean aBoolean) {
                        System.out.println("3: " + (System.currentTimeMillis() - startTime));
                    }
                });

        Observable<Integer> secondTransaction = database.update(queryThatInsertsinTableWithPrimaryKeyB)
                .dependsOn(database.beginTransaction())
                .parameters(new Object[0])
                .count();
        database.commit(secondTransaction)
                .toBlocking()
                .subscribe(new Subscriber<Boolean>() {
                    @Override
                    public void onCompleted() {
                        System.out.println("t21 completed: " + (System.currentTimeMillis() - startTime));
                    }

                    @Override
                    public void onError(Throwable throwable) {
                        throwable.printStackTrace();
                        System.out.println("t21 error: " + (System.currentTimeMillis() - startTime));
                    }

                    @Override
                    public void onNext(Boolean aBoolean) {
                        System.out.println("t21 onNext: " + aBoolean);
                        System.out.println("t21 onNext: " + (System.currentTimeMillis() - startTime));
                    }
                });
    }