告别繁琐的Elasticsearch集成！JoliCodeElastically如何让PHP对象与ES无缝同步

<code class="bash">composer require jolicode/elastically</code>

<code class="php">// src/Dto/Beer.php
namespace App\Dto;

class Beer
{
    public string $name;
    public string $style;
    public ?string $description = null;
    public array $hops = [];
}</code>

<code class="yaml"># config/elasticsearch/beers_mapping.yaml
settings:
    number_of_replicas: 1
    number_of_shards: 1
    refresh_interval: 1s # 开发时可以设短一点，生产环境设长一点
mappings:
    dynamic: false # 严格控制字段，避免意外添加
    properties:
        name:
            type: text
            fields:
                keyword:
                    type: keyword
        style:
            type: keyword
        description:
            type: text
            analyzer: english
        hops:
            type: keyword</code>

<code class="php">// 假设在非 Symfony 环境下
use JoliCode\Elastically\Factory;
use JoliCode\Elastically\Model\Document;
use App\Dto\Beer;

// Factory 配置，指向映射文件目录和 DTO 类映射
$factory = new Factory([
    Factory::CONFIG_MAPPINGS_DIRECTORY => __DIR__.'/config/elasticsearch', // 你的映射文件路径
    Factory::CONFIG_INDEX_CLASS_MAPPING => [
        'beers' => Beer::class, // '索引名' => DTO::class
    ],
    // Elastica 客户端配置，这里可以添加 Elasticsearch 主机等
    'hosts' => ['127.0.0.1:9200'],
]);

$client = $factory->buildClient();
$indexBuilder = $factory->buildIndexBuilder();
$indexer = $factory->buildIndexer();</code>

<code class="php">// 创建一个带版本号的新索引 (例如 beers_v123456)
$newIndex = $indexBuilder->createIndex('beers');
echo "Created new index: " . $newIndex->getName() . PHP_EOL;

// 将 'beers' 别名指向新索引，实现零停机切换
$indexBuilder->markAsLive($newIndex, 'beers');
echo "Alias 'beers' now points to: " . $newIndex->getName() . PHP_EOL;

// 清理旧的索引（如果有的话）
$indexBuilder->purgeOldIndices('beers');
echo "Old indices purged for 'beers'." . PHP_EOL;</code>

<code class="php">$ipa = new Beer();
$ipa->name = 'Hoppy IPA';
$ipa->style = 'IPA';
$ipa->description = 'A very hoppy and bitter IPA with citrus notes.';
$ipa->hops = ['Citra', 'Mosaic'];

$stout = new Beer();
$stout->name = 'Dark Roast Stout';
$stout->style = 'Stout';
$stout->description = 'Rich, dark stout with coffee and chocolate flavors.';
$stout->hops = ['Fuggles'];

// 将 DTO 加入索引队列
$indexer->scheduleIndex('beers', new Document('beer-1', $ipa));
$indexer->scheduleIndex('beers', new Document('beer-2', $stout));

// 刷新索引，确保数据立即可查
$indexer->flush();
$indexer->refresh('beers');

echo "Documents indexed and flushed." . PHP_EOL;</code>

<code class="php">// 执行搜索
$results = $client->getIndex('beers')->search('hoppy');

echo "Search results for 'hoppy':" . PHP_EOL;
foreach ($results->getResults() as $result) {
    /** @var Beer $beer */
    $beer = $result->getModel(); // ? 直接获取 DTO 对象！
    echo "  - Name: " . $beer->name . ", Style: " . $beer->style . PHP_EOL;
}

// 通过 ID 获取单个 DTO
/** @var Beer $retrievedBeer */
$retrievedBeer = $client->getIndex('beers')->getModel('beer-1');
echo "Retrieved beer by ID: " . $retrievedBeer->name . PHP_EOL;</code>

<code class="php">// 假设你已经修改了 beers_mapping.yaml
echo "Initiating mapping migration for 'beers'..." . PHP_EOL;

// 创建新版本索引，并自动将旧数据 ReIndex 到新索引
$newIndexAfterMigration = $indexBuilder->migrate($newIndex); // $newIndex 是之前创建的当前活跃索引
$indexBuilder->speedUpRefresh($newIndexAfterMigration); // 迁移完成后可以加速刷新
$indexBuilder->markAsLive($newIndexAfterMigration, 'beers'); // 将别名指向新索引
$indexBuilder->purgeOldIndices('beers'); // 清理旧索引

echo "Mapping migration completed. New active index: " . $newIndexAfterMigration->getName() . PHP_EOL;</code>