1. 引言：动态数据库连接的需求
在web应用开发中，尤其是在codeigniter框架下，我们常常需要连接并操作多个数据库。除了应用主数据库外，可能还会遇到需要根据用户输入、特定业务逻辑或外部系统集成需求，动态连接到其他数据库的场景。例如，从用户提供的数据库凭据中导入数据、构建多租户系统、或进行数据迁移等。codeigniter提供了灵活的机制来处理这类动态数据库连接，使得开发者能够按需建立和管理数据库会话。
2. CodeIgniter数据库配置基础
CodeIgniter的默认数据库配置通常位于application/config/database.php文件中。在这个文件中，你可以定义一个或多个数据库连接组，例如default、test等。default组是应用启动时自动加载的主数据库连接。
以下是一个典型的default数据库配置示例：
// application/config/database.php
$db['default'] = array(
'dsn' => '',
'hostname' => 'localhost',
'username' => 'root',
'password' => '',
'database' => 'primary_db', // 主数据库名称
'dbdriver' => 'mysqli',
'dbprefix' => '',
'pconnect' => FALSE,
'db_debug' => (ENVIRONMENT !== 'production'),
'cache_on' => FALSE,
'cachedir' => '',
'char_set' => 'utf8',
'dbcollat' => 'utf8_general_ci',
'swap_pre' => '',
'encrypt' => FALSE,
'compress' => FALSE,
'stricton' => FALSE,
'failover' => array(),
'save_queries' => TRUE
);3. 实现动态数据库连接
为了实现基于用户输入或其他动态值连接到辅助数据库，我们需要在运行时构建数据库连接配置数组，而不是仅仅依赖database.php中的预定义配置。这个过程通常在一个模型、控制器或自定义库中完成。
3.1 构建动态连接配置
首先，定义一个辅助方法来生成数据库连接参数数组。这个方法可以接收用户提供的数据库凭据作为参数。
以下示例展示了如何在控制器或模型中封装一个私有方法来动态构建连接配置：
1、系统采用.net2.0开发，数据库access2、三层架构，数据层、逻辑层和表示层分离3、系统完全使用div＋css布局，可以灵活处理界面4、技术特点: 使用模板页，大大减少代码量 动态生成竖向导航菜单 ul li实现表格 各种自定义用户空间 Reapter等数据控件的灵活运用
load->helper('form'); // 如果需要处理表单输入
$this->load->library('form_validation'); // 如果需要验证表单输入
}
/**
* 根据提供的凭据构建动态数据库连接配置数组
*
* @param array $credentials 包含 hostname, username, password, database 的数组
* @return array 数据库连接配置数组
*/
private function _build_dynamic_db_config($credentials) {
// 对输入凭据进行必要的验证和清理
if (empty($credentials['hostname']) || empty($credentials['username']) || empty($credentials['database'])) {
// 可以抛出异常或返回错误
log_message('error', 'Dynamic DB credentials missing required fields.');
return FALSE;
}
// 默认配置，可以根据需要调整
$config = array(
'dsn' => '',
'dbdriver' => 'mysqli',
'dbprefix' => '',
'pconnect' => FALSE,
'db_debug' => (ENVIRONMENT !== 'production'),
'cache_on' => FALSE,
'cachedir' => '',
'char_set' => 'utf8',
'dbcollat' => 'utf8_general_ci',
'swap_pre' => '',
'encrypt' => FALSE,
'compress' => FALSE,
'stricton' => FALSE,
'failover' => array(),
'save_queries' => TRUE
);
// 合并动态凭据
$config['hostname'] = $credentials['hostname'];
$config['username'] = $credentials['username'];
$config['password'] = isset($credentials['password']) ? $credentials['password'] : '';
$config['database'] = $credentials['database'];
return $config;
}
// ... 其他方法
}3.2 连接到动态数据库
有了动态配置数组后，可以使用$this->load->database()方法来建立连接。该方法的第二个参数设置为TRUE时，会返回数据库对象，而不是将其分配给$this->db（$this->db始终指向默认连接）。
$this->input->post('db_host'),
'username' => $this->input->post('db_user'),
'password' => $this->input->post('db_pass'),
'database' => $this->input->post('db_name')
);
// 2. 验证用户输入 (非常重要!)
$this->form_validation->set_rules('db_host', '数据库主机', 'required|trim');
$this->form_validation->set_rules('db_user', '用户名', 'required|trim');
$this->form_validation->set_rules('db_name', '数据库名', 'required|trim');
// 可以根据需要添加更多验证规则
if ($this->form_validation->run() === FALSE) {
// 验证失败，显示错误信息或重定向
echo validation_errors();
return;
}
// 3. 构建动态数据库配置
$dynamic_db_config = $this->_build_dynamic_db_config($user_input_credentials);
if ($dynamic_db_config === FALSE) {
echo "无法构建数据库配置，请检查输入。";
return;
}
// 4. 连接到动态数据库
// 将连接对象赋值给一个变量，例如 $external_db
$external_db = $this->load->database($dynamic_db_config, TRUE);
// 检查连接是否成功
if ($external_db === FALSE) {
echo "无法连接到外部数据库，请检查凭据。";
log_message('error', 'Failed to connect to dynamic database with credentials: ' . json_encode($user_input_credentials));
return;
}
// 此时，$external_db 就是指向外部数据库的连接对象
// $this->db 仍然指向主数据库
// ... 后续操作，如数据导入
echo "成功连接到外部数据库！";
}
}4. 多数据库实例的切换与操作
当您通过$this->load->database($config_array, TRUE)建立动态连接后，您将获得一个独立的数据库对象。这意味着您现在可以同时操作主数据库（通过$this->db）和动态连接的数据库（通过您指定的变量，例如$external_db）。
// 假设 $external_db 已经成功连接
// 从外部数据库读取数据
$query = $external_db->get('source_table'); // 查询外部数据库中的 'source_table'
$data_to_import = $query->result_array();
if (!empty($data_to_import)) {
echo "从外部数据库读取到 " . count($data_to_import) . " 条数据。
";
// 将数据插入到主数据库
foreach ($data_to_import as $row) {
// 在插入前，可能需要对数据进行清洗、转换或验证
$this->db->insert('target_table', $row); // 插入到主数据库的 'target_table'
}
echo "数据已成功导入到主数据库。";
} else {
echo "外部数据库中没有数据可供导入。";
}
// 注意：CodeIgniter的数据库类会自动管理连接的关闭，
// 但如果需要显式关闭，可以使用 $external_db->close();5. 数据导入实践
结合上述步骤，一个完整的数据导入流程可能如下：
- 用户界面： 提供一个表单，让用户输入外部数据库的连接信息（主机、用户名、密码、数据库名）。
- 控制器接收请求： 控制器接收表单提交的数据。
- 数据验证： 严格验证用户输入的数据库凭据，防止恶意注入或错误配置。
- 构建动态配置： 使用验证后的凭据构建数据库连接配置数组。
- 建立动态连接： 使用$this->load->database($config_array, TRUE)建立与外部数据库的连接。
- 数据读取： 从外部数据库查询并获取需要导入的数据。
- 数据处理： 对获取到的数据进行必要的转换、清洗和验证，以符合主数据库的结构和业务规则。
- 数据写入： 使用$this->db对象（主数据库连接）将处理后的数据插入到主数据库中。
- 结果反馈： 向用户反馈导入操作的结果（成功或失败，以及任何错误信息）。
6. 安全与性能注意事项
- 输入验证与过滤： 永远不要直接使用用户提供的凭据而不进行严格验证。使用CodeIgniter的表单验证库对hostname、username、database等字段进行必要检查，例如长度、字符类型等。
- 错误处理： 动态数据库连接可能会失败（例如，凭据错误、数据库不可达）。务必捕获$this->load->database()返回FALSE的情况，并向用户提供有意义的错误信息，同时记录详细的日志。
- 敏感信息处理： 数据库密码等敏感信息不应在日志中明文记录。在传输和存储时，应采取加密措施。
- 资源管理： CodeIgniter通常会自动管理数据库连接的生命周期。然而，如果您的应用频繁创建和销毁大量动态连接，可能会对性能产生影响。对于短期任务，通常不是问题；对于长期或高并发场景，可能需要考虑连接池或其他高级策略（尽管CI原生支持有限）。
- 连接持久性（pconnect）： pconnect设置为TRUE可以尝试使用持久连接，但在某些环境中可能导致问题或资源泄漏，通常建议设置为FALSE。
- 配置封装： 将动态数据库连接的逻辑封装在专门的模型、库或辅助函数中，以保持代码的模块化和可维护性。避免在控制器中直接处理所有数据库逻辑。
- 事务处理： 如果数据导入涉及多个步骤，且需要保证原子性，请务必使用数据库事务来确保数据一致性。
7. 总结
通过本教程，我们学习了如何在CodeIgniter框架中实现基于动态凭据的辅助数据库连接。这种方法极大地增强了应用的灵活性，使其能够适应各种复杂的数据库交互场景，如从外部系统导入数据。关键在于理解如何动态构建连接配置数组，并利用$this->load->database()方法的第二个参数来获取独立的数据库对象。同时，务必重视安全性和错误处理，以构建健壮、可靠的应用程序。
