CodeIgniter：实现动态多数据库连接与数据导入的实践指南

// 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
);

<?php
// 可以在模型 (e.g., application/models/Db_manager_model.php)
// 或控制器 (e.g., application/controllers/Import.php) 中定义

class Db_manager_model extends CI_Model {

    // ... 其他模型方法

    /**
     * 根据动态参数生成数据库连接配置数组
     *
     * @param string $hostname 数据库主机名
     * @param string $username 数据库用户名
     * @param string $password 数据库密码
     * @param string $database 数据库名称
     * @return array 数据库连接配置数组
     */
    private function getDynamicDbConfig($hostname, $username, $password, $database) {
        return array(
            'dsn'      => '',
            'hostname' => $hostname, // 动态值，来自用户输入
            'username' => $username, // 动态值，来自用户输入
            'password' => $password, // 动态值，来自用户输入
            'database' => $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
        );
    }
}

<?php
// application/controllers/Import.php

class Import extends CI_Controller {

    public function __construct() {
        parent::__construct();
        $this->load->model('db_manager_model'); // 加载包含 getDynamicDbConfig 的模型
        $this->load->helper('form'); // 如果需要处理表单输入
    }

    public function index() {
        // 加载一个包含表单的视图，让用户输入数据库凭据
        $this->load->view('import_form');
    }

    /**
     * 处理用户提交的数据库凭据并执行数据导入
     */
    public function process_import() {
        // 假设用户通过表单提交了数据库凭据
        $hostname = $this->input->post('db_hostname');
        $username = $this->input->post('db_username');
        $password = $this->input->post('db_password');
        $database = $this->input->post('db_name');

        // 1. 获取动态数据库配置
        $dynamic_db_config = $this->db_manager_model->getDynamicDbConfig($hostname, $username, $password, $database);

        // 2. 加载并获取动态数据库连接实例
        // 第二个参数 TRUE 表示返回数据库对象，而不是将其分配给 $this->db
        $dynamic_db = $this->load->database($dynamic_db_config, TRUE);

        if ($dynamic_db) {
            echo "成功连接到动态数据库！<br>";
            try {
                // 3. 从动态数据库读取数据
                // 假设要从 'source_table' 读取所有数据
                $query = $dynamic_db->get('source_table');
                $source_data = $query->result_array();

                // 4. 将数据导入到主数据库（$this->db 始终指向默认连接）
                if (!empty($source_data)) {
                    // 假设主数据库中存在 'target_table'
                    $this->db->insert_batch('target_table', $source_data);
                    echo "数据成功从动态数据库导入到主数据库。<br>";
                } else {
                    echo "动态数据库中没有数据可导入。<br>";
                }
            } catch (Exception $e) {
                echo "数据导入过程中发生错误: " . $e->getMessage() . "<br>";
            } finally {
                // 5. 关闭动态数据库连接（可选，CodeIgniter通常会自动管理，但显式关闭更安全）
                // $dynamic_db->close();
            }
        } else {
            echo "无法连接到动态数据库，请检查凭据或网络。<br>";
        }

        // 可以选择重定向或加载一个结果视图
        // $this->load->view('import_result', ['message' => $message]);
    }
}