Heim Backend-Entwicklung PHP-Tutorial Praxisleitfaden zur PHP-Elasticsearch- und relationalen Datenbankintegration

Praxisleitfaden zur PHP-Elasticsearch- und relationalen Datenbankintegration

Sep 13, 2023 pm 12:49 PM
php elasticsearch 关系型数据库

php Elasticsearch与关系型数据库的集成实践指南

Praktischer Leitfaden für die Integration von PHP Elasticsearch und relationalen Datenbanken

Einführung:

Mit dem Aufkommen des Internets und der Big-Data-Ära entwickeln sich auch die Methoden zur Datenspeicherung und -verarbeitung ständig weiter. Herkömmliche relationale Datenbanken zeigten nach und nach einige Mängel, wenn sie mit Szenarien wie großen Datenmengen, hoher gleichzeitiger Lese- und Schreibgeschwindigkeit und Volltextsuche konfrontiert wurden. Als verteilte Such- und Analysemaschine in Echtzeit hat Elasticsearch durch seine leistungsstarken Funktionen für Volltextsuche, Echtzeitanalyse und Datenvisualisierung nach und nach die Aufmerksamkeit und Nutzung der Branche auf sich gezogen.

In vielen praktischen Anwendungsszenarien müssen wir jedoch häufig vorhandene relationale Datenbanken mit Elasticsearch integrieren, um traditionelle Anforderungen an die Datenspeicherung und -verarbeitung sowie Funktionen wie Volltextsuche und intelligente Empfehlungen zu berücksichtigen. In diesem Artikel wird erläutert, wie Sie Elasticsearch mit einer relationalen Datenbank in einer PHP-Umgebung integrieren, und es werden spezifische Codebeispiele bereitgestellt.

Teil Eins: Umgebungsvorbereitung und -konfiguration

  1. Elasticsearch installieren

