65 lines
2.6 KiB
JavaScript
65 lines
2.6 KiB
JavaScript
// Скрипт для проверки таблицы profile_views
|
|
const { Pool } = require('pg');
|
|
require('dotenv').config();
|
|
|
|
const pool = new Pool({
|
|
host: process.env.DB_HOST,
|
|
port: parseInt(process.env.DB_PORT || '5432'),
|
|
database: process.env.DB_NAME,
|
|
user: process.env.DB_USERNAME,
|
|
password: process.env.DB_PASSWORD
|
|
});
|
|
|
|
async function checkProfileViewsTable() {
|
|
const client = await pool.connect();
|
|
try {
|
|
console.log('Проверка таблицы profile_views...');
|
|
|
|
// Проверяем наличие таблицы
|
|
const tableCheck = await client.query(`
|
|
SELECT EXISTS (
|
|
SELECT FROM information_schema.tables
|
|
WHERE table_schema = 'public'
|
|
AND table_name = 'profile_views'
|
|
);
|
|
`);
|
|
|
|
const tableExists = tableCheck.rows[0].exists;
|
|
console.log(`Таблица profile_views ${tableExists ? 'существует' : 'не существует'}`);
|
|
|
|
if (tableExists) {
|
|
// Проверяем количество записей в таблице
|
|
const countResult = await client.query('SELECT COUNT(*) FROM profile_views');
|
|
console.log(`Количество записей в таблице: ${countResult.rows[0].count}`);
|
|
|
|
// Получаем данные из таблицы
|
|
const dataResult = await client.query(`
|
|
SELECT pv.*,
|
|
v.telegram_id as viewer_telegram_id,
|
|
vp.telegram_id as viewed_telegram_id
|
|
FROM profile_views pv
|
|
LEFT JOIN users v ON pv.viewer_id = v.id
|
|
LEFT JOIN users vp ON pv.viewed_profile_id = vp.id
|
|
LIMIT 10
|
|
`);
|
|
|
|
if (dataResult.rows.length > 0) {
|
|
console.log('Данные из таблицы profile_views:');
|
|
dataResult.rows.forEach((row, index) => {
|
|
console.log(`${index + 1}. Просмотр: ${row.viewer_telegram_id || 'Неизвестно'} → ${row.viewed_telegram_id || 'Неизвестно'}, дата: ${row.view_date}`);
|
|
});
|
|
} else {
|
|
console.log('Таблица profile_views пуста');
|
|
}
|
|
}
|
|
} catch (error) {
|
|
console.error('Ошибка при проверке таблицы profile_views:', error);
|
|
} finally {
|
|
client.release();
|
|
await pool.end();
|
|
}
|
|
}
|
|
|
|
// Запускаем проверку
|
|
checkProfileViewsTable();
|