我让它工作。首先,我编辑了我的 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');
}
}