JavaScript Editor Javascript validator     Javascripts

Main Page


Previous Section Next Section

12.2 Updating Data with Transactions

A very important feature of most industrial-strength databases is support for transactions. A transaction is a set of database operations that must all complete or fail together. That is, either all the operations must complete successfully (commit the transaction), or all must be undone (roll back the transaction) so that the database is left in the state it was in before the transaction began.

The canonical transaction is depositing a check. If I write a check to you for $50 and you deposit it, we both expect that once the bank transaction is completed, your account will have increased by $50 and mine will have decreased by $50. Presumably the bank computer accomplishes this in two steps:

  1. Reduce my account by $50.

  2. Increase your account by $50.

If the system fails between steps 1 and 2 or for any reason your account cannot be increased by $50, the transaction should be rolled back; that is, it should fail as a whole (neither account should be affected).

If my account is reduced by $50 and your account is not increased, then the database has become corrupted. This should never be allowed, and it is the job of transactions to ensure either that both actions are taken or that neither is.

The remaining alternative, in which my account is not decreased but yours is increased, may be a happy outcome for you ("Bank Error In Your Favor—Collect $50"), but the bank would not be pleased.

12.2.1 The ACID Test

Database designers define the requirements of a transaction in the so-called "ACID" test. ACID is an acronym for Atomic, Consistent, Isolated, and Durable. Here's a brief summary of what each of these terms means:

Atomic

An atomic interaction is indivisible (i.e., it cannot be partially implemented). Every transaction must be atomic. For instance, in the previous banking example, it must not be possible to decrement my account but fail to increment yours. If the transaction fails, it must return the database to the state it would have been in without the transaction.

All transactions, even failed ones, affect the database in trivial ways (e.g., resources are expended, performance is affected). The atomic requirement only implies that, if a transaction is rolled back, all of the tables and data will be in the state they would have been in had the transaction not been attempted at all.

Consistent

The database is presumed to be in a consistent state before the transaction begins, and the transaction must leave it in a consistent state when it completes. While the transaction is being processed, however, the database need not be in a consistent state. To continue with our example of depositing a check, the database need not be consistent during the transaction (e.g., it is okay to decrement my account before incrementing your account), but it must end in a consistent state (i.e., when the transaction completes, the books must balance).

Isolated

Transactions are not processed one at a time. Typically a database may be processing many transactions at once, switching its attention back and forth among various operations. This creates the possibility that a transaction can view and act upon data that reflects intermediate changes from another transaction that is still in progress and that therefore currently has its data in an inconsistent state. Transaction isolation is designed to prevent this problem. For a transaction to be isolated, the effects of the transaction must be exactly as if the transaction were acted on alone; there can be no effects on or dependencies on other database activities. For more information, see the sidebar, "Data Isolation."

Durable

Once a transaction is committed, the effect on the database is permanent.

Data Isolation

Creating fully-isolated transactions in a multithreaded environment is a non-trivial exercise. There are three ways isolation can be violated:

  • Lost update: one thread reads a record, a second thread updates the record, and then the first thread overwrites the second thread's update.

  • Dirty read: thread one writes data; thread two reads what thread one wrote. Thread one then overwrites the data, thus leaving thread two with old data.

  • Unrepeatable read: thread one reads data; the data is then overwritten by thread two. Thread one tries to re-read the data but it has changed.

Database experts identify four degrees of isolation:

  • Degree 0 is limited only to preventing the overwriting of data by any other transaction that is of degree 1 or greater.

  • Degree 1 isolation has no lost updates.

  • Degree 2 isolation has no lost updates and no dirty reads but may have unrepeatable reads.

  • Degree 3 isolation has no lost updates, no dirty reads, and no unrepeatable reads.

While details about transaction isolation is beyond the scope of this book, the section on multiuser updates, later in this chapter, discusses issues related to avoiding violation of isolation.

12.2.2 Implementing Transactions

There are two ways to implement transactions in ASP.NET. You can allow the database to manage the transaction by using transactions within your stored procedure, or you can use connection-based transactions. In the latter case, the transaction is created and enforced outside of the database. This allows you to add transaction support to databases that do not otherwise provide for it.

As Appendix B shows, the Bug database is designed so that each bug event is recorded as one record in Bugs and one or more records in BugHistory. In the next example, you will elicit information from the user about a new bug (e.g., the description, severity, etc.), and you will update both the Bugs table and the BugHistory table.

If the update to the BugHistory table fails for any reason, you want to make sure the update to the Bugs table rolls back as well. To ensure this, you wrap these updates in a transaction.

In this example, you will offer the user the option to have the transaction implemented either by the database or by the connection, as shown in Figure 12-2.

Figure 12-2. Data form for transaction-based add
figs/pan2_1202.gif

The .aspx file for this form can be found later in Example 12-8.

If the user selects DB Transaction, call a stored procedure that implements the transaction semantics. If the user selects Connection Transaction, implement the transaction yourself, using an instance of the System.Data.SqlClient.SqlTransaction class.

12.2.2.1 Database transactions

To implement the DB Transaction option, you need a stored procedure (or sproc) that adds a record to the Bugs table and a record to the BugsHistory table, using SQL transaction support.

CREATE PROCEDURE spAddBugWithTransactions

To decide what parameters to provide to this sproc, you must examine the two tables you will update, as shown in Figure 12-3.

Figure 12-3. Bugs and BugHistory
figs/pan2_1203.gif

There are 12 fields that must be filled in for the two tables. For Bugs, the required fields are BugID, Product, Version, Description, and Reporter. Note, however, that you don't need to provide a BugID, which is an identity column provided by the database.

