duanpei8853 2013-01-04 15:04
浏览 58
已采纳

在codeigniter中加入两个数据库的查询

I need to write a join query of two tables from two databases and fetch the joined data. For eg, consider I have a database db1 which has some tables named companies, plans, customers. Suppose I need to join the two tables companies and plans with another table 'cdr' on another database db2 by grouping them using a similar column.

The query which I'm running right now is given below:

function get_per_company_total_use ($custid)
        {         
                 $this->DB1->select('ph_Companies.CompanyName');
                 $this->DB1->where('ph_Companies.Cust_ID', $custid);
                 $this->DB2->select_sum('cdr.call_length_billable')->from('cdr');
                 $this->DB2->group_by('cdr.CompanyName');
                 $this->db->join('Kalix2.ph_Companies', 'Kalix2.ph_Companies.CompanyName = Asterisk.cdr.CompanyName');
                 $query = $this->db->get();
                 if($query->result()){
                     foreach ($query->result() as $value) {
                         $companies[]= array($value->CompanyName,$value->call_length_billable);
                          }
                     return $companies;
                 }
                 else 
                     return FALSE;
        }

But my query is not fetching the data and throwing an error. This same query, I have run on a single database and is working. But I need help to find how this can be done with two databases.

  • 写回答

2条回答 默认 最新

  • douyan4470 2013-01-04 15:45
    关注

    You can just give the following if you need to join two database tables:

    function get_per_company_total_use ($custid)
            {         
                     $this->db->select('Kalix2.ph_Companies.CompanyName');
                     $this->db->where('Kalix2.ph_Companies.Cust_ID', $custid);
                     $this->db->select_sum('Asterisk.cdr.call_length_billable')->from('Asterisk.cdr');
                     $this->db->group_by('Asterisk.cdr.CompanyName');
                     $this->db->join('Kalix2.ph_Companies', 'Kalix2.ph_Companies.CompanyName = Asterisk.cdr.CompanyName');
                     $query = $this->db->get();
                     if($query->result()){
                         foreach ($query->result() as $value) {
                             $companies[]= array($value->CompanyName,$value->call_length_billable);
                              }
                         return $companies;
                     }
                     else 
                         return FALSE;
            }
    

    Here actually you need not give the connection variable DB1 or DB2, just give $this->db.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

悬赏问题

  • ¥15 使用Jdk8自带的算法,和Jdk11自带的加密结果会一样吗,不一样的话有什么解决方案,Jdk不能升级的情况
  • ¥15 画两个图 python或R
  • ¥15 在线请求openmv与pixhawk 实现实时目标跟踪的具体通讯方法
  • ¥15 八路抢答器设计出现故障
  • ¥15 请教一下c语言的代码里有一个地方不懂
  • ¥15 opencv 无法读取视频
  • ¥15 用matlab 实现通信仿真
  • ¥15 按键修改电子时钟,C51单片机
  • ¥60 Java中实现如何实现张量类,并用于图像处理(不运用其他科学计算库和图像处理库))
  • ¥20 5037端口被adb自己占了