如何使用 unique_ptr 创建 blob 流？

Question

使用以下代码时，我成功地将图像保存到“图像”blob 字段中：

if (OpenDialog1->Execute()) {
    ADOTable1->Insert();
    TStream* BlobStream = ADOTable1->CreateBlobStream(ADOTable1->FieldByName("Image"), bmWrite);
    std::unique_ptr<TFileStream> FileStream(new TFileStream(OpenDialog1->FileName, fmOpenRead));
    BlobStream->CopyFrom(FileStream.get(), FileStream->Size);
    delete BlobStream;
    ADOTable1->Post();
}

但是，我也想使用std:unique_ptr 创建BlobStream 对象，这样我就可以避免手动delete。当我尝试时

if (OpenDialog1->Execute()) {
    ADOTable1->Insert();
    std::unique_ptr<TStream> BlobStream(ADOTable1->CreateBlobStream(ADOTable1->FieldByName("Image"), bmWrite));
    std::unique_ptr<TFileStream> FileStream(new TFileStream(OpenDialog1->FileName, fmOpenRead));
    BlobStream->CopyFrom(FileStream.get(), FileStream->Size);
    ADOTable1->Post();
}

我得到 无法插入空行错误。我在这里做错了什么？我正在使用 C++ Builder 10.3.3。

Answer 1

在原始代码中，您在调用Post() 之前之前是delete'ing blob TStream 对象。

根据TADOBlobStream 文档：

http://docwiki.embarcadero.com/Libraries/en/Data.Win.ADODB.TADOBlobStream.Destroy

Destroy [即析构函数] 执行以下任务：

• 设置字段的数据。

• 将字段对象的 Modified 属性更改为 true。

• 在字段的数据集对象中触发字段更改事件。

• 调用继承的析构函数。

因此，您在 Post()'ing 之前设置了 blob 的字段数据，一切都很好。

在更新后的代码中，当BlobStream 超出范围在调用Post() 时，您是delete'ing blob TStream 对象。因此，尚未设置字段数据，因此出现错误。

为确保 blob TStream 对象在调用 Post() 之前被破坏，您可以：

• 在BlobStream 周围添加一个新范围：

if (OpenDialog1->Execute()) {
    std::unique_ptr<TFileStream> FileStream(new TFileStream(OpenDialog1->FileName, fmOpenRead));
    ADOTable1->Insert();
    {
    std::unique_ptr<TStream> BlobStream(ADOTable1->CreateBlobStream(ADOTable1->FieldByName("Image"), bmWrite));
    BlobStream->CopyFrom(FileStream.get(), FileStream->Size);
    }
    ADOTable1->Post();
}

• 手动拨打reset()BlobStream：

if (OpenDialog1->Execute()) {
    std::unique_ptr<TFileStream> FileStream(new TFileStream(OpenDialog1->FileName, fmOpenRead));
    ADOTable1->Insert();
    std::unique_ptr<TStream> BlobStream(ADOTable1->CreateBlobStream(ADOTable1->FieldByName("Image"), bmWrite));
    BlobStream->CopyFrom(FileStream.get(), FileStream->Size);
    BlobStream.reset();
    ADOTable1->Post();
}

无论哪种方式，如果在 Post()'ed 之前发生意外情况，您应该对新行插入进行一些错误处理，以便 Cancel() 插入新行，例如：

if (OpenDialog1->Execute()) {
    std::unique_ptr<TFileStream> FileStream(new TFileStream(OpenDialog1->FileName, fmOpenRead));
    ADOTable1->Insert();
    try {
        std::unique_ptr<TStream> BlobStream(ADOTable1->CreateBlobStream(ADOTable1->FieldByName("Image"), bmWrite));
        BlobStream->CopyFrom(FileStream.get(), FileStream->Size);
        BlobStream.reset();
        ADOTable1->Post();
    }
    catch (const Exception &) {
        ADOTable1->Cancel();
        throw;
    }
}