php - 如何在codeigniter中切换数据库

Question

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

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

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

$active_group = '默认'; $active_record = TRUE;

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

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

因为我有不同的 Controller 和模型，我怎样才能实现这个……我试过这样的: 先在login函数中获取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();
}

然后在我的 Controller 中，我运行了以下命令:

$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 的类变量。

编辑:

要在每次页面加载时保持当前数据库加载，您需要使用 session 。在处理下拉数据的 Controller 函数中，您可以输入类似于以下内容的内容:

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

在任何将使用数据库的 Controller 中，您需要添加代码来加载当前数据库:

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

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

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