For BugHistory, the obligatory fields are BugHistoryID, BugID, Status, Severity, Response, Owner, and DateStamp. BugHistoryID is another identity column and is thus provided by the database. Note that BugID must match the BugID generated by Bugs. Thus, rather than passing that into the stored procedure, you'll get it back from the database when you add the Bug record. Status will always be Open (new bugs are always open) and so you need not pass it in. Similarly, Response will always be "Bug Created." To simplify this, we'll assume that when you create a new bug, it is always assigned first to the user (i.e., Owner) whose ID is 1. The DateStamp need not be passed as a parameter, if your table is set up to default to the current date. Thus, you are left passing in just the ProductID, Version, Description, Reporter, and Severity:

@ProductID int,
@Version varChar(50),
@Description varChar(8000),
@Reporter int,
@Severity int

The core of the procedure is a pair of Insert statements. First you will insert values into the Bugs table:

Insert into Bugs values (@ProductID, @Version, @Description, @Reporter)

The Bugs table has an identity column, which you can retrieve with the SQL keyword @@identity:

declare @bugID int
select @bugID = @@identity

With that bugID in hand, you are ready to insert a record into BugHistory:

Insert into BugHistory 
(bugID, status, severity, response, owner)
values 
( @bugID,
       1,             -- status
       @Severity,
       'Bug Created', -- action
       1              -- owner
)

Notice that you are hardwiring the status (1 = open), the action (Bug Created) and the owner (6 = a person in QA).

To make this all work with database transactions, before the Insert statement that adds a record to the first table, you need only begin with the line:

Begin Transaction

After the insert, you'll check the @@error value, which should be 0 if the Insert succeeded:

if @@Error <> 0 goto ErrorHandler

If there is an error, you'll jump to the error handler, where you'll call Rollback Transaction:

ErrorHandler:
rollback transaction

If there is no error, you continue on to the second Insert statement. If there is no error after that insert, you are ready to commit the transaction and exit the sproc:

if @@Error <> 0 goto ErrorHandler
commit transaction
return

The net effect is that either both Insert statements are acted on, or neither is. The complete sproc is shown in Example 12-3.

Example 12-3. Stored procedure spAddBugWithTransactions
CREATE PROCEDURE spAddBugWithTransactions
@ProductID int,
@Version varChar(50),
@Description varChar(8000),
@Reporter int,
@Severity int
 AS
Begin Transaction
declare @bugID int
Insert into Bugs values (@ProductID, @Version, @Description, @Reporter)
select @bugID = @@identity
if @@Error <> 0 goto ErrorHandler

Insert into BugHistory 
(bugID, status, severity, response, owner, DateStamp)
values 
( @bugID,
       1,             -- status
       @Severity,
       'Bug Created', -- action
       1,              -- owner
       GetDate(  )  -- DateStamp
)
if @@Error <> 0 goto ErrorHandler
commit transaction
return
ErrorHandler:
rollback transaction
return
GO

With the stored procedure in hand, you are ready to create the ASP.NET page that allows the user to choose a database transaction or a connection-based transaction.

You'll start by creating the radio button list in the .aspx page. To do so, drag a RadioButtonList control onto the form, as shown in Figure 12-4.

Figure 12-4. The radio button list
figs/pan2_1204.gif

Set the properties for the buttons as shown in the following code snippet. You can do this from the Property window or by clicking on the HTML tag and updating the HTML directly:

<asp:radiobuttonlist id="rbTransaction" Runat="server" 
TextAlign="Right" RepeatLayout="flow" 
RepeatDirection="Vertical" repeatColumns="2" CellSpacing="3">
   <asp:ListItem Text="DB Transaction" Value="0" />
   <asp:ListItem Text="Connection Transaction" 
      Value="1" Selected="True" />
</asp:radiobuttonlist>

You also need controls for the various drop-downs and text fields (shown in the Example 12-8 later in this chapter), as well as a button.

<asp:button id="btnAdd" Runat="server" Text="Add"/>

When the user clicks the Add button, your button handler is fired. In C#, it takes the form:

private void btnAdd_Click(object sender, System.EventArgs e)
{
   int whichTransaction = 
     Convert.ToInt32(rbTransaction.SelectedItem.Value);
   if (whichTransaction == 0)
      UpdateDBTransaction(  );
   else
      UpdateConnectionTransaction(  );
}

In VB.NET, the btnAdd_Click event handler appears as follows:

Private Sub btnAdd_Click(sender As Object, e As EventArgs) _
                         Handles btnAdd.Click
   Dim whichTransaction = _
        Convert.ToInt32(rbTransaction.SelectedItem.Value)
   If whichTransaction = 0 Then
      UpdateDBTransaction(  )
   Else
      UpdateConnectionTransaction
   End If
End Sub

The entire job of the button handler is to determine which of the two buttons is chosen and to invoke the appropriate method. If the user chooses a database transaction, you will invoke the private UpdateDBTransaction helper method, which in turn will invoke the spAddBugWithTransactions stored procedure.

You will create a connection and a command object in the normal way, setting the command object's CommandType property to CommandType.StoredProcedure. You will then create all of the parameters and invoke the stored procedure by calling the ExecuteNonQuery method. There is nothing new or surprising here; all the work to support the transaction is actually done in the stored procedure itself. The C# version of UpdateDBTransaction looks like this:

