Session management

Each PHP Driver session can be explicitly closed to cleanup its resources.

Background

Given

a running Cassandra cluster

Session can only be closed once

Given

the following example:

$cluster = Dse::cluster()
               ->withPersistentSessions(false)
               ->build();
$session = $cluster->connect();
$session->close();

try {
    $session->close();
} catch (Dse\Exception $e) {
    echo $e->getMessage() . PHP_EOL;
}

When

it is executed

Then

its output should contain:

Already closing or closed

Session closes after outstanding requests are completed

Given

the following schema:

CREATE KEYSPACE simplex WITH replication = {
  'class': 'SimpleStrategy',
  'replication_factor': 1
};
USE simplex;
CREATE TABLE playlists (
  id uuid,
  title text,
  album text,
  artist text,
  song_id uuid,
  PRIMARY KEY (id, title, album, artist)
);
INSERT INTO playlists (id, song_id, artist, title, album)
VALUES (
  62c36092-82a1-3a00-93d1-46196ee77204,
  756716f7-2e54-4715-9f00-91dcbea6cf50,
  'Joséphine Baker',
  'La Petite Tonkinoise',
  'Bye Bye Blackbird'
);
INSERT INTO playlists (id, song_id, artist, title, album)
VALUES (
  62c36092-82a1-3a00-93d1-46196ee77204,
  f6071e72-48ec-4fcb-bf3e-379c8a696488,
  'Willi Ostermann',
  'Die Mösch',
  'In Gold'
);
INSERT INTO playlists (id, song_id, artist, title, album)
VALUES (
  62c36092-82a1-3a00-93d1-46196ee77204,
  fbdf82ed-0063-4796-9c7c-a3d4f47b4b25,
  'Mick Jager',
  'Memo From Turner',
  'Performance'
);

And

the following example:

$cluster   = Dse::cluster()->build();
$session   = $cluster->connect("simplex");
$future    = $session->executeAsync("SELECT * FROM simplex.playlists");
$session->close();

echo "Result contains {$future->get()->count()} rows" . PHP_EOL;

When

it is executed

Then

its output should contain:

Result contains 3 rows