CodeIgniter动态连接多数据库：实现用户输入凭据的灵活数据导入

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

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

class Data_Importer extends CI_Controller { // 或者在Model中

    public function __construct() {
        parent::__construct();
        $this->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;
    }

    // ... 其他方法
}

<?php
// 假设在Data_Importer控制器中

class Data_Importer extends CI_Controller {
    // ... (_build_dynamic_db_config 方法和构造函数)

    public function import_data_from_external_db() {
        // 1. 从用户输入获取数据库凭据 (例如通过POST请求)
        $user_input_credentials = array(
            'hostname' => $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 "成功连接到外部数据库！";
    }
}

// 假设 $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) . " 条数据。<br>";

    // 将数据插入到主数据库
    foreach ($data_to_import as $row) {
        // 在插入前，可能需要对数据进行清洗、转换或验证
        $this->db->insert('target_table', $row); // 插入到主数据库的 'target_table'
    }
    echo "数据已成功导入到主数据库。";
} else {
    echo "外部数据库中没有数据可供导入。";
}

// 注意：CodeIgniter的数据库类会自动管理连接的关闭，
// 但如果需要显式关闭，可以使用 $external_db->close();