import duckdb, sys
sys.stdout.reconfigure(encoding='utf-8')

L2 = 'I:/SOFTWARE/PYTHON_SRV/PYTHON_LOCAL/MyICR_Suite/local_db/parquet/scelte_rete.parquet'

dups = duckdb.sql(f"""
    SELECT prodotto, codice_rete, slot, COUNT(*) as n
    FROM '{L2}'
    GROUP BY ALL HAVING COUNT(*) > 1
    LIMIT 5
""").to_df()

print("Duplicati rimasti:", len(dups))
if not dups.empty:
    print(dups)

tot = duckdb.sql(f"SELECT COUNT(*) FROM '{L2}'").fetchone()[0]
print("Righe totali L2:", tot)

prod43850 = duckdb.sql(f"""
    SELECT * FROM '{L2}' WHERE prodotto = 43850
""").to_df()
print("\nProdotto 43850:")
print(prod43850.to_string(index=False))