GettingStartedTwo

GettingStartedTwo.php

<?php

$cluster = Cassandra::cluster()
    ->withPersistentSessions(true)
    ->withTokenAwareRouting(true)
    ->build();
$keyspace = 'killrvideo';

$session = $cluster->connect($keyspace);

$timestamp = new Cassandra\Timestamp();

$data = array(
    array(new Cassandra\Uuid('14c532ac-f5ae-479a-9d0a-36604732e01d'), $timestamp, 'luke@example.com', 'Luke', 'Tillman'),
    array(new Cassandra\Uuid('dbd29e70-a78c-4bd9-9f90-cb74412875b1'), $timestamp, 'jon@example.com', 'Jon', 'Haddad')
);

$insert = $session->prepare("INSERT INTO users (userid, created_date, email, firstname, lastname)
VALUES (?, ?, ?, ?, ?)");

foreach ($data as $arguments) {
    $result = $session->execute($insert, new Cassandra\ExecutionOptions(array('arguments' => $arguments)));

}

foreach ($result as $row) {
    printf("user: \"%s\" \"%s\" email: \"%s\" \n", $row['firstname'], $row['lastname'], $row['email']);
}



$result = $session->execute(new Cassandra\SimpleStatement('SELECT firstname, lastname, email FROM killrvideo.users'));

foreach ($result as $row) {
    printf("user: \"%s\" \"%s\" email: \"%s\" \n", $row['firstname'], $row['lastname'], $row['email']);
}

$data = array(
    array('language_evangelist@example.com', new Cassandra\Uuid('14c532ac-f5ae-479a-9d0a-36604732e01d')),
    array('techinal_evangelist@example.com', new Cassandra\Uuid('dbd29e70-a78c-4bd9-9f90-cb74412875b1'))
);

$update = $session->prepare('UPDATE users SET email = ? WHERE userid = ?');

foreach ($data as $arguments) {
    $futures[] = $session->executeAsync($update, new Cassandra\ExecutionOptions(array('arguments' => $arguments)));

}

foreach ($futures as $future) {
    $future->get(5);
}


$result = $session->execute(new Cassandra\SimpleStatement('SELECT firstname, lastname, email FROM killrvideo.users '));

foreach ($result as $row) {
    printf("user: \"%s\" \"%s\" email: \"%s\" \n", $row['firstname'], $row['lastname'], $row['email']);
}

$delete = $session->prepare('DELETE FROM users WHERE userid = ? ');

$session->execute($delete, new Cassandra\ExecutionOptions(array(
        'arguments' => array
        (new Cassandra\Uuid('14c532ac-f5ae-479a-9d0a-36604732e01d'))
    ))
);

$select = $session->prepare(new Cassandra\SimpleStatement('SELECT firstname, lastname, email FROM users WHERE userid = ? '));


$result = $session->execute($select, new Cassandra\ExecutionOptions(array(
'arguments' => array
(new Cassandra\Uuid('14c532ac-f5ae-479a-9d0a-36604732e01d'))
))
);

foreach ($result as $row) {
printf("user: \"%s\" \"%s\" email: \"%s\"  \n", $row['firstname'], $row['lastname'], $row['email']);
}

?>