Zuerst müssen wir den Elasticsearch-Server installieren und konfigurieren. Das entsprechende Installationspaket kann von der offiziellen Website (https://www.elastic.co/downloads/elasticsearch) heruntergeladen werden. Starten Sie nach Abschluss der Installation den Elasticsearch-Dienst.

  1. Installieren Sie die PHP-Elasticsearch-Bibliothek

Die Interaktion zwischen PHP und Elasticsearch kann über die offiziell bereitgestellte PHP-Elasticsearch-Bibliothek erreicht werden. Es kann über Composer installiert werden. Der Befehl lautet wie folgt:

composer require elasticsearch/elasticsearch
Nach dem Login kopieren

Nach Abschluss der Installation können wir die relevanten APIs von Elasticsearch verwenden, indem wir den entsprechenden Namespace importieren.

  1. Datenbankvorbereitung und -konfiguration

Wir müssen eine relationale Datenbank vorbereiten und darin die entsprechende Tabellenstruktur erstellen. Am Beispiel von MySQL können Sie mit der folgenden SQL-Anweisung eine Tabelle mit dem Namen „users“ erstellen:

CREATE TABLE users (
  id INT AUTO_INCREMENT PRIMARY KEY,
  name VARCHAR(50),
  age INT,
  email VARCHAR(50)
);
Nach dem Login kopieren

Als nächstes müssen wir die relationale Datenbank konfigurieren. Sie müssen die Datei config.php bearbeiten, um die datenbankverbindungsbezogenen Informationen zu konfigurieren, wie unten gezeigt: config.php文件,配置数据库连接相关信息,如下所示:

<?php
  $hostname = 'localhost';
  $username = 'your_username';
  $password = 'your_password';
  $database = 'your_database';
?>
Nach dem Login kopieren

第二部分:数据同步与索引建立

  1. 数据同步

在将数据库中的数据同步到Elasticsearch之前,我们需要编写一个PHP脚本来实现这一功能。以下是一个简单的示例:

<?php
  require 'vendor/autoload.php';
  require 'config.php';

  // 建立数据库连接
  $connection = new mysqli($hostname, $username, $password, $database);
  if ($connection->connect_error) {
    die("连接数据库失败:" . $connection->connect_error);
  }

  // 查询数据库数据
  $result = $connection->query("SELECT * FROM users");
  if (!$result) {
    die("查询数据失败:" . $connection->error);
  }

  // 将数据同步到Elasticsearch
  $client = ElasticsearchClientBuilder::create()->build();
  foreach ($result as $row) {
    $params = [
      'index' => 'users',
      'type' => 'user',
      'id' => $row['id'],
      'body' => [
        'name' => $row['name'],
        'age' => $row['age'],
        'email' => $row['email']
      ]
    ];
    $client->index($params);
  }

  echo "数据同步完成。";
?>
Nach dem Login kopieren

运行脚本之后,数据库中的数据将会同步到Elasticsearch的users索引中。

  1. 索引建立

索引是Elasticsearch中数据的组织方式,类似于关系型数据库中的表。我们需要在Elasticsearch中配置索引,并定义相应的字段映射。

以下是一个创建索引的示例代码:

<?php
  $params = [
    'index' => 'users',
    'body' => [
      'mappings' => [
        'user' => [
          'properties' => [
            'name' => [
              'type' => 'text'
            ],
            'age' => [
              'type' => 'integer'
            ],
            'email' => [
              'type' => 'keyword'
            ]
          ]
        ]
      ]
    ]
  ];

  $client->indices()->create($params);
?>
Nach dem Login kopieren

在以上示例中,我们定义了一个名为users的索引,包含了nameageemail三个字段,并使用了相应的字段映射。

第三部分:数据搜索与展示

  1. 数据搜索

在进行数据搜索之前,我们需要对Elasticsearch进行配置,并引入相应的依赖库。以下是一个简单的示例:

<?php
  require 'vendor/autoload.php';

  // 连接Elasticsearch
  $client = ElasticsearchClientBuilder::create()->build();

  // 查询用户信息
  $params = [
    'index' => 'users',
    'type' => 'user',
    'body' => [
      'query' => [
        'match' => [
          'name' => 'John'
        ]
      ]
    ]
  ];

  $response = $client->search($params);
  print_r($response);
?>
Nach dem Login kopieren

在以上示例中,我们查询了name

<?php
  require 'vendor/autoload.php';

  // 连接Elasticsearch
  $client = ElasticsearchClientBuilder::create()->build();

  // 查询用户信息
  $params = [
    'index' => 'users',
    'type' => 'user',
    'body' => [
      'query' => [
        'match' => [
          'name' => 'John'
        ]
      ]
    ]
  ];

  $response = $client->search($params);
  
  echo "查询到" . $response['hits']['total']['value'] . "条用户信息:" . PHP_EOL;
  
  foreach ($response['hits']['hits'] as $hit) {
    echo "ID:" . $hit['_id'] . ",Name:" . $hit['_source']['name'] . ",Age:" . $hit['_source']['age'] . ",Email:" . $hit['_source']['email'] . PHP_EOL;
  }
?>
Nach dem Login kopieren
Teil 2: Datensynchronisierung und Indexerstellung
  1. Datensynchronisierung

In der Datenbank Daten Vor der Synchronisierung mit Elasticsearch müssen wir ein PHP-Skript schreiben, um diese Funktion zu implementieren. Das Folgende ist ein einfaches Beispiel:

rrreee

Nach der Ausführung des Skripts werden die Daten in der Datenbank mit dem users-Index von Elasticsearch synchronisiert.

Indexerstellung

🎜🎜Index ist die Art und Weise, wie Daten in Elasticsearch organisiert werden, ähnlich wie Tabellen in relationalen Datenbanken. Wir müssen den Index in Elasticsearch konfigurieren und die entsprechende Feldzuordnung definieren. 🎜🎜Das Folgende ist ein Beispielcode zum Erstellen eines Index: 🎜rrreee🎜Im obigen Beispiel definieren wir einen Index mit dem Namen users, einschließlich name, Es gibt drei Felder: Alter und E-Mail, und die entsprechende Feldzuordnung wird verwendet. 🎜🎜Teil 3: Datensuche und -anzeige🎜🎜🎜Datensuche🎜🎜🎜Bevor wir die Datensuche durchführen, müssen wir Elasticsearch konfigurieren und die entsprechenden Abhängigkeitsbibliotheken einführen. Hier ist ein einfaches Beispiel: 🎜rrreee🎜Im obigen Beispiel fragen wir die Benutzerinformationen ab, die „John“ im Feld name enthalten. 🎜🎜🎜Datenanzeige🎜🎜🎜Nachdem wir die Suchergebnisse erhalten haben, können wir die Ergebnisse entsprechend den Anforderungen anzeigen und verarbeiten. Das Folgende ist ein einfaches Beispiel für einen Anzeigecode: 🎜rrreee🎜Das obige Beispiel zeigt die gesuchten Benutzerinformationen an. 🎜🎜Fazit: 🎜🎜Dieser Artikel stellt vor, wie man Elasticsearch mit einer relationalen Datenbank in einer PHP-Umgebung integriert, und stellt spezifische Codebeispiele bereit. Wir hoffen, dass den Lesern durch die Anleitung dieses Artikels eine nahtlose Integration beider gelingt, wodurch die leistungsstarken Funktionen und Leistungsvorteile von Elasticsearch vollständig genutzt und die Effizienz und Qualität der Datenspeicherung und -verarbeitung verbessert werden. 🎜

Das obige ist der detaillierte Inhalt vonPraxisleitfaden zur PHP-Elasticsearch- und relationalen Datenbankintegration. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn

Heiße KI -Werkzeuge

Undresser.AI Undress

Undresser.AI Undress

KI-gestützte App zum Erstellen realistischer Aktfotos

AI Clothes Remover

AI Clothes Remover

Online-KI-Tool zum Entfernen von Kleidung aus Fotos.

Undress AI Tool

Undress AI Tool

Ausziehbilder kostenlos

Clothoff.io

Clothoff.io

KI-Kleiderentferner

AI Hentai Generator

AI Hentai Generator

Erstellen Sie kostenlos Ai Hentai.

Heißer Artikel

R.E.P.O. Energiekristalle erklärten und was sie tun (gelber Kristall)
2 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌
Repo: Wie man Teamkollegen wiederbelebt
1 Monate vor By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Abenteuer: Wie man riesige Samen bekommt
4 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌

Heiße Werkzeuge

Notepad++7.3.1

Notepad++7.3.1

Einfach zu bedienender und kostenloser Code-Editor

SublimeText3 chinesische Version

SublimeText3 chinesische Version

Chinesische Version, sehr einfach zu bedienen

Senden Sie Studio 13.0.1

Senden Sie Studio 13.0.1

Leistungsstarke integrierte PHP-Entwicklungsumgebung

Dreamweaver CS6

Dreamweaver CS6

Visuelle Webentwicklungstools

SublimeText3 Mac-Version

SublimeText3 Mac-Version

Codebearbeitungssoftware auf Gottesniveau (SublimeText3)

CakePHP-Projektkonfiguration CakePHP-Projektkonfiguration Sep 10, 2024 pm 05:25 PM

In diesem Kapitel werden wir die Umgebungsvariablen, die allgemeine Konfiguration, die Datenbankkonfiguration und die E-Mail-Konfiguration in CakePHP verstehen.

PHP 8.4 Installations- und Upgrade-Anleitung für Ubuntu und Debian PHP 8.4 Installations- und Upgrade-Anleitung für Ubuntu und Debian Dec 24, 2024 pm 04:42 PM

PHP 8.4 bringt mehrere neue Funktionen, Sicherheitsverbesserungen und Leistungsverbesserungen mit einer beträchtlichen Menge an veralteten und entfernten Funktionen. In dieser Anleitung wird erklärt, wie Sie PHP 8.4 installieren oder auf PHP 8.4 auf Ubuntu, Debian oder deren Derivaten aktualisieren. Obwohl es möglich ist, PHP aus dem Quellcode zu kompilieren, ist die Installation aus einem APT-Repository wie unten erläutert oft schneller und sicherer, da diese Repositorys in Zukunft die neuesten Fehlerbehebungen und Sicherheitsupdates bereitstellen.

CakePHP Datum und Uhrzeit CakePHP Datum und Uhrzeit Sep 10, 2024 pm 05:27 PM

Um in cakephp4 mit Datum und Uhrzeit zu arbeiten, verwenden wir die verfügbare FrozenTime-Klasse.

CakePHP-Datei hochladen CakePHP-Datei hochladen Sep 10, 2024 pm 05:27 PM

Um am Datei-Upload zu arbeiten, verwenden wir den Formular-Helfer. Hier ist ein Beispiel für den Datei-Upload.

CakePHP-Routing CakePHP-Routing Sep 10, 2024 pm 05:25 PM

In diesem Kapitel lernen wir die folgenden Themen im Zusammenhang mit dem Routing kennen.

Besprechen Sie CakePHP Besprechen Sie CakePHP Sep 10, 2024 pm 05:28 PM

CakePHP ist ein Open-Source-Framework für PHP. Es soll die Entwicklung, Bereitstellung und Wartung von Anwendungen erheblich vereinfachen. CakePHP basiert auf einer MVC-ähnlichen Architektur, die sowohl leistungsstark als auch leicht zu verstehen ist. Modelle, Ansichten und Controller gu

So richten Sie Visual Studio-Code (VS-Code) für die PHP-Entwicklung ein So richten Sie Visual Studio-Code (VS-Code) für die PHP-Entwicklung ein Dec 20, 2024 am 11:31 AM

Visual Studio Code, auch bekannt als VS Code, ist ein kostenloser Quellcode-Editor – oder eine integrierte Entwicklungsumgebung (IDE) –, die für alle gängigen Betriebssysteme verfügbar ist. Mit einer großen Sammlung von Erweiterungen für viele Programmiersprachen kann VS Code c

CakePHP erstellt Validatoren CakePHP erstellt Validatoren Sep 10, 2024 pm 05:26 PM

Der Validator kann durch Hinzufügen der folgenden zwei Zeilen im Controller erstellt werden.

See all articles