Вызов хранимой процедуры в C#

Question

Я хочу вызвать хранимую процедуру с помощью C#.

Я хотел бы создать сокращенную форму для вызова процедуры.

Я все еще не хочу переопределять соединение и открывать его. Как создать метод - я все еще не открыл соединение с базой данных?

Я использую следующий код:

SqlConnection conn = null; 
SqlDataReader rdr = null; 

conn = new SqlConnection(""); 
conn.Open(); 

SqlCommand cmd = new SqlCommand("Procedure", conn); 
cmd.CommandType = CommandType.StoredProcedure; 

rdr = cmd.ExecuteReader(); 

while (rdr.Read()) 
{ 
} 

Answer 1

ответ FlyingStreudel это хорошо, но я адаптировал этот код, чтобы эта версия демонстрировала лучшие практики (ссылки внизу). Вы также можете использовать корпоративную библиотеку Microsoft, которая даст вам надежные классы доступа к данным.

private string _connectionString = "yourconnectionstring"; // from web.config, or wherever you store it 
public static SqlDataReader executeProcedure(string commandName, 
             Dictionary<string, object> params) 
{ 
    SqlConnection conn = new SqlConnection(_connectionString); 
    conn.Open(); 
    SqlCommand comm = conn.CreateCommand(); 
    comm.CommandType = CommandType.StoredProcedure; 
    comm.CommandText = commandName; 
    if (params != null) 
    { 
     foreach(KeyValuePair<string, object> kvp in params) 
      comm.Parameters.Add(new SqlParameter(kvp.Key, kvp.Value)); 
    } 
    return comm.ExecuteReader(System.Data.CommandBehavior.CloseConnection); 
} 

используется, например, так:

Dictionary<string, object> paras = new Dictionary<string, object>(); 
paras.Add("user_name", "Timmy"); 
paras.Add("date", DateTime.Now); 
using(SqlDataReader results = executeProcedure("sp_add_user", paras)) 
{ 
    while (results.Read()) 
    { 
     //do something with the rows returned 
    } 
} 

Ссылки:

How Microsoft use Connections in Enterprise Library

Keeping an SqlConnection open is 'foo bar'

Returning a data reader from a class

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

Если вы хотите, чтобы повторно использовать этот вид кода, один из возможных решений является обернуть такой метод (тот, который выполняет хранимую процедуру и возвращает результаты) в общий уровень доступа к данным вашего приложения. Изменения, которые вы должны учитывать, - это процедуры, которые не возвращают результаты, или ожидающие параметры.

Вы можете, например, обернуть этот код оболочки как ExecuteProcedure(), который ожидает, что строка соединения вернется в базу данных.

Есть много других способов решения этой задачи, поэтому вам нужно определить, какой будет наилучший вариант, соответствующий вашим конкретным требованиям.

Answer 4

Вы можете обернуть этот код и принять процедуру как параметр. Что-то вроде этого:

public SqlCommand GetData(string procedure) 
{ 
    var conn = new SqlConnection(connectionString); 
    var cmd = new SqlCommand(procedure, conn); 

    cmd.CommandType = CommandType.StoredProcedure; 
    conn.Open(); 
    return cmd; 
} 

Единственная проблема этого метода состоит в том, что вы не правильно распоряжаться ресурсами и полагаются на вызывающему сделать это.

Answer 5

Я понятия не имею, если я понимаю, что вы просите или нет, но вы имеете в виду что-то вроде:

public static SqlReader executeProcedure(SqlConnection oConn, string commandName, Dictionary<string, object> params) 
{ 
    SqlCommand comm = oConn.CreateCommand(); 
    comm.CommandType = CommandType.StoredProcedure; 
    comm.CommandText = commandName; 
    if (params != null) 
     foreach(KeyValuePair<string, object> kvp in params) 
      comm.Parameters.Add(new SqlParameter(kvp.Key, kvp.Value)); 
    return comm.ExecuteReader(); 
} 

Примером использования может быть

Dictionary<string, object> paras = new Dictionary<string, object>(); 
paras.Add("user_name", "Timmy"); 
paras.Add("date", DateTime.Now); 
SqlReader results = executeProcedure(oConn, "sp_add_user", paras); 
while (results.Read()) 
{ 
    //do something with the rows returned 
} 
results.Close();