数据库

框架模式使用 medoo 框架，提供最简便的操作。如果想使用 ORM 的朋友可以尝试添加 ServiceProvider，作为框架的一个扩充。

3.1 版本开始，一维数组结构改为二维数组配置. 数据库操作方面会考虑将 medoo 改为可选扩展，并且会考虑使用其他数据库操作进行替换。ORM 是不会内置到框架中，可能会使用一个扩展进行补充。

基础 medoo 使用

ORM 框架

数据库配置: 

  1. <?php
  2. return [
  3.     'default' => [
  4.         'adapter' => 'mysql',
  5.         'name' => 'ci',
  6.         'host' => '127.0.0.1',
  7.         'user' => 'travis',
  8.         'pass' => '',
  9.         'charset' => 'utf8',
  10.         'port' => 3306,
  11.     ]
  12. ];

框架提供辅助函数: database(), 函数返回一个 Medoo\Medoo 对象。提供最原始的操作，详细 Medoo 操作文档: Medoo Doc.

数据库模型

框架提供简单的数据库模型，暂时不提供 ORM 等复杂操作，因为本身定位不在此处，如果想要使用 ORM 等操作，可以通过自定义 服务提供器 来扩展。

模型没有强制要求继承 FastD\Model\Model，但是在每个模型初始化的时候，会默认在构造方法中注入 medoo 对象，分配在 db 属性当中。

  1. $model = model('demo');

模型放置在 Model 目录中，如果没有该目录，需要通过手动创建目录，通过使用 model 方法的时候，会自动将命名空间拼接到模型名之前，并且模型名不需要带上 Model 字样，如: model('demo'') 等于 new Model\DemoModel。

数据表结构

从 3.1 版本开始支持构建简单的数据表模型，通过简单命令构建基础的数据表模型。

  1. $ php bin/console seed:create Hello

文件构建在 database 目录下，名字自动构建如下: 

  1. <?php
  3. use FastD\Model\Migration;
  4. use Phinx\Db\Table;
  6. class Hello extends Migration
  7. {
  8.     /**
  9.      * Set up database table schema
  10.      */
  11.     public function setUp()
  12.     {
  13.         // create table
  14.         $table = $this->table('demo');
  15.         $table->addColumn('user_id', 'integer')
  16.             ->addColumn('created', 'datetime')
  17.             ->create();
  18.     }
  20.     public function dataSet(Table $table) {
  22.     }
  23. }

通过实现 setUp 方法，添加数据库结构，方便表结构迁移。

编写完成初步的表结构，运行命令: 

  1. $ php bin/console seed:run

自动构建数据表，但是需要先手动创建数据库。具体操作可参考: phinx

连接池

当实现 Swoole 服务的时候，数据库会启动一个连接池，在 onWorkerStart 启动时候连接数据库，并且在操作时候，检查连接是否断开，实现断线重连机制，断线重连注意事项: MySQL断线重连

实现原理:

框架提供 PoolInterface 接口类，实现 initPool 方法。

  1. <?php
  3. namespace FastD\Pool;
  5. use FastD\Model\Database;
  7. /**
  8.  * Class DatabasePool.
  9.  */
  10. class DatabasePool implements PoolInterface
  11. {
  12.     /**
  13.      * @var Database[]
  14.      */
  15.     protected $connections = [];
  17.     /**
  18.      * @var array
  19.      */
  20.     protected $config;
  22.     /**
  23.      * Database constructor.
  24.      *
  25.      * @param array $config
  26.      */
  27.     public function __construct(array $config)
  28.     {
  29.         $this->config = $config;
  30.     }
  32.     /**
  33.      * @param $key
  34.      *
  35.      * @return Database
  36.      */
  37.     public function getConnection($key)
  38.     {
  39.         if (!isset($this->connections[$key])) {
  40.             if (!isset($this->config[$key])) {
  41.                 throw new \LogicException(sprintf('No set %s database', $key));
  42.             }
  43.             $config = $this->config[$key];
  44.             $this->connections[$key] = new Database(
  45.                 [
  46.                     'database_type' => isset($config['adapter']) ? $config['adapter'] : 'mysql',
  47.                     'database_name' => $config['name'],
  48.                     'server' => $config['host'],
  49.                     'username' => $config['user'],
  50.                     'password' => $config['pass'],
  51.                     'charset' => isset($config['charset']) ? $config['charset'] : 'utf8',
  52.                     'port' => isset($config['port']) ? $config['port'] : 3306,
  53.                     'prefix' => isset($config['prefix']) ? $config['prefix'] : '',
  54.                 ]
  55.             );
  56.         }
  58.         return $this->connections[$key];
  59.     }
  61.     /**
  62.      * {@inheritdoc}
  63.      */
  64.     public function initPool()
  65.     {
  66.         foreach ($this->config as $name => $config) {
  67.             $this->getConnection($name);
  68.         }
  69.     }
  70. }
  1. <?php
  2. // ...
  3. public function onWorkerStart()
  4. {
  5.     foreach (app() as $service) {
  6.         if ($service instanceof FastD\Pool\PoolInterface) {
  7.             $service->initPool();
  8.         }
  9.     }
  10. }
  11. // ...

下一节: 缓存