C#调用MySQL存储过程,函数的最佳方法
本文关键字:最佳 方法 函数 调用 MySQL 存储过程 | 更新日期: 2023-09-27 18:31:20
您好,我编写了调用存储过程的 DAL,但我仍然不知道我是否应该对某些过程使用 ExecuteScalar、NonQuery 或 Reader。
例如,我写了这个我想调用的函数
CREATE FUNCTION `retornarIdArea`(cod longtext) RETURNS int(11)
BEGIN
DECLARE id int;
select AreaId into id FROM area where Codigo = cod;
return id;
END
应返回数据集的此过程
CREATE PROCEDURE `consultar_n_asunto`(in asun longtext, in est int)
BEGIN
select * from notas where Asunto LIKE CONCAT('%',CONCAT(asun,'%')) AND Estado = est;
END$$
最后是一个插入一些数据的过程,我使用输出参数进行选择来验证它。
CREATE PROCEDURE `registrar_dest`(in nomb longtext,
in dir longtext, in inst int, in mail longtext, in tel longtext,
in act int, out res tinyint(1))
BEGIN
-- verificar que no exista el destinatario
select count(*) into res from destinatario WHERE Nombre = nomb AND
Direccion = dir AND Email = mail AND Telefono = tel AND Activo = act;
IF res = 0 THEN
INSERT INTO destinatario (Nombre, Direccion, InstitucionId, Email, Telefono, Activo)
VALUES (nomb, dir, inst, mail, tel, act);
select count(*) into res from destinatario WHERE Nombre = nomb AND
Direccion = dir AND Email = mail AND Telefono = tel AND Activo = act;
ELSE
set res = -1;
END IF;
END$$
现在我用 C# 编写了这个来从 FUNCTIONS 返回值
public object ejecutarFuncion() { using (MySqlConnection conn = new MySqlConnection(stringDeConexion)) { using (MySqlCommand cmd = new MySqlCommand(procedimiento, conn)) { cmd.CommandType = System.Data.CommandType.StoredProcedure; //Se abre la conexión conn.Open(); //existen parámetros los recorremos y agregamos. foreach (KeyValuePair<string, object> pars in parametros) { cmd.Parameters.Add(new MySqlParameter(pars.Key, pars.Value)); } //Se crea la variable de retorno cmd.Parameters.Add(new MySqlParameter(nombreOut, tipoParOut)); cmd.Parameters[nombreOut].Direction = System.Data.ParameterDirection.ReturnValue; cmd.ExecuteNonQuery(); // Cerramos conexión conn.Close(); return cmd.Parameters[nombreOut].Value; } } }
如果你看到我在这里做了一个 ExecuteNonQuery(),但我应该使用 Execute Scalar? 还是只使用 parms 的返回值?
然后我编写了此方法来执行具有输出值的过程(其中一些执行更新,插入)操作,我使用输出值来检查操作是否正确完成。
public object ejecutarProcedimientoConOutput()
{
using (MySqlConnection conn = new MySqlConnection(stringDeConexion))
{
using (MySqlCommand cmd = new MySqlCommand(procedimiento, conn))
{
cmd.CommandType = System.Data.CommandType.StoredProcedure;
//Se abre la conexión
conn.Open();
//verificamos si se mando la lista de parámetros
if (parametros.Count > 0)
{
//existen parámetros los recorremos y agregamos.
foreach (KeyValuePair<string, object> pars in parametros)
{
cmd.Parameters.Add(new MySqlParameter(pars.Key, pars.Value));
cmd.Parameters[pars.Key].Direction = System.Data.ParameterDirection.Input;
}
}
cmd.Parameters.Add(new MySqlParameter(nombreOut, tipoParOut));
cmd.Parameters[nombreOut].Direction = System.Data.ParameterDirection.Output;
cmd.ExecuteNonQuery();
conn.Close();
return cmd.Parameters[nombreOut].Value;
}
}
}
同样,如果我正在执行更新或插入操作,但我使用输出参数来检查它是否已完成,您可以检查插入存储过程是否应该使用 ExecuteNonQuery 还是 ExecuteScalar?
对于返回数据集的过程与我上面编写的方法相同,但没有输出参数,我使用的是 executeReader,因为我只做一个选择而不使用输出参数。
我只想知道我是否为这些过程使用了正确的执行命令。
-
如果要返回受查询影响的行数然后使用
ExecuteNonReader()
. -
如果要返回第一行的第一列,请使用
ExecuteScalar
. -
如果需要创建
SqlDataReader
以便可以迭代在结果上,然后使用ExecuteReader
.
因此,您可以将ExecuteScalar
用于函数retornarIdArea
因为您只返回一列和一行(id),因此此函数适合上下文。
对于过程consultar_n_asunto
,您可以在选择多行并期望返回结果集时使用ExecuteReader
。