#!/usr/bin/env python3
import mysql.connector

# ====== CONFIGURACIÓN ======
DB_HOST = "10.2.12.223"
DB_USER = "gps"
DB_PASS = "p0o9i8u7"
DB_NAME = "gps_reportes"      # Ajusta si la DB se llama distinto
ORIGEN = "temporal_9099"      # Tabla origen
CHUNK_SIZE = 100              # Cantidad de filas por tabla
START_INDEX = 9100            # Primera tabla nueva
END_INDEX = 9200              # Última tabla nueva

# ====== CONEXIÓN ======
conn = mysql.connector.connect(
    host=DB_HOST,
    user=DB_USER,
    password=DB_PASS,
    database=DB_NAME
)
cursor = conn.cursor()

# ====== CONTAR FILAS ======
cursor.execute(f"SELECT COUNT(*) FROM {ORIGEN}")
total_rows = cursor.fetchone()[0]
print(f"Total de filas en {ORIGEN}: {total_rows}")

# ====== PROCESO DE DIVISIÓN ======
offset = 0
tabla_index = START_INDEX

while offset < total_rows and tabla_index <= END_INDEX:
    tabla_nueva = f"temporal_{tabla_index}"

    # Crear tabla nueva con misma estructura
    cursor.execute(f"CREATE TABLE IF NOT EXISTS {tabla_nueva} LIKE {ORIGEN}")
    conn.commit()
 # uopdat bloque de registros
    cursor.execute(
        f"update  {ORIGEN} set enproseco = tabla_index  ORDER BY IdReporte LIMIT {CHUNK_SIZE} "
        
    )
    
    # Copiar bloque de registros
    cursor.execute(
        f"INSERT INTO {tabla_nueva} "
        f"SELECT * FROM {ORIGEN} enproseco = tabla_index, {CHUNK_SIZE}"
    )
    
    cursor.execute(
        f"delete from   {ORIGEN} set enproseco = tabla_index  "
        
    )
    conn.commit()

    print(f"✔ Copiadas {CHUNK_SIZE} filas a {tabla_nueva} (offset {offset})")

    offset += CHUNK_SIZE
    tabla_index += 1

print("✅ División completada.")

cursor.close()
conn.close()