Last active
October 23, 2019 15:00
-
-
Save beccam/5abab3b4072d5a0027475481f1d5075f to your computer and use it in GitHub Desktop.
A basic C#/.NET demo CRUD application using the DataStax C# Driver for Apache Cassandra.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
using Cassandra; | |
using System.Linq; | |
using System; | |
namespace QuickStart | |
{ | |
class Program | |
{ | |
static void Main(string[] args) | |
{ | |
// TO DO: Fill in your own contact point | |
Cluster cluster = Cluster.Builder().AddContactPoint("127.0.0.1").Build(); | |
ISession session = cluster.Connect("demo"); | |
SetUser(session, "Jones", 35, "Austin", "[email protected]", "Bob"); | |
GetUser(session, "Jones"); | |
UpdateUser(session, 36, "Jones"); | |
GetUser(session, "Jones"); | |
DeleteUser(session, "Jones"); | |
cluster.Dispose(); | |
} | |
private static void SetUser(ISession session, String lastname, int age, String city, String email, String firstname) { | |
//TO DO: execute SimpleStatement that inserts one user into the table | |
var statement = new SimpleStatement("INSERT INTO users (lastname, age, city, email, firstname) VALUES (?,?,?,?,?)", lastname, age, city, email, firstname); | |
session.Execute(statement); | |
} | |
private static void GetUser(ISession session, String lastname){ | |
//TO DO: execute SimpleStatement that retrieves one user from the table | |
//TO DO: print firstname and age of user | |
var statement = new SimpleStatement("SELECT * FROM users WHERE lastname = ?", lastname); | |
var result = session.Execute(statement).First(); | |
Console.WriteLine("{0} {1}", result["firstname"], result["age"]); | |
} | |
private static void UpdateUser(ISession session, int age, String lastname) { | |
//TO DO: execute SimpleStatement that updates the age of one user | |
var statement = new SimpleStatement("UPDATE users SET age =? WHERE lastname = ?", age, lastname); | |
session.Execute(statement); | |
} | |
private static void DeleteUser(ISession session, String lastname) { | |
//TO DO: execute SimpleStatement that deletes one user from the table | |
var statement = new SimpleStatement("DELETE FROM users WHERE lastname = ?", lastname); | |
session.Execute(statement); | |
} | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment