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
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;
    }

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

// 假设在一个控制器或模型方法中
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();
        }
    }
}