Recopie MS-SQL vers PostgreSQL

Timer → SQL SELECT (MS-SQL) → Split → SQL INSERT (PostgreSQL)

# Datasource MS-SQL
camel.datasource.mssql.url=jdbc:sqlserver://mssql:1433;databaseName=sourcedb;encrypt=false
camel.datasource.mssql.driver-class-name=com.microsoft.sqlserver.jdbc.SQLServerDriver
camel.datasource.mssql.username=sa
camel.datasource.mssql.password=Str0ngPass!

# Datasource PostgreSQL
camel.datasource.postgres.url=jdbc:postgresql://postgres:5432/targetdb
camel.datasource.postgres.driver-class-name=org.postgresql.Driver
camel.datasource.postgres.username=camel
camel.datasource.postgres.password=camel

- route:
    id: mssql-to-postgres
    description: Recopie de la table produits de MS-SQL vers PostgreSQL
    from:
      uri: timer:sync
      parameters:
        period: 60000       # toutes les 60 secondes
        repeatCount: 1      # exécution unique (retirer pour répétition)
    steps:
      - log:
          message: "Démarrage de la synchronisation MS-SQL → PostgreSQL"

      # Lecture source MS-SQL
      - to:
          uri: jdbc:mssql
          parameters:
            useHeadersAsParameters: true
          body: "SELECT id, nom, prix, actif FROM dbo.produits"

      # Éclatement ligne par ligne
      - split:
          expression:
            simple: "${body}"
          steps:
            # Transformation des types (BIT → BOOLEAN)
            - setBody:
                expression:
                  groovy: |
                    def row = request.body
                    row['actif'] = row['actif'] == 1
                    return row

            # Insertion dans PostgreSQL (upsert)
            - to:
                uri: jdbc:postgres
                body: >
                  INSERT INTO produits (id, nom, prix, actif)
                  VALUES (:#id, :#nom, :#prix, :#actif)
                  ON CONFLICT (id) DO UPDATE
                  SET nom = EXCLUDED.nom,
                      prix = EXCLUDED.prix,
                      actif = EXCLUDED.actif

      - log:
          message: "Synchronisation terminée"

docker exec -it camel-postgres psql -U camel -d targetdb \
  -c "SELECT * FROM produits;"

 id |   nom    | prix  | actif
----+----------+-------+-------
  1 | Article A| 10.50 | t
  2 | Article B| 25.00 | t
  3 | Article C |  7.99 | t

body: >
  SELECT id, nom, prix, actif
  FROM dbo.produits
  ORDER BY id
  OFFSET :#offset ROWS FETCH NEXT 1000 ROWS ONLY