Home
last modified time | relevance | path

Searched refs:tableName (Results 1 - 25 of 369) sorted by relevance

12345678910>>...15

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsimple_tracker_log_table_manager.cpp42 const std::string tableName = GetLogTableName(table); in GetIndexSql() local
44 std::string indexCursor = "CREATE INDEX IF NOT EXISTS " + tableName + in GetIndexSql()
45 "_cursor_index ON " + tableName + "(cursor);"; in GetIndexSql()
46 std::string indexDataKey = "CREATE INDEX IF NOT EXISTS " + tableName + in GetIndexSql()
47 "_data_key_index ON " + tableName + "(data_key);"; in GetIndexSql()
64 std::string tableName = table.GetTableName(); in GetInsertTrigger() local
66 insertTrigger += "naturalbase_rdb_" + tableName + "_ON_INSERT AFTER INSERT \n"; in GetInsertTrigger()
67 insertTrigger += "ON '" + tableName + "'\n"; in GetInsertTrigger()
70 insertTrigger += CloudStorageUtils::GetCursorIncSql(tableName) + "\n"; in GetInsertTrigger()
78 insertTrigger += ", " + CloudStorageUtils::GetSelectIncCursorSql(tableName) in GetInsertTrigger()
93 std::string tableName = table.GetTableName(); GetUpdateTrigger() local
121 std::string tableName = table.GetTableName(); GetDeleteTrigger() local
144 std::string tableName = table.GetTableName(); GetDropTriggers() local
[all...]
H A Dcloud_sync_log_table_manager.cpp65 const std::string tableName = GetLogTableName(table); in GetIndexSql() local
67 std::string indexTimestampFlagGid = "CREATE INDEX IF NOT EXISTS " + tableName + in GetIndexSql()
68 "_cloud_time_flag_gid_index ON " + tableName + "(timestamp, flag, cloud_gid);"; in GetIndexSql()
69 std::string indexGid = "CREATE INDEX IF NOT EXISTS " + tableName + in GetIndexSql()
70 "_cloud_gid_index ON " + tableName + "(cloud_gid);"; in GetIndexSql()
71 std::string indexDataKey = "CREATE INDEX IF NOT EXISTS " + tableName + in GetIndexSql()
72 "_data_key_index ON " + tableName + "(data_key);"; in GetIndexSql()
73 std::string indexCursor = "CREATE INDEX IF NOT EXISTS " + tableName + in GetIndexSql()
74 "_cursor_index ON " + tableName + "(cursor);"; in GetIndexSql()
94 std::string tableName in GetInsertTrigger() local
129 std::string tableName = table.GetTableName(); GetUpdateTrigger() local
158 std::string tableName = table.GetTableName(); GetDeleteTrigger() local
192 std::string tableName = table.GetTableName(); GetDropTriggers() local
[all...]
H A Dsqlite_single_ver_relational_storage_executor.h64 int UpgradeDistributedTable(const std::string &tableName, DistributedTableMode mode, bool &schemaChanged,
87 int DeleteDistributedDeviceTable(const std::string &device, const std::string &tableName);
89 int DeleteDistributedAllDeviceTableLog(const std::string &tableName);
91 int DeleteDistributedDeviceTableLog(const std::string &device, const std::string &tableName);
93 int DeleteDistributedLogTable(const std::string &tableName);
134 int PutCloudSyncData(const std::string &tableName, const TableSchema &tableSchema,
156 int GetAndResetServerObserverData(const std::string &tableName, ChangeProperties &changeProperties);
158 int CleanTrackerData(const std::string &tableName, int64_t cursor);
165 int GetReferenceGid(const std::string &tableName, const CloudSyncBatch &syncBatch,
169 int CheckIfExistUserTable(const std::string &tableName);
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dcloud_meta_data.cpp29 int CloudMetaData::GetLocalWaterMark(const TableName &tableName, Timestamp &localMark) in GetLocalWaterMark() argument
32 if (cloudMetaVals_.count(tableName) == 0) { in GetLocalWaterMark()
33 int ret = ReadMarkFromMeta(tableName); in GetLocalWaterMark()
39 localMark = cloudMetaVals_[tableName].localMark; in GetLocalWaterMark()
43 int CloudMetaData::GetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timestamp &localMark) in GetLocalWaterMarkByType() argument
46 if (cloudMetaVals_.count(tableName) == 0) { in GetLocalWaterMarkByType()
47 int ret = ReadMarkFromMeta(tableName); in GetLocalWaterMarkByType()
54 localMark = cloudMetaVals_[tableName].insertLocalMark; in GetLocalWaterMarkByType()
56 localMark = cloudMetaVals_[tableName].updateLocalMark; in GetLocalWaterMarkByType()
58 localMark = cloudMetaVals_[tableName] in GetLocalWaterMarkByType()
64 GetCloudWaterMark(const TableName &tableName, std::string &cloudMark) GetCloudWaterMark() argument
78 SetLocalWaterMark(const TableName &tableName, Timestamp localMark) SetLocalWaterMark() argument
101 SetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timestamp localMark) SetLocalWaterMarkByType() argument
132 SetCloudWaterMark(const TableName &tableName, std::string &cloudMark) SetCloudWaterMark() argument
156 ReadMarkFromMeta(const TableName &tableName) ReadMarkFromMeta() argument
175 WriteMarkToMeta(const TableName &tableName, Timestamp localmark, std::string &cloudMark) WriteMarkToMeta() argument
188 WriteTypeMarkToMeta(const TableName &tableName, CloudMetaValue &cloudMetaValue) WriteTypeMarkToMeta() argument
254 CleanWaterMark(const TableName &tableName) CleanWaterMark() argument
274 CleanWaterMarkInMemory(const TableName &tableName) CleanWaterMarkInMemory() argument
[all...]
H A Dschema_mgr.cpp30 int SchemaMgr::ChkSchema(const TableName &tableName, RelationalSchemaObject &localSchema) in ChkSchema() argument
36 TableInfo tableInfo = localSchema.GetTable(tableName); in ChkSchema()
39 DBCommon::StringMiddleMasking(tableName).c_str(), tableName.size()); in ChkSchema()
44 DBCommon::StringMiddleMasking(tableName).c_str(), tableName.size()); in ChkSchema()
48 int ret = GetCloudTableSchema(tableName, cloudTableSchema); in ChkSchema()
51 DBCommon::StringMiddleMasking(tableName).c_str(), tableName.size(), ret); in ChkSchema()
156 std::string tableName in SetCloudDbSchema() local
209 GetCloudTableSchema(const TableName &tableName, TableSchema &retSchema) GetCloudTableSchema() argument
223 IsSharedTable(const std::string &tableName) IsSharedTable() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_cloud_interfaces_relational_ext_test.cpp56 void CheckTriggerObserverTest002(const std::string &tableName, std::atomic<int> &count);
82 void CheckTriggerTableData(size_t dataSize, const std::string &tableName, ChangeProperties &properties, in CheckTriggerTableData() argument
86 EXPECT_EQ(triggerTableData_.begin()->first, tableName); in CheckTriggerTableData()
133 void DistributedDBCloudInterfacesRelationalExtTest::CheckTriggerObserverTest002(const std::string &tableName, in CheckTriggerObserverTest002() argument
138 EXPECT_EQ(triggerTableData_.begin()->first, tableName); in CheckTriggerObserverTest002()
156 static void SetTracerSchemaTest001(const std::string &tableName) in SetTracerSchemaTest001() argument
159 schema.tableName = tableName; in SetTracerSchemaTest001()
213 for (const auto &tableName : tableNames) { in PrepareData()
215 sql = "create table " + tableName in PrepareData()
250 const std::string tableName = "sync_data"; InsertTriggerTest() local
337 const std::string tableName = "sync_data"; HWTEST_F() local
390 const std::string tableName = "sync_data"; UpdateTriggerTest() local
488 const std::string tableName = "sync_data"; HWTEST_F() local
591 const std::string tableName = "sync_data"; HWTEST_F() local
706 const std::string tableName = "sync_data"; HWTEST_F() local
769 const std::string tableName = "sync_data"; HWTEST_F() local
908 const std::string tableName = "sync_data"; HWTEST_F() local
979 InitLogicDeleteData(sqlite3 *&db, const std::string &tableName, uint64_t num) InitLogicDeleteData() argument
989 CheckLogicDeleteData(sqlite3 *&db, const std::string &tableName, uint64_t expectNum) CheckLogicDeleteData() argument
1023 const std::string tableName = "sync_data"; HWTEST_F() local
1264 const std::string tableName = "sync_data"; HWTEST_F() local
1291 InitDataStatus(const std::string &tableName, int count, sqlite3 *db) InitDataStatus() argument
1306 CheckDataStatus(const std::string &tableName, const std::string &condition, sqlite3 *db, int64_t expect) CheckDataStatus() argument
1332 const std::string tableName = "sync_data"; HWTEST_F() local
1374 const std::string tableName = "sync_data"; HWTEST_F() local
1430 const std::string tableName = "sync_data"; HWTEST_F() local
1463 CreateTableForStoreObserver(sqlite3 *db, const std::string tableName) CreateTableForStoreObserver() argument
1474 PrepareDataForStoreObserver(sqlite3 *db, const std::string &tableName, int begin, int dataCounts) PrepareDataForStoreObserver() argument
1554 std::string tableName = "primary_test"; HWTEST_F() local
1611 std::string tableName = "primary_test"; HWTEST_F() local
1662 std::string tableName = "primary_test"; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dprocess_notifier.cpp32 void ProcessNotifier::Init(const std::vector<std::string> &tableName, in Init() argument
36 InitSyncProcess(tableName, syncProcess_); in Init()
39 InitSyncProcess(tableName, syncProcess); in Init()
45 void ProcessNotifier::InitSyncProcess(const std::vector<std::string> &tableName, SyncProcess &syncProcess) in InitSyncProcess() argument
49 for (const auto &table: tableName) { in InitSyncProcess()
58 if (process.tableName.empty()) { in UpdateProcess()
63 syncProcess.tableProcess[process.tableName].process = process.tableStatus; in UpdateProcess()
66 syncProcess.tableProcess[process.tableName].downLoadInfo = process.downLoadInfo; in UpdateProcess()
70 syncProcess.tableProcess[process.tableName].upLoadInfo = process.upLoadInfo; in UpdateProcess()
131 uint32_t ProcessNotifier::GetUploadBatchIndex(const std::string &tableName) cons
141 ResetUploadBatchIndex(const std::string &tableName) ResetUploadBatchIndex() argument
157 GetLastUploadInfo(const std::string &tableName, Info &lastUploadInfo) const GetLastUploadInfo() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/
H A Dcloud_meta_data.h36 int GetLocalWaterMark(const TableName &tableName, Timestamp &localMark);
37 int GetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timestamp &localMark);
38 int GetCloudWaterMark(const TableName &tableName, std::string &cloudMark);
40 int SetLocalWaterMark(const TableName &tableName, Timestamp localMark);
41 int SetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timestamp localMark);
42 int SetCloudWaterMark(const TableName &tableName, std::string &cloudMark);
44 int CleanWaterMark(const TableName &tableName);
48 void CleanWaterMarkInMemory(const TableName &tableName);
59 int ReadMarkFromMeta(const TableName &tableName);
60 int WriteMarkToMeta(const TableName &tableName, Timestam
[all...]
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Drdb_predicates.cpp25 RdbPredicates::RdbPredicates(const std::string &tableName) : AbsRdbPredicates(tableName) in RdbPredicates() argument
38 RdbPredicates *RdbPredicates::CrossJoin(const std::string &tableName) in CrossJoin() argument
40 return Join(JoinType::CROSS, tableName); in CrossJoin()
46 RdbPredicates *RdbPredicates::InnerJoin(const std::string &tableName) in InnerJoin() argument
48 return Join(JoinType::INNER, tableName); in InnerJoin()
54 RdbPredicates *RdbPredicates::LeftOuterJoin(const std::string &tableName) in LeftOuterJoin() argument
56 return Join(JoinType::LEFT, tableName); in LeftOuterJoin()
61 RdbPredicates *RdbPredicates::Join(int join, const std::string &tableName) in Join() argument
63 if (tableName in Join()
[all...]
/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/medialibrary_tool/src/command/
H A Dlist_command_v10.cpp30 static int32_t ListAsset(const ExecEnv &env, const std::string &tableName, const std::string &uri) in ListAsset() argument
32 if (tableName.empty()) { in ListAsset()
36 printf("Table Name: %s\n", tableName.c_str()); in ListAsset()
38 auto res = UserFileClientEx::Query(tableName, uri, resultSet, true); in ListAsset()
43 printf("%s query issue failed. tableName:%s, uri:%s\n", STR_FAIL.c_str(), tableName.c_str(), in ListAsset()
62 static int32_t ListAssets(const ExecEnv &env, const std::string &tableName) in ListAssets() argument
64 if (tableName.empty()) { in ListAssets()
68 printf("Table Name: %s\n", tableName.c_str()); in ListAssets()
70 auto res = UserFileClientEx::Query(tableName, "", resultSe in ListAssets()
107 string tableName = UserFileClientEx::GetTableNameByUri(env.listParam.listUri); Start() local
[all...]
H A Drecv_command_v10.cpp83 static int32_t RecvAsset(const ExecEnv &env, const std::string &tableName, const std::string &uri) in RecvAsset() argument
85 if (tableName.empty()) { in RecvAsset()
89 printf("Table Name: %s\n", tableName.c_str()); in RecvAsset()
91 auto res = UserFileClientEx::Query(tableName, uri, resultSet); in RecvAsset()
95 printf("%s query issue. tableName:%s, uri:%s\n", STR_FAIL.c_str(), tableName.c_str(), uri.c_str()); in RecvAsset()
114 static int32_t RecvAssets(const ExecEnv &env, const std::string &tableName) in RecvAssets() argument
116 if (tableName.empty()) { in RecvAssets()
120 printf("Table Name: %s\n", tableName.c_str()); in RecvAssets()
122 auto res = UserFileClientEx::Query(tableName, "", resultSe in RecvAssets()
154 string tableName = UserFileClientEx::GetTableNameByUri(env.recvParam.recvUri); Start() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dstorage_proxy.h42 int GetLocalWaterMark(const std::string &tableName, Timestamp &localMark);
44 int GetLocalWaterMarkByMode(const std::string &tableName, CloudWaterType mode, Timestamp &localMark);
46 int PutLocalWaterMark(const std::string &tableName, Timestamp &localMark);
48 int PutWaterMarkByMode(const std::string &tableName, CloudWaterType mode, Timestamp &localMark);
50 int GetCloudWaterMark(const std::string &tableName, std::string &cloudMark);
52 int SetCloudWaterMark(const std::string &tableName, std::string &cloudMark);
60 int GetUploadCount(const std::string &tableName, const Timestamp &timestamp, const bool isCloudForcePush,
69 int GetCloudData(const std::string &tableName, const Timestamp &timeRange,
80 int GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket,
83 int PutCloudSyncData(const std::string &tableName, DownloadDat
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_log_table_manager.cpp48 const std::string tableName = GetLogTableName(table); in CreateRelationalLogTable() local
51 std::string createTableSql = "CREATE TABLE IF NOT EXISTS " + tableName + "(" \ in CreateRelationalLogTable()
82 const std::string tableName = "naturalbase_kv_aux_sync_data_log"; in CreateKvSyncLogTable() local
84 std::string createTableSql = "CREATE TABLE IF NOT EXISTS " + tableName + "(" \ in CreateKvSyncLogTable()
96 std::string createIndexSql = "CREATE INDEX IF NOT EXISTS gid_hash_key ON " + tableName + "(cloud_gid, hash_key)"; in CreateKvSyncLogTable()
101 return UpgradeKvSyncLogTable(tableName, db); in CreateKvSyncLogTable()
106 const std::string tableName = GetLogTableName(table); in GetIndexSql() local
109 "time_flag_index ON " + tableName + "(timestamp, flag);"; in GetIndexSql()
113 "hashkey_index ON " + tableName + "(hash_key);"; in GetIndexSql()
122 int SqliteLogTableManager::UpgradeKvSyncLogTable(const std::string &tableName, sqlite argument
142 CreateKvCloudFlagIndex(const std::string &tableName, sqlite3 *db) CreateKvCloudFlagIndex() argument
[all...]
/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/medialibrary_tool/src/
H A Duserfile_client_ex.cpp78 static std::string GetOperation(const std::string &tableName, MediaToolOperation oprn) in GetOperation() argument
80 if (tableName == PhotoColumn::PHOTOS_TABLE) { in GetOperation()
85 } else if (tableName == AudioColumn::AUDIOS_TABLE) { in GetOperation()
91 MEDIA_ERR_LOG("get operation failed. tableName:%{public}s", tableName.c_str()); in GetOperation()
95 static bool CheckTableName(const std::string &tableName) in CheckTableName() argument
101 if (tableName.empty()) { in CheckTableName()
104 if (VALID_TABLENAME_WHITELIST.find(tableName) == VALID_TABLENAME_WHITELIST.end()) { in CheckTableName()
121 static inline std::string GetInsertUri(const std::string &tableName) in GetInsertUri() argument
123 std::string uri = GetOperation(tableName, MediaToolOperatio in GetInsertUri()
132 GetQueryUri(const std::string &tableName) GetQueryUri() argument
143 GetListUri(const std::string &tableName) GetListUri() argument
154 GetCloseUri(const std::string &tableName) GetCloseUri() argument
165 GetUpdateUri(const std::string &tableName) GetUpdateUri() argument
176 GetDeleteUri(const std::string &tableName) GetDeleteUri() argument
218 InsertExt(const std::string &tableName, const std::string &name, std::string &outString, bool isRestart) InsertExt() argument
247 Query(const std::string &tableName, const std::string &uri, std::shared_ptr<DataShare::DataShareResultSet> &resultSet, bool isList, bool isRestart) Query() argument
369 string tableName = GetTableNameByUri(uri); Trash() local
406 string tableName = GetTableNameByUri(uri); Delete() local
456 GetResultsetByDisplayName( const std::string &tableName, const std::string &displayName) GetResultsetByDisplayName() argument
480 std::string tableName; GetTableNameByMediaType() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Drelational_virtual_device.cpp27 int RelationalVirtualDevice::PutData(const std::string &tableName, const std::vector<VirtualRowData> &dataList) in PutData() argument
29 return static_cast<VirtualRelationalVerSyncDBInterface *>(storage_)->PutLocalData(dataList, tableName); in PutData()
32 int RelationalVirtualDevice::GetAllSyncData(const std::string &tableName, std::vector<VirtualRowData> &data) in GetAllSyncData() argument
34 return static_cast<VirtualRelationalVerSyncDBInterface *>(storage_)->GetAllSyncData(tableName, data); in GetAllSyncData()
37 int RelationalVirtualDevice::GetSyncData(const std::string &tableName, in GetSyncData() argument
40 return static_cast<VirtualRelationalVerSyncDBInterface *>(storage_)->GetVirtualSyncData(tableName, hashKey, data); in GetSyncData()
53 void RelationalVirtualDevice::EraseSyncData(const std::string &tableName) in EraseSyncData() argument
55 static_cast<VirtualRelationalVerSyncDBInterface *>(storage_)->EraseSyncData(tableName); in EraseSyncData()
H A Drelational_virtual_device.h31 int PutData(const std::string &tableName, const std::vector<VirtualRowData> &dataList);
32 int GetAllSyncData(const std::string &tableName, std::vector<VirtualRowData> &data);
33 int GetSyncData(const std::string &tableName, const std::string &hashKey, VirtualRowData &data);
37 void EraseSyncData(const std::string &tableName);
40 void PutDeviceData(const std::string &tableName, const std::vector<T> &data) in PutDeviceData() argument
46 this->PutData(tableName, dataList); in PutDeviceData()
/foundation/communication/netmanager_base/services/netstatsmanager/include/
H A Dnet_stats_database_helper.h41 int32_t CreateTable(const std::string &tableName, const std::string &tableInfo);
42 int32_t InsertData(const std::string &tableName, const std::string &paramList,
44 int32_t SelectData(std::vector<NetStatsInfo> &infos, const std::string &tableName, uint64_t start, uint64_t end);
49 int32_t QueryData(const std::string &tableName, const std::string &ident, uint64_t start, uint64_t end,
51 int32_t QueryData(const std::string &tableName, const uint32_t uid, const std::string &ident, uint64_t start,
53 int32_t DeleteData(const std::string &tableName, uint64_t start, uint64_t end);
54 int32_t DeleteData(const std::string &tableName, uint64_t uid);
55 int32_t ClearData(const std::string &tableName);
59 int32_t UpdateStatsFlag(const std::string &tableName, uint32_t uid, uint32_t flag);
73 int32_t GetTableVersion(TableVersion &version, const std::string &tableName);
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/storage_fuzzer/
H A Dstorage_fuzzer.cpp163 bool SetAndGetLocalWaterMark(TableName &tableName, Timestamp mark) in SetAndGetLocalWaterMark() argument
165 if (g_storageProxy->PutLocalWaterMark(tableName, mark) != E_OK) { in SetAndGetLocalWaterMark()
170 if (g_storageProxy->GetLocalWaterMark(tableName, retMark) != E_OK) { in SetAndGetLocalWaterMark()
181 bool SetAndGetCloudWaterMark(TableName &tableName, std::string &mark) in SetAndGetCloudWaterMark() argument
183 if (g_storageProxy->SetCloudWaterMark(tableName, mark) != E_OK) { in SetAndGetCloudWaterMark()
188 if (g_storageProxy->GetCloudWaterMark(tableName, retMark) != E_OK) { in SetAndGetCloudWaterMark()
260 void CreateTableForStoreObserver(sqlite3 *db, const std::string &tableName) in CreateTableForStoreObserver() argument
262 std::string sql = "create table " + tableName + "(id INTEGER primary key, name TEXT);"; in CreateTableForStoreObserver()
264 sql = "create table no_" + tableName + "(id INTEGER, name TEXT);"; in CreateTableForStoreObserver()
266 sql = "create table mult_" + tableName in CreateTableForStoreObserver()
271 InitLogicDeleteData(sqlite3 *&db, const std::string &tableName, uint64_t num) InitLogicDeleteData() argument
281 InitDataStatus(const std::string &tableName, int count, sqlite3 *db) InitDataStatus() argument
296 GetHashKey(const std::string &tableName, const std::string &condition, sqlite3 *db, std::vector<std::vector<uint8_t>> &hashKey) GetHashKey() argument
311 ClientObserverFuzz(const std::string &tableName) ClientObserverFuzz() argument
322 StoreObserverFuzz(const std::string &tableName) StoreObserverFuzz() argument
336 DropLogicDeletedDataFuzz(std::string tableName, uint64_t num) DropLogicDeletedDataFuzz() argument
344 LockAndUnLockFuzz(std::string tableName, int count) LockAndUnLockFuzz() argument
359 std::string tableName = fuzzerData.GetString(len); CombineClientFuzzTest() local
[all...]
/foundation/filemanagement/dfs_service/test/unittests/utils/preference/
H A Dcloud_pref_impl_test.cpp157 std::string tableName = "testTable"; in HWTEST_F() local
159 CloudPrefImpl cloudPreImpl(userId_, bundleName, tableName); in HWTEST_F()
303 string tableName = "testTable"; in HWTEST_F() local
304 CloudPrefImpl cloudPrefImpl(userId, bundleName, tableName); in HWTEST_F()
319 string tableName = "testTable"; in HWTEST_F() local
320 CloudPrefImpl cloudPrefImpl(userId, bundleName, tableName); in HWTEST_F()
335 string tableName = "testTable"; in HWTEST_F() local
336 CloudPrefImpl cloudPrefImpl(userId, bundleName, tableName); in HWTEST_F()
351 string tableName = ""; in HWTEST_F() local
352 CloudPrefImpl cloudPrefImpl(userId, bundleName, tableName); in HWTEST_F()
389 string tableName = ""; HWTEST_F() local
410 string tableName = ""; HWTEST_F() local
445 string tableName = ""; HWTEST_F() local
466 string tableName = ""; HWTEST_F() local
487 string tableName = ""; HWTEST_F() local
508 string tableName = ""; HWTEST_F() local
529 string tableName = ""; HWTEST_F() local
550 string tableName = ""; HWTEST_F() local
571 string tableName = ""; HWTEST_F() local
592 string tableName = ""; HWTEST_F() local
613 string tableName = ""; HWTEST_F() local
634 string tableName = ""; HWTEST_F() local
655 string tableName = ""; HWTEST_F() local
676 string tableName = ""; HWTEST_F() local
697 string tableName = ""; HWTEST_F() local
716 string tableName = ""; HWTEST_F() local
735 string tableName = ""; HWTEST_F() local
[all...]
/foundation/ability/form_fwk/services/src/
H A Dform_rdb_data_mgr.cpp98 if (formRdbTableConfig.tableName.empty()) { in InitFormRdbTable()
103 auto formRdbTableCfgIter = formRdbTableCfgMap_.find(formRdbTableConfig.tableName); in InitFormRdbTable()
105 formRdbTableCfgMap_[formRdbTableConfig.tableName] = formRdbTableConfig; in InitFormRdbTable()
107 formRdbTableCfgMap_.emplace(formRdbTableConfig.tableName, formRdbTableConfig); in InitFormRdbTable()
116 : "CREATE TABLE IF NOT EXISTS " + formRdbTableConfig.tableName in InitFormRdbTable()
166 ErrCode FormRdbDataMgr::InsertData(const std::string &tableName, const std::string &key) in InsertData() argument
169 if (formRdbTableCfgMap_.find(tableName) == formRdbTableCfgMap_.end()) { in InsertData()
170 HILOG_ERROR("Form rdb hasn't initialized this table:%{public}s", tableName.c_str()); in InsertData()
185 ret = rdbStore_->InsertWithConflictResolution(rowId, tableName, valuesBucket, in InsertData()
199 ret = rdbStore_->InsertWithConflictResolution(rowId, tableName, valuesBucke in InsertData()
211 InsertData(const std::string &tableName, const std::string &key, const std::string &value) InsertData() argument
258 DeleteData(const std::string &tableName, const std::string &key) DeleteData() argument
302 QueryData(const std::string &tableName, const std::string &key, std::string &value) QueryData() argument
355 QueryData(const std::string &tableName, const std::string &key, std::unordered_map<std::string, std::string> &values) QueryData() argument
421 QueryAllData(const std::string &tableName, std::unordered_map<std::string, std::string> &datas) QueryAllData() argument
487 QueryAllKeys(const std::string &tableName, std::set<std::string> &datas) QueryAllKeys() argument
569 InsertData( const std::string &tableName, const NativeRdb::ValuesBucket &valuesBucket, int64_t &rowId) InsertData() argument
[all...]
/foundation/bundlemanager/app_domain_verify/test/unittest/services/app_domain_verify_rdb_test/
H A Dapp_domain_verify_rdb_data_manager_test.cpp72 rdbConfig.tableName = Constants::RDB_TABLE_NAME; in HWTEST_F()
89 rdbConfig.tableName = Constants::RDB_TABLE_NAME; in HWTEST_F()
91 "CREATE TABLE IF NOT EXISTS " + rdbConfig.tableName + "(KEY TEXT NOT NULL PRIMARY KEY, VALUE TEXT NOT NULL);"); in HWTEST_F()
109 rdbConfig.tableName = Constants::RDB_TABLE_NAME; in HWTEST_F()
111 "CREATE TABLE IF NOT EXISTS " + rdbConfig.tableName + "(KEY TEXT NOT NULL PRIMARY KEY, VALUE TEXT NOT NULL);"); in HWTEST_F()
127 rdbConfig.tableName = Constants::RDB_TABLE_NAME; in HWTEST_F()
129 "CREATE TABLE IF NOT EXISTS " + rdbConfig.tableName + "(KEY TEXT NOT NULL PRIMARY KEY, VALUE TEXT NOT NULL);"); in HWTEST_F()
148 rdbConfig.tableName = Constants::RDB_TABLE_NAME; in HWTEST_F()
150 "CREATE TABLE IF NOT EXISTS " + rdbConfig.tableName + "(KEY TEXT NOT NULL PRIMARY KEY, VALUE TEXT NOT NULL);"); in HWTEST_F()
168 rdbConfig.tableName in HWTEST_F()
[all...]
/foundation/multimedia/media_library/frameworks/services/media_backup_extension/src/restore/
H A Ddb_upgrade_utils.cpp28 bool DbUpgradeUtils::IsTableExists(NativeRdb::RdbStore &store, const std::string &tableName) in IsTableExists() argument
31 std::vector<NativeRdb::ValueObject> bindArgs = {tableName}; in IsTableExists()
39 MEDIA_INFO_LOG("Media_Restore: tableName=%{public}s, isExists:%{public}d", tableName.c_str(), isExists); in IsTableExists()
47 NativeRdb::RdbStore &store, const std::string &tableName, const std::string &columnName) in IsColumnExists()
50 std::vector<NativeRdb::ValueObject> bindArgs = {tableName, columnName}; in IsColumnExists()
58 MEDIA_INFO_LOG("Media_Restore: tableName=%{public}s, columnName=%{public}s, isExists:%{public}d", in IsColumnExists()
59 tableName.c_str(), in IsColumnExists()
46 IsColumnExists( NativeRdb::RdbStore &store, const std::string &tableName, const std::string &columnName) IsColumnExists() argument
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/relationalstoredelegate_fuzzer/
H A Drelationalstoredelegate_fuzzer.cpp100 void MultiCombineTest(const uint8_t *data, const std::string &tableName, const std::string &extendColName, in MultiCombineTest() argument
104 schema.tableName = tableName; in MultiCombineTest()
109 g_delegate->CleanTrackerData(tableName, 0); in MultiCombineTest()
117 g_delegate->UpsertData(tableName, { records }, recordStatus); in MultiCombineTest()
139 std::string tableName = fuzzerData.GetString(len % lenMod); in CombineTest() local
140 g_delegate->CreateDistributedTable(tableName); in CombineTest()
157 MultiCombineTest(data, tableName, extendColName, trackerColNames, isLogicDeleted); in CombineTest()
158 std::string deviceId = device.size() > 0 ? device[0] : tableName; in CombineTest()
161 g_delegate->RemoveDeviceData(deviceId, tableName); in CombineTest()
[all...]
/foundation/ability/form_fwk/services/include/
H A Dform_rdb_data_mgr.h34 std::string tableName { Constants::FORM_RDB_TABLE_NAME };
70 * @param tableName The name of table to be inserted
74 ErrCode InsertData(const std::string &tableName, const std::string &key);
78 * @param tableName The name of table to be inserted
83 ErrCode InsertData(const std::string &tableName, const std::string &key, const std::string &value);
87 * @param tableName The name of table to be excute deleted action.
91 ErrCode DeleteData(const std::string &tableName, const std::string &key);
95 * @param tableName The name of table to be query.
100 ErrCode QueryData(const std::string &tableName, const std::string &key,
105 * @param tableName Th
[all...]
/foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/
H A Drdb_predicates.h33 * @param tableName Indicates the table name of the database.
35 API_EXPORT explicit RdbPredicates(const std::string &tableName);
50 API_EXPORT RdbPredicates *CrossJoin(const std::string &tableName);
55 API_EXPORT RdbPredicates *InnerJoin(const std::string &tableName);
60 API_EXPORT RdbPredicates *LeftOuterJoin(const std::string &tableName);
76 RdbPredicates *Join(int join, const std::string &tableName);

Completed in 18 milliseconds

12345678910>>...15