Procedura: Eseguire le transazioni
Il driver SQLSRV dei driver Microsoft per PHP per SQL Server fornisce tre funzioni per l'esecuzione di transazioni:
Il driver PDO_SQLSRV fornisce tre metodi per l'esecuzione di transazioni:
Per un esempio, vedere PDO::beginTransaction .
Di seguito in questo argomento viene descritto come usare il driver SQLSRV per eseguire le transazioni.
Osservazioni:
I passaggi principali per l'esecuzione di una transazione sono i seguenti:
Avviare la transazione con sqlsrv_begin_transaction.
Verificare l'esito positivo o negativo di ogni query inclusa nella transazione.
Se appropriato, eseguire il commit della transazione con sqlsrv_commit. In caso contrario, eseguire il rollback della transazione con sqlsrv_rollback. Dopo la chiamata a sqlsrv_commit o sqlsrv_rollback viene ripristinata la modalità autocommit per il driver.
Per impostazione predefinita, i driver Microsoft per PHP per SQL Server sono in modalità di commit automatico. Ciò significa che viene eseguito automaticamente il commit di tutte le query al completamento dell'operazione a meno che non siano state programmate come parte di una transazione esplicita usando sqlsrv_begin_transaction.
Se non viene eseguito il commit di una transazione esplicita tramite sqlsrv_commit, viene eseguito il rollback alla chiusura della connessione o al termine dello script.
Non usare Transact-SQL incorporato per l'esecuzione delle transazioni. Ad esempio, non eseguire un'istruzione con "BEGIN TRANSACTION" come query Transact-SQL per iniziare una transazione. Il comportamento transazionale previsto non può essere garantito quando si usa Transact-SQL incorporato per l'esecuzione delle transazioni.
Usare le funzioni sqlsrv elencate in precedenza per eseguire le transazioni.
Esempio
Descrizione
L'esempio seguente esegue diverse query come parte di una transazione. Se tutte le query hanno esito positivo, viene eseguito il commit della transazione. Se una delle query ha esito negativo, viene eseguito il rollback della transazione.
L'esempio tenta di eliminare un ordine di vendita dalla tabella Sales.SalesOrderDetail e di correggere i livelli di inventario del prodotto nella tabella Product.ProductInventory per ogni prodotto dell'ordine di vendita. Queste query vengono incluse in una transazione perché tutte le query devono essere completate correttamente per riflettere accuratamente lo stato degli ordini e la disponibilità del prodotto.
La prima query dell'esempio recupera gli ID prodotto e le quantità per l'ID ordine di vendita specificato. Questa query non è inclusa nella transazione. Lo script viene tuttavia interrotto se la query ha esito negativo perché ID prodotto e quantità sono necessari per completare le query della transazione successiva.
Le query che seguono (eliminazione dell'ordine di vendita e aggiornamento delle quantità di inventario del prodotto) sono parte della transazione.
Nell'esempio si presuppone che SQL Server e il database AdventureWorks siano installati nel computer locale. Quando si esegue l'esempio dalla riga di comando, tutto l'output viene scritto nel browser.
Codice
<?php
/* Connect to the local server using Windows Authentication and
specify the AdventureWorks database as the database in use. */
$serverName = "(local)";
$connectionInfo = array( "Database"=>"AdventureWorks");
$conn = sqlsrv_connect( $serverName, $connectionInfo);
if( $conn === false )
{
echo "Could not connect.\n";
die( print_r( sqlsrv_errors(), true));
}
/* Begin transaction. */
if( sqlsrv_begin_transaction($conn) === false )
{
echo "Could not begin transaction.\n";
die( print_r( sqlsrv_errors(), true));
}
/* Set the Order ID. */
$orderId = 43667;
/* Execute operations that are part of the transaction. Commit on
success, roll back on failure. */
if (perform_trans_ops($conn, $orderId))
{
//If commit fails, roll back the transaction.
if(sqlsrv_commit($conn))
{
echo "Transaction committed.\n";
}
else
{
echo "Commit failed - rolling back.\n";
sqlsrv_rollback($conn);
}
}
else
{
"Error in transaction operation - rolling back.\n";
sqlsrv_rollback($conn);
}
/*Free connection resources*/
sqlsrv_close( $conn);
/*---------------- FUNCTION: perform_trans_ops -----------------*/
function perform_trans_ops($conn, $orderId)
{
/* Define query to update inventory based on sales order info. */
$tsql1 = "UPDATE Production.ProductInventory
SET Quantity = Quantity + s.OrderQty
FROM Production.ProductInventory p
JOIN Sales.SalesOrderDetail s
ON s.ProductID = p.ProductID
WHERE s.SalesOrderID = ?";
/* Define the parameters array. */
$params = array($orderId);
/* Execute the UPDATE statement. Return false on failure. */
if( sqlsrv_query( $conn, $tsql1, $params) === false ) return false;
/* Delete the sales order. Return false on failure */
$tsql2 = "DELETE FROM Sales.SalesOrderDetail
WHERE SalesOrderID = ?";
if(sqlsrv_query( $conn, $tsql2, $params) === false ) return false;
/* Return true because all operations were successful. */
return true;
}
?>
Commenti
Per porre l'attenzione sul comportamento delle transazioni, una parte della gestione degli errori consigliata non è inclusa nell'esempio. Nel caso di un'applicazione di produzione è consigliabile cercare eventuali errori in tutte le chiamate a una funzione sqlsrv e gestirli di conseguenza.
Vedi anche
Aggiornamento dei dati (Driver Microsoft per PHP per SQL Server)