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

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

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

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

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

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

<?php

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

$session   = $cluster->connect();

이 예에서는 127.0.0.1는 로컬 호스트의 Cassandra 노드를 나타냅니다. <code>$cluster->build()는 Cassandra 클러스터 객체를 반환합니다. 127.0.0.1代表本地主机上的Cassandra节点。$cluster->build() 会返回一个Cassandra 集群对象。

2. 创建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参数指定了数据的备份策略。

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

<?php

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

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

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

<?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() 对象来生成一个唯一标识符。

5. 查询数据
   使用我们之前准备的 $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()循环从查询中检索数据，并使用字符串拼接将数据输出到控制台。

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

<?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라는 새 키스페이스가 생성됩니다. 복제 매개변수는 데이터 백업 전략을 지정합니다.
테이블 만들기 🎜테이블을 만들려면 이름, 열 계열 및 관련 열이 필요합니다. Cassandra는 컬럼 패밀리를 사용하여 데이터를 구성하고 저장합니다. 다음은 테이블을 생성하는 샘플 코드입니다. 🎜🎜rrreee🎜이 코드는 $my_table이라는 새 테이블을 생성합니다. 테이블에는 id 및 name이라는 두 개의 열이 포함되어 있습니다. 여기서 id는 기본 키 열입니다. 🎜
🎜새 데이터 삽입🎜데이터를 삽입하려면 다음 코드를 사용하세요. 🎜🎜rrreee🎜이 예에서는 명령문을 준비한 후 John Doe code>라는 명령문을 실행했습니다. 이름. 여기서는 PHP의 <code>Uuid() 개체를 참조하여 고유 식별자를 생성합니다. 🎜
🎜데이터 쿼리🎜이전에 준비한 $statement 변수를 사용하여 my_table 테이블의 데이터를 쿼리합니다. 🎜🎜rrreee🎜여기서 예를 들어, 간단히 foreach() 루프를 사용하여 쿼리에서 데이터를 검색하고 문자열 연결을 사용하여 데이터를 콘솔에 출력할 수 있습니다. 🎜
🎜데이터 업데이트 및 삭제 🎜데이터 업데이트 및 삭제는 데이터 삽입과 유사합니다. 이를 달성하려면 다음 코드를 사용하세요. 🎜🎜rrreee🎜이 예에서는 UPDATE 키워드와 키를 사용하여 이름을 업데이트한 다음 DELETE 키워드와 키를 사용합니다. 행을 삭제합니다. 🎜🎜요약🎜🎜이 기사에서는 PHP 드라이버와 CQL을 사용하여 Cassandra 데이터베이스를 연결하고, Keyspace 및 테이블을 생성하고, 데이터를 삽입, 업데이트, 삭제하고 PHP에서 데이터를 쿼리하는 방법을 배웠습니다. 🎜🎜애플리케이션을 개발할 때 Cassandra 데이터베이스와 PHP를 결합하면 애플리케이션을 더 빠르고 안정적이며 확장 가능하게 만들고 최신 NoSQL 데이터베이스 기술을 사용할 수 있습니다. 동시에 Cassandra의 PHP 드라이버를 사용하면 Cassandra 데이터베이스를 더 쉽게 통합하고 관리할 수 있습니다. 🎜

위 내용은 PHP를 사용하여 Cassandra 데이터베이스 운영의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!