如何在codeigniter中切换数据库

Question

我是CI的新手,我只想知道有没有办法在CI中切换数据库,例如:在登录页面中,有一个下拉列表,您可以指定要连接的数据库,查看如下所示

<select name="select" id="select"  >
  <option value="1">DB1</option>                
  <option value="2">DB2</option>              
</select>

我在database.php中有2个数据库,default另一个是local 默认情况下我使用的是默认数据库.

$active_group = 'default'; $active_record = TRUE;

我的问题是如何根据下拉值指定db,如果我选择DB1,连接到默认值,DB2转到本地....我知道如何通过以下方式手动切换db:

 $this->load->database('default', TRUE); OR
 $this->load->database('local', TRUE);

由于我有不同的控制器和模型,我怎么能实现这一点...我尝试过:首先在登录功能中获取dropdownlist的值:

$this->load->model('My_Model');
$db = $this->input->post('select')
$this->My_Model->getDB($db);

然后在我的模型中我得到了功能:

function getDB($db)
{
    if($db ==1)
    {
        $this->db  = $this->load->database('default', TRUE);
         }
    elseif($db ==2)
    {
        $this->db  = $this->load->database('local', TRUE);
    }
}

不幸的是,它不起作用.....任何帮助都会得到很多赞赏!!!!

Answer 1

我知道了。首先，我编辑了database.php配置文件以包含新数据库。然后，在模型中，我声明了一个类变量$current_db，并编写了以下两个函数：

function getDB($db){
    if($db ==1){
        $this->current_db  = $this->load->database('default', TRUE);
    } elseif($db ==2) {
        $this->current_db  = $this->load->database('local', TRUE);
    }
}

function dyno_query($table, $id){
    $query = $this->current_db->get_where($table, array('id' => $id));
    return $query->result_array();
}

然后在我的控制器中，运行以下命令：

$arr = array();
$this->My_Model->getDB(1);
$arr['default'] = $this->My_Model->dyno_query('default_table', 2);
$this->My_Model->getDB(2);
$arr['local'] = $this->My_Model->dyno_query('local_table', 74);
var_dump($arr);

结果是一个数组，其中包含来自两个数据库的数据。也许所有这些的关键是使用$ db以外的名称定义一个类变量。

编辑：

为了保持当前数据库在每次页面加载时的加载，您需要使用会话。在处理下拉数据的控制器功能中，您可以输入类似于以下内容的内容：

$db = $this->input->post('select')
$this->My_Model->getDB($db);
$this->session->set_userdata($db);

在将使用数据库的任何控制器中，您都需要添加代码以加载当前数据库：

function __construct(){
    parent::__construct();
    $this->load->model('My_Model');
    $db = $this->session->userdata('db');
    $this->My_Model->getDB($db);
}

编辑：

如果您需要从各种模型访问相同的数据库，建议使用EllisLab的mddd库。只需使用以下代码创建一个名为Db_manager.php的PHP文件，并将其放入您的application / libraries目录中：

class Db_manager
{
    var $connections = array();
    var $CI;

    function __construct()
    {
        $this->CI =& get_instance();
    }

    function get_connection($db_name)
    {
        // connection exists? return it
        if (isset($this->connections[$db_name])) 
        {
            return $this->connections[$db_name];
       }
       else
       {
            // create connection. return it.
            $this->connections[$db_name] = $this->CI->load->database($db_name, true);
            return $this->connections[$db_name];
        }
    }
}

在将使用数据库的每个模型的构造函数中，添加以下内容：

var $current_db;

function __construct(){
    parent::__construct();
    $this->load->library('Db_manager');
    $db = $this->session->userdata('db');
    if ($db == 1){
        $this->current_db = $this->db_manager->get_connection('default');
    } else {
        $this->current_db = $this->db_manager->get_connection('alternate');
    }
}