Laravel新手问询：只读外部遗留库复杂查询缓存与模型化处理

嘿，针对你这个只读外部遗留库+复杂查询缓存+模型化处理的需求，我给你整理了一套落地的方案，完全贴合Laravel的使用习惯：

1. 配置外部只读数据库连接 #

首先在config/database.php里添加你的外部数据库连接配置，适配遗留库的类型：

'connections' => [
    // ... 项目原有数据库连接
    'legacy_readonly' => [
        'driver' => 'mysql', // 根据你的数据库类型调整（比如pgsql/sqlsrv）
        'host' => env('LEGACY_DB_HOST'),
        'database' => env('LEGACY_DB_DATABASE'),
        'username' => env('LEGACY_DB_USERNAME'),
        'password' => env('LEGACY_DB_PASSWORD'),
        'charset' => 'utf8',
        'collation' => 'utf8_unicode_ci',
        'prefix' => '',
        'strict' => false, // 遗留库通常不严格遵循SQL标准
    ],
],

然后在.env文件中补充对应的环境变量即可。

2. 创建自定义Eloquent模型 #

创建一个对应外部Products表的模型，适配只读场景，同时保留Eloquent的所有便捷特性：

namespace App\Models;

use Illuminate\Database\Eloquent\Model;
use Illuminate\Database\Eloquent\Casts\Attribute;

class LegacyProduct extends Model
{
    // 指定使用外部只读数据库连接
    protected $connection = 'legacy_readonly';
    // 关联遗留库的Products表
    protected $table = 'Products';
    // 只读场景下不需要维护时间戳字段
    public $timestamps = false;
    // 允许Eloquent访问所有表字段
    protected $guarded = [];

    // 可选：重写写操作方法，防止误修改数据
    public function save(array $options = [])
    {
        throw new \RuntimeException('该模型为只读，无法执行保存操作');
    }

    public function delete()
    {
        throw new \RuntimeException('该模型为只读，无法执行删除操作');
    }

    // 示例：添加访问器，像普通模型一样格式化字段
    protected function formattedPrice(): Attribute
    {
        return Attribute::make(
            get: fn ($value, $attributes) => '$' . number_format($attributes['price'], 2),
        );
    }
}

3. 封装复杂的热门产品查询逻辑 #

在模型里添加静态方法，实现你的复杂查询逻辑，接收起始日期和结果数量两个参数：

public static function topProducts($startDate, $limit = 500)
{
    // 这里替换成你实际的复杂查询逻辑，比如关联统计、多条件过滤等
    return self::query()
        ->select(
            'Products.id',
            'Products.name',
            'Products.price',
            \Illuminate\Support\Facades\DB::raw('SUM(ProductSales.quantity) as total_sales') // 示例统计销量
        )
        ->join('ProductSales', 'Products.id', '=', 'ProductSales.product_id')
        ->where('ProductSales.sale_date', '>=', $startDate)
        ->groupBy('Products.id', 'Products.name', 'Products.price')
        ->orderBy('total_sales', 'desc')
        ->limit($limit)
        ->get();
}

4. 添加缓存逻辑（每日自动更新） #

把高开销的查询结果缓存起来，设置24小时有效期，缓存键包含参数确保唯一性：

public static function getCachedTopProducts($startDate, $limit = 500)
{
    // 生成唯一缓存键，区分不同参数的查询结果
    $cacheKey = sprintf('legacy_top_products_%s_%d', $startDate, $limit);

    // 缓存24小时，到期自动刷新
    return \Illuminate\Support\Facades\Cache::remember($cacheKey, now()->addDay(), function () use ($startDate, $limit) {
        return self::topProducts($startDate, $limit);
    });

    // 如果你需要固定在每天某个时间点刷新（比如凌晨2点），可以替换成：
    // return Cache::rememberUntil($cacheKey, now()->tomorrow()->setTime(2, 0), function () use ($startDate, $limit) {
    //     return self::topProducts($startDate, $limit);
    // });
}

5. 像普通Laravel模型一样使用 #

现在你可以在控制器、服务类里直接调用，返回的是Eloquent集合，支持所有集合方法和模型属性/访问器：

// 示例：获取2024年1月1日以来的前300个热门产品
$topProducts = \App\Models\LegacyProduct::getCachedTopProducts('2024-01-01', 300);

// 遍历处理，和普通模型完全一致
foreach ($topProducts as $product) {
    echo "产品名称：{$product->name}，格式化价格：{$product->formatted_price}，总销量：{$product->total_sales}";
}

// 还可以用集合的链式操作做二次处理
$cheapTopProducts = $topProducts->filter(fn($p) => $p->price < 50)->sortBy('price');

额外实用技巧 #

• 如果需要手动刷新某组参数的缓存，可以调用Cache::forget($cacheKey)，或者写个Artisan命令批量刷新指定缓存。
• 若你的查询逻辑过于复杂，可以把查询逻辑抽成单独的查询类（比如TopProductQuery），保持模型的简洁性。
• 因为是只读库，Eloquent的查询构造器可以放心使用，不用担心意外写入数据。

内容的提问来源于stack exchange，提问作者wivku