13. SQL : sélectionner les commandes ouvertes

Lisez un ensemble limité d’enregistrements SQL avec une requête SELECT et créez un CSV de vérification.

Objectif et prérequis

Lisez un ensemble limité d’enregistrements SQL avec une requête SELECT et créez un CSV de vérification.

Cet exemple utilise des données et paramètres de démonstration. Validez le résultat attendu dans votre propre environnement avant de connecter des destinations de production. Les identifiants demo_* sont illustratifs : sélectionnez vos propres connexions ou sources pédagogiques dans l’éditeur. Le JSON ci-dessous présente la structure des blocs et connexions, pas une archive de flux prête à transférer.

Connexion demo_sql est une base SQL pédagogique illustrative. Toutes les adresses, utilisateurs et secrets sont configurés dans le gestionnaire de connexions, et non dans le JSON du graphe.

Données d’entrée pédagogiques

order_id	status	amount
101	open	120
102	closed	70
103	open	30

Blocs, connexions et paramètres exacts

13. SQL : sélectionner les commandes ouvertes. Topologie de l’exemple 13 : 2 blocs, 1 connexion. Les identifiants de nœuds et les ports du graphe configuré sont conservés. — **Schéma du flux 13**
Topologie de l’exemple 13 : 2 blocs, 1 connexion. Les identifiants de nœuds et les ports du graphe configuré sont conservés.

Ajoutez les blocs listés dans le concepteur, ouvrez les propriétés de chacun et définissez ces valeurs. Les noms demo_* désignent les sources et connexions pédagogiques.

Bloc	Paramètre
1 Connexion `sql`	Rôle: `source` Connexion: `demo_sql` Objet externe: Méthode de lecture: `query` Requête: `SELECT order_id, amount FROM demo_orders WHERE status = 'open' ORDER BY order_id`
2 Exportation de données `out`	Format: `csv` Nom du fichier: `open_orders` Rôle: `download` Séparateur: `;` Fuseau horaire: `Europe/Kyiv`

Connexions des ports

sql out → out in

Configuration complète du graphe en JSON

{
  "version": 3,
  "nodes": [
    {
      "id": "sql",
      "type": "connection",
      "label": "sql",
      "config": {
        "role": "source",
        "connection_id": "demo_sql",
        "external": {
          "source_mode": "query",
          "query": "SELECT order_id, amount FROM demo_orders WHERE status = 'open' ORDER BY order_id"
        }
      }
    },
    {
      "id": "out",
      "type": "export",
      "label": "out",
      "config": {
        "format": "csv",
        "filename": "open_orders",
        "destination": "download",
        "delimiter": ";",
        "timezone": "Europe/Kyiv"
      }
    }
  ],
  "edges": [
    {
      "source": "sql",
      "target": "out",
      "source_port": "out",
      "target_port": "in"
    }
  ]
}

Résultat attendu

order_id	amount
101	120
103	30

Deux enregistrements, avec un total amount de 150. ORDER BY rend l’ordre du fichier de vérification déterministe.

Exécuter et vérifier

Créez au préalable demo_orders avec les lignes illustrées dans la base pédagogique, ainsi que la connexion demo_sql.
Testez la connexion et sélectionnez le mode requête dans le bloc source.
Exécutez et vérifiez les identifiants 101/103 ; l’enregistrement fermé 102 ne doit pas apparaître dans le résultat.

Erreurs courantes

La lecture autorise une seule requête sans modification ; n’insérez ni DDL ni instructions multiples.
Les noms de tables et de schémas dépendent de votre base ; utilisez schema.demo_orders si nécessaire.
Sans ORDER BY, l’ordre du résultat SQL n’est pas garanti.