Function test_pg_stats_view_exists

tests/pg_stats_test.rs:6–47

()

#[tokio::test]
async fn test_pg_stats_view_exists() {
    // Create a temporary database
    let temp_dir = tempfile::tempdir().unwrap();
    let db_path = temp_dir.path().join("test_pg_stats.db");
    let db_handler = Arc::new(DbHandler::new(db_path.to_str().unwrap()).unwrap());

    // Create session for catalog queries
    let session_id = Uuid::new_v4();
    db_handler.create_session_connection(session_id).await.unwrap();

    // Create a sample table with data for statistics
    db_handler.execute("CREATE TABLE sample_table (
        id INTEGER PRIMARY KEY,
        name VARCHAR(50),
        age INTEGER,
        email TEXT,
        status VARCHAR(20) DEFAULT 'active',
        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
        is_verified BOOLEAN DEFAULT FALSE
    )").await.unwrap();

    // Insert some sample data
    db_handler.execute("INSERT INTO sample_table (name, age, email, status, is_verified) VALUES
        ('Alice Johnson', 25, 'alice@example.com', 'active', 1),
        ('Bob Smith', 30, 'bob@example.com', 'inactive', 0),
        ('Carol Davis', 28, 'carol@example.com', 'active', 1),
        ('David Wilson', 35, 'david@example.com', 'pending', 0),
        ('Eve Brown', 22, 'eve@example.com', 'active', 1)
    ").await.unwrap();

    // Test basic pg_stats view query
    let result = db_handler.query_with_session("SELECT COUNT(*) FROM pg_stats", &session_id).await.unwrap();
    assert!(!result.rows.is_empty(), "Should get a count result");

    let count_bytes = result.rows[0][0].as_ref().unwrap();
    let count_str = String::from_utf8(count_bytes.clone()).unwrap();
    let count: i32 = count_str.parse().unwrap();

    // Should have statistics for all columns in our sample table (7 columns)
    assert!(count >= 7, "Should have statistics for at least 7 columns, got {}", count);
    println!("✅ pg_stats view contains {} column statistics", count);
}

#[tokio::test]
async fn test_pg_stats_column_structure() {