在许多企业级应用场景中，我们可能需要从外部系统或用户提供的数据库中动态导入数据到主应用数据库。codeigniter 框架提供了灵活的数据库连接管理机制，允许开发者不仅可以配置多个固定的数据库连接，还能根据运行时动态参数建立新的连接。本教程将指导您如何在 codeigniter 中实现这一功能。
CodeIgniter 数据库连接机制概述
CodeIgniter 的数据库配置通常定义在 application/config/database.php 文件中。此文件包含一个 $db 数组，其中可以定义一个或多个数据库连接组，例如 default、second_db 等。当您通过 $this->load->database() 加载数据库时，如果没有指定配置，默认会加载 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
);实现动态数据库连接的原理
动态数据库连接的核心思想是，不依赖 database.php 中预定义的连接组名称，而是在代码运行时，根据用户提供的数据库凭证（如主机名、用户名、密码、数据库名等），动态构建一个完整的数据库配置数组，然后将这个数组传递给 $this->load->database() 方法。
这种方式的优点在于：
构建动态连接配置
首先，我们需要一个方法来接收用户输入的数据库凭证，并将其格式化为 CodeIgniter 数据库配置数组。这个方法可以放在模型、控制器或自定义的帮助函数中。考虑到数据库操作的封装性，通常建议将其放在模型中。
假设用户通过表单提交了数据库连接信息，我们可以在控制器中接收这些信息，并将其传递给一个模型方法来处理。
// application/models/Database_manager_model.php
'',
'hostname' => $credentials['hostname'],
'username' => $credentials['username'],
'password' => $credentials['password'] ?? '', // 密码可能为空
'database' => $credentials['database'],
'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
);
return $config;
}
}加载并切换数据库实例
在控制器中，我们可以接收用户提交的表单数据，然后调用模型中的方法来获取动态配置，并加载第二个数据库连接。
// application/controllers/Import_data.php
load->model('database_manager_model');
// 默认数据库连接通常在 autoload.php 中加载，或在需要时手动加载
// $this->load->database(); // 这会加载默认连接，并使其成为 $this->db
}
public function index() {
// 加载一个视图，显示表单供用户输入数据库凭证
$this->load->view('import_form');
}
public function process_import() {
// 假设用户通过 POST 请求提交了数据库凭证
$user_credentials = array(
'hostname' => $this->input->post('db_hostname'),
'username' => $this->input->post('db_username'),
'password' => $this->input->post('db_password'),
'database' => $this->input->post('db_name')
);
// 获取动态数据库配置
$dynamic_config = $this->database_manager_model->getDynamicDbConfig($user_credentials);
if ($dynamic_config === FALSE) {
// 处理配置获取失败的情况
echo "错误：数据库凭证不完整或无效。";
return;
}
// 尝试加载第二个数据库连接
// 第二个参数 TRUE 表示返回一个数据库对象，而不是将此连接设为 $this->db
$second_db = $this->load->database($dynamic_config, TRUE);
if ($second_db) {
echo "成功连接到外部数据库！
";
// 现在可以使用 $second_db 对象来执行对外部数据库的操作
// 示例：从外部数据库导入数据到主数据库
try {
// 1. 从外部数据库查询数据
$data_to_import = $second_db->get('external_table')->result_array();
if (!empty($data_to_import)) {
// 2. 将数据插入到主数据库
// 注意：如果您的主数据库连接不是 $this->db，您需要先加载它并获取其对象
// 例如：$primary_db = $this->load->database('default', TRUE);
// 或者确保 $this->db 仍然指向主数据库
// 假设 $this->db 仍然指向主数据库
$this->db->insert_batch('primary_table', $data_to_import);
echo "数据已成功从 'external_table' 导入到主数据库的 'primary_table'。
";
} else {
echo "外部数据库中没有数据可供导入。
";
}
} catch (Exception $e) {
echo "数据导入过程中发生错误：" . $e->getMessage() . "
";
log_message('error', 'Data import failed: ' . $e->getMessage());
}
// 关闭动态连接（可选，CodeIgniter 会在请求结束时自动清理）
// $second_db->close();
} else {
echo "无法连接到外部数据库。请检查凭证。
";
// 可以在此处获取 CodeIgniter 的数据库错误信息
// if (isset($this->db->error()['message'])) {
// echo "错误信息：" . $this->db->error()['message'] . "
";
// }
}
}
}重要提示：
当您使用 $this->load->database($config, TRUE) 时，它会返回一个新的数据库连接对象。您应该使用这个对象（例如 $second_db）来执行针对该数据库的查询。
-
$this->db 变量始终指向最后加载的非返回式数据库连接。如果您需要同时操作两个数据库，建议为每个连接都使用 TRUE 参数获取其独立对象。例如：
$primary_db = $this->load->database('default', TRUE); // 获取主数据库对象 $second_db = $this->load->database($dynamic_config, TRUE); // 获取动态数据库对象 // 使用 $primary_db 进行主数据库操作 $primary_db->insert('some_table', $data); // 使用 $second_db 进行外部数据库操作 $external_data = $second_db->get('another_table')->result_array();
注意事项
- 安全性： 用户提供的数据库凭证必须经过严格的验证和清理。永远不要直接将用户输入用于构建 SQL 查询或配置。在 getDynamicDbConfig 方法中添加数据验证逻辑至关重要。
- 错误处理： 动态连接可能会失败，例如凭证错误、数据库不可达等。务必检查 $this->load->database() 的返回值，并提供用户友好的错误信息。CodeIgniter 的数据库类在连接失败时，如果 db_debug 为 TRUE，可能会抛出异常或返回 FALSE。
- 资源管理： 频繁地建立和关闭数据库连接会带来性能开销。如果需要连接到多个不同的外部数据库，考虑连接池或缓存策略。对于单个动态连接，CodeIgniter 会在请求结束时自动关闭，通常无需手动调用 close()。
- 驱动兼容性： 确保您的 CodeIgniter 环境支持用户指定数据库的驱动程序（例如 mysqli、pdo 等）。
- 权限控制： 确保用于动态连接的数据库用户拥有执行所需操作（如 SELECT、INSERT）的最小权限，避免使用具有过高权限的账户。
总结
通过上述方法，您可以在 CodeIgniter 框架中灵活地实现动态数据库连接。这不仅允许您的应用与外部数据库进行交互，还能在不修改核心配置文件的情况下，根据业务需求或用户输入切换数据源，极大地增强了应用的适应性和功能性。在实施过程中，请务必重视安全性、错误处理和资源管理，以构建健壮可靠的应用。
