0

即使我已经TransactionScope到位，我也无法在数据表上实现同步数据访问。

我有一个 WCF 服务，它负责访问存储在 SQL 数据库中的序列化对象图；这是通过一个名为的操作契约来实现的GetObject，它使用 given 从表中返回一个序列化对象tokenId。tokenId 在我们的场景中是相关的，以确保没有两个用户在任何时间点都可以访问同一行（对象图）。

而对于 wcf 服务，我们的服务是多线程的（CuncurrencyisMultiple和InstanceContextModeis PerCall）。

public CustomObject GetObject(string username, string userTeam)
{
     int tokenID = Database.GetNextToken(username, userTeam);

     MainDataLayer.LoadData loadData = new MainDataLayer.LoadData();
     return loadData.GetObject (tokenID);
}

GetNextToken(tokenID)调用 aCLR stored procedure以访问事务范围内的数据库表。

 public static void usp_GetNextToken(SqlString userID, SqlString userTeam)
  {
    using (TransactionScope transactionScope = new TransactionScope())
    {
      using (SqlConnection connection = new SqlConnection("context connection = true"))
      {
        connection.Open();

        SqlDataRecord record = new SqlDataRecord(new SqlMetaData[1]
        {
          new SqlMetaData("objectId", SqlDbType.Int)
        });

SqlDataAdapter sqlDataAdapter2 = new SqlDataAdapter(new SqlCommand("SELECT top (1) * FROM myTable where lockedby= ' ' ORDER BY createdate DESC ", connection));


          DataSet dataSet2 = new DataSet();
          if (connection.State == ConnectionState.Closed)
            connection.Open();
          ((DataAdapter) sqlDataAdapter2).Fill(dataSet2);

          if (dataSet2.Tables[0].Rows.Count > 0)
          {
            new SqlCommand(string.Concat(new object[4]
            {
              (object) "UPDATE myTable SET lockedby = '",
              (object) userID.ToString(),
              (object) "' WHERE objectId = ",
              (object) int.Parse(dataSet2.Tables[0].Rows[0][" objectId "].ToString())
            }), connection).ExecuteNonQuery();
            record.SetSqlInt32(0, (SqlInt32) int.Parse(dataSet2.Tables[0].Rows[0][" objectId "].ToString()));
            SqlContext.Pipe.Send(record);
            return;
          }
        }
        record.SetSqlInt32(0, (SqlInt32) 0);
        SqlContext.Pipe.Send(record);
      }
      transactionScope.Complete();
    }
  }

问题 有了所有这些，我们在大多数情况下最终都会让多个用户访问同一个对象图。

4

1 回答 1

0

不确定您要在这里实现什么。TransactionScope 仅在适当的位置，因此您可以提交或回滚 SQL 语句。

我认为您可以使用它lock来防止处理多个请求：

private static object DatabaseLock = new object();

public CustomObject GetObject(string username, string userTeam)
{
    lock (DatabaseLock)
    {
        int tokenID = Database.GetNextToken(username, userTeam);

        MainDataLayer.LoadData loadData = new MainDataLayer.LoadData();
        return loadData.GetObject (tokenID);
    }
}

然而，这会影响性能。

是不是更简单地创建一个Concurrency设置为的服务Single？

于 2013-11-11T11:06:27.247 回答