private void UpdateDBTransaction(  )
{
   // connection string to connect to the Bugs Database
   string connectionString = 
      "server=YourServer; uid=sa; pwd=YourPassword; " +
      "database=ProgASPDotNetBugs";

   // Create connection object, initialize with 
   // connection string. Open it.
   System.Data.SqlClient.SqlConnection connection = 
      new System.Data.SqlClient.SqlConnection(connectionString);
   connection.Open(  );

   // create a second command object for the bugs history table
   System.Data.SqlClient.SqlCommand command = 
      new System.Data.SqlClient.SqlCommand(  );
   command.Connection = connection;

   command.CommandText= "spAddBugWithTransactions";
   command.CommandType = CommandType.StoredProcedure;

   // declare the parameter object
   System.Data.SqlClient.SqlParameter param;

   // add each parameter and set its direciton and value
   param = command.Parameters.Add("@ProductID",SqlDbType.Int); 
   param.Direction = ParameterDirection.Input;
   param.Value = lbProduct.SelectedItem.Value;  // from the list box

   param = command.Parameters.Add("@Version",SqlDbType.VarChar,50); 
   param.Direction = ParameterDirection.Input;
   param.Value = txtVersion.Text;               // from the text box

   param = command.Parameters.Add("@Description",SqlDbType.VarChar,8000); 
   param.Direction = ParameterDirection.Input;
   param.Value = txtDescription.Text;           // from the text box

   param = command.Parameters.Add("@Reporter",SqlDbType.Int); 
   param.Direction = ParameterDirection.Input;
   param.Value = lbReporter.SelectedItem.Value; // from the list box

   param = command.Parameters.Add("@Severity",SqlDbType.Int); 
   param.Direction = ParameterDirection.Input;
   param.Value = lbSeverity.SelectedItem.Value; // from the list box

   command.ExecuteNonQuery(  ); // execute the sproc
}

Here's the same code in VB .NET:

Private Sub UpdateDBTransaction(  )
   ' connection string to connect to the Bugs Database
   Dim connectionString As String = _
      "server=YourServer; uid=sa; pwd=YourPassword" & _
      "database=ProgASPDotNetBugs"

   ' Create connection object, initialize with 
   ' connection string. Open it.
   Dim connection As New _
     System.Data.SqlClient.SqlConnectionconnectionString)
   connection.Open(  )

   ' create a second command object for the bugs history table
   Dim command As New _
      System.Data.SqlClient.SqlCommand(  )
   command.Connection = connection

   command.CommandText= "spAddBugWithTransactions"
   command.CommandType = CommandType.StoredProcedure

   ' declare the parameter object
   Dim param As System.Data.SqlClient.SqlParameter

   ' add each parameter and set its direciton and value
   param = command.Parameters.Add("@ProductID",SqlDbType.Int)
   param.Direction = ParameterDirection.Input
   param.Value = lbProduct.SelectedItem.Value  ' from the list box

   param = command.Parameters.Add("@Version",SqlDbType.VarChar,50)
   param.Direction = ParameterDirection.Input
   param.Value = txtVersion.Text               ' from the text box

   param = command.Parameters.Add("@Description",SqlDbType.VarChar,8000)
   param.Direction = ParameterDirection.Input
   param.Value = txtDescription.Text           ' from the text box

   param = command.Parameters.Add("@Reporter",SqlDbType.Int)
   param.Direction = ParameterDirection.Input
   param.Value = lbReporter.SelectedItem.Value ' from the list box

   param = command.Parameters.Add("@Severity",SqlDbType.Int)
   param.Direction = ParameterDirection.Input
   param.Value = lbSeverity.SelectedItem.Value ' from the list box

   command.ExecuteNonQuery(  ) ' execute the sproc
End Sub
12.2.2.2 Connection transaction

The user may choose to use a connection transaction rather than a DB transaction. If so, the method UpdateConnectionTransaction is called. With a Connection transaction there is no transaction support provided by the stored procedure, instead you add the transaction support by creating an SQLTransaction object.

For illustration purposes, you'll add to the Bugs table using a stored procedure, but one that does not provide transaction support. You'll add to the BugHistory table using a simple SQL Insert statement. You want the simple update and the stored procedure call to be wrapped inside a transaction, however, to ensure that either both succeed or neither does.

To get started, you'll write the spAddBug sproc shown in Example 12-4 to insert a record into Bugs.

Example 12-4. The spAddBug stored procedure
CREATE PROCEDURE spAddBug
@ProductID int,
@Version varChar(50),
@Description varChar(8000),
@Reporter int,
@BugID int output
 AS
Insert into Bugs values (@ProductID, @Version, @Description, @Reporter)
select @BugID = @@identity

You need only those parameters required for the Bugs table; the BugHistory table is not updated by this sproc. In addition, you must add an output parameter, @BugID, to return the identity of the new Bug record, so that you can pass this to the new record in BugHistory.

The body of the sproc is nothing more than an Insert statement and a statement to set the @BugID parameter with the new BugID retrieved from the @@identity value.

The job of the UpdateConnectionTransaction method, shown in the complete listing below (see Example 12-6) is to invoke both the stored procedure and the SQL Update statement, using a Connection transaction. The steps are as follows:

  1. Create the connection string and the SqlConnection object.

  2. Create the SqlCommand object.

  3. Open the connection.

  4. Instantiate a SqlTransaction object by calling the BeginTransaction method of the SqlConnection object.

  5. Set the SqlCommand object's Transaction property to the SqlTransaction object you've instantiated, and set the SqlCommand object's Connection property to the SqlConnection object you've created.

  6. Open a try block in which you will try to update the two tables. If an exception is thrown, you will catch the exception and roll back the transaction.

  7. Set the SQL command object's CommandText property to the name of the stored procedure, and set the CommandType property to CommandType.StoredProcedure.

  8. Add all the parameters, including the output parameters.

  9. Invoke the Query.

  10. Get back the BugID and use that to invoke a SQL statement to update the BugHistory table.

  11. Commit the transaction.

