Sdílet prostřednictvím

Úprava dat pomocí uložených procedur

Platí pro: .NET Framework .NET Standard

Stáhnout ADO.NET

Uložené procedury mohou přijímat data jako vstupní parametry a můžou vracet data jako výstupní parametry, sady výsledků nebo návratové hodnoty. Následující ukázka ukazuje, jak Microsoft SqlClient Data Provider pro SQL Server odesílá a přijímá vstupní parametry, výstupní parametry a návratové hodnoty. Příklad vloží nový záznam do tabulky, kde sloupec primárního klíče je sloupec identity.

Poznámka:

Pokud k úpravě nebo odstranění dat prostřednictvím SqlDataAdapter používáte uložené procedury, ujistěte se, že v definici uložené procedury nepoužíváte příkaz SET NOCOUNT ON. To způsobí, že počet ovlivněných řádků bude nulový, což DataAdapter interpretuje jako konflikt souběžnosti. V tomto případě se dojde k vyvolání DBConcurrencyException.

Example

Ukázka používá následující uloženou proceduru k vložení nové kategorie do tabulky NorthwindCategories . Uložená procedura přebírá hodnotu ve sloupci CategoryName jako vstupní parametr a pomocí funkce SCOPE_IDENTITY() načte novou hodnotu pole identity, CategoryID a vrátí ji ve výstupním parametru. Příkaz RETURN používá funkci @@ROWCOUNT k vrácení počtu vložených řádků.

CREATE PROCEDURE dbo.InsertCategory  
  @CategoryName nvarchar(15),  
  @Identity int OUT  
AS  
INSERT INTO Categories (CategoryName) VALUES(@CategoryName)  
SET @Identity = SCOPE_IDENTITY()  
RETURN @@ROWCOUNT

Následující příklad kódu používá uloženou proceduru InsertCategory uvedenou výše jako zdroj pro InsertCommand z SqlDataAdapter. Po vložení záznamu do databáze se výstupní @Identity parametr projeví v DataSet při zavolání metody Update objektu SqlDataAdapter. Kód také načte vrácenou hodnotu.

using System;
using System.Data;
using Microsoft.Data.SqlClient;

class Program
{
    static void Main()
    {
        string connectionString = GetConnectionString();
        ReturnIdentity(connectionString);
        // Console.ReadLine();
    }

    private static void ReturnIdentity(string connectionString)
    {
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            // Create a SqlDataAdapter based on a SELECT query.
            SqlDataAdapter adapter = new SqlDataAdapter(
                "SELECT CategoryID, CategoryName FROM dbo.Categories", connection);

            // Create a SqlCommand to execute the stored procedure.
            adapter.InsertCommand = new SqlCommand("InsertCategory", connection);
            adapter.InsertCommand.CommandType = CommandType.StoredProcedure;

            // Create a parameter for the ReturnValue.
            SqlParameter parameter = adapter.InsertCommand.Parameters.Add("@RowCount", SqlDbType.Int);
            parameter.Direction = ParameterDirection.ReturnValue;

            // Create an input parameter for the CategoryName.
            // You do not need to specify direction for input parameters.
            adapter.InsertCommand.Parameters.Add("@CategoryName", SqlDbType.NChar, 15, "CategoryName");

            // Create an output parameter for the new identity value.
            parameter = adapter.InsertCommand.Parameters.Add("@Identity", SqlDbType.Int, 0, "CategoryID");
            parameter.Direction = ParameterDirection.Output;

            // Create a DataTable and fill it.
            DataTable categories = new DataTable();
            adapter.Fill(categories);

            // Add a new row.
            DataRow categoryRow = categories.NewRow();
            categoryRow["CategoryName"] = "New Beverages";
            categories.Rows.Add(categoryRow);

            // Update the database.
            adapter.Update(categories);

            // Retrieve the ReturnValue.
            Int rowCount = (Int)adapter.InsertCommand.Parameters["@RowCount"].Value;

            Console.WriteLine("ReturnValue: {0}", rowCount.ToString());
            Console.WriteLine("All Rows:");
            foreach (DataRow row in categories.Rows)
            {
                    Console.WriteLine("  {0}: {1}", row[0], row[1]);
            }
        }
    }

    static private string GetConnectionString()
    {
        // To avoid storing the connection string in your code,
        // you can retrieve it from a configuration file.
        return "Data Source=(local);Initial Catalog=Northwind;Integrated Security=true";
    }
}

Viz také

  • Last updated on