한국어
한국어
Cassandra는 대규모 데이터가 처리되는 시나리오에서 널리 사용되는 고성능 분산 데이터베이스 시스템입니다. Cassandra는 기존의 관계형 데이터베이스와 비교하여 더 강력한 확장 성과 신뢰성을 제공합니다. PHP 프로젝트에서 Cassandra를 사용하면 PDO (PHP Data Objects) 확장을 통해 통합 데이터 액세스 인터페이스를 구현할 수 있습니다. 이 기사에서는 PDO를 통해 Cassandra 데이터베이스를 연결하고 작동하는 방법을 설명합니다.
PDO를 사용하여 Cassandra를 작동하려면 먼저 관련 확장이 시스템에 설치되어 있는지 확인해야합니다. Linux 기반 환경에서는 다음 명령을 통해 설치할 수 있습니다.
sudo apt-get install php-pdo
sudo apt-get install php-cassandra설치가 완료되면 다음 명령에 의해 모듈이로드되는지 확인할 수 있습니다.
php -m | grep pdo
php -m | grep cassandraCassandra에 연결하려면 호스트 주소, 포트 번호 및 선택 인증 정보를 제공해야합니다. 연결을 설정하기위한 예제 코드는 다음과 같습니다.
try {
$pdoCassandra = new PDO('cassandra:host=127.0.0.1,port=9042');
// 기본 크롤링 모드 및 오류 처리 방법을 설정하십시오
$pdoCassandra->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
$pdoCassandra->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
echo "Connected to Cassandra database.";
} catch (PDOException $e) {
echo "Connection failed: " . $e->getMessage();
}프로젝트 배포 환경에 따라 호스트 주소 및 포트 번호와 같은 연결 매개 변수를 조정할 수 있습니다.
연결이 성공한 후에는 데이터 쿼리 및 쓰기 작업을 수행 할 수 있습니다. 다음은 두 가지 일반적인 유형의 작동 예입니다.
try {
$stmt = $pdoCassandra->query('SELECT * FROM my_table');
while ($row = $stmt->fetch()) {
// 출력 쿼리 결과
echo $row['column1'] . ' ' . $row['column2'];
}
} catch (PDOException $e) {
echo "Query failed: " . $e->getMessage();
} try {
$stmt = $pdoCassandra->prepare('INSERT INTO my_table (column1, column2) VALUES (?, ?)');
$stmt->execute(['value1', 'value2']);
echo "Data inserted successfully.";
} catch (PDOException $e) {
echo "Insertion failed: " . $e->getMessage();
}실제 데이터베이스 테이블 구조에 따라 테이블 이름과 필드 이름을 조정하십시오.
데이터베이스 작업을 완료 한 후에는 자원을 확보하기 위해 연결을 닫는 것이 좋습니다.
$pdoCassandra = null;이 기사의 예와 단계를 통해 PHP 프로젝트에서 Cassandra 데이터베이스의 연결 및 작업을 쉽게 구현할 수 있습니다. PDO의 추상화 계층을 사용하여 개발자는보다 일관된 데이터베이스 작업 경험을 얻을 수 있으며, 이는 시스템의 유지 관리 및 확장성에 도움이됩니다.
팁 : 시스템 보안을 보장하려면 소스 코드에서 하드 코드를 피하기 위해 사용자 이름 및 비밀번호와 같은 연결 정보를 올바르게 유지해야합니다. 구성 파일 또는 환경 변수에 저장하고 합리적인 액세스 권한을 설정하는 것을 고려하십시오.