Example 12-5 shows the complete source code for this example in C#, and Example 12-6 shows it in VB .NET. This code is very similar to the examples in Chapter 11, with the addition of UpdateDBTransaction and UpdateConnectionTransaction, which are shown in bold.

Example 12-5. C# Updating with transactions
using System;
using System.Collections;
using System.ComponentModel;
using System.Data;
using System.Data.SqlClient;
using System.Drawing;
using System.Text;
using System.Web;
using System.Web.SessionState;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.HtmlControls;

namespace BugHistoryTransactions
{
   public class WebForm1 : System.Web.UI.Page
   {
      protected System.Web.UI.WebControls.DataGrid DataGrid1;
      protected System.Web.UI.WebControls.DataGrid HistoryGrid;
      protected System.Web.UI.WebControls.Panel BugHistoryPanel;
      protected System.Web.UI.WebControls.DropDownList lbProduct;
      protected System.Web.UI.WebControls.TextBox txtVersion;
      protected System.Web.UI.WebControls.TextBox txtDescription;
      protected System.Web.UI.WebControls.DropDownList lbSeverity;
      protected System.Web.UI.WebControls.Button btnAdd;
      protected System.Web.UI.WebControls.DropDownList lbReporter;
      protected System.Web.UI.WebControls.RadioButtonList rbTransaction;

      private string connectionString = 
          "server=YourServer; uid=sa; pwd=YourPassword; " & _
          "database=ProgASPDotNetBugs";

   
      public WebForm1(  )
      {
         Page.Init += new System.EventHandler(Page_Init);
      }

      public void OnItemDataBoundEventHandler(
         Object sender, DataGridItemEventArgs e)
      {
         ListItemType itemType = (ListItemType)e.Item.ItemType;
         if (itemType == ListItemType.Header || 
            itemType == ListItemType.Footer || 
            itemType == ListItemType.Separator)
            return;
         
         if (e.Item.DataItem == null) return;
         if (((DataRowView)e.Item.DataItem).
            Row.ItemArray[8].ToString(  ) == "High")
         {
            TableCell severityCell = (TableCell) e.Item.Controls[7];
            severityCell.ForeColor = Color.FromName("Red");
         }
      }

      public void OnSelectedIndexChangedHandler(Object sender, EventArgs e) 
      {
         UpdateBugHistory(  );
      }

      private void UpdateBugHistory(  )
      {
         int index = DataGrid1.SelectedIndex;
         if (index != -1)
         {
            // get the bug id from the data grid
            int bugID = (int) DataGrid1.DataKeys[index];

            // Get a dataset based on that BugID
            DataSet dataSet = CreateBugHistoryDataSet(bugID);

            // bind to the table returned and make
            // the panel visible
            HistoryGrid.DataSource = dataSet.Tables[0];
            HistoryGrid.DataBind(  );
            BugHistoryPanel.Visible = true;
            
         }
         else
         {
            // no history to display, hide the panel
            BugHistoryPanel.Visible = false;
         }
      }

      private void Page_Load(object sender, System.EventArgs e)
      {
         if (!IsPostBack)
         {
            // hide the history panel
            UpdateBugHistory(  );

            // set the data source for the 
            // grid to the first table 
            DataSet ds = CreateBugDataSet(  );
            DataGrid1.DataSource = ds.Tables[0];
            DataGrid1.DataBind(  );

            lbProduct.DataSource = GetDataReader("lkProduct");
            lbProduct.DataBind(  );

            lbSeverity.DataSource = GetDataReader("lkSeverity");
            lbSeverity.DataBind(  );

            lbReporter.DataSource = GetDataReader("People");
            lbReporter.DataBind(  );
         }      
      }

      private SqlDataReader GetDataReader(string whichTable)
      {

         // Create connection object, initialize with 
         // connection string. Open it.
         System.Data.SqlClient.SqlConnection connection = 
            new System.Data.SqlClient.SqlConnection(connectionString);

         connection.Open(  );

         // Create a SqlCommand object and assign the connection
         System.Data.SqlClient.SqlCommand command = 
            new System.Data.SqlClient.SqlCommand(  );
         command.Connection = connection;

         // set the stored procedure to get the bug records
         command.CommandText = "select * from " + whichTable;

         // return the data reader
         return command.ExecuteReader(CommandBehavior.CloseConnection);
      }

      private DataSet CreateBugHistoryDataSet(int bugID)
      {

         // Create connection object, initialize with 
         // connection string. Open it.
         System.Data.SqlClient.SqlConnection connection = 
            new System.Data.SqlClient.SqlConnection(connectionString);
         connection.Open(  );

         // create a second command object for the bugs history table
         System.Data.SqlClient.SqlCommand command = 
            new System.Data.SqlClient.SqlCommand(  );
         command.Connection = connection;

         command.CommandText= "spBugHistory";
         command.CommandType = CommandType.StoredProcedure;

         // declare the parameter object
         System.Data.SqlClient.SqlParameter param;

         // Add a new parameter, get back a reference to it
         param = command.Parameters.Add("@BugID", SqlDbType.Int); 

         // set the parameter's direction and value
         param.Direction = ParameterDirection.Input;
         param.Value = bugID;

         // create a second data adapter and add the command 
         // and map the table
         // then fill the dataset from this second adapter
         SqlDataAdapter dataAdapter = new SqlDataAdapter(  );
         dataAdapter.SelectCommand = command;
         dataAdapter.TableMappings.Add("Table", "BugHistory");

         DataSet dataSet = new DataSet(  );
         dataAdapter.Fill(dataSet);

         return dataSet;
      }

