如何在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 转到本地的...。 我知道如何手动切换数据库：

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

既然我有不同的控制器和模型，我怎么能做到这一点......我确实尝试过： 首先在登录函数中获取下拉列表的值：

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

编辑：

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

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

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

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