From 818e18cc9589d0a40e61f53eef6536c2c3ffa931 Mon Sep 17 00:00:00 2001 From: jiahaoluo Date: Sun, 23 Apr 2023 12:14:20 +0000 Subject: [PATCH] add sdk delete records Signed-off-by: jiahaoluo Change-Id: I987c8fe5a7f6449b8e18e30788747a9e066466fb --- .../src/data_sync/sdk_helper.cpp | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/services/cloudsyncservice/src/data_sync/sdk_helper.cpp b/services/cloudsyncservice/src/data_sync/sdk_helper.cpp index 52afeb008..5d762cac0 100644 --- a/services/cloudsyncservice/src/data_sync/sdk_helper.cpp +++ b/services/cloudsyncservice/src/data_sync/sdk_helper.cpp @@ -98,12 +98,12 @@ int32_t SdkHelper::CreateRecords(shared_ptr context, std::shared_ptr>, const DriveKit::DKError &)> callback) { - auto err = database_->SaveRecords(context, records, DriveKit::DKSavePolicy::DK_SAVE_IF_UNCHANGED, callback); + auto err = database_->SaveRecords(context, records, DriveKit::DKSavePolicy::DK_SAVE_IF_UNCHANGED, + callback); if (err != DriveKit::DKLocalErrorCode::NO_ERROR) { - LOGE("drivekit save records err %{public}d", err); + LOGE("drivekit saves records err %{public}d", err); return E_CLOUD_SDK; } - return E_OK; } @@ -113,10 +113,12 @@ int32_t SdkHelper::DeleteRecords(shared_ptr context, std::shared_ptr>, const DriveKit::DKError &)> callback) { - auto result = std::make_shared>(); - DriveKit::DKError err; - std::thread ([=]() { callback(context, nullptr, result, err); }).detach(); - + auto err = database_->DeleteRecords(context, records, DriveKit::DKSavePolicy::DK_SAVE_IF_UNCHANGED, + callback); + if (err != DriveKit::DKLocalErrorCode::NO_ERROR) { + LOGE("drivekit deletes records err %{public}d", err); + return E_CLOUD_SDK; + } return E_OK; } -- Gitee