Home
last modified time | relevance | path

Searched refs:inserter (Results 1 - 18 of 18) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_data_inserter.cpp55 RelationalSyncDataInserter inserter; in CreateInserter() local
56 inserter.SetHashDevId(DBCommon::TransferStringToHex(DBCommon::TransferHashString(deviceName))); in CreateInserter()
57 inserter.SetRemoteFields(remoteFields); in CreateInserter()
58 inserter.SetQuery(query); in CreateInserter()
60 inserter.SetLocalTable(localTable); in CreateInserter()
61 inserter.SetTableMode(localSchema.GetTableMode()); in CreateInserter()
63 inserter.SetInsertTableName(localTable.GetTableName()); in CreateInserter()
65 inserter.SetInsertTableName(DBCommon::GetDistributedTableName(deviceName, localTable.GetTableName(), info)); in CreateInserter()
67 return inserter; in CreateInserter()
H A Drelational_sync_able_storage.cpp550 auto inserter = RelationalSyncDataInserter::CreateInserter(deviceName, query, storageEngine_->GetSchema(), in SaveSyncDataItems() local
552 inserter.SetEntries(dataItems); in SaveSyncDataItems()
570 errCode = handle->SaveSyncItems(inserter); in SaveSyncDataItems()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor.cpp832 RelationalSyncDataInserter &inserter, sqlite3_stmt *&stmt) in DeleteSyncDataItem()
835 int errCode = inserter.GetDeleteSyncDataStmt(dbHandle_, stmt); in DeleteSyncDataItem()
863 RelationalSyncDataInserter &inserter, int64_t &rowid) in SaveSyncDataItem()
866 return DeleteSyncDataItem(dataItem, inserter, saveStmt.rmDataStmt); in SaveSyncDataItem()
868 if ((mode_ == DistributedTableMode::COLLABORATION && inserter.GetLocalTable().GetIdentifyKey().size() == 1u && in SaveSyncDataItem()
869 inserter.GetLocalTable().GetIdentifyKey().at(0) == "rowid") || in SaveSyncDataItem()
870 (mode_ == DistributedTableMode::SPLIT_BY_DEVICE && inserter.GetLocalTable().GetPrimaryKey().size() == 1u && in SaveSyncDataItem()
871 inserter.GetLocalTable().GetPrimaryKey().at(0) == "rowid") || in SaveSyncDataItem()
872 inserter.GetLocalTable().GetAutoIncrement()) { // No primary key of auto increment in SaveSyncDataItem()
873 int errCode = DeleteSyncDataItem(dataItem, inserter, saveStm in SaveSyncDataItem()
831 DeleteSyncDataItem(const DataItem &dataItem, RelationalSyncDataInserter &inserter, sqlite3_stmt *&stmt) DeleteSyncDataItem() argument
862 SaveSyncDataItem(const DataItem &dataItem, SaveSyncDataStmt &saveStmt, RelationalSyncDataInserter &inserter, int64_t &rowid) SaveSyncDataItem() argument
893 DeleteSyncLog(const DataItem &dataItem, RelationalSyncDataInserter &inserter, sqlite3_stmt *&stmt) DeleteSyncLog() argument
924 ProcessMissQueryData(const DataItem &item, RelationalSyncDataInserter &inserter, sqlite3_stmt *&rmDataStmt, sqlite3_stmt *&rmLogStmt) ProcessMissQueryData() argument
963 SaveSyncDataItem(RelationalSyncDataInserter &inserter, SaveSyncDataStmt &saveStmt, DataItem &item) SaveSyncDataItem() argument
988 SaveSyncDataItems(RelationalSyncDataInserter &inserter) SaveSyncDataItems() argument
1014 SaveSyncItems(RelationalSyncDataInserter &inserter, bool useTrans) SaveSyncItems() argument
[all...]
H A Dsqlite_single_ver_relational_storage_executor.h83 int SaveSyncItems(RelationalSyncDataInserter &inserter, bool useTrans = true);
109 int SaveSyncDataItems(RelationalSyncDataInserter &inserter);
258 int SaveSyncDataItem(RelationalSyncDataInserter &inserter, SaveSyncDataStmt &saveStmt, DataItem &item);
260 int SaveSyncDataItem(const DataItem &dataItem, SaveSyncDataStmt &saveStmt, RelationalSyncDataInserter &inserter,
263 int DeleteSyncDataItem(const DataItem &dataItem, RelationalSyncDataInserter &inserter, sqlite3_stmt *&rmDataStmt);
271 int DeleteSyncLog(const DataItem &item, RelationalSyncDataInserter &inserter, sqlite3_stmt *&rmLogStmt);
272 int ProcessMissQueryData(const DataItem &item, RelationalSyncDataInserter &inserter, sqlite3_stmt *&rmDataStmt,
/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/src/drawing/engine_adapter/skia_adapter/
H A Dskia_hm_symbol_config_ohos.cpp113 std::inserter(out.curveArgs, out.curveArgs.begin())); in ConvertPiecewiseParameter()
115 std::inserter(out.properties, out.properties.begin())); in ConvertPiecewiseParameter()
/foundation/filemanagement/app_file_service/tests/unittests/backup_sa/module_ipc/
H A Dsched_scheduler_test.cpp78 transform(bundleNames.begin(), bundleNames.end(), inserter(backupExtNameMap, backupExtNameMap.end()), in Init()
/foundation/graphic/graphic_3d/lume/Lume_3D/src/ecs/systems/
H A Dnode_system.cpp851 auto inserter = std::back_inserter(entitiesWithNode); variable
852 inserter = std::set_difference(nodeEntities_.cbegin(), nodeEntities_.cend(), first, last, inserter,
858 inserter = std::set_difference(first, last, nodeEntities_.cbegin(), nodeEntities_.cend(), inserter,
/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/
H A Dhmp_bundle_installer.cpp204 std::inserter(normalBundleList, normalBundleList.begin())); in RollbackHmpBundle()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/avrcp_tg/
H A Davrcp_tg_connection.cpp169 std::transform(infos_.begin(), infos_.end(), std::inserter(addrs, addrs.end()), in GetDeviceAddresses()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_task_context.cpp464 inserter(algoIntersection, algoIntersection.begin())); in ChooseCompressAlgo()
/foundation/barrierfree/accessibility/services/aams/src/
H A Daccessibility_settings_config.cpp263 std::copy_if(name.begin(), name.end(), std::inserter(targets, targets.end()), in SetShortkeyMultiTarget()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/avrcp_ct/
H A Davrcp_ct_connection.cpp195 std::transform(infos_.begin(), infos_.end(), std::inserter(addrs,addrs.end()), in GetDeviceAddresses()
/foundation/CastEngine/castengine_cast_plus_stream/src/rtsp/src/
H A Drtsp_controller.cpp1149 featureSet.end(), inserter(negotiateFeatureSet, negotiateFeatureSet.begin())); in ProcessFeatureSet()
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/rtsp/src/
H A Drtsp_controller.cpp1149 featureSet.end(), inserter(negotiateFeatureSet, negotiateFeatureSet.begin())); in ProcessFeatureSet()
/foundation/arkui/ace_engine/frameworks/core/components_v2/common/
H A Delement_proxy.cpp1629 std::inserter(idsToRemove, idsToRemove.begin())); in ReleaseRedundantComposeIds()
/foundation/resourceschedule/device_standby/services/core/src/
H A Dstandby_service_impl.cpp864 allowSet.end(), std::inserter(restrictSet, restrictSet.begin())); in GetEligiableRestrictSet()
/foundation/communication/netstack/frameworks/js/napi/tls/src/
H A Dtls_socket.cpp142 set_intersection(vecA.begin(), vecA.end(), vecB.begin(), vecB.end(), inserter(result, result.begin())); in SeekIntersection()
H A Dtls_socket_server.cpp92 set_intersection(vecA.begin(), vecA.end(), vecB.begin(), vecB.end(), inserter(result, result.begin())); in SeekIntersection()

Completed in 31 milliseconds