Como executar transações
O driver SQLSRV dos Drivers da Microsoft para PHP para SQL Server oferece três funções para a execução de transações:
O driver PDO_SQLSRV oferece três métodos para a execução de transações:
Para obter um exemplo, consulte PDO::beginTransaction .
O restante deste tópico explica e demonstra como usar o driver SQLSRV para executar transações.
Comentários
As etapas para executar uma transação podem ser resumidas da seguinte forma:
Inicie a transação com sqlsrv_begin_transaction.
Verifique o êxito ou a falha de cada consulta que é parte da transação.
Se adequado, confirme a transação com sqlsrv_commit. Caso contrário, reverta a transação com sqlsrv_rollback. Depois de chamar sqlsrv_commit ou sqlsrv_rollback, o driver será retornado para o modo de confirmação automática.
Por padrão, o Drivers da Microsoft para PHP para SQL Server está no modo de confirmação automática. Isso significa que todas as consultas são confirmadas automaticamente quando obtêm êxito, exceto se foram designadas como parte de uma transação explícita usando sqlsrv_begin_transaction.
Se uma transação explícita não for confirmada com sqlsrv_commit, ela será revertida no fechamento da conexão ou no encerramento do script.
Não use o Transact-SQL inserido para executar transações. Por exemplo, não execute uma instrução com "BEGIN TRANSACTION" como a consulta Transact-SQL para iniciar uma transação. O comportamento transacional esperado não pode ser garantido ao usar o Transact-SQL inserido para executar transações.
As funções do sqlsrv listadas anteriormente devem ser usadas para executar transações.
Exemplo
Descrição
O exemplo a seguir executa várias consultas como parte de uma transação. Se todas as consultas forem bem-sucedidas, a transação será confirmada. Se uma das consultas falhar, a transação será revertida.
O exemplo tenta excluir uma ordem de venda da tabela Sales.SalesOrderDetail e ajustar os níveis de estoque de produto na tabela Product.ProductInventory para cada produto na ordem de venda. Essas consultas estão incluídas em uma transação porque todas as consultas devem ter êxito para que o banco de dados reflita com precisão o estado dos pedidos e a disponibilidade do produto.
A primeira consulta no exemplo recupera identificações e quantidades de produto para uma identificação especificada de ordem de venda. Esta consulta não faz parte da transação. No entanto, o script será encerrado se essa consulta falhar porque as identificações e quantidades de produto são necessárias para concluir consultas que fazem parte da transação subsequente.
As consultas resultantes (exclusão da ordem de venda e atualização das quantidades de estoque do produto) são parte da transação.
O exemplo supõe que o SQL Server e o banco de dados AdventureWorks estejam instalados no computador local. Toda a saída será gravada no console quando o exemplo for executado da linha de comando.
Código
<?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;
}
?>
Comentários
Com a finalidade de nos concentrarmos no comportamento da transação, alguns tratamentos de erro recomendados não estão incluídos no exemplo anterior. Para um aplicativo de produção, é recomendável verificar se há erros em qualquer chamada a uma função sqlsrv e tratá-los de acordo com as necessidades do aplicativo.
Consulte Também
Atualizar dados (Drivers da Microsoft para PHP para SQL Server)