2

我想使用 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())
{
}
4

5 回答 5

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();
于 2012-05-11T18:06:25.133 回答
2

FlyingStreudel 的回答很好，但我已经修改了该代码以制作演示最佳实践的版本（底部的链接）。您还可以使用 Microsoft 的 Enterprise Library，它将为您提供强大的数据访问类。

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
    }
}

参考：

Microsoft 如何在企业库中使用连接

保持 SqlConnection 打开是 'foo bar'

从类中返回数据读取器

于 2012-05-11T20:33:53.303 回答
0 
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();

}}
于 2012-05-11T18:04:27.037 回答
0

如果您希望重用此类代码，一种可能的解决方案是将此类方法（执行存储过程并返回结果的方法）包装到应用程序的通用数据访问层中。您必须考虑的变化是针对不返回结果或期望参数的过程。

例如，您可以将此 shell 代码包装为 ExecuteProcedure()，它需要返回数据库的连接字符串。

还有无数其他方法可以完成此类任务，因此您需要确定最适合您的特定要求的选项。

于 2012-05-11T18:04:51.060 回答
0

您可以包装此代码并将过程作为参数。像这样的东西：

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

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

此方法的唯一问题是您没有正确处理资源并且依赖调用者这样做。

于 2012-05-11T18:05:33.883 回答