Utiliser PHP pour exploiter la base de données Cassandra-tutoriel php-php.cn

Utiliser PHP pour exploiter la base de données Cassandra

PHPz

Libérer： 2023-05-16 15:52:01

original

1095 Les gens l'ont consulté

Cassandra est un système de gestion de bases de données distribuées basé sur NoSQL qui peut prendre en charge le traitement de grandes quantités de données. PHP, en tant que langage de programmation côté serveur populaire, peut être utilisé pour faire fonctionner la base de données Cassandra. Cet article explique comment utiliser le pilote PHP et CQL pour connecter et exploiter la base de données Cassandra.

Avant de commencer, assurez-vous d'avoir installé la base de données Cassandra et le pilote PHP en suivant les étapes suivantes :

1 Installez la base de données Cassandra
2 Installez PHP
3 Installez le pilote PHP Cassandra

Veuillez rechercher. étapes d'installation associées par vous-même Tutoriel. Voici les étapes de base pour faire fonctionner une base de données Cassandra en PHP :

Connexion à une base de données Cassandra
Pour vous connecter à une base de données Cassandra, utilisez le code suivant fourni par le pilote Cassandra de PHP :

<?php

$cluster   = Cassandra::cluster()
             ->withContactPoints('127.0.0.1')
             ->build();

$session   = $cluster->connect();

Copier après la connexion

Dans cet exemple, 127.0.0.1< /code> représente le nœud Cassandra sur l'hôte local. <code>$cluster->build() renvoie un objet cluster Cassandra. 127.0.0.1代表本地主机上的Cassandra节点。$cluster->build() 会返回一个Cassandra 集群对象。

创建Keyspace
一个Keyspace在Cassandra中类似于一个数据库，它包含多个表。使用PHP中Cassandra的 session 对象创建一个 Keyspace，其代码如下:

<?php

$session->execute("CREATE KEYSPACE my_keyspace WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1};");

Copier après la connexion

这里创建了一个名为my_keyspace的新Keyspace。replication参数指定了数据的备份策略。

创建表
创建表需要一个名称、列族以及相关的列。Cassandra使用列族来组织和存储数据。以下是创建表的示例代码：

<?php

$session->execute("CREATE TABLE my_keyspace.my_table (id UUID primary key, name text);");

Copier après la connexion

这个代码会创建一个名为 $my_table的新表。该表包含了 id 和 name 两列，其中 id 是主键列。

插入新数据
要插入数据，使用以下代码：

<?php

$statement = $session->prepare("INSERT INTO my_keyspace.my_table (id, name) VALUES (?, ?)");

$session->execute($statement, array(new CassandraUuid(), "John Doe"));

Copier après la connexion

在这个例子中，我们准备了一个语句，然后执行了一个名为 John Doe的名字。在这里，我们引用了 PHP 的 Uuid() 对象来生成一个唯一标识符。

查询数据
使用我们之前准备的 $statement 变量来查询 my_table 表中的数据：

<?php

$statement = $session->prepare("SELECT * FROM my_keyspace.my_table");
$results   = $session->execute($statement);

foreach ($results as $row) {
    echo $row['id'] . " " . $row['name'] . "
";
}

Copier après la connexion

在这个例子中，我们可以简单地使用 foreach()循环从查询中检索数据，并使用字符串拼接将数据输出到控制台。

更新与删除数据
更新与删除数据与插入数据时类似的。使用以下代码实现：

<?php

$statement = $session->prepare("UPDATE my_keyspace.my_table SET name = ? WHERE id = ?");

$session->execute($statement, array("Jane Doe", new CassandraUuid()));

$statement = $session->prepare("DELETE FROM my_keyspace.my_table WHERE id = ?");

$session->execute($statement, array(new CassandraUuid()));

Copier après la connexion

在这个例子中，我们使用 UPDATE 关键字和键来更新名称，然后使用 DELETE

Un espace de clés est similaire à une base de données dans Cassandra, il contient plusieurs tables. Créez un Keyspace à l'aide de l'objet session de Cassandra en PHP. Le code est le suivant :

rrreee

my_keyspace

$my_table

id

name

id

John Doe code> nom. Ici, nous faisons référence à l'objet <code>Uuid()

$statement

my_table

foreach()

UPDATE

DELETE