const mysql = require('mysql2/promise');
const fs = require('fs');

async function updateActivityTimes() {
    const connection = await mysql.createConnection({
        host: '139.155.104.10',
        port: 3306,
        user: 'root',
        password: 'Xml@uk2025',
        database: 'ryc',
        authPlugins: {
            mysql_native_password: () => () => Buffer.alloc(0)
        }
    });

    try {
        console.log('连接数据库成功');

        // 读取SQL文件
        const sqlContent = fs.readFileSync('./update-activity-times.sql', 'utf8');
        
        // 分割SQL语句
        const sqlStatements = sqlContent
            .split(';')
            .map(stmt => stmt.trim())
            .filter(stmt => stmt && !stmt.startsWith('--'));

        console.log(`准备执行 ${sqlStatements.length} 条SQL语句`);

        // 执行每条SQL语句
        for (let i = 0; i < sqlStatements.length; i++) {
            const sql = sqlStatements[i];
            if (sql) {
                console.log(`执行SQL ${i + 1}: ${sql.substring(0, 50)}...`);
                const [result] = await connection.execute(sql);
                
                if (sql.toLowerCase().startsWith('select')) {
                    console.log('查询结果:', result);
                } else {
                    console.log(`影响行数: ${result.affectedRows}`);
                }
            }
        }

        console.log('所有SQL语句执行完成');

    } catch (error) {
        console.error('执行失败:', error);
    } finally {
        await connection.end();
        console.log('数据库连接已关闭');
    }
}

updateActivityTimes();