Simple insert with transaction is not happening

[alwinjosh]

Trying to execute following insert query does not commit transaction due to transaction reference counter is not decremented.

db.update( "INSERT INTO ADDRESS_REL (ADDRESS_ID, ADDRESS_DETAILS ) VALUES ( ?, ? )") .parameterStream(Flowable.just(105L, "Address of 105")) .transacted() .counts() .blockingSubscribe(tx -> System.out.println(tx.isComplete() ? "complete" : tx.value()));

Do I missed any hint to transaction ?

[davidmoten]

Thanks for report, I'll have a look soon.

On Tue, 19 Dec. 2017, 04:39 alwinjosh, [email protected] wrote:

Trying to execute following insert query does not commit transaction due to transaction reference counter is not decremented.

db.update( "INSERT INTO ADDRESS_REL (ADDRESS_ID, ADDRESS_DETAILS ) VALUES ( ?, ? )") .parameterStream(Flowable.just(105L, "Address of 105")) .transacted() .counts() .blockingSubscribe(tx -> System.out.println(tx.isComplete() ? "complete" : tx.value()));

Do I missed any hint to transaction ?

— You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub https://github.com/davidmoten/rxjava2-jdbc/issues/13, or mute the thread https://github.com/notifications/unsubscribe-auth/AATa61qAFts9mBsHofDNesWu5GYmIqmjks5tBqpIgaJpZM4RF3PV .

[davidmoten]

Yep, update/insert transactions need work. That case wasn't tested for. I'll see what I can do, plus I notice that the transactions generally needs more documentation.

[pkziel]

Is it still the problem ? Could you give an example how to make two updates/inserts in one transaction ?

[davidmoten]

oops, I'll revisit this

[yonghun8343]

i have a same problem... is this fixed???

[davidmoten]

Thanks for the reminder. I guess it's not fixed yet, I'll have a look soon.