Thinkphp 连接多个数据库

红太狼 2022-03-01 11:20 365阅读 0赞

今天开发项目的时候发现需要跨库做数据查询，所以查了连接过多个数据库的方法，现在分享出来给大家看一下：

## 第一种方法：**模型实例化指定连接** ##

查询的时候发现，使用M方法直接连接也可以如下：

新版支持在实例化模型的时候指定数据库连接,例如:

$User = new Model('User','think\_','mysql://root:1234@localhost/thinkphp');

或者使用M方法实例化：

$User = M('User','think\_','mysql://root:1234@localhost/thinkphp');

同样的道理,在实例化中传入的数据库连接信息也可以采用配置名称的方式,例如：

$User = M('User','think\_','DB\_CONFIG2');

M方法的第二个参数是数据表的前缀,如果留空表示采用项目配置的数据表前缀,第三个参数则是当前实例化需要的数据库连接信息。

PS：该方法使用的时候发现会影响接下来数据库的查询，也即接下来的M方法的连接也会受到上面方法的影响，解决的方法也很简单，重新对接下来第一个使用的M方法做连接即可恢复；该方法影响比较大，建议不是使用。

# 第二种方法：**动态切换连接** #

[系统][Link 1]还提供了更灵活的动态操作,可以使用模型类提供的db方法进行多数据库连接和切换操作，用法：

Model->db("数据库编号","数据库配置");

数据库编号用数字格式,对于已经调用过的数据库连接,是不需要再传入数据库连接信息的,系统会自动记录,对于初始化的数据库连接,内部的数据库编号是0,因此为了避免冲突,请不要再次定义数据库编号为0的数据库配置。

数据库配置的定义方式和模型定义connection属性一样,支持数组、字符串以及调用配置参数三种格式。

Db方法调用后返回当前的模型实例,直接可以继续进行模型的其他操作,所以该方法可以在查询的过程中动态切换,例如：

$this->db(1,"mysql://root:123456@localhost:3306/test")->query("查询SQL");

该方法添加了一个编号为1的数据库连接,并自动切换到当前的数据库连接。

当第二次切换到相同的数据库的时候,就不需要传入数据库连接信息了,可以直接使用：

$this->db(1)->query("查询SQL");

在没有再次进行数据库切换之前,当前的所有操作都是针对db(1)所设置的数据库。

如果需要切换到默认的数据库连接,只需要调用：

$this->db(0);

如果我们已经在项目配置中定义了其他的数据库连接信息,我们就可以直接在db方法中调用配置进行连接了：

$this->db(1,"DB\_CONFIG1")->query("查询SQL"); $this->db(2,"DB\_CONFIG2")->query("查询SQL");

如果切换数据库之后,数据表和当前不一致的话,可以使用table方法指定要操作的数据表：

$this->db(1)->table("top\_user")->find();

如果要返回当前的数据库连接,可以直接调用空的db方法即可,例如：

$db = $this->db();

# 第三种方法：D方法配置 #

在数据库配置文件中加入新的配置项：

//默认数据库链接
    'DB_TYPE'=>'mysql',
    'DB_HOST'=>'localhost',
    'DB_NAME'=>'news',
    'DB_USER'=>'root',
    'DB_PWD'=>'123',
    'DB_PORT'=>'3306',
    'DB_PREFIX'=>'news_',
    //我的第一个数据库连接
    'DB_BBS'=>array(
    'DB_TYPE' => 'mysql',
    'DB_HOST'=>'localhost',
    'DB_NAME'=>'bbs',
    'DB_USER'=>'root',
    'DB_PWD'=>'123',
    'DB_PORT'=>'3306',
    ),
    //第二个数据库链接,
    'DB_NEWS'=>array(
    'DB_TYPE' => 'mysql',
    'DB_HOST'=>'localhost',
    'DB_NAME'=>'news',
    'DB_USER'=>'root',
    'DB_PWD'=>'123',
    'DB_PORT'=>'3306',
    )
    );

在Model的定义中加入：

<?php
     class NewsModel extends Model{
    
            protected $connection = 'DB_NEWS'; //指定配置项
            protected $tablePrefix = 'new_'; //后缀
            protected $tableName = 'News';// 数据表
    
    
     }

代码中利用D方法申请使用既可：

D('News')->where("id='" . $id . "'")->find();

[Link 1]: https://www.2cto.com/os/