• 数据库配置
    • 基本配置
    • 数据库主从设置
    • 附属从数据库支持二维数组
    • 数据库设置只支持数组

    数据库配置

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

    引入相关类

    • use PDO;
    • use Tests\Database\DatabaseTestCase as TestCase;

      基本配置

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

    数据库配置

    1. protected function createDatabaseManager(): Manager
    2. {
    3.     $container = new Container();
    5.     $manager = new Manager($container);
    7.     $this->assertInstanceof(IContainer::class, $manager->container());
    8.     $this->assertInstanceof(Container::class, $manager->container());
    10.     $option = new Option([
    11.         'database' => [
    12.             'default' => 'mysql',
    13.             'connect' => [
    14.                 'mysql' => [
    15.                     'driver'   => 'mysql',
    16.                     'host'     => $GLOBALS['LEEVEL_ENV']['DATABASE']['MYSQL']['HOST'],
    17.                     'port'     => $GLOBALS['LEEVEL_ENV']['DATABASE']['MYSQL']['PORT'],
    18.                     'name'     => $GLOBALS['LEEVEL_ENV']['DATABASE']['MYSQL']['NAME'],
    19.                     'user'     => $GLOBALS['LEEVEL_ENV']['DATABASE']['MYSQL']['USER'],
    20.                     'password' => $GLOBALS['LEEVEL_ENV']['DATABASE']['MYSQL']['PASSWORD'],
    21.                     'charset'  => 'utf8',
    22.                     'options'  => [
    23.                         PDO::ATTR_PERSISTENT => false,
    24.                     ],
    25.                     'separate'           => false,
    26.                     'distributed'        => false,
    27.                     'master'             => [],
    28.                     'slave'              => [],
    29.                 ],
    30.             ],
    31.         ],
    32.     ]);
    34.     $container->singleton('option', $option);
    36.     $eventDispatch = $this->createMock(IDispatch::class);
    38.     $eventDispatch->method('handle')->willReturn(null);
    39.     $this->assertNull($eventDispatch->handle('event'));
    41.     $container->singleton(IDispatch::class, $eventDispatch);
    43.     return $manager;
    44. }

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

    1. public function testBaseUse()
    2. {
    3.     $manager = $this->createDatabaseManager();
    5.     $data = ['name' => 'tom', 'content' => 'I love movie.'];
    7.     $this->assertSame('1',
    8.         $manager
    9.             ->table('guest_book')
    10.             ->insert($data)
    11.     );
    13.     $result = $manager->table('guest_book', 'name,content')
    14.         ->where('id', 1)
    15.         ->findOne();
    17.     $this->assertSame('tom', $result->name);
    18.     $this->assertSame('I love movie.', $result->content);
    19. }

    数据库主从设置

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

    1. public function testParseDatabaseOptionDistributedIsTrue()
    2. {
    3.     $manager = $this->createDatabaseManager();
    5.     $option = [
    6.         'driver'   => 'mysql',
    7.         'host'     => '127.0.0.1',
    8.         'port'     => 3306,
    9.         'name'     => 'test',
    10.         'user'     => 'root',
    11.         'password' => '123456',
    12.         'charset'  => 'utf8',
    13.         'options'  => [
    14.             PDO::ATTR_PERSISTENT => false,
    15.         ],
    16.         'separate'           => false,
    17.         'distributed'        => true,
    18.         'master'             => [],
    19.         'slave'              => ['host' => '127.0.0.1'],
    20.     ];
    22.     $optionNew = $this->invokeTestMethod($manager, 'parseDatabaseOption', [$option]);
    24.     $data = <<<'eot'
    25.         {
    26.             "driver": "mysql",
    27.             "separate": false,
    28.             "distributed": true,
    29.             "master": {
    30.                 "host": "127.0.0.1",
    31.                 "port": 3306,
    32.                 "name": "test",
    33.                 "user": "root",
    34.                 "password": "123456",
    35.                 "charset": "utf8",
    36.                 "options": {
    37.                     "12": false
    38.                 }
    39.             },
    40.             "slave": [
    41.                 {
    42.                     "host": "127.0.0.1",
    43.                     "port": 3306,
    44.                     "name": "test",
    45.                     "user": "root",
    46.                     "password": "123456",
    47.                     "charset": "utf8",
    48.                     "options": {
    49.                         "12": false
    50.                     }
    51.                 }
    52.             ]
    53.         }
    54.         eot;
    56.     $this->assertSame(
    57.         $data,
    58.         $this->varJson($optionNew)
    59.     );
    60. }

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

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

    1. public function testParseDatabaseOptionDistributedIsTrueWithTwoDimensionalArray()
    2. {
    3.     $manager = $this->createDatabaseManager();
    5.     $option = [
    6.         'driver'   => 'mysql',
    7.         'host'     => '127.0.0.1',
    8.         'port'     => 3306,
    9.         'name'     => 'test',
    10.         'user'     => 'root',
    11.         'password' => '123456',
    12.         'charset'  => 'utf8',
    13.         'options'  => [
    14.             PDO::ATTR_PERSISTENT => false,
    15.         ],
    16.         'separate'           => false,
    17.         'distributed'        => true,
    18.         'master'             => [],
    19.         'slave'              => [
    20.             ['host' => '127.0.0.1'],
    21.             ['password' => '123456'],
    22.         ],
    23.     ];
    25.     $optionNew = $this->invokeTestMethod($manager, 'parseDatabaseOption', [$option]);
    27.     $data = <<<'eot'
    28.         {
    29.             "driver": "mysql",
    30.             "separate": false,
    31.             "distributed": true,
    32.             "master": {
    33.                 "host": "127.0.0.1",
    34.                 "port": 3306,
    35.                 "name": "test",
    36.                 "user": "root",
    37.                 "password": "123456",
    38.                 "charset": "utf8",
    39.                 "options": {
    40.                     "12": false
    41.                 }
    42.             },
    43.             "slave": [
    44.                 {
    45.                     "host": "127.0.0.1",
    46.                     "port": 3306,
    47.                     "name": "test",
    48.                     "user": "root",
    49.                     "password": "123456",
    50.                     "charset": "utf8",
    51.                     "options": {
    52.                         "12": false
    53.                     }
    54.                 },
    55.                 {
    56.                     "password": "123456",
    57.                     "host": "127.0.0.1",
    58.                     "port": 3306,
    59.                     "name": "test",
    60.                     "user": "root",
    61.                     "charset": "utf8",
    62.                     "options": {
    63.                         "12": false
    64.                     }
    65.                 }
    66.             ]
    67.         }
    68.         eot;
    70.     $this->assertSame(
    71.         $data,
    72.         $this->varJson($optionNew)
    73.     );
    74. }

    数据库设置只支持数组

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

    1. public function testParseDatabaseOptionMasterAndSlaveMustBeAnArray()
    2. {
    3.     $this->expectException(\InvalidArgumentException::class);
    4.     $this->expectExceptionMessage(
    5.         'Database option `slave` must be an array.'
    6.     );
    8.     $manager = $this->createDatabaseManager();
    10.     $option = [
    11.         'driver'   => 'mysql',
    12.         'host'     => '127.0.0.1',
    13.         'port'     => 3306,
    14.         'name'     => 'test',
    15.         'user'     => 'root',
    16.         'password' => '123456',
    17.         'charset'  => 'utf8',
    18.         'options'  => [
    19.             PDO::ATTR_PERSISTENT => false,
    20.         ],
    21.         'separate'           => false,
    22.         'distributed'        => true,
    23.         'master'             => [],
    24.         'slave'              => 'notarray',
    25.     ];
    27.     $this->invokeTestMethod($manager, 'parseDatabaseOption', [$option]);
    28. }