Semántica de filas MySQL
01La corrección suele ocultarse en los ajustes de conexión.
Una ruta MySQL suele unir tablas operativas con destinos analíticos o de socios. Consulta, índices, juegos de caracteres, collations, tiempos, lotes y escritura determinan la corrección y la carga aceptable sobre el origen.
Consulta por una ruta indexada
Define base, tablas o consultas, columnas, filtros indexados, orden, claves, juego de caracteres, collation, zona horaria y conversiones. La selección debe ser estable para poder reconciliarla.
Reinicia tras un lote confirmado
Divide el trabajo grande en lotes o checkpoints deterministas y elige límites de transacción. Un reinicio debe distinguir filas confirmadas de un lote que falló antes de completarse.
Fija el significado de texto y tiempo
Acuerda nulos, valores unsigned y precisión, fechas y horas, codificación, claves, inserción o actualización, fallos de restricciones, filas rechazadas y recuentos origen-destino.
Ruta Flower específica de MySQL
02Convierte tablas operativas en un flujo incremental controlado.
El adaptador MySQL de Flower ofrece consultas, escrituras y transacciones con identificadores y parámetros MySQL. El flujo define descubrimiento, conversiones, calidad, checkpoints y evidencias sin código de aplicación.
Construye una ventana determinista
Usa watermark indexado, desempate único y orden explícito. Solapa ventanas con tiempos gruesos o relojes distintos; reconcilia claves para evitar duplicados de negocio.
Normaliza casos límite MySQL
Valida rangos unsigned, precisión DECIMAL, fechas cero o inválidas, BIT, binarios, JSON y nulos. Convierte con zona y charset declarados antes de que otros sistemas reinterpreten valores.
Escribe dentro de una transacción conocida
Las escrituras preparadas usan transacciones acotadas. Recuentos, restricciones, rechazos y claves confirmadas se reconcilian antes de avanzar, evitando duplicados tras perder conexión.
Guía de producción MySQL
03Controla carga de origen, deriva y duplicados.
MySQL suele servir aplicaciones sensibles a latencia: la integración debe ser predecible. Sondeo rápido, offsets grandes, conversiones implícitas o escaneos amplios pueden dañar el producto aunque el pipeline parezca correcto.
Política de lectura consistente
Define si cada lote ve una vista READ COMMITTED nueva o si la ejecución necesita snapshot REPEATABLE READ. Mantén transacciones cortas y define el fallo ante DDL.
Presupuesto de índices y pool
Verifica la ruta con volúmenes reales. Limita conexiones, duración, lotes y flujos; alerta si crece la edad de extracción aunque cada consulta tenga éxito.
Contrato de clave duplicada y borrado
Elige insert, update, upsert, append o reemplazo preparado. Define significado de claves duplicadas, representación de borrados, actualizaciones desordenadas y reconciliación final.