Class: VertxCassandra::Mapper

Inherits:
Object
  • Object
show all
Defined in:
/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/mapper.rb

Overview

It is like , but adapted for Vert.x.

Instance Method Summary (collapse)

Instance Method Details

- (void) delete(primaryKey, handler) { ... }

This method returns an undefined value.

Asynchronous delete method based on the column values of the primary key.

Parameters:

  • primaryKey (Array<Object>)
    primary key used to find row to delete

Yields:

  • result handler


66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/mapper.rb', line 66

def delete(*args)
  if args[0].class == Array && true
    if (block_given?)
      return @j_del.java_method(:delete, [Java::JavaUtil::List.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].map { |element| ::Vertx::Util::Utils.to_object(element) },block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? nil : nil) } : promise)
    else
      promise = ::Vertx::Util::Utils.promise
      @j_del.java_method(:delete, [Java::JavaUtil::List.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].map { |element| ::Vertx::Util::Utils.to_object(element) },block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? nil : nil) } : promise)
      return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future, nil)
    end
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling delete(#{args[0]})"
  end
end

- (void) get(primaryKey, handler) { ... }

This method returns an undefined value.

Asynchronous get method based on the column values of the primary key.

Parameters:

  • primaryKey (Array<Object>)
    primary key used to retrieve row

Yields:

  • result handler


24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/mapper.rb', line 24

def get(*args)
  if args[0].class == Array && true
    if (block_given?)
      return @j_del.java_method(:get, [Java::JavaUtil::List.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].map { |element| ::Vertx::Util::Utils.to_object(element) },block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? @j_arg_T.wrap(ar.result) : nil) } : promise)
    else
      promise = ::Vertx::Util::Utils.promise
      @j_del.java_method(:get, [Java::JavaUtil::List.java_class,Java::IoVertxCore::Handler.java_class]).call(args[0].map { |element| ::Vertx::Util::Utils.to_object(element) },block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? @j_arg_T.wrap(ar.result) : nil) } : promise)
      return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future, nil)
    end
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling get(#{args[0]})"
  end
end

- (void) save(entity, handler) { ... }

This method returns an undefined value.

Asynchronous save method.

Parameters:

  • entity (Object)
    object to be stored in database

Yields:

  • result handler


45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-cassandra/mapper.rb', line 45

def save(*args)
  if @j_arg_T.accept?(args[0]) && true
    if (block_given?)
      return @j_del.java_method(:save, [Java::java.lang.Object.java_class,Java::IoVertxCore::Handler.java_class]).call(@j_arg_T.unwrap(args[0]),block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? nil : nil) } : promise)
    else
      promise = ::Vertx::Util::Utils.promise
      @j_del.java_method(:save, [Java::java.lang.Object.java_class,Java::IoVertxCore::Handler.java_class]).call(@j_arg_T.unwrap(args[0]),block_given? ? Proc.new { |ar| yield(ar.failed ? ar.cause : nil, ar.succeeded ? nil : nil) } : promise)
      return ::Vertx::Util::Utils.safe_create(promise.future(),::Vertx::Future, nil)
    end
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling save(#{args[0]})"
  end
end