C# SQL, Multiple Commands
本文关键字:Commands Multiple SQL | 更新日期: 2023-09-27 18:07:12
我想写一个应该与数据库通信的方法,但我不确定我的方法是否正确。
public void dbWorkerLogin(int workerNumber) {
// Connection string stored in "conn"
if (!new SqlCommand("Some Command WHERE id=" +workernumber,conn).executeReader().HasRows)
{
new SqlCommand("exec STORED_PROCEDURE1 " + workerNumber, conn).ExecuteNonQuery();
new SqlCommand("exec STORED_PROCEDURE2 " + workerNumber, conn).ExecuteNonQuery();
}
else
{
new SqlCommand("exec STORED_PROCEDURE3 " + workerNumber,conn).ExecuteNonQuerry();
}
1)是否可以这样写,并以关键字new启动每个SqlCommand ?或者我应该这样做:
SqlCommand command = new SqlCommand(null, conn);
command = ...;
然后循环变量'command'还是这样?
using(SqlCommand cmd = new SqlCommand("COMMAND", conn);
2)我的过程是否有效,或者我应该使用SqlCommand.Prepare()函数将我的数据转换为正确的数据类型?如。workerNumber为整型,但在数据库中以十进制形式存储。
using (SqlCommand cmd = new SqlCommand("STORED_PROCEDURE", conn))
{
cmd.CommandType = CommandType.StoredProcedure;
cmd.Parametres.Add("@id", SqlDbType.Decimal).Value = workNumber;
cmd.Prepare();
cmd.ExecuteNonQuery();
}
你能不能总结一下什么该用,什么不该用?不幸的是,由于对DB的访问有限,我无法测试第一个代码,所以我不确定它是否可以无错误地执行。谢谢你在这个问题上的任何帮助!
编辑:几个小时后,我到达了这个阶段:
public int getWorkerNumber(string uniqueID)
{
using (conn = new SqlConnection(ConfigurationManager.ConnectionStrings["dbConnect"].ConnectionString))
{
conn.Open();
using (SqlCommand cmd = new SqlCommand("SELECT number FROM worker WHERE workerID = @id",conn))
{
cmd.Parameters.Add("@id", SqlDbType.Decimal).Value = uniqueID;
using (SqlDataReader reader = cmd.ExecuteReader())
{
int answer;
while (reader.Read())
{
answer = (int)reader.GetDecimal(0);
}
return answer;
}
}
}
}
还有这个
public string dbLoginWorker(int workerNumber)
{
SqlCommand cmd;
SqlDataReader reader;
using (conn = new SqlConnection(ConfigurationManager.ConnectionStrings["dbConnect"].ConnectionString))
{
conn.Open();
cmd = new SqlCommand("SELECT column FROM table WHERE id= @workernumber", conn);
cmd.Parameters.Add("@workernumber", SqlDbType.Decimal).Value = workerNumber;
reader = cmd.ExecuteReader();
if (!reader.HasRows)
{
cmd = new SqlCommand("STORED_PROCEDURE1", conn);
cmd.CommandType = CommandType.StoredProcedure;
cmd.Parameters.Add("@ID", SqlDbType.Decimal).Value = workerNumber;
cmd.Parameters.Add("@VARCHAR", SqlDbType.VarChar).Value = "text";
cmd.Prepare();
reader.Close();
cmd.ExecuteNonQuery();
cmd.Dispose();
reader.Dispose();
return "procedure 1 executed";
else
{
cmd = new SqlCommand("STORED_PROCEDURE2", conn);
cmd.CommandType = CommandType.StoredProcedure;
cmd.Parameters.Add("@ID", SqlDbType.Decimal).Value = workerNumber;
cmd.Parameters.Add("@INT", SqlDbType.SmallInt).Value = 1;
cmd.Parameters.Add("@VARCHAR", SqlDbType.VarChar).Value = "text";
cmd.Prepare();
reader.Close();
cmd.ExecuteNonQuery();
cmd.Dispose();
reader.Dispose();
return "procedure 2 executed";
}
}
}
两个方法都是函数式的(如果我没有重写错误的话:))。我不确定哪一种方法(第一种或第二种)在稳定性方面更好,如果这种方法更好,更能抵抗SQL注入。有人能评论一下这个话题吗?再次感谢您的帮助!
1)在可能的情况下,最好总是使用USING
块。这包括SqlConnection
, SqlCommand
, SqlReader
和其他实现idisable的对象。USING
块会自动关闭和处置对象,因此您不必这样做。
2)我相信你在错误的地方使用了Prepare()方法。看看下面的StackOverflow文章,了解正确的用法:PrepareMethodInstructions。
3)在dbLoginWorker()
方法中,第一个查询仅用于确定是否找到行。因此,我建议将SELECT
命令更改为SELECT TOP 1 column FROM table WHERE id= @workernumber
,以便查询更快,更有效。
4)我不相信你的命令会受到SQL注入攻击,因为它们是完全参数化的。干得好。
5)作为一个普遍的想法,我建议阅读重构技术。如果您为每个SQL命令创建三个额外的方法,并将它们命名为适当的名称,那么您的dbLoginWorker()
方法就可以变得更具可读性和可维护性,以及自文档化。您还可以设置一个基于连接名称创建连接的方法,这样就不会有那么多重复的代码。例如:
public static SqlConnection GetConnection(string connectionName)
{
SqlConnection conn = new SqlConnection(ConfigurationManager.ConnectionStrings[connectionName].ConnectionString);
conn.Open();
return conn;
}
public string dbLoginWorker(int workerNumber)
{
using (conn = GetConnection("dbConnect"))
{
if (CanFindWorkerNumber(conn, workerNumber))
ExecuteProcedure1(conn);
else
ExecuteProcedure2(conn);
}
}
public bool CanFindWorkerNumber (SqlConnection conn, int workerNumber)
{
bool success = false;
using (SqlCommand cmd = new SqlCommand("SELECT TOP 1 column FROM table WHERE id= @workernumber", conn))
{
cmd.Parameters.Add("@workernumber", SqlDbType.Decimal);
cmd.Prepare();
cmd.Parameters[0].Value = workerNumber;
success = cmd.ExecuteScalar() != null;
}
return success;
}
public void ExecuteProcedure1(SqlConnection conn)
{
using (SqlCommand cmd = new SqlCommand("STORED_PROCEDURE1", conn))
{
cmd.CommandType = CommandType.StoredProcedure;
cmd.Parameters.Add("@ID", SqlDbType.Decimal);
cmd.Parameters.Add("@VARCHAR", SqlDbType.VarChar);
cmd.Prepare();
cmd.Parameters[0].Value = workerNumber;
cmd.Parameters[1].Value = "text";
cmd.ExecuteNonQuery();
}
}
public void ExecuteProcedure1(SqlConnection conn)
{
using (SqlCommand cmd = new SqlCommand("STORED_PROCEDURE1", conn))
{
cmd.CommandType = CommandType.StoredProcedure;
cmd.Parameters.Add("@ID", SqlDbType.Decimal);
cmd.Parameters.Add("@INT", SqlDbType.SmallInt).Value);
cmd.Parameters.Add("@VARCHAR", SqlDbType.VarChar);
cmd.Prepare();
cmd.Parameters[0] = workerNumber;
cmd.Parameters[1] = 1;
cmd.Parameters[2] = "text";
cmd.ExecuteNonQuery();
}
}
您实际上可以在一个SQL推荐中完成此操作。现在,您回拉结果集只是为了查看它是否有行,然后根据它执行不同的命令。您应该能够在一个命令中完成该操作,并适当地处理它和连接:
var sql =
@"
IF EXISTS(Some Command WHERE id=@workernumber)
BEGIN
exec STORED_PROCEDURE1 @workernumber;
exec STORED_PROCEDURE2 @workernumber;
END
ELSE
exec STORED_PROCEDURE3 @workernumber;
";
请注意,您不容易受到SQL注入,因为您没有处理字符串,只有整数。