      private DataSet CreateBugDataSet(  )
      {


         // Create connection object, initialize with 
         // connection string. Open it.
         System.Data.SqlClient.SqlConnection connection = 
            new System.Data.SqlClient.SqlConnection(connectionString);
         connection.Open(  );

         // Create a SqlCommand object and assign the connection
         System.Data.SqlClient.SqlCommand command = 
            new System.Data.SqlClient.SqlCommand(  );
         command.Connection = connection;
         command.CommandText = "spBugs";
         command.CommandType = CommandType.StoredProcedure;

         // create a data adapter and assign the command object
         // and add the table mapping for bugs
         SqlDataAdapter dataAdapter = new SqlDataAdapter(  );
         dataAdapter.SelectCommand = command;
         dataAdapter.TableMappings.Add("Table", "Bugs");

         // Create the dataset and use the data adapter to fill it
         DataSet dataSet = new DataSet(  );
         dataAdapter.Fill(dataSet);
         return dataSet;
      }

      private void Page_Init(object sender, EventArgs e)
      {
         InitializeComponent(  );
      }

      #region Web Form Designer generated code
      /// <summary>
      /// Required method for Designer support - do not modify
      /// the contents of this method with the code editor.
      /// </summary>
      private void InitializeComponent(  )
      {    
         this.btnAdd.Click += new System.EventHandler(this.btnAdd_Click);
         this.Load += new System.EventHandler(this.Page_Load);

      }
      #endregion

      private void UpdateConnectionTransaction(  )
    {

         // Create connection object, initialize with 
         // connection string. Open it.
         System.Data.SqlClient.SqlConnection connection = 
            new System.Data.SqlClient.SqlConnection(connectionString);

         // declare the command object for the sql statements
         System.Data.SqlClient.SqlCommand command = 
            new System.Data.SqlClient.SqlCommand(  );

         // declare an instance of SqlTransaction
         SqlTransaction transaction;

         // connection string to connect to the Bugs Database
         connection.Open(  );

         // begin the transaction
         transaction = connection.BeginTransaction(  );

         // attach the transaction to the command
         command.Transaction = transaction;

         // attach connection to the command
         command.Connection = connection;

         try
         {
            command.CommandText = "spAddBug";
            command.CommandType = CommandType.StoredProcedure;

            // declare the parameter object
            System.Data.SqlClient.SqlParameter param;

            // add each parameter and set its direciton and value
            param = command.Parameters.Add("@ProductID",SqlDbType.Int); 
            param.Direction = ParameterDirection.Input;
           // from the list box
            param.Value = lbProduct.SelectedItem.Value;  
            param = command.Parameters.Add(
         "@Version",SqlDbType.VarChar,50); 
            param.Direction = ParameterDirection.Input;
      // from the text box
            param.Value = txtVersion.Text;               
            param = command.Parameters.Add(
         "@Description",SqlDbType.VarChar,8000); 
            param.Direction = ParameterDirection.Input;
            // from the text box 
      param.Value = txtDescription.Text;           
            param = command.Parameters.Add("@Reporter",SqlDbType.Int); 
            param.Direction = ParameterDirection.Input;
      // from the list box
            param.Value = lbReporter.SelectedItem.Value;            
            param = command.Parameters.Add("@BugID",SqlDbType.Int); 
            param.Direction = ParameterDirection.Output;

            command.ExecuteNonQuery(  ); // execute the sproc
            
            // retrieve the identity column
            int BugID = 
            Convert.ToInt32(command.Parameters["@BugID"].Value);

            // formulate the string to update the bug history
            string strAddBugHistory = "Insert into BugHistory " +
               "(bugID, status, severity, response, owner) values (" + BugID + ",1," + 
               lbSeverity.SelectedItem.Value + ", 'Bug Created', 1)";

            // set up the command object to update the bug hsitory
            command.CommandType = CommandType.Text;
            command.CommandText = strAddBugHistory;

            // execute the insert statement
            command.ExecuteNonQuery(  ); 

            // commit the transaction
            transaction.Commit(  );
         }
         catch (Exception e)
         {
            Trace.Write(e.Message);
            transaction.Rollback(  );
         }
      }

      private void UpdateDBTransaction(  )
      {

         // Create connection object, initialize with 
         // connection string. Open it.
         System.Data.SqlClient.SqlConnection connection = 
            new System.Data.SqlClient.SqlConnection(connectionString);
         connection.Open(  );

         // create a second command object for the bugs history table
         System.Data.SqlClient.SqlCommand command = 
            new System.Data.SqlClient.SqlCommand(  );
         command.Connection = connection;

         command.CommandText= "spAddBugWithTransactions";
         command.CommandType = CommandType.StoredProcedure;

         // declare the parameter object
         System.Data.SqlClient.SqlParameter param;

         // add each parameter and set its direciton and value
         param = command.Parameters.Add("@ProductID",SqlDbType.Int); 
         param.Direction = ParameterDirection.Input;
         param.Value = lbProduct.SelectedItem.Value;  // from the list box

         param = command.Parameters.Add("@Version",SqlDbType.VarChar,50); 
         param.Direction = ParameterDirection.Input;
         param.Value = txtVersion.Text;               // from the text box

         param = command.Parameters.Add(
      "@Description",SqlDbType.VarChar,8000); 
         param.Direction = ParameterDirection.Input;
      // from the text box
         param.Value = txtDescription.Text;           
         param = command.Parameters.Add("@Reporter",SqlDbType.Int); 
         param.Direction = ParameterDirection.Input;
         param.Value = lbReporter.SelectedItem.Value; // from the list box

         param = command.Parameters.Add("@Severity",SqlDbType.Int); 
         param.Direction = ParameterDirection.Input;
         param.Value = lbSeverity.SelectedItem.Value; // from the list box

         command.ExecuteNonQuery(  ); // execute the sproc
      }

