Utiliser PHP pour exploiter la base de données Cassandra

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

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

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

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

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

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

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

prepare("INSERT INTO my_keyspace.my_table (id, name) VALUES (?, ?)"); $session->execute($statement, array(new CassandraUuid(), "John Doe"));

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

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

prepare("SELECT * FROM my_keyspace.my_table"); $results = $session->execute($statement); foreach ($results as $row) { echo $row['id'] . " " . $row['name'] . " "; }

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

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

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()));

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

Créer un espace de clés

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'objetsessionde Cassandra en PHP. Le code est le suivant :

rrreee

Un nouveau Keyspace nommé my_keyspaceest créé ici. Le paramètre de réplication spécifie la stratégie de sauvegarde des données.
Créer une table La création d'une table nécessite un nom, une famille de colonnes et des colonnes associées. Cassandra utilise des familles de colonnes pour organiser et stocker les données. Voici un exemple de code pour créer une table : rrreeeCe code créera une nouvelle table nommée $my_table. Le tableau contient deux colonnes : idet name, où idest la colonne de clé primaire.
Insérer de nouvelles donnéesPour insérer des données, utilisez le code suivant : rrreeeDans cet exemple, nous avons préparé une instruction puis exécuté une instruction nommée John Doe code> nom. Ici, nous faisons référence à l'objet Uuid()de PHP pour générer un identifiant unique.
Interroger des donnéesUtilisez la variable $statementque nous avons préparée précédemment pour interroger les données de la table my_table: rrreeeDans ce Par exemple, nous pouvons simplement utiliser une boucle foreach()pour récupérer les données de la requête et utiliser la concaténation de chaînes pour afficher les données sur la console.
Mettre à jour et supprimer des données La mise à jour et la suppression de données sont similaires à l'insertion de données. Utilisez le code suivant pour y parvenir : rrreeeDans cet exemple, nous utilisons le mot-clé et la clé UPDATEpour mettre à jour le nom, puis nous utilisons le mot-clé et la clé DELETEpour supprimer la ligne. RésuméDans cet article, nous avons appris comment connecter la base de données Cassandra, créer des espaces de clés et des tables, insérer, mettre à jour, supprimer des données et interroger des données de PHP à l'aide du pilote PHP et de CQL. Lors du développement d'applications, la combinaison de la base de données Cassandra avec PHP peut rendre vos applications plus rapides, fiables, évolutives et utiliser la dernière technologie de base de données NoSQL. Dans le même temps, l'utilisation du pilote PHP de Cassandra vous facilite l'intégration et la gestion des bases de données Cassandra.