Databricks Integration

builder.Services.AddScoped<IDatabricksApiClient, DatabricksApiClient>();
builder.Services.AddScoped<IDatabricksRepository, DatabricksRepository>();

{
  "Databricks": {
    "AuthMode": "StaticToken",
    "AccessToken": "your-databricks-token"
  }
}

{
  "Databricks": {
    "AuthMode": "AzureCli"
  }
}

{
  "Databricks": {
    "AuthMode": "ManagedIdentity"
  }
}

query GetSemielaboradoAnalisisById($id: String!) {
  getSemielaboradoAnalisisById(id: $id) {
    id
    semana
    turnoId
    fechaAnalisis
    horaMuestreo
    lote
    homologacionId
    mezclaTrigo
    molinoId
    silo
    inspectorId
    estado
    tipoHarina
    observaciones
    createdAt
    updatedAt
    active
  }
}

query GetSemielaboradoAnalisisPaged($filter: FilterRequestInput) {
  getSemielaboradoAnalisisPaged(filter: $filter) {
    items {
      id
      fechaAnalisis
      lote
      homologacionId
      estado
    }
    totalCount
    pageInfo {
      hasNextPage
      hasPreviousPage
    }
  }
}

query GetSemielaboradoAnalisisByConditions($filter: FilterRequestInput) {
  getSemielaboradoAnalisisByConditions(filter: $filter) {
    id
    fechaAnalisis
    lote
    estado
  }
}

query GetRutaDistanciaById($id: String!) {
  getRutaDistanciaById(id: $id) {
    id
    anio
    categoria
    origen
    destino
    distanciaKm
    usuarioCreacion
    createdAt
    updatedAt
    active
  }
}

query GetRutaDistanciaAvailableImportYears($currentYear: String!) {
  getRutaDistanciaAvailableImportYears(currentYear: $currentYear)
}

query GetMaterialesPorSector($sectorMaterial: String!) {
  getMaterialesPorSector(sectorMaterial: $sectorMaterial) {
    # Material fields
  }
}

query GetMaterialesByConditions($filter: FilterRequestInput) {
  getMaterialesByConditions(filter: $filter) {
    # Material fields
  }
}

{
  id: string                    // Primary key
  semana: string                // Week number
  turnoId: string              // Shift ID
  fechaAnalisis: DateTime       // Analysis date
  horaMuestreo: string         // Sampling time
  lote: string                 // Batch/lot number
  homologacionId: string       // Homologation ID (flour type)
  mezclaTrigo: string          // Wheat mixture
  molinoId: string             // Mill ID
  silo: string                 // Silo identifier
  inspectorId: string          // Inspector ID
  estado: string               // Status
  tipoHarina: string           // Flour type
  observaciones: string        // Observations/notes
  createdAt: DateTime          // Creation timestamp
  updatedAt: DateTime          // Update timestamp
  active: boolean              // Active flag (default: true)
}

{
  id: string                    // Primary key
  anio: int                     // Year (e.g., 2025)
  categoria: string             // Category (T0, T1, T2, IMP-TRIGO)
  origen: string                // Origin location
  destino: string               // Destination location
  distanciaKm: decimal          // Distance in kilometers
  usuarioCreacion: string       // Creator user
  createdAt: DateTime           // Creation timestamp
  updatedAt: DateTime           // Update timestamp
  active: boolean               // Active flag (default: true)
}

{
  productoTerminado: string     // Finished product code
  centro: string                // Center/plant code
  nombreCentro: string          // Center name
  listaMaterial: string         // Material list
  descripcionPT: string         // Product description
  versionSistemaProd: string    // Production system version
  versionTol: string            // Tolerance version
  codPro: string                // Product code
  pro: string                   // Product
  cantidad: decimal             // Quantity
  um: string                    // Unit of measure
  porcentajeMax: decimal        // Maximum percentage
  porcentajeMin: decimal        // Minimum percentage
  unidadTolerancia: string      // Tolerance unit
  usuario: string               // User
  estadoVersionSistema: string  // System version status
  fechaIngreso: string          // Entry date
  fechaActualizacion: string    // Update date
  fechaCargaSistema: string     // System load date
  validoDesde: string           // Valid from
  validoHasta: string           // Valid until
  fechaIngresoTolerancia: string // Tolerance entry date
  vigDesdeTol: string           // Tolerance valid from
  vigHastaTol: string           // Tolerance valid until
  estadoTolerancia: string      // Tolerance status
  usuarioTol: string            // Tolerance user
  temporal: string              // Temporary flag
}

{
  pagination: PaginationInput   // Page number and size
  sort: SortInput[]            // Sort criteria
  conditions: ConditionInput[] // Filter conditions
}

{
  pageNumber: int  // Page number (1-based)
  pageSize: int    // Items per page
}

{
  field: string     // Field name to sort by
  direction: string // "ASC" or "DESC"
}

{
  field: string      // Field name
  operator: string   // Comparison operator (=, !=, >, <, >=, <=, LIKE, IN)
  value: string      // Comparison value
}

Task<JsonElement> ExecuteQueryAsync(string sql)

Task<int> ExecuteNonQueryAsync(string sql)

Task ExecuteNonQueryFastAsync(string sql)

using (var uow = new DatabricksUnitOfWork(client))
{
    await uow.AddOperationAsync("INSERT INTO ...");
    await uow.AddOperationAsync("UPDATE ...");
    await uow.CommitAsync();
}

mutation CreateSemielaboradoAnalisis($input: SemielaboradoAnalisisInput!) {
  createSemielaboradoAnalisis(input: $input) {
    id
    fechaAnalisis
    estado
  }
}

mutation UpdateRutaDistancia($id: String!, $input: RutaDistanciaInput!) {
  updateRutaDistancia(id: $id, input: $input) {
    id
    distanciaKm
    updatedAt
  }
}

⏳ Timeout esperando resultado de Databricks.

❌ Databricks error: Estado=FAILED, Mensaje={error message}

{
  "Databricks": {
    "BaseUrl": "https://your-databricks-workspace.azuredatabricks.net",
    "WarehouseId": "your-warehouse-id",
    "DatabricksId": "2ff814a6-3304-4ab8-85cb-cd0e6f879c1d",
    "AuthMode": "ManagedIdentity",
    "AccessToken": "optional-static-token"
  }
}