Home / Questions / 47566
Accepted
Alejandro Ricotti
Asked: 2020-02-04 05:33:26 +0800 CST 2020-02-04 05:33:26 +0800 CST

从 C# 调用存储过程的方法

  • 772

我有这个方法来执行存储过程

    public void EjecutarSP(string sp)
    {
        try
        {
            SqlCommand cmd = new SqlCommand(sp, ConexionBD.con);
            cmd.CommandType = CommandType.StoredProcedure;
            ConexionBD.Conectar();
            cmd.ExecuteNonQuery();
            ConexionBD.Desconectar();
        }
        catch (Exception ex)
        {
            throw new Exception(" Error al ejecutar procedimiento almacenado ", ex);
        }
    }

当存储过程不接收或返回任何值时，此方法通常为我服务，我想知道是否有任何方法可以使它们在存储过程接收和返回参数时通用，我认为对于返回部分我可以使用ExecuteReader 返回一个表，然后在应用程序中处理它，但是对于发送参数的部分，我不知道是否可以做一些通用的事情，因为并非所有存储过程都接收相同数量的参数

c#

2 Answers

  1. Best Answer

    此方法将帮助您使用通用数据类型执行存储过程：

    public IEnumerable<T> EjecutarStoredProcedure<T>(string storedProcedure, string connectionString, SqlParameter[] parameters, Func<SqlDataReader, T> body)
{
    List<T> results = new List<T>();

    using (Connection connection = new Connection())
    {
        SqlCommand command = connection.CreateSPConnection(storedProcedure, connectionString);
        command.Parameters.AddRange(parameters);
        SqlDataReader reader = command.ExecuteReader();
        while (reader.Read())
        {
            results.Add(body(reader));
        }
        reader.Close();
    }
    return results;
}

    现在，为了能够调用该方法，如下所示：

    public IEnumerable<UserEntity> GetUser()
{
    try
    {
        return ProceduresExecution.Instance.EjecutarStoredProcedure<UserEntity>("NombreStoredProcedure",
            GlobalData.ConnectionStringDefault,
            new SqlParameter[]{
                new SqlParameter("@inUserId", 123),
                new SqlParameter("@OtroParametro", "OtroParametro")
            },
            reader =>
            {
                return new UserEntity
                {   
                    //En esta sección van todas las propiedades de la Entidad UserEntity y ["Aqui"] van mapeados a los nombres de las columnas que recuperaste en la consulta de base de datos
                    UserId = (int)reader["UserId"],
                    Nombre = reader["Nombre"].ToString()
                    UserTypeId = (int)reader["UserTypeId"]              };
            });
    }
    catch (Exception e)
    {
        throw new Exception("Error al obtener el usuario" + ex.message);
    }
}

    发送到方法

    new SqlParameter[] {
    new SqlParameter("@inUserId", 123),
    new SqlParameter("@OtroParametro", "OtroParametro")
},

    您正在发送所有所需的参数，以便您最终可以以通用方式以您想要的类的类型自动接收它们。

    • 1

  2. 如果您愿意，可以使用已经具有所需重载方法的Sql Helper类，或者另一种方法是使其适应您的需求。

    看看这个教程，它使用了这样一个类。

    • 0