QueryPHP

Appearance

数据库配置 ​

Testing Is Documentation

tests/Database/ManagerTest.php

我们可以在 config/database.php 文件中定义数据库连接。

Uses

php
<?php

use Leevel\Database\ConnectionException;
use Leevel\Kernel\Utils\Api;
use Tests\Database\DatabaseTestCase as TestCase;

基本配置 ​

数据库配置基本定义功能展示。

数据库配置

php
# Tests\Database::createDatabaseManager
protected function createDatabaseManager(?Container $container = null): Manager
{
    if (null === $container) {
        $container = new Container();
    }
    $manager = new Manager($container);

    $this->assertInstanceof(IContainer::class, $manager->container());
    $this->assertInstanceof(Container::class, $manager->container());

    $config = new Config([
        'database' => [
            'default' => 'mysql',
            'connect' => [
                'mysql' => [
                    'driver' => 'mysql',
                    'host' => $GLOBALS['LEEVEL_ENV']['DATABASE']['MYSQL']['HOST'],
                    'port' => $GLOBALS['LEEVEL_ENV']['DATABASE']['MYSQL']['PORT'],
                    'name' => $GLOBALS['LEEVEL_ENV']['DATABASE']['MYSQL']['NAME'],
                    'user' => $GLOBALS['LEEVEL_ENV']['DATABASE']['MYSQL']['USER'],
                    'password' => $GLOBALS['LEEVEL_ENV']['DATABASE']['MYSQL']['PASSWORD'],
                    'charset' => 'utf8',
                    'configs' => [
                        \PDO::ATTR_PERSISTENT => false,
                        \PDO::ATTR_CASE => \PDO::CASE_NATURAL,
                        \PDO::ATTR_ORACLE_NULLS => \PDO::NULL_NATURAL,
                        \PDO::ATTR_STRINGIFY_FETCHES => false,
                        \PDO::ATTR_EMULATE_PREPARES => false,
                        \PDO::ATTR_TIMEOUT => 30,
                    ],
                    'separate' => false,
                    'master' => [],
                    'slave' => [],
                ],
                'password_right' => [
                    'driver' => 'mysql',
                    'password' => $GLOBALS['LEEVEL_ENV']['DATABASE']['MYSQL']['PASSWORD'],
                ],
                'password_not_right' => [
                    'driver' => 'mysql',
                    'password' => 'not right',
                ],
            ],
        ],
        'cache' => [
            'default' => 'file',
            'expire' => 86400,
            'time_preset' => [],
            'connect' => [
                'file' => [
                    'driver' => 'file',
                    'path' => __DIR__.'/databaseCacheManager',
                    'expire' => null,
                ],
                'redis' => [
                    'driver' => 'redis',
                    'host' => $GLOBALS['LEEVEL_ENV']['CACHE']['REDIS']['HOST'],
                    'port' => $GLOBALS['LEEVEL_ENV']['CACHE']['REDIS']['PORT'],
                    'password' => $GLOBALS['LEEVEL_ENV']['CACHE']['REDIS']['PASSWORD'],
                    'select' => 0,
                    'timeout' => 0,
                    'persistent' => false,
                    'expire' => null,
                ],
            ],
        ],
    ]);

    $container->singleton('config', $config);
    $eventDispatch = $this->createMock(IDispatch::class);
    $this->assertNull($eventDispatch->handle('event'));
    $container->singleton(IDispatch::class, $eventDispatch);
    $cacheManager = $this->createCacheManager($container, $config, 'file');
    $container->singleton('caches', $cacheManager);
    $container->singleton('cache', $cacheManager->connect());

    $this->databaseConnects[] = $manager->connect();

    return $manager;
}

请使用这样的格式来定义连接，系统会自动帮你访问数据库。 系统底层实质上会使用 \Leevel\Config\Config 来管理配置信息。

php
public function testBaseUse(): void
{
    $manager = $this->createDatabaseManager();

    $data = ['name' => 'tom', 'content' => 'I love movie.'];

    self::assertSame(
        1,
        $manager
            ->table('guest_book')
            ->insert($data)
    );

    $result = $manager->table('guest_book', 'name,content')
        ->where('id', 1)
        ->findOne()
    ;

    self::assertSame('tom', $result->name);
    self::assertSame('I love movie.', $result->content);
}

数据库主从设置 ​

框架允许用户一个主数据库作为写入、更新以及删除,外加多个附属从数据库作为只读数据库来共同提供数据库服务。 需要系统配置需要开启 separate,主要用于读写分离。 master 为主数据库负责写，slave 为附属从数据库设置负责读。

