PHP를 사용하여 Cassandra 데이터베이스 운영-PHP 튜토리얼-php.cn

PHP를 사용하여 Cassandra 데이터베이스 운영

PHPz

풀어 주다： 2023-05-16 15:52:01

원래의

1124명이 탐색했습니다.

Cassandra는 대용량 데이터 처리를 지원할 수 있는 NoSQL 기반 분산 데이터베이스 관리 시스템입니다. 널리 사용되는 서버 측 프로그래밍 언어인 PHP를 사용하여 Cassandra 데이터베이스를 운영할 수 있습니다. 이 글에서는 PHP 드라이버와 CQL을 사용하여 Cassandra 데이터베이스를 연결하고 운영하는 방법을 소개합니다.

시작하기 전에 다음 단계에 따라 Cassandra 데이터베이스와 PHP 드라이버를 설치했는지 확인하세요.

1. Cassandra 데이터베이스 설치
2. PHP 설치
3. Cassandra PHP 드라이버 설치

관련 설치 단계를 직접 튜토리얼로 제공합니다. 다음은 PHP에서 Cassandra 데이터베이스를 작동하기 위한 기본 단계입니다.

Cassandra 데이터베이스에 연결
Cassandra 데이터베이스에 연결하려면 PHP의 Cassandra 드라이버에서 제공하는 다음 코드를 사용하세요.

<?php

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

$session   = $cluster->connect();

로그인 후 복사

이 예에서는 127.0.0.1< /code>는 로컬 호스트의 Cassandra 노드를 나타냅니다. <code>$cluster->build()는 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};");

로그인 후 복사

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

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

<?php

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

로그인 후 복사

这个代码会创建一个名为 $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"));

로그인 후 복사

在这个例子中，我们准备了一个语句，然后执行了一个名为 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'] . "
";
}

로그인 후 복사

在这个例子中，我们可以简单地使用 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()));

로그인 후 복사

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

키스페이스는 Cassandra의 데이터베이스와 유사하며 여러 테이블을 포함합니다. PHP에서 Cassandra의 session 개체를 사용하여 키스페이스를 만듭니다. 코드는 다음과 같습니다.

rrreee

my_keyspace

$my_table

id

name

id

John Doe code>라는 명령문을 실행했습니다. 이름. 여기서는 PHP의 <code>Uuid()

$statement

my_table