Class: CassandraObject::Adapters::CassandraSchemalessAdapter::QueryBuilder

Inherits:
Object
  • Object
show all
Defined in:
lib/cassandra_object/adapters/cassandra_schemaless_adapter.rb

Instance Method Summary collapse

Constructor Details

#initialize(adapter, scope) ⇒ QueryBuilder

Returns a new instance of QueryBuilder.



9
10
11
12
 
# File 'lib/cassandra_object/adapters/cassandra_schemaless_adapter.rb', line 9

def initialize(adapter, scope)
  @adapter = adapter
  @scope = scope
end

Instance Method Details

#select_string ⇒ Object 



14
15
16
17
18
19
20
21
 
# File 'lib/cassandra_object/adapters/cassandra_schemaless_adapter.rb', line 14

def select_string
  selected_values = @scope.select_values.select { |sv| sv == :column1 || sv == :values }
  if selected_values.any?
    (['KEY'] | selected_values) * ','
  else
    '*'
  end
end

#to_query_async ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
 
# File 'lib/cassandra_object/adapters/cassandra_schemaless_adapter.rb', line 23

def to_query_async
  # empty ids
  return nil if !@scope.id_values.present? && !@scope.where_values.present? && !@scope.is_all && !@scope.limit_value.present?

  if @scope.id_values.empty?
    str = [
      "SELECT #{select_string} FROM #{@scope.klass.column_family}",
      where_string_async(nil)
    ]
    str << 'ALLOW FILTERING' if @scope.klass.allow_filtering
    return [] << str.delete_if(&:blank?) * ' '
  end
  str = [
    "SELECT #{select_string} FROM #{@scope.klass.column_family}",
    where_string_async(@scope.id_values)
  ]
  str << 'ALLOW FILTERING' if @scope.klass.allow_filtering
  [str.delete_if(&:blank?) * ' ']
end

#where_string_async(ids) ⇒ Object 



43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
 
# File 'lib/cassandra_object/adapters/cassandra_schemaless_adapter.rb', line 43

def where_string_async(ids)
  conditions = []

  if ids.present?
    conditions << if ids.size > 1
                    "#{@adapter.primary_key_column} IN (#{ids.map { |id| "'#{id}'" }.join(',')})"
                  else
                    "#{@adapter.primary_key_column} = '#{ids.first}'"
                  end
  end

  select_values = @scope.select_values.select { |sv| sv != :column1 }
  if select_values.size > 0
    select_str = select_values.size > 1 ? "column1 IN (#{select_values.map { |sv| '?' }.join(',')})" : 'column1 = ?'
    conditions << select_str
  end
  conditions += @scope.where_values.select.each_with_index { |_, i| i.even? }
  conditions.any? ? "WHERE #{conditions.join(' AND ')}" : nil
end