How to use Hyperf framework for cross-database query

How to use the Hyperf framework for cross-database query

Introduction:
With the development of applications, we often need to query between multiple databases. For example, in an e-commerce application, we may need to query product information (stored in one database) and user information (stored in another database). When developing applications using the Hyperf framework, cross-database queries can also be easily implemented.

This article will introduce how to use the Hyperf framework to perform cross-database queries and provide specific code examples.

1. Configure multiple database connections
First, we need to configure multiple database connections in the configuration file of the Hyperf framework (config/autoload/database.php). For example, we configured two connections: "database1" and "database2", corresponding to two databases.

return [
    'default' => env('DB_DRIVER', 'mysql'),
    'connections' => [
        'database1' => [
            'driver' => env('DB_DRIVER', 'mysql'),
            'host' => env('DB_HOST', 'localhost'),
            'port' => env('DB_PORT', 3306),
            'database' => env('DB_DATABASE1', 'database1'),
            'username' => env('DB_USERNAME', 'root'),
            'password' => env('DB_PASSWORD', ''),
            'charset' => 'utf8mb4',
            'collation' => 'utf8mb4_general_ci',
            'prefix' => '',
            'pool' => [
                'min_connections' => 1,
                'max_connections' => 10,
                'connect_timeout' => 10.0,
                'wait_timeout' => 3.0,
                'heartbeat' => -1,
                'max_idle_time' => (float)env('DB_MAX_IDLE_TIME', 60),
            ],
            'options' => [
                // ...
            ],
        ],
        'database2' => [
            'driver' => env('DB_DRIVER', 'mysql'),
            'host' => env('DB_HOST', 'localhost'),
            'port' => env('DB_PORT', 3306),
            'database' => env('DB_DATABASE2', 'database2'),
            'username' => env('DB_USERNAME', 'root'),
            'password' => env('DB_PASSWORD', ''),
            'charset' => 'utf8mb4',
            'collation' => 'utf8mb4_general_ci',
            'prefix' => '',
            'pool' => [
                'min_connections' => 1,
                'max_connections' => 10,
                'connect_timeout' => 10.0,
                'wait_timeout' => 3.0,
                'heartbeat' => -1,
                'max_idle_time' => (float)env('DB_MAX_IDLE_TIME', 60),
            ],
            'options' => [
                // ...
            ],
        ],
    ],
];

2. Configure the model-associated database connection
In the Hyperf framework, we can specify the model-associated database connection by setting the model's properties. For example, we have a product model Product, which is associated with the database connection "database1":

namespace AppModel;

use HyperfDatabaseModelModel;

class Product extends Model
{
    protected $connection = 'database1';
    
    // ...
}

Similarly, in the user model User, we set it to be associated with the database connection "database2":

namespace AppModel;

use HyperfDatabaseModelModel;

class User extends Model
{
    protected $connection = 'database2';
    
    // ...
}

3. Perform cross-database query
With the above preparations, we can perform cross-database query in the controller or other places. An example is given below to demonstrate how to query data in the product table and user table.

namespace AppController;

use AppModelProduct;
use AppModelUser;
use HyperfHttpServerAnnotationController;
use HyperfHttpServerAnnotationGetMapping;

/**
 * @Controller()
 */
class CrossDatabaseController
{
    /**
     * @GetMapping(path="/cross-database")
     */
    public function crossDatabase()
    {
        // 查询商品信息
        $product = Product::query()->where('id', 1)->first();
        echo "商品名称：" . $product->name . "
";
        
        // 查询用户信息
        $user = User::query()->where('id', 1)->first();
        echo "用户名：" . $user->name . "
";
    }
}

In the above example, we queried different databases through the Product model and User model respectively, realizing cross-database query.

Conclusion:
This article introduces how to use the Hyperf framework to perform cross-database queries. By configuring multiple database connections and setting up model-associated database connections, we can easily implement cross-database query functions. Mastering this skill, we can better handle data associations and queries between multiple libraries in the application, and improve development efficiency.

The above is the detailed content of How to use Hyperf framework for cross-database query. For more information, please follow other related articles on the PHP Chinese website!