数据库配置

Testing Is Documentation

tests/Database/ManagerTest.php数据库配置 - 图1

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

Uses

  1. <?php
  3. use PDO;
  4. use Tests\Database\DatabaseTestCase as TestCase;

基本配置

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

数据库配置

  1. # Tests\Database::createDatabaseManager
  2. protected function createDatabaseManager(): Manager
  3. {
  4.     $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.                         PDO::ATTR_CASE              => PDO::CASE_NATURAL,
  25.                         PDO::ATTR_ORACLE_NULLS      => PDO::NULL_NATURAL,
  26.                         PDO::ATTR_STRINGIFY_FETCHES => false,
  27.                         PDO::ATTR_EMULATE_PREPARES  => false,
  28.                         PDO::ATTR_TIMEOUT           => 30,
  29.                     ],
  30.                     'separate'           => false,
  31.                     'distributed'        => false,
  32.                     'master'             => [],
  33.                     'slave'              => [],
  34.                 ],
  35.                 'password_right' => [
  36.                     'driver'   => 'mysql',
  37.                     'password' => $GLOBALS['LEEVEL_ENV']['DATABASE']['MYSQL']['PASSWORD'],
  38.                 ],
  39.                 'password_not_right' => [
  40.                     'driver'   => 'mysql',
  41.                     'password' => 'not right',
  42.                 ],
  43.             ],
  44.         ],
  45.         'cache' => [
  46.             'default'     => 'file',
  47.             'expire'      => 86400,
  48.             'time_preset' => [],
  49.             'connect'     => [
  50.                 'file' => [
  51.                     'driver'    => 'file',
  52.                     'path'      => __DIR__.'/databaseCacheManager',
  53.                     'expire'    => null,
  54.                 ],
  55.                 'redis' => [
  56.                     'driver'     => 'redis',
  57.                     'host'       => $GLOBALS['LEEVEL_ENV']['CACHE']['REDIS']['HOST'],
  58.                     'port'       => $GLOBALS['LEEVEL_ENV']['CACHE']['REDIS']['PORT'],
  59.                     'password'   => $GLOBALS['LEEVEL_ENV']['CACHE']['REDIS']['PASSWORD'],
  60.                     'select'     => 0,
  61.                     'timeout'    => 0,
  62.                     'persistent' => false,
  63.                     'expire'     => null,
  64.                 ],
  65.             ],
  66.         ],
  67.     ]);
  69.     $container->singleton('option', $option);
  70.     $eventDispatch = $this->createMock(IDispatch::class);
  71.     $this->assertNull($eventDispatch->handle('event'));
  72.     $container->singleton(IDispatch::class, $eventDispatch);
  73.     $cache = $this->createCacheManager($container, $option, 'file');
  74.     $container->singleton('caches', $cache);
  76.     $this->databaseConnects[] = $manager->connect();
  78.     return $manager;
  79. }

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

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

