Database Reference
In-Depth Information
cluster =
Cluster.Builder().AddContactPoint(node).Build();
session = cluster.Connect();
Metadata metadata = cluster.Metadata;
Console.WriteLine("Cluster: " +
metadata.ClusterName.ToString());
foreach (Host host in metadata.AllHosts()) {
Console.WriteLine("Host: " + host.Address);
}
}
public void Close() {
cluster.Shutdown();
}
public void CreateSchema() {
session.Execute("CREATE KEYSPACE IF NOT
EXISTS portfolio_demo " +
"WITH REPLICATION = { 'class': 'Sim-
pleStrategy', " +
"'replication_factor': 1 };");
session.Execute("CREATE TABLE IF NOT EXISTS
portfolio_demo.portfolio (" +
"portfolio_id UUID, ticker TEXT, " +
"current_price DECIMAL, current_change
DECIMAL, " +
"current_change_percent FLOAT, " +
"PRIMARY KEY(portfolio_id, ticker));");
}
public void LoadData() {
session.Execute("INSERT INTO portfo-
lio_demo.portfolio " +
"(portfolio_id, ticker, current_price, "
+
" current_change, current_change_percent)
