Cách thực hiện một thủ tục lưu sẵn trong chương trình C#

Question

Tôi muốn thực hiện quy trình được lưu trữ này từ chương trình C#.

Tôi đã viết các thủ tục lưu trữ sau đây trong một cửa sổ truy vấn SQLServer và lưu nó như stored1:

use master 
go 
create procedure dbo.test as 

DECLARE @command as varchar(1000), @i int 
SET @i = 0 
WHILE @i < 5 
BEGIN 
Print 'I VALUE ' +CONVERT(varchar(20),@i) 
EXEC(@command) 
SET @i = @i + 1 
END 

EDITED:

using System; 
using System.Collections.Generic; 
using System.Text; 
using System.Data; 
using System.Data.SqlClient; 
namespace AutomationApp 
{ 
    class Program 
    { 
     public void RunStoredProc() 
     { 
      SqlConnection conn = null; 
      SqlDataReader rdr = null; 

      Console.WriteLine("\nTop 10 Most Expensive Products:\n"); 

      try 
      { 
       conn = new SqlConnection("Server=(local);DataBase=master;Integrated Security=SSPI"); 
       conn.Open(); 
       SqlCommand cmd = new SqlCommand("dbo.test", conn); 
       cmd.CommandType = CommandType.StoredProcedure; 
       rdr = cmd.ExecuteReader(); 
       /*while (rdr.Read()) 
       { 
        Console.WriteLine(
         "Product: {0,-25} Price: ${1,6:####.00}", 
         rdr["TenMostExpensiveProducts"], 
         rdr["UnitPrice"]); 
       }*/ 
      } 
      finally 
      { 
       if (conn != null) 
       { 
        conn.Close(); 
       } 
       if (rdr != null) 
       { 
        rdr.Close(); 
       } 
      } 
     } 
     static void Main(string[] args) 
     { 
      Console.WriteLine("Hello World"); 
      Program p= new Program(); 
      p.RunStoredProc();  
      Console.Read(); 
     } 
    } 
} 

này hiển thị ngoại lệ Cannot find the stored procedure dbo.test. Tôi có cần cung cấp đường dẫn không? Nếu có, trong đó vị trí nên lưu trữ các thủ tục được lưu trữ?

Answer 1

using (var conn = new SqlConnection(connectionString)) 
using (var command = new SqlCommand("ProcedureName", conn) { 
          CommandType = CommandType.StoredProcedure }) { 
    conn.Open(); 
    command.ExecuteNonQuery(); 
} 

Answer 2

using (SqlConnection sqlConnection1 = new SqlConnection("Your Connection String")) { 
using (SqlCommand cmd = new SqlCommand()) { 
    Int32 rowsAffected; 

    cmd.CommandText = "StoredProcedureName"; 
    cmd.CommandType = CommandType.StoredProcedure; 
    cmd.Connection = sqlConnection1; 

    sqlConnection1.Open(); 

    rowsAffected = cmd.ExecuteNonQuery(); 

}} 

Answer 3

using (SqlConnection conn = new SqlConnection("Server=(local);DataBase=Northwind;Integrated Security=SSPI")) { 
    conn.Open(); 

    // 1. create a command object identifying the stored procedure 
    SqlCommand cmd = new SqlCommand("CustOrderHist", conn); 

    // 2. set the command object so it knows to execute a stored procedure 
    cmd.CommandType = CommandType.StoredProcedure; 

    // 3. add parameter to command, which will be passed to the stored procedure 
    cmd.Parameters.Add(new SqlParameter("@CustomerID", custId)); 

    // execute the command 
    using (SqlDataReader rdr = cmd.ExecuteReader()) { 
     // iterate through results, printing each to console 
     while (rdr.Read()) 
     { 
      Console.WriteLine("Product: {0,-35} Total: {1,2}",rdr["ProductName"],rdr["Total"]); 
     } 
    } 
} 

Dưới đây là một số liên kết thú vị bạn có thể đọc:

• http://www.csharp-station.com/Tutorials/AdoDotNet/Lesson07.aspx
• http://www.c-sharpcorner.com/UploadFile/dclark/InsOutsinCS11302005072332AM/InsOutsinCS.aspx
• http://www.codeproject.com/KB/cs/simplecodeasp.aspx
• http://msdn.microsoft.com/en-us/library/ms171921(VS.80).aspx

