Connettore SQL

Panoramica

Il connettore SQL scrive dati su database relazionali.

Tipo Connettore: SqlWriter

Database Supportati:

• MySQL
• PostgreSQL
• SQL Server (MSSQL)

Configurazione

MySQL

{
  "type": "SqlWriter",
  "config": {
    "connectionString": "user:password@tcp(localhost:3306)/database_name",
    "driver": "mysql",
    "table": "sensor_data",
    "writeAction": "Insert",
    "mode": "ColumnMapping",
    "columns": {
      "temperature": "temp_column",
      "pressure": "press_column",
      "timestamp": "ts_column"
    }
  }
}

PostgreSQL

{
  "type": "SqlWriter",
  "config": {
    "connectionString": "host=localhost port=5432 user=postgres password=pass dbname=mydb sslmode=disable",
    "driver": "postgres",
    "table": "measurements",
    "writeAction": "Insert",
    "mode": "ColumnMapping",
    "columns": {
      "temperature": "temperature",
      "humidity": "humidity"
    }
  }
}

SQL Server

{
  "type": "SqlWriter",
  "config": {
    "connectionString": "sqlserver://user:pass@localhost:1433?database=mydb",
    "driver": "sqlserver",
    "table": "sensor_readings",
    "writeAction": "Upsert",
    "mode": "ColumnMapping",
    "columns": {
      "sensor_id": "id",
      "value": "reading_value"
    }
  }
}

Parametri di Configurazione

• connectionString: Stringa di connessione specifica del database
• driver: Driver database (mysql, postgres, sqlserver)
• table: Nome tabella di destinazione
• writeAction: Operazione di scrittura (Insert, Update, Upsert)
• mode: Modalità mappatura (ColumnMapping)
• columns: Mappa chiavi payload a colonne database

Azioni di Scrittura

Insert

Aggiungi nuove righe:

{
  "writeAction": "Insert"
}

Update

Aggiorna righe esistenti (richiede condizione WHERE):

{
  "writeAction": "Update"
}

Upsert

Inserisci o aggiorna se esiste:

{
  "writeAction": "Upsert"
}

Mappatura Colonne

Mappa chiavi payload Meddle a colonne database:

{
  "columns": {
    "payload_key": "database_column",
    "temperature": "temp_celsius",
    "pressure": "pressure_bar",
    "timestamp": "recorded_at"
  }
}

Stringhe di Connessione

MySQL

user:password@tcp(host:port)/database?param=value

PostgreSQL

host=localhost port=5432 user=user password=pass dbname=db sslmode=disable

SQL Server

sqlserver://user:pass@host:port?database=db&param=value

Caso d’Uso: Logging Dati Produzione

{
  "type": "SqlWriter",
  "config": {
    "connectionString": "user:pass@tcp(mysql.local:3306)/production",
    "driver": "mysql",
    "table": "machine_logs",
    "writeAction": "Insert",
    "mode": "ColumnMapping",
    "columns": {
      "machine_id": "machine_id",
      "temperature": "temperature",
      "speed": "rpm",
      "status": "operational_status",
      "timestamp": "log_time"
    }
  }
}

Best Practice

1. Crea indici appropriati su colonne frequentemente interrogate
2. Usa Upsert per operazioni idempotenti
3. Assicurati che lo schema tabella corrisponda alle mappature colonne
4. Usa connection pooling per scenari ad alto throughput
5. Monitora prestazioni database e tempi esecuzione query

Risoluzione dei Problemi

Connessione Fallita

• Verifica formato stringa di connessione
• Controlla che il server database sia in esecuzione
• Verifica credenziali
• Controlla regole firewall

Colonna Non Trovata

• Assicurati che i nomi colonne nella mappatura corrispondano allo schema database
• Controlla che la tabella esista
• Verifica case sensitivity

Connettori Correlati

• InfluxDB - Alternativa time-series
• MongoDB - Alternativa NoSQL
• Reshape - Trasforma dati prima della scrittura