Database Reference
In-Depth Information
cluster = None
session = None
def connect(self, host):
self.cluster = Cluster(host)
self.session = self.cluster.connect()
print "Cluster: %s" %
self.cluster.metadata.cluster_name
for host in self.cluster.metadata.all_hosts():
print "Host: %s" % host
def close(self):
self.cluster.shutdown()
def create_schema(self):
self.session.execute("CREATE KEYSPACE IF NOT
EXISTS portfolio_demo "
"WITH REPLICATION = {
'class': 'SimpleStrategy', "
"'replication_factor': 1
};")
self.session.execute("CREATE TABLE IF NOT
EXISTS "
"portfolio_demo.portfolio
(portfolio_id UUID, "
"ticker TEXT, cur-
rent_price DECIMAL, "
"current_change DECIMAL, "
"current_change_percent
FLOAT, "
"PRIMARY KEY(portfolio_id,
ticker));")
def load_data(self):
self.session.execute("INSERT INTO portfo-
lio_demo.portfolio "
