Class: ReactivePgClient::PgTransaction
- Inherits:
-
PgClient
- Object
- PgClient
- ReactivePgClient::PgTransaction
- Defined in:
- /Users/julien/java/reactive-pg-client/target/classes/reactive-pg-client/pg_transaction.rb
Overview
A transaction that allows to control the transaction and receive events.
Constant Summary
- @@j_api_type =
Object.new
Class Method Summary (collapse)
- + (Boolean) accept?(obj)
- + (Object) j_api_type
- + (Object) j_class
- + (Object) unwrap(obj)
- + (Object) wrap(obj)
Instance Method Summary (collapse)
-
- (self) abort_handler { ... }
Set an handler to be called when the transaction is aborted.
-
- (void) commit { ... }
Like #commit with an handler to be notified when the transaction commit has completed.
-
- (self) prepare(sql = nil) { ... }
Create a prepared query.
- - (self) prepared_batch(sql = nil, batch = nil) { ... }
- - (self) prepared_query(sql = nil, arguments = nil) { ... }
- - (self) query(sql = nil) { ... }
-
- (void) rollback { ... }
Like #rollback with an handler to be notified when the transaction rollback has completed.
Methods inherited from PgClient
Class Method Details
+ (Boolean) accept?(obj)
22 23 24 |
# File '/Users/julien/java/reactive-pg-client/target/classes/reactive-pg-client/pg_transaction.rb', line 22 def @@j_api_type.accept?(obj) obj.class == PgTransaction end |
+ (Object) j_api_type
31 32 33 |
# File '/Users/julien/java/reactive-pg-client/target/classes/reactive-pg-client/pg_transaction.rb', line 31 def self.j_api_type @@j_api_type end |
+ (Object) j_class
34 35 36 |
# File '/Users/julien/java/reactive-pg-client/target/classes/reactive-pg-client/pg_transaction.rb', line 34 def self.j_class Java::IoReactiversePgclient::PgTransaction.java_class end |
+ (Object) unwrap(obj)
28 29 30 |
# File '/Users/julien/java/reactive-pg-client/target/classes/reactive-pg-client/pg_transaction.rb', line 28 def @@j_api_type.unwrap(obj) obj.j_del end |
+ (Object) wrap(obj)
25 26 27 |
# File '/Users/julien/java/reactive-pg-client/target/classes/reactive-pg-client/pg_transaction.rb', line 25 def @@j_api_type.wrap(obj) PgTransaction.new(obj) end |
Instance Method Details
- (self) abort_handler { ... }
Set an handler to be called when the transaction is aborted.
73 74 75 76 77 78 79 |
# File '/Users/julien/java/reactive-pg-client/target/classes/reactive-pg-client/pg_transaction.rb', line 73 def abort_handler if block_given? @j_del.java_method(:abortHandler, [Java::IoVertxCore::Handler.java_class]).call(Proc.new { yield }) return self end raise ArgumentError, "Invalid arguments when calling abort_handler()" end |
- (void) commit { ... }
This method returns an undefined value.
Like #commit with an handler to be notified when the transaction commit has completed
51 52 53 54 55 56 57 58 |
# File '/Users/julien/java/reactive-pg-client/target/classes/reactive-pg-client/pg_transaction.rb', line 51 def commit if !block_given? return @j_del.java_method(:commit, []).call() elsif block_given? return @j_del.java_method(:commit, [Java::IoVertxCore::Handler.java_class]).call((Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) end raise ArgumentError, "Invalid arguments when calling commit()" end |
- (self) prepare(sql = nil) { ... }
Create a prepared query.
41 42 43 44 45 46 47 |
# File '/Users/julien/java/reactive-pg-client/target/classes/reactive-pg-client/pg_transaction.rb', line 41 def prepare(sql=nil) if sql.class == String && block_given? @j_del.java_method(:prepare, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(sql,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::ReactivePgClient::PgPreparedQuery) : nil) })) return self end raise ArgumentError, "Invalid arguments when calling prepare(#{sql})" end |
- (self) prepared_batch(sql = nil, batch = nil) { ... }
108 109 110 111 112 113 114 |
# File '/Users/julien/java/reactive-pg-client/target/classes/reactive-pg-client/pg_transaction.rb', line 108 def prepared_batch(sql=nil,batch=nil) if sql.class == String && batch.class == Array && block_given? @j_del.java_method(:preparedBatch, [Java::java.lang.String.java_class,Java::JavaUtil::List.java_class,Java::IoVertxCore::Handler.java_class]).call(sql,batch.map { |element| element.j_del },(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::ReactivePgClient::PgRowSet) : nil) })) return self end raise ArgumentError, "Invalid arguments when calling prepared_batch(#{sql},#{batch})" end |
- (self) prepared_query(sql = nil, arguments = nil) { ... }
94 95 96 97 98 99 100 101 102 103 |
# File '/Users/julien/java/reactive-pg-client/target/classes/reactive-pg-client/pg_transaction.rb', line 94 def prepared_query(sql=nil,arguments=nil) if sql.class == String && block_given? && arguments == nil @j_del.java_method(:preparedQuery, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(sql,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::ReactivePgClient::PgRowSet) : nil) })) return self elsif sql.class == String && arguments.class.method_defined?(:j_del) && block_given? @j_del.java_method(:preparedQuery, [Java::java.lang.String.java_class,Java::IoReactiversePgclient::Tuple.java_class,Java::IoVertxCore::Handler.java_class]).call(sql,arguments.j_del,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::ReactivePgClient::PgRowSet) : nil) })) return self end raise ArgumentError, "Invalid arguments when calling prepared_query(#{sql},#{arguments})" end |
- (self) query(sql = nil) { ... }
83 84 85 86 87 88 89 |
# File '/Users/julien/java/reactive-pg-client/target/classes/reactive-pg-client/pg_transaction.rb', line 83 def query(sql=nil) if sql.class == String && block_given? @j_del.java_method(:query, [Java::java.lang.String.java_class,Java::IoVertxCore::Handler.java_class]).call(sql,(Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? ::Vertx::Util::Utils.safe_create(ar.result,::ReactivePgClient::PgRowSet) : nil) })) return self end raise ArgumentError, "Invalid arguments when calling query(#{sql})" end |
- (void) rollback { ... }
This method returns an undefined value.
Like #rollback with an handler to be notified when the transaction rollback has completed
62 63 64 65 66 67 68 69 |
# File '/Users/julien/java/reactive-pg-client/target/classes/reactive-pg-client/pg_transaction.rb', line 62 def rollback if !block_given? return @j_del.java_method(:rollback, []).call() elsif block_given? return @j_del.java_method(:rollback, [Java::IoVertxCore::Handler.java_class]).call((Proc.new { |ar| yield(ar.failed ? ar.cause : nil) })) end raise ArgumentError, "Invalid arguments when calling rollback()" end |