php
public function testParseDatabaseConfigSeparateIsTrue(): void
{
    $manager = $this->createDatabaseManager();

    $config = [
        'driver' => 'mysql',
        'host' => '127.0.0.1',
        'port' => 3306,
        'name' => 'test',
        'user' => 'root',
        'password' => '123456',
        'charset' => 'utf8',
        'configs' => [
            \PDO::ATTR_PERSISTENT => false,
            \PDO::ATTR_CASE => \PDO::CASE_NATURAL,
            \PDO::ATTR_ORACLE_NULLS => \PDO::NULL_NATURAL,
            \PDO::ATTR_STRINGIFY_FETCHES => false,
            \PDO::ATTR_EMULATE_PREPARES => false,
            \PDO::ATTR_TIMEOUT => 30,
        ],
        'separate' => true,
        'master' => [],
        'slave' => ['host' => '127.0.0.1'],
    ];

    $configNew = $this->invokeTestMethod($manager, 'normalizeDatabaseConfig', [$config]);

    $data = <<<'eot'
        {
            "driver": "mysql",
            "separate": true,
            "master": {
                "host": "127.0.0.1",
                "port": 3306,
                "name": "test",
                "user": "root",
                "password": "123456",
                "charset": "utf8",
                "configs": {
                    "12": false,
                    "8": 0,
                    "11": 0,
                    "17": false,
                    "20": false,
                    "2": 30
                }
            },
            "slave": [
                {
                    "host": "127.0.0.1",
                    "port": 3306,
                    "name": "test",
                    "user": "root",
                    "password": "123456",
                    "charset": "utf8",
                    "configs": {
                        "12": false,
                        "8": 0,
                        "11": 0,
                        "17": false,
                        "20": false,
                        "2": 30
                    }
                }
            ]
        }
        eot;

    self::assertSame(
        $data,
        $this->varJson($configNew)
    );
}

附属从数据库支持二维数组 ​

从数据库支持多个，支持二维数组

php
public function testParseDatabaseConfigSeparateIsTrueWithTwoDimensionalArray(): void
{
    $manager = $this->createDatabaseManager();

    $config = [
        'driver' => 'mysql',
        'host' => '127.0.0.1',
        'port' => 3306,
        'name' => 'test',
        'user' => 'root',
        'password' => '123456',
        'charset' => 'utf8',
        'configs' => [
            \PDO::ATTR_PERSISTENT => false,
            \PDO::ATTR_CASE => \PDO::CASE_NATURAL,
            \PDO::ATTR_ORACLE_NULLS => \PDO::NULL_NATURAL,
            \PDO::ATTR_STRINGIFY_FETCHES => false,
            \PDO::ATTR_EMULATE_PREPARES => false,
            \PDO::ATTR_TIMEOUT => 30,
        ],
        'separate' => true,
        'master' => [],
        'slave' => [
            ['host' => '127.0.0.1'],
            ['password' => '123456'],
        ],
    ];

    $configNew = $this->invokeTestMethod($manager, 'normalizeDatabaseConfig', [$config]);

    $data = <<<'eot'
        {
            "driver": "mysql",
            "separate": true,
            "master": {
                "host": "127.0.0.1",
                "port": 3306,
                "name": "test",
                "user": "root",
                "password": "123456",
                "charset": "utf8",
                "configs": {
                    "12": false,
                    "8": 0,
                    "11": 0,
                    "17": false,
                    "20": false,
                    "2": 30
                }
            },
            "slave": [
                {
                    "host": "127.0.0.1",
                    "port": 3306,
                    "name": "test",
                    "user": "root",
                    "password": "123456",
                    "charset": "utf8",
                    "configs": {
                        "12": false,
                        "8": 0,
                        "11": 0,
                        "17": false,
                        "20": false,
                        "2": 30
                    }
                },
                {
                    "password": "123456",
                    "host": "127.0.0.1",
                    "port": 3306,
                    "name": "test",
                    "user": "root",
                    "charset": "utf8",
                    "configs": {
                        "12": false,
                        "8": 0,
                        "11": 0,
                        "17": false,
                        "20": false,
                        "2": 30
                    }
                }
            ]
        }
        eot;

    self::assertSame(
        $data,
        $this->varJson($configNew)
    );
}

数据库设置只支持数组 ​

数据库主从连接只支持数组。

php
public function testParseDatabaseConfigMasterAndSlaveMustBeAnArray(): void
{
    $this->expectException(\InvalidArgumentException::class);
    $this->expectExceptionMessage(
        'Database config `slave` must be an array.'
    );

    $manager = $this->createDatabaseManager();

    $config = [
        'driver' => 'mysql',
        'host' => '127.0.0.1',
        'port' => 3306,
        'name' => 'test',
        'user' => 'root',
        'password' => '123456',
        'charset' => 'utf8',
        'configs' => [
            \PDO::ATTR_PERSISTENT => false,
            \PDO::ATTR_CASE => \PDO::CASE_NATURAL,
            \PDO::ATTR_ORACLE_NULLS => \PDO::NULL_NATURAL,
            \PDO::ATTR_STRINGIFY_FETCHES => false,
            \PDO::ATTR_EMULATE_PREPARES => false,
            \PDO::ATTR_TIMEOUT => 30,
        ],
        'separate' => false,
        'master' => [],
        'slave' => 'notarray',
    ];

    $this->invokeTestMethod($manager, 'normalizeDatabaseConfig', [$config]);
}

MIT Licensed | Copyright © 2010-present Xiangmin Liu