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注入。有人能评论一下这个话题吗?再次感谢您的帮助!

C# SQL, Multiple Commands

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注入,因为您没有处理字符串,只有整数。