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