Drivers and Sample Code - Practical Cassandra - page 154

class SampleApp

def connect host
@cluster = Cql::Client.connect(host: host)
end

def close
@cluster.close
end

def create_schema
create_keyspace = <<-CQL
CREATE KEYSPACE IF NOT EXISTS portfolio_demo
WITH REPLICATION = { 'class': 'Sim-
pleStrategy',

'replication_factor': 1

};

CQL

create_portfolio = <<-CQL
CREATE TABLE IF NOT EXISTS portfo-
lio_demo.portfolio (
portfolio_id UUID,
ticker TEXT,
current_price DECIMAL,
current_change DECIMAL,
current_change_percent FLOAT,
PRIMARY KEY(portfolio_id, ticker)
);
CQL

@cluster.execute(create_keyspace)
@cluster.execute(create_portfolio)
end

def load_data
row_one = <<-CQL
INSERT INTO portfolio_demo.portfolio