Answer 4

Bạn có nghĩa là mã của bạn là DDL? Nếu có, MSSQL không có sự khác biệt. Các ví dụ trên cũng cho thấy cách gọi điều này. Chỉ cần đảm bảo

CommandType = CommandType.Text 

Answer 5

SqlConnection conn = null; 
SqlDataReader rdr = null; 
conn = new SqlConnection("Server=(local);DataBase=Northwind;Integrated Security=SSPI"); 
conn.Open(); 

// 1. create a command object identifying 
//  the stored procedure 
SqlCommand cmd = new SqlCommand("CustOrderHist", conn); 

// 2. set the command object so it knows 
// to execute a stored procedure 
cmd.CommandType = CommandType.StoredProcedure; 

// 3. add parameter to command, which 
// will be passed to the stored procedure 
cmd.Parameters.Add(new SqlParameter("@CustomerID", custId)); 

// execute the command 
rdr = cmd.ExecuteReader(); 

// iterate through results, printing each to console 
while (rdr.Read()) 
{ 
    Console.WriteLine("Product: {0,-35} Total: {1,2}", rdr["ProductName"], rdr["Total"]); 
} 

Answer 6

Calling Thủ tục Store trong C#

SqlCommand cmd = new SqlCommand("StoreProcedureName",con); 
cmd.CommandType=CommandType.StoredProcedure; 
cmd.Parameters.AddWithValue("@value",txtValue.Text); 
int rowAffected=cmd.ExecuteNonQuery(); 

Answer 7

Không Dapper trả lời ở đây. Vì vậy, tôi đã thêm một

using Dapper; 
using System.Data.SqlClient; 

using (var cn = new SqlConnection(@"Server=(local);DataBase=master;Integrated Security=SSPI")) 
    cn.Execute("dbo.test", commandType: CommandType.StoredProcedure); 

Answer 8

Bằng cách sử dụng Ado.net

using System; 
using System.Data; 
using System.Data.SqlClient; 
using System.Configuration; 

namespace PBDataAccess 
{ 
    public class AddContact 
    { 
     // for preparing connection to sql server database 

     private SqlConnection conn; 

     // for preparing sql statement or stored procedure that 
     // we want to execute on database server 

     private SqlCommand cmd; 

     // used for storing the result in datatable, basically 
     // dataset is collection of datatable 

     private DataSet ds; 

     // datatable just for storing single table 

     private DataTable dt; 

     // data adapter we use it to manage the flow of data 
     // from sql server to dataset and after fill the data 
     // inside dataset using fill() method 

     private SqlDataAdapter da; 


     // created a method, which will return the dataset 

     public DataSet GetAllContactType() 
     { 



    // retrieving the connection string from web.config, which will 
    // tell where our database is located and on which database we want 
    // to perform opearation, in this case we are working on stored 
    // procedure so you might have created it somewhere in your database. 
    // connection string will include the name of the datasource, your 
    // database name, user name and password. 

     using (conn = new SqlConnection(ConfigurationManager.ConnectionString["conn"] 
     .ConnectionString)) 

       { 
        // Addcontact is the name of the stored procedure 
        using (cmd = new SqlCommand("Addcontact", conn)) 

        { 
         cmd.CommandType = CommandType.StoredProcedure; 

        // here we are passing the parameters that 
        // Addcontact stored procedure expect. 
        cmd.Parameters.Add("@CommandType", 
        SqlDbType.VarChar, 50).Value = "GetAllContactType"; 

         // here created the instance of SqlDataAdapter 
         // class and passed cmd object in it 
         da = new SqlDataAdapter(cmd); 

         // created the dataset object 
         ds = new DataSet(); 

         // fill the dataset and your result will be 
         stored in dataset 
         da.Fill(ds); 
        }      
      } 
      return ds; 
     } 
} 

****** Stored Procedure ****** 

CREATE PROCEDURE Addcontact 
@CommandType VARCHAR(MAX) = NULL 
AS 
BEGIN 
    IF (@CommandType = 'GetAllContactType') 
    BEGIN 
    SELECT * FROM Contacts 
    END 
END 

Answer 9

Hãy kiểm SprocMapper (i là tác giả)

https://www.nuget.org/packages/SprocMapper/

SqlServerAccess sqlAccess = new SqlServerAccess("your connection string"); 
var result = sqlAccess.Procedure().ExecuteNonQuery("StoreProcedureName"); 

Cũng có một một loạt các tính năng khác mà bạn có thể thích.

Answer 10

đây là một ví dụ về một thủ tục lưu trữ mà trả về giá trị và nó thực hiện trong C#

CREATE PROCEDURE [dbo].[InsertPerson] 
-- Add the parameters for the stored procedure here 
@FirstName nvarchar(50),@LastName nvarchar(50), 
@PersonID int output 
AS 
BEGIN 
    insert [dbo].[Person](LastName,FirstName) Values(@LastName,@FirstName) 