      private void btnAdd_Click(object sender, System.EventArgs e)
      {
         int whichTransaction = Convert.ToInt32(rbTransaction.SelectedItem.Value);
         if (whichTransaction == 0)
            UpdateDBTransaction(  );
         else
            UpdateConnectionTransaction(  );
      }
   }   
}
Example 12-6. VB.NET Updating with transactions
Imports System.Data.SqlClient

Namespace BugHistoryTransactions

    Public Class WebForm1
        Inherits System.Web.UI.Page

        Protected DataGrid1 As System.Web.UI.WebControls.DataGrid
        Protected HistoryGrid As System.Web.UI.WebControls.DataGrid
        Protected BugHistoryPanel As System.Web.UI.WebControls.Panel
        Protected lbProduct As System.Web.UI.WebControls.DropDownList
        Protected txtVersion As System.Web.UI.WebControls.TextBox
        Protected txtDescription As System.Web.UI.WebControls.TextBox
        Protected lbSeverity As System.Web.UI.WebControls.DropDownList
        Protected WithEvents btnAdd As System.Web.UI.WebControls.Button
        Protected lbReporter As System.Web.UI.WebControls.DropDownList
        Protected rbTransaction As _
          System.Web.UI.WebControls.RadioButtonList

        ' connection string to connect to the Bugs Database
        Private connectionString As String = _
           "server=localhost; uid=sa; pwd=; database=ProgASPDotNetBugs"

        Public Sub OnItemDataBoundEventHandler( _
        ByVal sender As Object, ByVal e As DataGridItemEventArgs)

            Dim itemType As ListItemType = CType(e.Item.ItemType, _
              ListItemType)
            If itemType = ListItemType.Header And _
               itemType = ListItemType.Footer And _
               itemType = ListItemType.Separator Then
                Return
            End If

            If e.Item.DataItem Is Nothing Then Return
            If CType(e.Item.DataItem, _
             DataRowView).Row.ItemArray(8).ToString(  ) = "High" Then

                Dim severityCell As TableCell = _
                   CType(e.Item.Controls(7), TableCell)
                severityCell.ForeColor = Color.FromName("Red")
            End If
        End Sub

        Public Sub OnSelectedIndexChangedHandler( _
        ByVal sender As Object, ByVal e As EventArgs)

            UpdateBugHistory(  )
        End Sub

        Private Sub UpdateBugHistory(  )

            Dim index As Integer = DataGrid1.SelectedIndex
            If index <> -1 Then
                ' get the bug id from the data grid
                Dim bugID As Integer = _
                   CType(DataGrid1.DataKeys(index), Integer)

                ' Get a dataset based on that BugID
                Dim dataSet As DataSet = _
                   CreateBugHistoryDataSet(bugID)

                ' bind to the table returned and make
                ' the panel visible
                HistoryGrid.DataSource = dataSet.Tables(0)
                HistoryGrid.DataBind(  )
                BugHistoryPanel.Visible = True
            Else
                ' no history to display, hide the panel
                BugHistoryPanel.Visible = False
            End If
        End Sub

        Private Sub Page_Load( _
        ByVal sender As Object, ByVal e As System.EventArgs) _
           Handles MyBase.Load

            If Not IsPostBack Then
                ' hide the history panel
                UpdateBugHistory(  )

                ' set the data source for the
                ' grid to the first table
                Dim ds As DataSet = CreateBugDataSet(  )
                DataGrid1.DataSource = ds.Tables(0)
                DataGrid1.DataBind(  )

                lbProduct.DataSource = GetDataReader("lkProduct")
                lbProduct.DataBind(  )

                lbSeverity.DataSource = GetDataReader("lkSeverity")
                lbSeverity.DataBind(  )

                lbReporter.DataSource = GetDataReader("People")
                lbReporter.DataBind(  )

            End If
        End Sub

        Private Function GetDataReader(ByVal whichTable As String) _
          As SqlDataReader

            ' Create connection object, initialize with
            ' connection string. Open it.
            Dim connection As New _
               System.Data.SqlClient.SqlConnection(connectionString)

            connection.Open(  )

            ' Create a SqlCommand object and assign the connection
            Dim command As New _
               System.Data.SqlClient.SqlCommand
            command.Connection = connection

            ' set the stored procedure to get the bug records
            command.CommandText = "select * from " & whichTable

            ' return the data reader
            Return command.ExecuteReader( _
               CommandBehavior.CloseConnection)
        End Function

        Private Function CreateBugHistoryDataSet(ByVal bugID As Integer) _
          As DataSet

            ' Create connection object, initialize with
            ' connection string. Open it.
            Dim connection As New _
               System.Data.SqlClient.SqlConnection(connectionString)

            connection.Open(  )

            ' Create a SqlCommand object and assign the connection
            Dim command As New _
               System.Data.SqlClient.SqlCommand
            command.Connection = connection

            command.CommandText = "spBugHistory"
            command.CommandType = CommandType.StoredProcedure

            ' declare the parameter object
            Dim param As System.Data.SqlClient.SqlParameter

            ' Add a new parameter, get back a reference to it
            param = command.Parameters.Add("@BugID", SqlDbType.Int)

            ' set the parameter's direction and value
            param.Direction = ParameterDirection.Input
            param.Value = bugID

            ' create a second data adapter and add the command
            ' and map the table
            ' then fill the dataset from this second adapter
            Dim dataAdapter As New SqlDataAdapter
            dataAdapter.SelectCommand = command
            dataAdapter.TableMappings.Add("Table", "BugHistory")

            Dim dataSet As New DataSet
            dataAdapter.Fill(dataSet)

            Return dataSet
        End Function

        Private Function CreateBugDataSet(  ) As DataSet

            ' Create connection object, initialize with
            ' connection string. Open it.
            Dim connection As New _
               System.Data.SqlClient.SqlConnection(connectionString)

            connection.Open(  )

            ' Create a SqlCommand object and assign the connection
            Dim command As New _
               System.Data.SqlClient.SqlCommand
            command.Connection = connection
            command.CommandText = "spBugs"
            command.CommandType = CommandType.StoredProcedure

            ' create a data adapter and assign the command object
            ' and add the table mapping for bugs
            Dim dataAdapter As New SqlDataAdapter
            dataAdapter.SelectCommand = command
            dataAdapter.TableMappings.Add("Table", "Bugs")

            ' Create the dataset and use the data adapter to fill it
            Dim dataSet As New DataSet
            dataAdapter.Fill(dataSet)
            Return dataSet
        End Function

