Module: AbstractedCassandraRepository

Included in:
CassandraService
Defined in:
lib/cassandra/abstracted_cassandra_repository.rb

Instance Method Summary collapse

Instance Method Details

#create(cql_query = '', keyspace_name = nil, table_name = nil) ⇒ Object 



18
19
20
21
22
23
24
25
 
# File 'lib/cassandra/abstracted_cassandra_repository.rb', line 18

def create(cql_query='', keyspace_name=nil, table_name=nil)
	# puts 'create'
	if keyspace_name && table_name
		session = cassandra_cluster.connect(keyspace_name)
		# Building the cql using 'INSERT INTO' with 'IF NOT EXISTS'
		result = session.execute(cql_query)
	end
end

#delete(id = nil, keyspace_name = nil, table_name = nil) ⇒ Object 



45
46
47
48
49
50
51
 
# File 'lib/cassandra/abstracted_cassandra_repository.rb', line 45

def delete(id=nil, keyspace_name=nil, table_name=nil)
	# puts 'delete'
	if keyspace_name && table_name
		session = cassandra_cluster.connect(keyspace_name)
		result = session.execute("DELETE FROM #{table_name} WHERE id = ?", arguments: [id])
	end
end

#find_all(keyspace_name = nil, table_name = nil) ⇒ Object 



10
11
12
13
14
15
16
 
# File 'lib/cassandra/abstracted_cassandra_repository.rb', line 10

def find_all(keyspace_name=nil, table_name=nil)
	# puts 'find_all'
	if keyspace_name && table_name
		session = cassandra_cluster.connect(keyspace_name)
		result = session.execute("SELECT * FROM #{table_name}")
	end
end

#find_by_id(id = nil, keyspace_name = nil, table_name = nil) ⇒ Object 



2
3
4
5
6
7
8
 
# File 'lib/cassandra/abstracted_cassandra_repository.rb', line 2

def find_by_id(id=nil, keyspace_name=nil, table_name=nil)
	# puts 'find_by_id'
	if keyspace_name && table_name
		session = cassandra_cluster.connect(keyspace_name)
		result = session.execute("SELECT * FROM #{table_name} WHERE id = ?", arguments: [id])
	end
end

#run_query(cql_query = '', keyspace_name = nil, table_name = nil) ⇒ Object 



53
54
55
56
57
58
 
# File 'lib/cassandra/abstracted_cassandra_repository.rb', line 53

def run_query(cql_query='', keyspace_name=nil, table_name=nil)
	if keyspace_name && table_name
		session = cassandra_cluster.connect(keyspace_name)
		result = session.execute(cql_query)
	end
end

#save(value_hashes = {}, keyspace_name = nil, table_name = nil) ⇒ Object 



36
37
38
39
40
41
42
43
 
# File 'lib/cassandra/abstracted_cassandra_repository.rb', line 36

def save(value_hashes={}, keyspace_name=nil, table_name=nil)
	# puts 'save'
	if keyspace_name && table_name
		session = cassandra_cluster.connect(keyspace_name)
		# Building the cql using 'INSERT INTO' without 'IF NOT EXISTS'
		result = session.execute(cql_query)
	end
end

#update(id = nil, value_hashes = {}, keyspace_name = nil, table_name = nil) ⇒ Object 



27
28
29
30
31
32
33
34
 
# File 'lib/cassandra/abstracted_cassandra_repository.rb', line 27

def update(id=nil, value_hashes={}, keyspace_name=nil, table_name=nil)
	# puts 'update'
	if keyspace_name && table_name
		session = cassandra_cluster.connect(keyspace_name)
		# Building the cql using UPDATE
		result = session.execute(cql_query)
	end
end