6

我只是以多线程方式测试 PetaPoco Transaction ......

我有一个简单的测试用例：

-- 简单的值对象称为 MediaDevice -- 插入一条记录并更新 1000 次

void TransactionThread(Object object)
{


    Database db = (Database) object;

    for(int i= 0; i < 1000;i++)
    {


        Transaction transaction = db.GetTransaction();

        MediaDevice device = new  MediaDevice();
        device.Name = "Name";
        device.Brand = "Brand";

        db.Insert(device);

        device.Name = "Name_Updated";
        device.Brand = "Brand_Updated";


        db.Update(device);

        transaction.Complete();

    }


    long count = db.ExecuteScalar<long>("SELECT Count(*) FROM MediaDevices");

    Console.WriteLine("Number of all records:" + count);

}

我在两个线程中这样调用它：[两个线程的单个数据库对象]

void TransactionTest()
{

    Database db =  GetDatabase();

    Thread tThread1 = ... // thread for  TransactionTest()

    Thread tThread2 = ... // thread for  TransactionTest()

     tThread1.Start(db); // pass Database to TransactionTest()
     tThread2.Start(db); // pass same Database to TransactionTest()

}

我收到 Null 错误或有时数据库的对象处理错误..

但是当我提供两个数据库实例时，

void TransactionTest()
{

    Database db =  GetDatabase();
    Database db2 =  GetDatabase();

    Thread tThread1 = ... // thread for  TransactionTest()

    Thread tThread2 = ... // thread for  TransactionTest()


    tThread1.Start(db);  // pass Database instance db to TransactionTest()
    tThread2.Start(db2); // pass Database intance db2 to TransactionTest()

}

一切正常...

好吧，当我在事务中检查 PetaPoco 源代码时，我在事务中看到了。完成

 public virtual void Complete()
        {
            _db.CompleteTransaction();
            _db = null;
        }

我的问题是能够使用来自多个线程的事务我必须使用数据库对象的新副本吗？或者我做错了什么？

为了使其线程安全，我是否必须在每次数据更新查询时打开和关闭新数据库？

4

3 回答 3

4

是的，每个线程都需要一个单独的 PetaPoco 数据库实例。请参阅 PetaPoco 文档中的这句话：

注意：要使事务工作，所有操作都需要使用相同的 PetaPoco 数据库对象实例。因此，您可能希望使用每个 http 请求或每个线程 IOC 容器来提供该对象的共享实例。就我个人而言，StructureMap 是我最喜欢的。

我将给出线索的短语加粗。也就是说，每个线程都应该使用 PetaPoco 数据库对象的一个​​实例。

于 2012-09-28T18:48:22.527 回答
1

对不起，伙计..是的，你是对的。他们将对象更改为空。所以你不能使用同一个对象来线程化。你必须使用他们使用的描述，如 db=GetDataBase() ；db2=GetDataBase();

否则您可以根据您的要求更改源代码。我认为他们的许可证允许。但我不确定。

于 2012-06-26T10:22:16.863 回答
1

您好在选择查询中使用 nolock，因为表可能被锁定。long count = db.ExecuteScalar("SELECT Count(*) with nolock FROM MediaDevices");

于 2012-06-26T06:10:01.873 回答