#Region " Web Form Designer Generated Code "

        'This call is required by the Web Form Designer.
        <System.Diagnostics.DebuggerStepThrough()> Private Sub InitializeComponent(  )

        End Sub

        'NOTE: The following placeholder declaration is required by
        'the Web Form Designer.
        'Do not delete or move it.
        Private designerPlaceholderDeclaration As System.Object

        Private Sub Page_Init(ByVal sender As System.Object, _
          ByVal e As System.EventArgs) Handles MyBase.Init
            'CODEGEN: This method call is required by the Web Form Designer
            'Do not modify it using the code editor.
            InitializeComponent(  )
        End Sub

#End Region

        Private Sub UpdateConnectionTransaction(  )

            ' Create connection object, initialize with
            ' connection string. Open it.
            Dim connection As New _
               System.Data.SqlClient.SqlConnection(connectionString)

            ' Create a SqlCommand object and assign the connection
            Dim command As New _
               System.Data.SqlClient.SqlCommand

            ' declare an instance of SqlTransaction
            Dim transaction As SqlTransaction

            ' connection string to connect to the Bugs Database
            connection.Open(  )

            ' begin the transaction
            transaction = connection.BeginTransaction(  )

            ' attach the transaction to the command
            command.Transaction = transaction

            ' attach connection to the command
            command.Connection = connection

            Try

                command.CommandText = "spAddBug"
                command.CommandType = CommandType.StoredProcedure

                ' declare the parameter object
                Dim param As System.Data.SqlClient.SqlParameter

                ' add each parameter and set its direciton and value
                param = command.Parameters.Add("@ProductID", SqlDbType.Int)
                param.Direction = ParameterDirection.Input
                ' from the list box
                param.Value = lbProduct.SelectedItem.Value
                param = command.Parameters.Add( _
                  "@Version", SqlDbType.VarChar, 50)
                param.Direction = ParameterDirection.Input
                ' from the text box
                param.Value = txtVersion.Text
                param = command.Parameters.Add( _
             "@Description", SqlDbType.VarChar, 8000)
                param.Direction = ParameterDirection.Input
                ' from the text box
                param.Value = txtDescription.Text
                param = command.Parameters.Add("@Reporter", SqlDbType.Int)
                param.Direction = ParameterDirection.Input
                ' from the list box
                param.Value = lbReporter.SelectedItem.Value
                param = command.Parameters.Add("@BugID", SqlDbType.Int)
                param.Direction = ParameterDirection.Output

                command.ExecuteNonQuery(  ) ' execute the sproc

                ' retrieve the identity column
                Dim BugID As Integer = _
                Convert.ToInt32(command.Parameters("@BugID").Value)

                ' formulate the string to update the bug history
                Dim strAddBugHistory As String = _
                   "Insert into BugHistory " & _
                   "(bugID, status, severity, response, owner) values (" _
                   & BugID & ",1," & _
                   lbSeverity.SelectedItem.Value & ", 'Bug Created', 5)"

                ' set up the command object to update the bug hsitory
                command.CommandType = CommandType.Text
                command.CommandText = strAddBugHistory

                ' execute the insert statement
                command.ExecuteNonQuery(  )

                ' commit the transaction
                transaction.Commit(  )

            Catch e As Exception

                Trace.Write(e.Message)
                transaction.Rollback(  )
            End Try
        End Sub

        Private Sub UpdateDBTransaction(  )

            ' Create connection object, initialize with
            ' connection string. Open it.
            Dim connection As New _
               System.Data.SqlClient.SqlConnection(connectionString)

            connection.Open(  )

            ' Create a SqlCommand object and assign the connection
            Dim command As New _
               System.Data.SqlClient.SqlCommand
            command.Connection = connection

            command.CommandText = "spAddBugWithTransactions"
            command.CommandType = CommandType.StoredProcedure

            ' declare the parameter object
            Dim param As System.Data.SqlClient.SqlParameter

            ' add each parameter and set its direciton and value
            param = command.Parameters.Add("@ProductID", SqlDbType.Int)
            param.Direction = ParameterDirection.Input
            param.Value = lbProduct.SelectedItem.Value  ' from the list box

            param = command.Parameters.Add("@Version", _
              SqlDbType.VarChar, 50)
            param.Direction = ParameterDirection.Input
            param.Value = txtVersion.Text               ' from the text box

            param = command.Parameters.Add( _
              "@Description", SqlDbType.VarChar, 8000)
            param.Direction = ParameterDirection.Input
            ' from the text box
            param.Value = txtDescription.Text
            param = command.Parameters.Add("@Reporter", SqlDbType.Int)
            param.Direction = ParameterDirection.Input
            param.Value = lbReporter.SelectedItem.Value  ' from the list 

            param = command.Parameters.Add("@Severity", SqlDbType.Int)
            param.Direction = ParameterDirection.Input
            param.Value = lbSeverity.SelectedItem.Value  ' from the list 

            command.ExecuteNonQuery(  ) ' execute the sproc
        End Sub

        Private Sub btnAdd_Click(ByVal sender As System.Object, _
          ByVal e As System.EventArgs) Handles btnAdd.Click

            Dim whichTransaction As Integer = _
              Convert.ToInt32(rbTransaction.SelectedItem.Value)
            If whichTransaction = 0 Then
                UpdateDBTransaction(  )
            Else
                UpdateConnectionTransaction(  )
            End If
        End Sub

    End Class