数据库主从设置

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

  1. public function testParseDatabaseOptionDistributedIsTrue(): void
  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.             PDO::ATTR_CASE              => PDO::CASE_NATURAL,
  16.             PDO::ATTR_ORACLE_NULLS      => PDO::NULL_NATURAL,
  17.             PDO::ATTR_STRINGIFY_FETCHES => false,
  18.             PDO::ATTR_EMULATE_PREPARES  => false,
  19.             PDO::ATTR_TIMEOUT           => 30,
  20.         ],
  21.         'separate'           => false,
  22.         'distributed'        => true,
  23.         'master'             => [],
  24.         'slave'              => ['host' => '127.0.0.1'],
  25.     ];
  27.     $optionNew = $this->invokeTestMethod($manager, 'normalizeDatabaseOption', [$option]);
  29.     $data = <<<'eot'
  30.         {
  31.             "driver": "mysql",
  32.             "separate": false,
  33.             "distributed": true,
  34.             "master": {
  35.                 "host": "127.0.0.1",
  36.                 "port": 3306,
  37.                 "name": "test",
  38.                 "user": "root",
  39.                 "password": "123456",
  40.                 "charset": "utf8",
  41.                 "options": {
  42.                     "12": false,
  43.                     "8": 0,
  44.                     "11": 0,
  45.                     "17": false,
  46.                     "20": false,
  47.                     "2": 30
  48.                 }
  49.             },
  50.             "slave": [
  51.                 {
  52.                     "host": "127.0.0.1",
  53.                     "port": 3306,
  54.                     "name": "test",
  55.                     "user": "root",
  56.                     "password": "123456",
  57.                     "charset": "utf8",
  58.                     "options": {
  59.                         "12": false,
  60.                         "8": 0,
  61.                         "11": 0,
  62.                         "17": false,
  63.                         "20": false,
  64.                         "2": 30
  65.                     }
  66.                 }
  67.             ]
  68.         }
  69.         eot;
  71.     $this->assertSame(
  72.         $data,
  73.         $this->varJson($optionNew)
  74.     );
  75. }

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

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

  1. public function testParseDatabaseOptionDistributedIsTrueWithTwoDimensionalArray(): void
  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.             PDO::ATTR_CASE              => PDO::CASE_NATURAL,
  16.             PDO::ATTR_ORACLE_NULLS      => PDO::NULL_NATURAL,
  17.             PDO::ATTR_STRINGIFY_FETCHES => false,
  18.             PDO::ATTR_EMULATE_PREPARES  => false,
  19.             PDO::ATTR_TIMEOUT           => 30,
  20.         ],
  21.         'separate'           => false,
  22.         'distributed'        => true,
  23.         'master'             => [],
  24.         'slave'              => [
  25.             ['host' => '127.0.0.1'],
  26.             ['password' => '123456'],
  27.         ],
  28.     ];
  30.     $optionNew = $this->invokeTestMethod($manager, 'normalizeDatabaseOption', [$option]);
  32.     $data = <<<'eot'
  33.         {
  34.             "driver": "mysql",
  35.             "separate": false,
  36.             "distributed": true,
  37.             "master": {
  38.                 "host": "127.0.0.1",
  39.                 "port": 3306,
  40.                 "name": "test",
  41.                 "user": "root",
  42.                 "password": "123456",
  43.                 "charset": "utf8",
  44.                 "options": {
  45.                     "12": false,
  46.                     "8": 0,
  47.                     "11": 0,
  48.                     "17": false,
  49.                     "20": false,
  50.                     "2": 30
  51.                 }
  52.             },
  53.             "slave": [
  54.                 {
  55.                     "host": "127.0.0.1",
  56.                     "port": 3306,
  57.                     "name": "test",
  58.                     "user": "root",
  59.                     "password": "123456",
  60.                     "charset": "utf8",
  61.                     "options": {
  62.                         "12": false,
  63.                         "8": 0,
  64.                         "11": 0,
  65.                         "17": false,
  66.                         "20": false,
  67.                         "2": 30
  68.                     }
  69.                 },
  70.                 {
  71.                     "password": "123456",
  72.                     "host": "127.0.0.1",
  73.                     "port": 3306,
  74.                     "name": "test",
  75.                     "user": "root",
  76.                     "charset": "utf8",
  77.                     "options": {
  78.                         "12": false,
  79.                         "8": 0,
  80.                         "11": 0,
  81.                         "17": false,
  82.                         "20": false,
  83.                         "2": 30
  84.                     }
  85.                 }
  86.             ]
  87.         }
  88.         eot;
  90.     $this->assertSame(
  91.         $data,
  92.         $this->varJson($optionNew)
  93.     );
  94. }

数据库设置只支持数组

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

  1. public function testParseDatabaseOptionMasterAndSlaveMustBeAnArray(): void
  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.             PDO::ATTR_CASE              => PDO::CASE_NATURAL,
  21.             PDO::ATTR_ORACLE_NULLS      => PDO::NULL_NATURAL,
  22.             PDO::ATTR_STRINGIFY_FETCHES => false,
  23.             PDO::ATTR_EMULATE_PREPARES  => false,
  24.             PDO::ATTR_TIMEOUT           => 30,
  25.         ],
  26.         'separate'           => false,
  27.         'distributed'        => true,
  28.         'master'             => [],
  29.         'slave'              => 'notarray',
  30.     ];
  32.     $this->invokeTestMethod($manager, 'normalizeDatabaseOption', [$option]);
  33. }