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