Come trasferire i dati tramite SQL Gateway tra controller e qualsiasi database

 

Come funziona?

Requisiti di sistema

Sono necessari i seguenti requisiti di sistema:

oServer SQL (ad esempio MySQL, non fornito da Schneider Electric)

oClient SQL (ad esempio MySQL Workbench, non fornito da Schneider Electric)

oDatabase, creato con SQL Client (ad esempio MySQL Workbench)

oSQL Gateway (è un'installazione separata sul DVD EcoStruxure Machine Expert)

oLibreria SqlRemoteAccess (parte dell'installazione EcoStruxure Machine Expert)

Come trasferire i dati tramite SQL Gateway tra controller e qualsiasi database

Per poter trasferire i dati, è necessario dapprima stabilire la connessione SQL con il SQL Gateway. Per informazioni dettagliate, vedere il documento SQL Gateway - Guida utente.

I blocchi funzione per lo scambio dei dati richiedono l'indirizzo IP del SQL Gateway e la porta su cui avviene l'ascolto. Inoltre, il nome della connessione, per cui è configurata la connessione al database SQL all'interno del gateway, deve essere fornito al blocco funzione.

NOTA: La sintassi SQL negli esempi di codice in questa descrizione dipende da un server MySQL; se si usa un altro server SQL, i comandi possono essere diversi.

Scrittura di dati da un controller nel database mediante connessione TCP sicura

Dichiarazione:

PROGRAM WriteData_Secured
VAR
    fbSqlDbRequest          : SE_SQL.FB_SqlDbRequest;
    stExtConnectionSettings : SE_SQL.ST_ExtendedConnectionSettings;
    refRequestWstring       : SE_SQL.RequestWstring;
    refUserData             : SE_SQL.UserData;
    etSqlRequest            : SE_SQL.ET_SqlRequest;
END_VAR

Implementazione:

stExtConnectionSettings.wsDbConnectionName      := "ConnectionCountry";
stExtConnectionSettings.wsGwIpAddress           := "10.128.154.47";
stExtConnectionSettings.wGwPort                 := 3458;
stExtConnectionSettings.timSqlTimeout           := T#5S;
stExtConnectionSettings.timSqlConnectionTimeout := T#10S;
etSqlRequest                            := SE_SQL.ET_SqlRequest.Write;

// SQL Command to insert a new Country
refRequestWstring[1] := "INSERT INTO world.countries (Country, CapitalCity, Language)";
refRequestWstring[2] := "values ('Germany', 'Berlin', 'german')";

IF NOT fbSqlDbRequest.q_xReady THEN
  fbSqlDbRequest(i_xEnable:= TRUE,
                 i_xExecute:= FALSE,
                 i_etSqlRequest:= etSqlRequest,
                 i_refRequestWstring:= refRequestWstring,
                 i_uiNumOfWstrings:= 2,
                 i_refUserData:= refUserData,
                 iq_stExtendedConnSettings:= stExtConnectionSettings);
ELSE
  fbSqlDbRequest(i_xEnable:= TRUE,
                 i_xExecute:= TRUE,
                 i_etSqlRequest:= etSqlRequest,
                 i_refRequestWstring:= refRequestWstring,
                 i_uiNumOfWstrings:= 2,
                 i_refUserData:= refUserData,
                 iq_stExtendedConnSettings:= stExtConnectionSettings);
END_IF

Descrizione dei parametri utilizzati

NOTA: È possibile utilizzare soltanto una richiesta per chiamata del blocco funzione.

Lettura dei dati con un controller da un database mediante connessione TCP sicura

Dichiarazione:

PROGRAM ReadData_Secured
VAR
    fbSqlDbRequest          : SE_SQL.FB_SqlDbRequest;
    stExtConnectionSettings : SE_SQL.ST_ExtendedConnectionSettings;
    refRequestWstring       : SE_SQL.RequestWstring;
    refUserData             : SE_SQL.UserData;
    etSqlRequest            : SE_SQL.ET_SqlRequest;
END_VAR

Implementazione:

stExtConnectionSettings.wsDbConnectionName      := "ConnectionCountry";
stExtConnectionSettings.wsGwIpAddress           := "10.128.154.47";
stExtConnectionSettings.wGwPort                 := 3458;
stExtConnectionSettings.timSqlTimeout           := T#5S;
stExtConnectionSettings.timSqlConnectionTimeout := T#10S;
etSqlRequest                            := SE_SQL.ET_SqlRequest.Read;

// SQL Command to read all Countries in a database
refRequestWstring[1] := "SELECT * FROM world.countries";

IF NOT fbSqlDbRequest.q_xReady THEN
  fbSqlDbRequest(i_xEnable:= TRUE,
                 i_xExecute:= FALSE,
                 i_etSqlRequest:= etSqlRequest,
                 i_refRequestWstring:= refRequestWstring,
                 i_uiNumOfWstrings:= 1,
                 i_refUserData:= refUserData,
                 iq_stExtendedConnSettings:= stExtConnectionSettings);
ELSE
  fbSqlDbRequest(i_xEnable:= TRUE,
                 i_xExecute:= TRUE,
                 i_etSqlRequest:= etSqlRequest,
                 i_refRequestWstring:= refRequestWstring,
                 i_uiNumOfWstrings:= 1,
                 i_refUserData:= refUserData,
                 iq_stExtendedConnSettings:= stExtConnectionSettings);
END_IF

Descrizione dei parametri utilizzati

Impostazioni avanzate per il buffer dati / Richiesta con i parametri globali

NOTA: Le impostazioni avanzate possono essere sovrascritte specificamente per il progetto nel Gestore libreria.