您好,我编写了调用存储过程的 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# 编写了 this 从 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; } } }
If you see I do a ExecuteNonQuery() here, but should I used Execute Scalar? or just use the return value from parms?
然后我写了这个方法来执行带有输出值的Procedures(其中一些做更新,插入)操作,我使用输出值来检查操作是否正确完成。
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
因为您选择多行并期望返回结果集。
关于C# 调用 MySQL 存储过程、函数的最佳方式,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/18815625/