Query con instrucciones MongoSQL

Instrucción SELECT

SELECT * FROM sessions;

MongoSQL devuelve todos los documentos de la colección Sessions.

Declaración LIMIT

SELECT * FROM users LIMIT 2;

MongoSQL devuelve dos documentos de la colección Users.

Instrucción WHERE

SELECT * FROM users WHERE name = 'Jon Snow';

MongoSQL devuelve documentos de la colección Users donde el name del usuario es Jon Snow.

CON palabra clave

La palabra clave WITH facilita la creación de fuentes de datos derivadas para su uso posterior.

WITH RecentSales AS (
  SELECT customer_id, SUM(amount) AS total_sales
  FROM sales
  WHERE sale_date > '2025-01-01'
  GROUP BY customer_id
)
SELECT customer_id, total_sales
FROM RecentSales
WHERE total_sales > 1000;

MongoSQL retorna documentos de la colección Sales que tienen customer_id con ventas totales superiores a 1000 después del 1 de enero de 2025.

APLANAR

FLATTEN aplana los datos semiestructurados (pares de nombre y valor en JSON) en columnas separadas. Los nombres de los campos se convierten en nombres de columnas que contienen todos los valores de ese campo en filas.

La sintaxis para aplanar documentos anidados es una función FLATTEN que se puede utilizar en la cláusula FROM junto con una fuente de datos y opciones.

SELECT *
FROM FLATTEN(<data source>
 WITH DEPTH => <integer>,
 SEPARATOR => <string>
)

Ejemplo de aplanamiento

En un escenario de ejemplo, una colección customerInfo contiene documentos que están estructurados de la siguiente manera:

{
  id: 1,
  location: "New York",
  customer: {
    age: 50,
    email: "customer@email.com",
    satisfaction: 5
  }
}

Si ejecutas la query SELECT * FROM customerInfo, MongoSQL devuelve documentos con los siguientes campos de nivel superior:

Si ejecutas la query SELECT * FROM FLATTEN(customerInfo), MongoSQL devuelve documentos con los siguientes campos de nivel superior:

Cuando utilizas FLATTEN, cada campo aplanado del documento original se convierte en un campo de primer nivel en el conjunto de resultados. Los campos anidados se concatenan con los nombres de campo principal y se separan mediante el delimitador por defecto, _.

UNWIND

UNWIND descompone un campo de arreglo de la fuente de datos de entrada para generar una fila para cada elemento de ese arreglo. Para aprender más información sobre el desenrollado, consulta la Documentación de la etapa de agregación $unwind.

La sintaxis para descomprimir campos de arreglo es una función UNWIND que se puede utilizar en la cláusula FROM junto con una fuente de datos y opciones.

SELECT *
FROM UNWIND(<data source>
 WITH PATH | PATHS => <array_paths>,
 INDEX => <identifier>,
 OUTER => <bool>
)

Ejemplo de desenrollado: campos de nivel superior

En un escenario de ejemplo, una colección customerInfo contiene documentos que están estructurados de la siguiente manera:

{
  id: 1,
  location: "New York",
  customer: {
    age: 50,
    email: "customer@email.com",
    satisfaction: 5
  },
  visits: [
    {
      year: 2020,
      score: 10
    },
    {
      year: 2021,
      score: 8
    },
    {
      year: 2022
      score: 7
    }
  ]
}

Si ejecutas la query SELECT * FROM customerInfo, MongoSQL devuelve documentos con los siguientes campos de nivel superior:

Si ejecutas la query SELECT * FROM UNWIND(customerInfo WITH PATH => visits, INDEX => idx), MongoSQL devuelve documentos con los siguientes campos de nivel superior:

Cuando usas UNWIND con PATH => visits, cada objeto visits se convierte en una fila de tabla.

Ejemplo de desenrollado: matrices anidadas y hermanas

En un escenario de ejemplo, una colección customerInfo contiene documentos que están estructurados de la siguiente manera:

{
  "id": 1,
  "location": "New York",
  "customer": {
    "age": 50,
    "email": "customer@email.com",
    "satisfaction": 5
  },
  "visits": [
    {
      "year": 2020,
      "score": 10
    },
    {
      "year": 2021,
      "score": 8
    },
    {
      "year": 2022,
      "score": 7
    }
  ],
  "purchases": [
    {
      "transaction": "1A",
      "transactions": [
        {
          "amount": 100
        },
        {
          "amount": 150
        }
      ]
    },
    {
      "transaction": "2B",
      "transactions": [
        {
          "amount": 200
        }
      ]
    }
  ]
}

Supongamos que ejecuta la siguiente consulta:

SELECT v.year AS visit_year, v.score AS visit_score, p.transaction AS transaction_id, t.amount AS purchase_amount
FROM UNWIND(
  customerInfo WITH PATHS => (
    visits[INDEX => visit_idx],
    purchases[OUTER => TRUE, INDEX => purchase_idx].transactions[]
  ),
  INDEX => idx,
  OUTER => FALSE
)

La query anterior realiza lo siguiente:

• Desenrolla la matriz visits y asigna un nombre de índice visit_idx para rastrear la posición del índice dentro de la matriz desenrollada.

• Desenrolla el arreglo purchases y desenrolla el arreglo transactions dentro de cada objeto purchases. También conserva cualquier compra con un arreglo transactions vacío o faltante utilizando OUTER => TRUE.

MongoSQL devuelve documentos con los siguientes campos:

En los resultados, cada fila contiene datos de una única entrada visits y una única entrada transactions.

Ejemplo combinado de FLATTEN y UNWIND

El siguiente ejemplo combina las funciones FLATTEN y UNWIND.

En un escenario de ejemplo, una colección customerInfo contiene documentos que están estructurados de la siguiente manera:

{
  id: 1,
  location: "New York",
  customer: {
    age: 50,
    email: "customer@email.com",
    satisfaction: 5
  },
  visits: [
    {
      year: 2020,
      score: 10
    },
    {
      year: 2021,
      score: 8
    },
    {
      year: 2022
      score: 7
    }
  ]
}

Si ejecutas la query SELECT * FROM customerInfo, MongoSQL devuelve documentos con los siguientes campos de nivel superior:

Si ejecutas la query Select * from FLATTEN(UNWIND(customerInfo WITH PATH => visits, INDEX => idx)), MongoSQL devuelve documentos con los siguientes campos de nivel superior:

Cuando se utilizan ambas funciones FLATTEN y UNWIND, el visits arreglo se desenrolla y el documento resultante se aplana.