QQ 咨询
谢谢打赏
微信交流
432

thinkphp3.2如何跨数据库联合查询
时间: 2019-09-02 18:27:52  作者:北桥苏  阅读:(198)

使用情景:有些项目的数据库是独立部署在一台服务器上,而有时当前项目又需要使用其他项目的数据库。其实就是一个基于tp3.2的项目要连接两个数据库,并可以在一个模型上可以同时使用两个库。


一、配置

注:这里关于数据库表前缀最好在模型里通过属性tablePrefix设置,不建议DB_PREFIX' => 'think_'


    return array(
            // 数据库1
            "db_option1" => array(
                'db_type'  => 'mysql',
                'db_user'  => 'root',
                'db_pwd'   => 'root',
                'db_host'  => 'localhost',
                'db_port'  => '3306',
                'db_name'  => 'temp_eshop',
                'db_charset'=>    'utf8',
            ),

            // 数据库2
            "db_option2" => array(
                'db_type'  => 'mysql',
                'db_user'  => 'root',
                'db_pwd'   => 'root',
                'db_host'  => 'localhost',
                'db_port'  => '3306',
                'db_name'  => 'temp_logitcs',
                'db_charset'=>    'utf8',
            ),
    );


二、设置主数据库公用模型


    namespace Common\Model;
    use Think\Model;

    class BaseModel extends Model {

        // 主连接的数据库,db_option1为该数据库配置数组键
        protected $connection = "db_option1";

    }

 

三、设置主数据库公用模型


    namespace Common\Model;
    use Think\Model;

    class BaseModel extends Model {

        // 主连接的数据库,db_option1为该数据库配置数组键
        protected $connection = "db_option1";

    }

 

四、设置主数据库下的一张表对应当前模型


namespace Home\Model;
use Think\Model;
use Common\Model\BaseModel;

class TestModel extends BaseModel{
    
    // 继承父模型,表示在主数据库下的其中一张数据表,以下都是该数据库下的customan表的操作
    protected $tableName = "customan";
    
    public function currentDbTable() {
        return $this->where(array("id"=>2))->find();
    }

}


五、在主数据库下customan切换其他数据库

提示:使用tp模型中的db方法实现切换


namespace Home\Model;
use Think\Model;
use Common\Model\BaseModel;

class TestModel extends BaseModel{
    
    // 继承父模型,表示在主数据库下的其中一张数据表,以下都是该数据库下的customan表的操作
    protected $tableName = "customan";
    
    public function currentDbTable() {
        return $this->where(array("id"=>2))->find();
    }
    
   // 多数据库下混合操作
   public function getexids() {
       
       // 给主数据库设为编号1,并且此方法的$this已指向该数据库句柄
       $this->db(1,"db_option1");
       
       // 注意:越后的设置$this重新指向越往后,这里支持$this->db(2,"db_option2")->query("select * from user where uid=2")写法;
       $this->db(2,"db_option2");
       
       // 编号1数据库连接的一张表的实例
       $shop_products = $this->db(1)->table("products");
       $shop_users = $this->db(1)->table("users");
       
       // 编号2数据库连接的一张表的实例
       $logitcs_customan = $this->db(2)->table("customan");
       
       // 使用编号2数据库下一张表进行查询
       $res = $logitcs_customan->select();
       
       //$res = $shop_users->select();
       //$customans = $this->select()
       
       // 返回此次结果
       return $res;
       
   }

}

 

总结 : 除了在预先定义数据库连接和实例化的时候指定数据库连接外,我们还可以在模型操作过程中动态的切换数据库,支持切换到相同和不同的数据库类型。

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

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

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

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






用户登录


     QQ登录

我的标签


随机文章

  • 安卓手机如何快速投屏到windows(10/8.1/7)电脑上前提: 手机和电脑连接的网络必须在同一局域网…… 查看详情
  • 消息队列篇——windows本地搭建RabbitMQ ServerMQ全称为Message Queue, 消息…… 查看详情
  • 微信小程序自定义券票二维码文件流上传到OSS解决方法目前项目中有这样一下需求,通过传入的不同的参…… 查看详情

友情链接





Copyright© 2016-2020 北桥苏 & 版权所有    赣ICP备16002525号-1
如有侵权、不妥之处,请联系站长的客服并出示版权证明以便删除。敬请谅解! 站长客服联系方式:QQ2652364582