class Rockset::DB

Attributes

model[R]
rockset_client[R]

Public Class Methods

new(apikey, apiserver = 'api.rs2.usw2.rockset.com') click to toggle source

alias_method :insert, :create_document alias_method :create_table, :create_collection

# File lib/rockset.rb, line 18
def initialize(apikey, apiserver = 'api.rs2.usw2.rockset.com')
  @rockset_client = RocksetClient.new apikey, apiserver
end

Public Instance Methods

create_collection(collection_name, workspace = 'commons') click to toggle source
# File lib/rockset.rb, line 35
def create_collection(collection_name, workspace = 'commons')
  collection = create_collection_request(collection_name)
  rockset_obj.create_collection(workspace, collection)
end
create_document(collection, values, workspace = 'commons') click to toggle source
# File lib/rockset.rb, line 30
def create_document(collection, values, workspace = 'commons')
  docs = create_doc_request(values)
  rockset_obj.addDocuments(workspace, collection, docs)
end
query(query_str) click to toggle source
# File lib/rockset.rb, line 22
def query(query_str)
  query_request = QueryRequest.new
  query_sql = QueryRequestSql.new.query(query_str)
  req = query_request.sql(query_sql)
  res = rockset_obj.query req
  res.get_results.to_a
end

Private Instance Methods

create_collection_request(value) click to toggle source
# File lib/rockset.rb, line 51
def create_collection_request(value)
  collection_req = CreateCollectionRequest.new
  collection_req.name(value)
end
create_doc_request(values) click to toggle source
# File lib/rockset.rb, line 46
def create_doc_request(values)
  add_doc_req = AddDocumentsRequest.new
  add_doc_req.data(values)
end
rockset_obj() click to toggle source
# File lib/rockset.rb, line 42
def rockset_obj
  @rockset_client ||= create_client
end