WordPress插件开发：自定义数据表的创建与数据初始化策略

<?php
/**
 * 在插件激活或更新时创建/更新数据库表
 */
function my_plugin_create_tables() {
    global $wpdb;

    // 引入dbDelta函数
    require_once(ABSPATH . 'wp-admin/includes/upgrade.php');

    // 定义要创建的表结构
    $table_name = $wpdb->prefix . 'profil_member';
    $charset_collate = $wpdb->get_charset_collate();

    $sql = "CREATE TABLE IF NOT EXISTS $table_name (
        id_profil bigint(20) UNSIGNED NOT NULL AUTO_INCREMENT,
        id_member bigint(20) UNSIGNED NOT NULL,
        id_subscription bigint(20) UNSIGNED NOT NULL,
        createdAt DATETIME DEFAULT CURRENT_TIMESTAMP,
        updatedAt DATETIME,
        state int DEFAULT 1,
        PRIMARY KEY(id_member, id_subscription),
        FOREIGN KEY (id_profil) REFERENCES {$wpdb->prefix}profil(id),
        FOREIGN KEY (id_member) REFERENCES {$wpdb->prefix}member(id)
    ) $charset_collate;";

    // 执行dbDelta，创建或更新表
    dbDelta($sql);

    // 可以在这里添加其他表的创建逻辑
}

<?php
/**
 * 填充profil_member表的数据
 * 假定从member表获取id_member，并为id_profil和id_subscription生成默认值或从其他逻辑获取
 */
function my_plugin_populate_profil_member() {
    global $wpdb;

    $profil_member_table = $wpdb->prefix . 'profil_member';
    $member_table = $wpdb->prefix . 'member'; // 假设存在member表

    // 检查新表是否为空，避免重复插入
    $count = $wpdb->get_var("SELECT COUNT(*) FROM $profil_member_table");
    if ($count > 0) {
        // 表已有数据，无需初始化
        return;
    }

    // 从member表获取需要导入的数据
    // 假设member表有'id'字段，我们将其作为id_member
    $members = $wpdb->get_results("SELECT id FROM $member_table", ARRAY_A);

    if (!empty($members)) {
        foreach ($members as $member) {
            // 假设 id_profil 和 id_subscription 需要根据业务逻辑生成或获取
            // 这里我们使用示例值，实际应用中应替换为真实逻辑
            $id_profil = 1; // 示例值
            $id_subscription = 1; // 示例值

            $wpdb->insert(
                $profil_member_table,
                array(
                    'id_member'       => $member['id'],
                    'id_profil'       => $id_profil,
                    'id_subscription' => $id_subscription,
                    'createdAt'       => current_time('mysql'),
                    'state'           => 1,
                ),
                array(
                    '%d', // id_member
                    '%d', // id_profil
                    '%d', // id_subscription
                    '%s', // createdAt
                    '%d', // state
                )
            );

            // 检查插入是否成功
            if ($wpdb->last_error) {
                // 记录错误或进行其他处理
                error_log("Error inserting data into $profil_member_table: " . $wpdb->last_error);
            }
        }
    }
}

<?php
/**
 * 插件更新函数，处理数据库迁移和数据初始化
 */
function my_plugin_update_routine() {
    // 获取当前插件版本
    $current_version = get_option('my_plugin_version', '1.0'); // 默认版本

    // 假设目标版本是1.7
    if (version_compare($current_version, '1.7', '<')) {
        // 1. 创建或更新表结构
        my_plugin_create_tables(); // 调用前面定义的表创建函数

        // 2. 填充数据（确保在表结构创建后执行）
        my_plugin_populate_profil_member(); // 调用数据填充函数

        // 3. 更新插件版本号，确保此逻辑只执行一次
        update_option('my_plugin_version', '1.7');
    }

    // 可以继续添加其他版本的更新逻辑
    // if (version_compare($current_version, '1.8', '<')) { ... }
}

// 在插件主文件中，通常在插件激活钩子中或init钩子中调用此更新函数
// 例如：register_activation_hook(__FILE__, 'my_plugin_update_routine');
// 或者在每次插件加载时检查版本
add_action('plugins_loaded', 'my_plugin_update_routine');