为什么这个查询会产生文件共享冲突？

Question

下面的代码给了我错误（我从 catch 块中的 MessageBox.Show() 得到它）

"PopulateBla() 中的异常：存在文件共享冲突。A 不同的进程可能正在使用文件 [,,,,,,]

代码

using (SqlCeCommand cmd = new SqlCeCommand(SQL_GET_VENDOR_ITEMS, new SqlCeConnection(SQLCE_CONN_STR))) 
{
    cmd.Parameters.Add("@VendorID", SqlDbType.NVarChar, 10).Value = vendorId; 
    cmd.Parameters.Add("@VendorItemID", SqlDbType.NVarChar, 19).Value = vendorItemId;
    try 
    {
        cmd.Connection.Open();
        using (SqlCeDataReader SQLCEReader = cmd.ExecuteReader(CommandBehavior.SingleRow)) 
        {
            if (SQLCEReader.Read())  
            {
                itemID = SQLCEReader.GetString(ITEMID_INDEX);
                packSize = SQLCEReader.GetString(PACKSIZE_INDEX);
                recordFound = true;
            }
        }
    } 
    catch (SqlCeException err) 
    {
        MessageBox.Show(string.Format("Exception in PopulateControlsIfVendorItemsFound: {0}\r\n", err.Message));//TODO: Remove
    } 
    finally 
    {
        if (cmd.Connection.State == ConnectionState.Open) 
        {
            cmd.Connection.Close();
        }
    }
}

SQL_GET_VENDOR_ITEMS 是我的查询字符串。

这里可能会发生什么文件共享问题？

更新

这种代码使得 ctacke 推荐的重构变得困难：

public void setINVQueryItemGroup( string ID )
{
    try
    {
        dynSQL += " INNER JOIN td_item_group ON t_inv.id = td_item_group.id AND t_inv.pack_size = td_item_group.pack_size WHERE td_item_group.item_group_id = '" + ID + "'";
    } 
    catch( Exception ex )
    {
        CCR.ExceptionHandler( ex, "InvFile.setINVQueryDept" );
    }
}

通过单独的方法附加 SQL 语句，更改全局变量 (dynSQL)，同时可能允许 SQL 注入（取决于分配 ID 的位置/方式）。如果这还不够，任何抛出的异常都可能误导疲倦的 bughunter，因为它表明它发生在不同的方法中（无疑是粗心的复制和粘贴操作的受害者）。

这是“编码恐怖” - 值得。几行代码可以忽略多少最佳实践？

这是另一个例子：

string dynSQL = "SELECT * FROM purgatory WHERE vendor_item = '" + VendorItem + "' ";

if (vendor_id != "")
{
    dynSQL += "AND vendor_id = '" + vendor_id + "' ";
}

可以通过将 args 替换为“？”来完成，但是用于确定要分配哪些/多少参数的代码将比 Joe Garagiola 的平均夹板丑 42 倍。

Answer 1

我真的很喜欢 Chris 使用单一连接到您的数据库的想法。您可以像这样向您的班级声明全局：

public ClayShannonDatabaseClass
{

    private SqlCeConnection m_openConnection;

    public ClayShannonDatabaseClass()
    {
       m_openConnection = new SqlCeConnection();
       m_openConnection.Open();
    }

    public void Dispose()
    {
       m_openConnection.Close();
       m_openConnection.Dispose();
       m_openConnection = null;
    }

}

我猜你的代码会在你尝试实际打开数据库时崩溃。

为了验证这一点，您可以在代码中粘贴一个整数值来帮助您调试。

例子：

int debugStep = 0;
try 
{
    //cmd.Connection.Open(); (don't call this if you use m_openConnection)
    debugStep = 1;
    using (SqlCeDataReader SQLCEReader = cmd.ExecuteReader(CommandBehavior.SingleRow)) 
    {
        debugStep = 2;
        if (SQLCEReader.Read())  
        {
            debugStep = 3;
            itemID = SQLCEReader.GetString(ITEMID_INDEX);
            debugStep = 4;
            packSize = SQLCEReader.GetString(PACKSIZE_INDEX);
            debugStep = 5;
            recordFound = true;
        }
    }
} 
catch (SqlCeException err) 
{
    string msg = string.Format("Exception in PopulateControlsIfVendorItemsFound: {0}\r\n", err.Message);
    string ttl = string.Format("Debug Step: {0}", debugStep);
    MessageBox.Show(msg, ttl); //TODO: Remove
}
// finally (don't call this if you use m_openConnection)
// {
//     if (cmd.Connection.State == ConnectionState.Open) 
//     {
//         cmd.Connection.Close();
//     }
// }

我猜你的错误出现在第 1 步。

Answer 2

如果文件未标记为只读（您检查过，对吗？），那么您有另一个进程对该文件具有非共享锁定。

如果 SQL CE 附带的 isql.exe 数据库浏览器在后台运行，它就是一个常见的罪魁祸首。

根据您的 SQLCE 版本，很可能另一个进程有一个打开的连接（不记得是哪个版本开始允许多个进程连接），所以如果您在后台有任何其他应用程序打开它，那也可能是个问题。

您还使用了大量连接到该数据库的连接，它们并不总是被清理并立即释放到 Dispose。我强烈建议构建一个简单的连接管理器类，它保持与数据库的单个（或更多类似两个）连接，并将它们重用于所有操作。