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

async function queryData() {
  const connection = await mysql.createConnection({
    host: '139.155.104.10',
    port: 3306,
    user: 'ryc',
    password: 'KiYap3E8X8RLcM6T',
    database: 'ryc'
  });

  try {
    console.log('连接数据库成功！');
    
    // 查询stage_id=8的阶段信息
    console.log('\n=== 查询 t_activity 表中 id=8 的阶段信息 ===');
    const [rows1] = await connection.execute(
      'SELECT id, pid, name, sort_order FROM t_activity WHERE id = ?',
      [8]
    );
    console.log(`找到 ${rows1.length} 条记录：`);
    rows1.forEach(row => {
      console.log(`ID: ${row.id}, PID: ${row.pid}, Name: ${row.name}, Sort: ${row.sort_order}`);
    });

    // 查询activity_id=6的所有阶段
    console.log('\n=== 查询 activity_id=6 的所有阶段 ===');
    const [rows2] = await connection.execute(
      'SELECT id, pid, name, sort_order FROM t_activity WHERE pid = ? ORDER BY sort_order',
      [6]
    );
    console.log(`找到 ${rows2.length} 条阶段记录：`);
    rows2.forEach(row => {
      console.log(`ID: ${row.id}, PID: ${row.pid}, Name: ${row.name}, Sort: ${row.sort_order}`);
    });

    // 查询主比赛信息
    console.log('\n=== 查询主比赛 id=6 的信息 ===');
    const [rows3] = await connection.execute(
      'SELECT id, pid, name FROM t_activity WHERE id = ?',
      [6]
    );
    console.log(`找到 ${rows3.length} 条记录：`);
    rows3.forEach(row => {
      console.log(`ID: ${row.id}, PID: ${row.pid}, Name: ${row.name}`);
    });

  } catch (error) {
    console.error('查询出错：', error);
  } finally {
    await connection.end();
  }
}

queryData();