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

// application/models/Database_manager_model.php
<?php
defined('BASEPATH') OR exit('No direct script access allowed');

class Database_manager_model extends CI_Model {

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

    /**
     * 根据动态凭证构建数据库配置数组
     * @param array $credentials 包含 hostname, username, password, database 的数组
     * @return array 返回 CodeIgniter 数据库配置数组
     */
    public function getDynamicDbConfig(array $credentials) {
        // 建议在此处对 $credentials 进行严格的输入验证和清理
        // 以防止 SQL 注入或其他安全问题

        // 确保所有必需的凭证都已提供
        if (empty($credentials['hostname']) || empty($credentials['username']) || empty($credentials['database'])) {
            // 根据实际需求处理错误，例如抛出异常或返回 FALSE
            log_message('error', 'Missing database credentials for dynamic connection.');
            return FALSE;
        }

        $config = array(
            'dsn'      => '',
            '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
<?php
defined('BASEPATH') OR exit('No direct script access allowed');

class Import_data extends CI_Controller {

    public function __construct() {
        parent::__construct();
        $this->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 "成功连接到外部数据库！<br>";
            // 现在可以使用 $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'。<br>";
                } else {
                    echo "外部数据库中没有数据可供导入。<br>";
                }
            } catch (Exception $e) {
                echo "数据导入过程中发生错误：" . $e->getMessage() . "<br>";
                log_message('error', 'Data import failed: ' . $e->getMessage());
            }

            // 关闭动态连接（可选，CodeIgniter 会在请求结束时自动清理）
            // $second_db->close();

        } else {
            echo "无法连接到外部数据库。请检查凭证。<br>";
            // 可以在此处获取 CodeIgniter 的数据库错误信息
            // if (isset($this->db->error()['message'])) {
            //     echo "错误信息：" . $this->db->error()['message'] . "<br>";
            // }
        }
    }
}