aravind/glink-website
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added code to insert data into Cassandra DB

Browse Source
This commit is contained in:
Aadhavan Srinivasan
2023-06-06 23:53:32 -05:00
parent f451850601
commit c81937d6a5
1 changed files with 16 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
result.php
View File

@@ -5,15 +5,26 @@ use Casssandra;
$cluster = Cassandra::cluster()->build();
$keyspace = 'glink';
$url = $_GET["url"];
$shortlink = $_GET["glink"];
$session = $cluster->connect($keyspace);
$statement = new Cassandra\SimpleStatement('SELECT name FROM data WHERE id=5');
//$statement = new Cassandra\SimpleStatement('SELECT name FROM data WHERE id=5');
$rand_num = rand(0,999999);
$future = $session->executeAsync($statement);
$values = array(
'id' => $rand_num,
'url' => $url,
'shortlink' => $shortlink,
);
$statement = new Cassandra\SimpleStatement('INSERT INTO data (id, url, shortlink, when_created) VALUES (?,?,?,toTimestamp(now()))');
$options = array('arguments' => $values);
$future = $session->executeAsync($statement,$options);
$result = $future->get();
foreach ($result as $row) {
printf("The name is %s",$row['name']);
}
printf('Successful');
?>