    set @PersonID=SCOPE_IDENTITY() 
END 
Go 


-------------- 
// Using stored procedure in adapter to insert new rows and update the identity value. 
    static void InsertPersonInAdapter(String connectionString, String firstName, String lastName) { 
     String commandText = "dbo.InsertPerson"; 
     using (SqlConnection conn = new SqlConnection(connectionString)) { 
     SqlDataAdapter mySchool = new SqlDataAdapter("Select PersonID,FirstName,LastName from [dbo].[Person]", conn); 

     mySchool.InsertCommand = new SqlCommand(commandText, conn); 
     mySchool.InsertCommand.CommandType = CommandType.StoredProcedure; 

     mySchool.InsertCommand.Parameters.Add( 
      new SqlParameter("@FirstName", SqlDbType.NVarChar, 50, "FirstName")); 
     mySchool.InsertCommand.Parameters.Add( 
      new SqlParameter("@LastName", SqlDbType.NVarChar, 50, "LastName")); 

     SqlParameter personId = mySchool.InsertCommand.Parameters.Add(new SqlParameter("@PersonID", SqlDbType.Int, 0, "PersonID")); 
     personId.Direction = ParameterDirection.Output; 

     DataTable persons = new DataTable(); 
     mySchool.Fill(persons); 

     DataRow newPerson = persons.NewRow(); 
     newPerson["FirstName"] = firstName; 
     newPerson["LastName"] = lastName; 
     persons.Rows.Add(newPerson); 

     mySchool.Update(persons); 
     Console.WriteLine("Show all persons:"); 
     ShowDataTable(persons, 14); 

Answer 11

Đây là mã để thực hiện các thủ tục lưu trữ với và với các thông số ra. Lưu ý rằng tên thuộc tính của đối tượng cần phải khớp với các tham số của thủ tục đã lưu.

private static string ConnString = ConfigurationManager.ConnectionStrings["SqlConnection"].ConnectionString; 
    private SqlConnection Conn = new SqlConnection(ConnString); 

    public void ExecuteStoredProcedure(string procedureName) 
    { 
     SqlConnection sqlConnObj = new SqlConnection(ConnString); 

     SqlCommand sqlCmd = new SqlCommand(procedureName, sqlConnObj); 
     sqlCmd.CommandType = CommandType.StoredProcedure; 

     sqlConnObj.Open(); 
     sqlCmd.ExecuteNonQuery(); 
     sqlConnObj.Close(); 
    } 

    public void ExecuteStoredProcedure(string procedureName, object model) 
    { 
     var parameters = GenerateSQLParameters(model); 
     SqlConnection sqlConnObj = new SqlConnection(ConnString); 

     SqlCommand sqlCmd = new SqlCommand(procedureName, sqlConnObj); 
     sqlCmd.CommandType = CommandType.StoredProcedure; 

     foreach (var param in parameters) 
     { 
      sqlCmd.Parameters.Add(param); 
     } 

     sqlConnObj.Open(); 
     sqlCmd.ExecuteNonQuery(); 
     sqlConnObj.Close(); 
    } 

    private List<SqlParameter> GenerateSQLParameters(object model) 
    { 
     var paramList = new List<SqlParameter>(); 
     Type modelType = model.GetType(); 
     var properties = modelType.GetProperties(); 
     foreach (var property in properties) 
     { 
      if (property.GetValue(model) == null) 
      { 
       paramList.Add(new SqlParameter(property.Name, DBNull.Value)); 
      } 
      else 
      { 
       paramList.Add(new SqlParameter(property.Name, property.GetValue(model))); 
      } 
     } 
     return paramList; 

    }