CodeIgniter 动态配置与切换数据库连接指南

霞舞

发布时间：2025-10-05 13:28:39

244人浏览过

来源于php中文网

原创

codeigniter 动态配置与切换数据库连接指南

本教程将详细介绍在 CodeIgniter 框架中如何实现动态配置和切换数据库连接。针对用户通过表单提供数据库凭据的需求，文章将指导读者创建灵活的数据库连接函数，并利用 CodeIgniter 的数据库加载机制，实现在运行时动态连接到不同的数据库实例，从而支持从外部数据库导入数据到主数据库的场景。

1. CodeIgniter 数据库连接基础

在 CodeIgniter 中，默认的数据库连接配置通常定义在 application/config/database.php 文件中。这个文件允许您设置一个或多个数据库连接组，其中 default 组是应用程序启动时自动加载的主数据库连接。

以下是一个典型的 default 数据库连接配置示例：

// application/config/database.php

$db['default'] = array(
    'dsn'      => '',
    'hostname' => 'localhost',
    'username' => 'root',
    'password' => '',
    'database' => 'first_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
);

通过这种方式配置的数据库，在控制器或模型中可以直接通过 $this->db 对象进行访问。

2. 实现动态数据库连接

当需要根据用户输入或其他运行时数据来连接到不同的数据库时，我们不能仅仅依赖 database.php 中的静态配置。CodeIgniter 允许我们通过传递一个配置数组给 $this->load->database() 方法来建立动态连接。

2.1 封装动态连接配置函数

为了更好地管理动态连接参数，建议创建一个辅助函数来根据传入的凭据生成数据库配置数组。这个函数可以放在模型、库文件或辅助函数中，具体取决于您的项目结构。

PathFinder

AI驱动的销售漏斗分析工具

下载

例如，在一个模型中，您可以定义如下方法：

<?php
defined('BASEPATH') OR exit('No direct script access allowed');

class Data_import_model extends CI_Model {

    public function __construct() {
        parent::__construct();
    }

    /**
     * 根据动态参数生成数据库连接配置数组
     *
     * @param string $hostname 数据库主机名
     * @param string $username 数据库用户名
     * @param string $password 数据库密码
     * @param string $database_name 数据库名称
     * @return array 数据库配置数组
     */
    private function get_dynamic_db_config($hostname, $username, $password, $database_name) {
        $config = array(
            'dsn'      => '',
            'hostname' => $hostname,
            'username' => $username,
            'password' => $password,
            'database' => $database_name,
            'dbdriver' => 'mysqli', // 或 'pdo', 'postgre' 等
            '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;
    }

    // 其他模型方法...
}

2.2 加载与切换动态数据库连接

一旦有了动态配置数组，就可以使用 $this->load->database() 方法来加载并获取数据库连接对象。关键在于将第二个参数设置为 TRUE，这会使方法返回数据库对象本身，而不是将其赋值给 $this->db（这会覆盖主数据库连接）。

// 假设在一个控制器或模型方法中
public function import_external_data() {
    // 1. 从用户输入获取数据库凭据
    // 实际应用中，这里需要对用户输入进行严格的验证和过滤
    $input_hostname = $this->input->post('hostname', TRUE);
    $input_username = $this->input->post('username', TRUE);
    $input_password = $this->input->post('password', FALSE); // 密码通常不进行XSS过滤
    $input_database = $this->input->post('database_name', TRUE);

    // 2. 生成动态数据库配置
    $dynamic_config = $this->get_dynamic_db_config(
        $input_hostname,
        $input_username,
        $input_password,
        $input_database
    );

    // 3. 尝试连接到外部数据库
    $external_db = NULL;
    try {
        // 第二个参数 TRUE 表示返回数据库对象，不覆盖 $this->db
        $external_db = $this->load->database($dynamic_config, TRUE);

        if ($external_db->conn_id === FALSE) {
            // 连接失败处理
            log_message('error', '无法连接到外部数据库：' . $external_db->error()['message']);
            echo "错误：无法连接到指定的数据库。";
            return;
        }

        // 4. 从外部数据库导入数据
        // 示例：从外部数据库查询数据
        $query = $external_db->get('your_external_table');
        $external_data = $query->result_array();

        // 5. 将数据导入到主数据库
        if (!empty($external_data)) {
            // $this->db 仍然指向主数据库连接
            $this->db->insert_batch('your_primary_table', $external_data);
            if ($this->db->affected_rows() > 0) {
                echo "数据成功导入！";
            } else {
                echo "数据导入失败或无新数据。";
            }
        } else {
            echo "外部数据库中没有可导入的数据。";
        }

    } catch (Exception $e) {
        log_message('error', '动态数据库连接或操作异常：' . $e->getMessage());
        echo "发生错误：" . $e->getMessage();
    } finally {
        // 可选：如果需要，手动关闭外部数据库连接
        // CodeIgniter 通常会处理连接关闭，但在长时间运行的脚本中手动关闭可能有助于资源管理。
        if ($external_db && is_object($external_db) && method_exists($external_db, 'close')) {
             //$external_db->close();
        }
    }
}

在这个例子中，$this->db 始终代表您的主数据库连接，而 $external_db 则代表通过用户输入动态建立的外部数据库连接。您可以同时对这两个连接执行数据库操作。

3. 注意事项与最佳实践

安全性优先： 接收用户提供的数据库凭据是高风险操作。
- 输入验证： 严格验证所有用户输入（主机名、用户名、数据库名）。
- 密码安全： 确保密码在传输过程中加密（例如使用 HTTPS）。在服务器端处理时，不要记录明文密码。
- 权限最小化： 告知用户，他们提供的数据库账户应具有最小的必要权限（例如，只读或仅限特定表的写入权限），以降低潜在的安全风险。
- SQL 注入防护： 始终使用 CodeIgniter 的查询构造器或预处理语句来执行查询，以防止 SQL 注入。
错误处理： 动态连接可能会因为凭据错误、数据库不可用等原因失败。务必使用 try-catch 块捕获异常，并提供友好的错误提示，同时记录详细的错误日志。
资源管理： CodeIgniter 会自动管理数据库连接。但在某些特殊场景下（如在循环中建立大量临时连接），您可能需要考虑手动关闭连接，尽管这通常不是必需的。
配置复用： 动态配置数组中的许多参数（如 dbdriver, char_set, dbcollat 等）通常是固定的。可以考虑将这些固定值作为默认参数，只让用户输入核心凭据。
性能考虑： 频繁地建立和关闭数据库连接会带来性能开销。如果需要连接到少数几个已知的、非动态的辅助数据库，最好在 database.php 中预先配置它们，而不是每次都动态创建。动态连接适用于凭据确实需要在运行时确定的场景。