在Codeigniter中联接两个数据库的查询

问题描述：

我需要编写来自两个数据库的两个表的联接查询，并获取联接的数据. 例如，假设我有一个数据库db1，该数据库具有一些名为公司，计划，客户的表.假设我需要通过使用相似的列对两个表公司进行分组，并与另一个数据库db2上的另一个表"cdr"一起计划.

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.

答

如果需要连接两个数据库表，则可以给出以下内容:

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;
        }

实际上，您不需要给连接变量DB1或DB2，只需给$ this-> db.

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

在Codeigniter中联接两个数据库的查询

相关推荐