数据库配置

我们可以在 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. }