End Namespace

The complete source code for the .aspx file is shown in Example 12-7. Again, this is relatively unchanged from the examples in Chapter 11, with the addition of the list boxes, text boxes, and buttons necessary to gather the new Bug data.

Example 12-7. The .aspx file
<%@ Page language="c#" Codebehind="WebForm1.aspx.cs" 
AutoEventWireup="false" Inherits="BugHistoryTransactions.WebForm1" Trace="true"%>
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN" >
<HTML>
   <HEAD>
      <meta name="GENERATOR" content="Microsoft Visual Studio.NET 7.0">
      <meta name="CODE_LANGUAGE" content="Visual Basic 7.0">
      <meta name="vs_defaultClientScript" content="JavaScript">
      <meta name="vs_targetSchema" 
       content="http://schemas.microsoft.com/intellisense/ie5">   </HEAD>
   <body>
      <form id="Form1" method="post" runat="server">
         <table>
            <tr>
               <th>Product</th>
               <th>Version</th>
               <th>Description</th>
               <th>Reporter</th>
               <th>Severity</th>
            </tr>
            <tr>
               <td>
                  <asp:dropdownlist id="lbProduct" runat="server" 
                  DataValueField="ProductID" 
                  DataTextField="ProductDescription" />
               </td>
               <td>
                  <asp:textbox id="txtVersion" Runat="server" Width="60"/>
               </td>
               <td>
                  <asp:textbox id="txtDescription" 
                   Runat="server" Width="250"/>
               </td>
               <td>
                  <asp:dropdownlist id="lbReporter" Runat="server" 
                  DataValueField="PersonID" DataTextField="FullName"/>
               </td>
               <td>
                  <asp:dropdownlist id="lbSeverity" Runat="server" 
                  DataValueField="SeverityID" 
                  DataTextField="SeverityDescription"/>
               </td>
            </tr>
            <tr>
               <td>
                  <asp:radiobuttonlist id="rbTransaction" Runat="server" 
                  TextAlign="Right" RepeatLayout="flow" 
                  RepeatDirection="Vertical" repeatColumns="2" 
                   CellSpacing="3">
                     <asp:ListItem Text="DB Transaction" Value="0" />
                     <asp:ListItem Text="Connection Transaction" 
                        Value="1" Selected="True" />
                  </asp:radiobuttonlist>
               </td>
               <td>
                  <asp:button id="btnAdd" Runat="server" Text="Add" />
               </td>
            </tr>
         </table>
         <br>
         <asp:datagrid id="DataGrid1" runat="server" EnableViewState="true" 
         AutoGenerateColumns="False" HeaderStyle-Font-Bold="True" 
         AlternatingItemStyle-BackColor="LightGrey" 
         OnSelectedIndexChanged="OnSelectedIndexChangedHandler" 
         OnItemDataBound="OnItemDataBoundEventHandler" 
         BorderColor="#000099" BorderWidth="5px" 
         HeaderStyle-BackColor="PapayaWhip" CellPadding="5" 
          DataKeyField="BugID">
            <Columns>
               <asp:ButtonColumn Text="History" CommandName="Select" />
               <asp:BoundColumn DataField="BugID" HeaderText="Bug ID" />
               <asp:BoundColumn DataField="Description" 
                HeaderText="Description" />
               <asp:BoundColumn DataField="Reporter" 
                HeaderText="Reported By" />
               <asp:BoundColumn DataField="Response" 
                HeaderText="Most Recent Action" />
               <asp:BoundColumn DataField="Owner" HeaderText="Owned By" />
               <asp:BoundColumn DataField="StatusDescription" 
                HeaderText="Status" />
               <asp:BoundColumn DataField="SeverityDescription"       
                HeaderText="Severity" />
               <asp:BoundColumn DataField="DateStamp" 
                HeaderText="LastUpdated" />
            </Columns>
         </asp:datagrid>
         <asp:panel id="BugHistoryPanel" Runat="server">
            <asp:DataGrid id="HistoryGrid" AutoGenerateColumns="False" 
            HeaderStyle-Font-Bold AlternatingItemStyle-BackColor="LightGrey" 
            BorderColor="#000099" BorderWidth="5px" 
            HeaderStyle-BackColor="PapayaWhip" CellPadding="5" Runat="server">
               <Columns>
                  <asp:BoundColumn DataField="Response" 
                   HeaderText="Most Recent Action" />
                  <asp:BoundColumn DataField="Owner" HeaderText="Owned By" />
                  <asp:BoundColumn DataField="StatusDescription" 
                   HeaderText="Status" />
                  <asp:BoundColumn DataField="SeverityDescription" 
                   HeaderText="Severity" />
                  <asp:BoundColumn DataField="DateStamp" 
                   HeaderText="LastUpdated" />
               </Columns>
            </asp:DataGrid>
         </asp:panel>
      </form>
   </body>
</HTML>
    Previous Section Next Section


    JavaScript Editor Javascript validator     Javascripts 
    R7



    ©