TP3实现多数据库连接的方法 (tp3如何连接多个数据库)
在传统的Web开发中，一个Web应用通常只使用一个数据库。然而，在一些高性能、高并发、大规模数据存储的场景下，一个数据库往往难以满足需求，需要使用多个数据库来共同完成任务。比如，在电商平台中，一个数据库可能存储用户信息和订单信息，而另一个数据库存储商品信息和库存信息。这样可以有效地降低单个数据库的负载，提高整个系统的性能和可靠性。
在使用PHP框架ThinkPHP3搭建Web应用时，如何实现多数据库连接呢？本文将介绍两种方法：配置文件方式和运行时动态连接方式。
方法一：配置文件方式
ThinkPHP3提供了一个在配置文件中添加多个数据库连接参数的方法。在database.php配置文件中添加如下代码：
“`
return array(
‘DB_TYPE’ => ‘mysql’, // 数据库类型
‘DB_HOST’ => ‘localhost’, // 服务器地址
‘DB_NAME’ => ‘thinkphp’, // 数据库名
‘DB_USER’ => ‘root’, // 用户名
‘DB_PWD’ => ”, // 密码
‘DB_PORT’ => ‘3306’, // 端口
‘DB_PREFIX’ => ‘think_’, // 数据库表前缀
‘DB_CHARSET’=> ‘utf8’, // 数据库编码
‘DB_DEBUG’ => true, // 数据库调试模式 开启后可以记录SQL日志
‘DB_FIELDS_CACHE’=>true, // 启用字段缓存
‘DB_PARAMS’ => array(), // 数据库连接参数
‘DB_DEPLOY_TYPE’=> 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
‘DB_RW_SEPARATE’=>true, // 数据库读写是否分离 主从式有效
‘DB_MASTER_NUM’=>1, // 读写分离后 主服务器数量
‘DB_SLAVE_NO’=>” // 指定从服务器序号
);
return array(
‘DB_TYPE’ => ‘mysql’, // 数据库类型
‘DB_HOST’ => ‘localhost’, // 服务器地址
‘DB_NAME’ => ‘secondDB’, // 数据库名
‘DB_USER’ => ‘root’, // 用户名
‘DB_PWD’ => ”, // 密码
‘DB_PORT’ => ‘3306’, // 端口
‘DB_PREFIX’ => ‘tp_’, // 数据库表前缀
‘DB_CHARSET’=> ‘utf8’, // 数据库编码
‘DB_DEBUG’ => true, // 数据库调试模式 开启后可以记录SQL日志
‘DB_FIELDS_CACHE’=>true, // 启用字段缓存
‘DB_PARAMS’ => array(), // 数据库连接参数
‘DB_DEPLOY_TYPE’=> 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
‘DB_RW_SEPARATE’=>true, // 数据库读写是否分离 主从式有效
‘DB_MASTER_NUM’=>1, // 读写分离后 主服务器数量
‘DB_SLAVE_NO’=>” // 指定从服务器序号
);
“`
在这个例子中，我们配置了两个数据库连接，分别为名为thinkphp的数据库和名为secondDB的数据库。具体的参数配置可以根据自己的需求进行调整。
接下来，在Model中使用指定的数据库，在Model类的构造函数中调用parent::__construct($name, $tablePrefix, $connection)，其中$name为数据库连接的名称，$tablePrefix为表前缀，$connection为连接时间。代码如下：
“`
class UserModel extends \Think\Model {
protected $connection = array(
‘DB_TYPE’ => ‘mysql’, // 数据库类型
‘DB_HOST’ => ‘localhost’, // 服务器地址
‘DB_NAME’ => ‘thinkphp’, // 数据库名
‘DB_USER’ => ‘root’, // 用户名
‘DB_PWD’ => ”, // 密码
‘DB_PORT’ => ‘3306’, // 端口
‘DB_PREFIX’ => ‘think_’, // 数据库表前缀
‘DB_CHARSET’=> ‘utf8’, // 数据库编码
‘DB_DEBUG’ => true, // 数据库调试模式 开启后可以记录SQL日志
‘DB_FIELDS_CACHE’=>true, // 启用字段缓存
‘DB_PARAMS’ => array(), // 数据库连接参数
‘DB_DEPLOY_TYPE’=> 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器)
‘DB_RW_SEPARATE’=>true, // 数据库读写是否分离 主从式有效
‘DB_MASTER_NUM’=>1, // 读写分离后 主服务器数量
‘DB_SLAVE_NO’=>” // 指定从服务器序号
);
}
“`
在这个例子中，我们通过在Model中定义$connection属性，指定了使用数据库名为thinkphp的数据库。如果想要使用secondDB数据库，只需要修改$connection属性中的DB_NAME参数即可。
使用配置文件的方式可以方便地管理多个数据库连接，但是有时候需要在运行时动态地切换数据库连接，这时候就需要使用方法二。
方法二：运行时动态连接方式
在有些场合下，我们需要在运行时动态地切换数据库连接，比如在多个租户共用一个系统的情况下，每个租户对应一个独立的数据库。这时候，我们可以使用ThinkPHP3提供的setConfig和getConfig方法来实现动态连接。
setConfig方法可以设置数据库连接参数，getConfig方法可以获取当前的数据库连接参数。
下面是一个使用示例：
“`
class UserController extends \Think\Controller {
public function index() {
// 获取请求参数中的租户标识
$tenant = I(‘get.tenant’);
// 根据租户标识获取对应的数据库连接参数
$config = $this->getConfigByTenant($tenant);
// 切换到对应的数据库连接
C(‘DB_CONFIG’, $config);
// 实例化Model，并使用对应的数据库连接
$user = new UserModel();
$list = $user->select();
$this->assign(‘list’, $list);
$this->display();
}
private function getConfigByTenant($tenant) {
// 根据租户标识获取对应的数据库连接参数
// 这里只是伪代码，实际情况可以根据业务需求进行调整
switch ($tenant) {
case ‘user1’:
return array(
‘DB_TYPE’ => ‘mysql’,
‘DB_HOST’ => ‘localhost’,
‘DB_NAME’ => ‘user1’,
‘DB_USER’ => ‘root’,
‘DB_PWD’ => ”,
‘DB_PORT’ => ‘3306’,
‘DB_PREFIX’ => ”,
‘DB_CHARSET’=> ‘utf8’,
‘DB_DEBUG’ => true,
‘DB_FIELDS_CACHE’=>true,
‘DB_PARAMS’ => array(),
‘DB_DEPLOY_TYPE’=> 1,
‘DB_RW_SEPARATE’=>true,
‘DB_MASTER_NUM’=>1,
‘DB_SLAVE_NO’=>”
);
case ‘user2’:
return array(
‘DB_TYPE’ => ‘mysql’,
‘DB_HOST’ => ‘localhost’,
‘DB_NAME’ => ‘user2’,
‘DB_USER’ => ‘root’,
‘DB_PWD’ => ”,
‘DB_PORT’ => ‘3306’,
‘DB_PREFIX’ => ”,
‘DB_CHARSET’=> ‘utf8’,
‘DB_DEBUG’ => true,
‘DB_FIELDS_CACHE’=>true,
‘DB_PARAMS’ => array(),
‘DB_DEPLOY_TYPE’=> 1,
‘DB_RW_SEPARATE’=>true,
‘DB_MASTER_NUM’=>1,
‘DB_SLAVE_NO’=>”
);
// …
}
}
}
“`
在这个例子中，我们首先获取请求参数中的租户标识，然后根据标识获取对应的数据库连接参数。然后使用C(‘DB_CONFIG’, $config)方法切换到对应的数据库连接。最后实例化Model，并使用对应的数据库连接。
需要注意的是，这种方式切换数据库连接只作用于当前请求，不会影响到其他请求。
本文介绍了在ThinkPHP3中实现多个数据库连接的方法。通过配置文件方式和运行时动态连接方式，可以方便地管理多个数据库连接，实现灵活切换。在实际应用中，可以根据业务需求和性能要求选择合适的方式。
