Query con instrucciones MongoSQL

Instrucción SELECT

SELECT * FROM sessions;

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

Instrucció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 puede ser usada 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 a modo de ejemplo, una colección de customerInfo contiene documentos 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 $unwind documentación de la etapa de agregación.

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 desenrollar: campos de nivel superior

En un escenario a modo de ejemplo, una colección de customerInfo contiene documentos 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 Unwind: Arreglos Anidados y Hermanos

En un escenario a modo de ejemplo, una colección de customerInfo contiene documentos 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
        }
      ]
    }
  ]
}

Supón que ejecutas la siguiente query:

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

La query anterior realiza lo siguiente:

• Desenrolla el arreglo visits y asigna un nombre de índice visit_idx para rastrear la posición del índice dentro del arreglo desenrollado. No incluye valores faltantes o vacíos de visits al establecer OUTER => FALSE.

• Desenrolla el arreglo purchases y desenrolla el arreglo transactions dentro de cada objeto purchases. Conserva cualquier purchases arreglo faltante o vacío utilizando OUTER => TRUE. También asigna un nombre de índice purchase_idx para rastrear la posición del índice dentro del arreglo desenrollado purchases, y un nombre de índice purchases_transactions_idx para rastrear la posición dentro del arreglo desenrollado transactions dentro de cada objeto purchases.

• Selecciona los subcampos year y score de los objetos visits, el subcampo transaction de los objetos purchases y el subcampo amount de los objetos transactions dentro de cada objeto purchases, así como todos los campos de índice.

En la consulta anterior:

• OUTER => TRUE se configura como un parámetro de nivel superior en el origen de datos UNWIND, convirtiéndose en el valor predeterminado utilizado para todos los PATHS, a menos que el valor OUTER a nivel de ruta sea diferente.

• INDEX => idx se configura como un parámetro de nivel superior en el origen de datos UNWIND, convirtiéndose en el valor predeterminado utilizado para todos los PATHS, a menos que el valor INDEX a nivel de ruta sea diferente.

  Por ejemplo, transactions no especificó un valor específico de INDEX. Por lo tanto, utiliza este valor de nivel superior para crear el nombre del índice añadiendo _idx a la ruta completa.

MongoSQL devuelve documentos con los siguientes campos:

Ejemplo combinado de FLATTEN y UNWIND

El siguiente ejemplo combina las funciones FLATTEN y UNWIND.

En un escenario a modo de ejemplo, una colección de customerInfo contiene documentos 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.