## 连接多个数据库 >[success] Redis 也是同样的配置方法，只是 ::class 不同 通常需求中连接两个数据库有以下两种情况： - 第二个库频繁使用 - 第二个库少量使用 ## 第二个库频繁使用 配置一个新的 ConnectionPool::class 类的 Bean 调用另一个数据库 >[danger] 使用该功能需先阅读 "核心功能 > 依赖注入" 章节 首先在 .env 增加新的数据库使用的连接信息： ~~~ DATABASE_DSN_2='mysql:host=127.0.0.1;port=3306;charset=utf8;dbname=test' DATABASE_USERNAME_2=root DATABASE_PASSWORD_2= ~~~ 然后在 manifest.php 增加名称为 `db2` 的 Connection::class 依赖配置： - 配置中使用了上面配置的新环境变量 ~~~ // Database [ // 名称 'name' => 'db2', // 类路径 'class' => \Mix\Database\Connection::class, // 初始化方法 'initMethod' => 'connect', // 属性注入 'properties' => [ // 数据源格式 'dsn' => getenv('DATABASE_DSN_2'), // 数据库用户名 'username' => getenv('DATABASE_USERNAME_2'), // 数据库密码 'password' => getenv('DATABASE_PASSWORD_2'), // 驱动连接选项: http://php.net/manual/zh/pdo.setattribute.php 'attributes' => [ // 设置默认的提取模式: \PDO::FETCH_OBJ | \PDO::FETCH_ASSOC \PDO::ATTR_DEFAULT_FETCH_MODE => \PDO::FETCH_ASSOC, // 超时 \PDO::ATTR_TIMEOUT => 5, ], // 事件调度器 'eventDispatcher' => ['ref' => \Mix\Event\EventDispatcher::class], ], ], ~~~ 新增一个拨号器 Database2Dialer::class： - 通过依赖名称 `db2` 实例化数据库连接对象 ~~~ <?php namespace App\Common\Dialers; use Mix\Database\Connection; use Mix\Pool\DialerInterface; /** * Class Database2Dialer * @package App\Common\Dialers * @author liu,jian <coder.keda@gmail.com> */ class Database2Dialer implements DialerInterface { /** * 拨号 * @return Connection */ public function dial() { // 创建一个连接并返回 return context()->get('db2'); } } ~~~ 在 manifest.php 增加名称为 `dbPool2` 的 ConnectionPool::class 依赖配置： - 配置中 dialer 属性引用了 Database2Dialer::class 完成拨号 ~~~ // Database连接池 [ // 名称 'name' => 'dbPool2', // 作用域 'scope' => \Mix\Bean\BeanDefinition::SINGLETON, // 类路径 'class' => \Mix\Database\Pool\ConnectionPool::class, // 属性注入 'properties' => [ // 最多可空闲连接数 'maxIdle' => 5, // 最大连接数 'maxActive' => 50, // 拨号器 'dialer' => ['ref' => \App\Common\Dialers\Database2Dialer::class], ], ], // Database连接池拨号 [ // 类路径 'class' => \App\Common\Dialers\Database2Dialer::class, ], ~~~ 业务代码中调用： ~~~ /** @var \Mix\Database\Pool\ConnectionPool $dbPool */ $dbPool = context()->get('dbPool2'); $db = $dbPool->getConnection(); //... $db->release(); // 不手动释放的连接不会归还连接池，会在析构时丢弃 ~~~ ## 第二个库少量使用 通过依赖注入直接实例化另一个数据库的连接 >[danger] 使用该功能需先阅读 "核心功能 > 依赖注入" 章节 首先在 .env 增加新的数据库使用的连接信息： ~~~ DATABASE_DSN_2='mysql:host=127.0.0.1;port=3306;charset=utf8;dbname=test' DATABASE_USERNAME_2=root DATABASE_PASSWORD_2= ~~~ 然后在 manifest.php 增加名称为 `db2` 的 Connection::class 依赖配置： - 配置中使用了上面配置的新环境变量 ~~~ // Database [ // 名称 'name' => 'db2', // 类路径 'class' => \Mix\Database\Connection::class, // 初始化方法 'initMethod' => 'connect', // 属性注入 'properties' => [ // 数据源格式 'dsn' => getenv('DATABASE_DSN_2'), // 数据库用户名 'username' => getenv('DATABASE_USERNAME_2'), // 数据库密码 'password' => getenv('DATABASE_PASSWORD_2'), // 驱动连接选项: http://php.net/manual/zh/pdo.setattribute.php 'attributes' => [ // 设置默认的提取模式: \PDO::FETCH_OBJ | \PDO::FETCH_ASSOC \PDO::ATTR_DEFAULT_FETCH_MODE => \PDO::FETCH_ASSOC, // 超时 \PDO::ATTR_TIMEOUT => 5, ], // 事件调度器 'eventDispatcher' => ['ref' => \Mix\Event\EventDispatcher::class], ], ], ~~~ 业务代码中调用： ~~~ /** @var \Mix\Database\Connection $db */ $db = context()->get('db2'); ~~~