Home
last modified time | relevance | path

Searched refs:errCode (Results 1 - 25 of 1849) sorted by relevance

12345678910>>...74

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_storage_executor_cache.cpp31 int errCode = -E_NOT_SUPPORT; in PrepareForSavingCacheData() local
37 errCode = PrepareForSavingData(SELECT_CACHE_LOCAL_HASH_SQL, insertLocalSql, updateLocalSql, in PrepareForSavingCacheData()
46 errCode = PrepareForSavingData(selectSyncHashSql, insertSyncSql, updateSyncSql, saveSyncStatements_); in PrepareForSavingCacheData()
48 if (errCode != E_OK) { in PrepareForSavingCacheData()
49 LOGE("Prepare to save sync cache data failed:%d", errCode); in PrepareForSavingCacheData()
51 return CheckCorruptedStatus(errCode); in PrepareForSavingCacheData()
56 int errCode = E_OK; in ResetForSavingCacheData() local
58 SQLiteUtils::ResetStatement(saveLocalStatements_.insertStatement, false, errCode); in ResetForSavingCacheData()
59 SQLiteUtils::ResetStatement(saveLocalStatements_.updateStatement, false, errCode); in ResetForSavingCacheData()
60 SQLiteUtils::ResetStatement(saveLocalStatements_.queryStatement, false, errCode); in ResetForSavingCacheData()
72 int errCode = E_OK; ResetForMigrateCacheData() local
87 int errCode = DBCommon::CalcValueHash(REMOVE_DEVICE_DATA_KEY, hashKey); RemoveDeviceDataInCacheMode() local
139 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetMinVersionCacheData() local
171 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); MigrateRmDevData() local
209 int errCode = SQLiteUtils::AttachNewDatabase(dbHandle_, type, passwd, attachDbAbsPath, attachAsName); AttachMainDbAndCacheDb() local
239 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetMaxVersionInCacheDb() local
262 int errCode = PutIntoConflictAndCommitForMigrateCache(dataItem, {dataItem.dev.empty(), dataItem.dev}, notify, MigrateDataItem() local
304 int errCode = E_OK; CheckDataWithQuery() local
343 int errCode = CheckDataWithQuery(dataItems); MigrateDataItems() local
384 int errCode = StartTransaction(TransactType::IMMEDIATE); MigrateSyncDataByVersion() local
438 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); DelCacheDbDataByVersion() local
471 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); VacuumLocalData() local
493 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, migrateLocaldataSql); MigrateLocalData() local
505 int errCode = BindPrimaryKeySyncDataInCacheMode(statement, hashKey, recordVersion); BindSyncDataInCacheMode() local
548 int errCode = SQLiteUtils::BindBlobToStatement(statement, BIND_CACHE_SYNC_HASH_KEY_INDEX, hashKey, false); BindPrimaryKeySyncDataInCacheMode() local
563 int errCode = SQLiteUtils::BindInt64ToStatement(statement, BIND_CACHE_SYNC_STAMP_INDEX, dataItem.timestamp); BindTimestampSyncDataInCacheMode() local
581 int errCode = SQLiteUtils::BindBlobToStatement(statement, BIND_CACHE_SYNC_DEV_INDEX, devVect, true); BindDevSyncDataInCacheMode() local
597 int errCode = E_OK; GetExpandedCheckSql() local
633 int errCode = E_OK; SaveSyncDataItemInCacheMode() local
673 int errCode = BindSyncDataInCacheMode(statement, dataItem, hashKey, recordVersion); SaveSyncDataToCacheDatabase() local
688 int errCode = SQLiteUtils::GetStatement(dbHandle_, INSERT_CACHE_LOCAL_SQL, statement); PutLocalDataToCacheDB() local
711 int errCode = SQLiteUtils::BindBlobToStatement(statement, BindLocalDataInCacheMode() local
755 int errCode = PrepareForNotifyConflictAndObserver(dataItem, deviceInfo, notify, isPermitForceWrite); PutIntoConflictAndCommitForMigrateCache() local
789 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetMinTimestampInCacheDB() local
817 int errCode = GetMinTimestampInCacheDB(minTimeInCache); InitMigrateTimestampOffset() local
850 int errCode = InitMigrateTimestampOffset(); ProcessTimestampForSyncDataInCacheDB() local
907 int errCode = PrepareForSavingData(querySQL, insertSQL, updateSQL, migrateSyncStatements_); InitMigrateData() local
923 int errCode = migrateSyncStatements_.ResetStatement(); ClearMigrateData() local
944 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); DeleteMetaData() local
973 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); DeleteMetaDataByPrefixKey() local
[all...]
H A Dsqlite_single_ver_storage_executor.cpp37 int errCode = E_OK; in ResetOrRegetStmt() local
38 SQLiteUtils::ResetStatement(stmt, false, errCode); in ResetOrRegetStmt()
39 if (errCode != E_OK) { in ResetOrRegetStmt()
40 LOGE("[ResetOrRegetStmt] reset stmt failed:%d.", errCode); in ResetOrRegetStmt()
42 SQLiteUtils::ResetStatement(stmt, true, errCode); in ResetOrRegetStmt()
43 errCode = SQLiteUtils::GetStatement(db, sql, stmt); in ResetOrRegetStmt()
44 if (errCode != E_OK) { in ResetOrRegetStmt()
45 LOGE("[ResetOrRegetStmt] reget failed:%d.", errCode); in ResetOrRegetStmt()
48 return errCode; in ResetOrRegetStmt()
54 int errCode in GetEntryFromStatement() local
126 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetKvData() local
161 int errCode = SQLiteUtils::BindBlobToStatement(statement, BIND_KV_KEY_INDEX, key, false); BindPutKvData() local
200 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SYNC_HASH_SQL, statement); GetKvDataByHashKey() local
259 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); SaveKvData() local
299 int errCode = SaveKvData(type, key, value, timestamp); PutKvData() local
325 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetEntries() local
345 int errCode = E_OK; GetEntries() local
367 int errCode = E_OK; GetCount() local
421 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); InitCurrentMaxStamp() local
441 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); PrepareForSyncDataByTime() local
466 int errCode = E_OK; ReleaseContinueStatement() local
482 int errCode = SQLiteUtils::GetColumnBlobValue(statement, SYNC_RES_ORI_DEV_INDEX, devVect); GetDataItemForSync() local
503 int errCode; GetSyncDataItems() local
541 int errCode = PrepareForSyncDataByTime(begin, end, statement); GetSyncDataByTimestamp() local
555 int errCode = PrepareForSyncDataByTime(begin, end, statement, true); GetDeletedSyncDataByTimestamp() local
581 int errCode = SQLiteUtils::GetStatement(db, SELECT_SYNC_MODIFY_SQL, stmt); GetFullDataStatement() local
605 int errCode = E_OK; GetQueryDataStatement() local
615 int errCode = SQLiteUtils::StepWithRetry(stmt, isMemDB); GetNextDataItem() local
629 int errCode = GetQueryDataStatement(dbHandle_, query, timeRange, queryStmt); GetSyncDataWithQuery() local
657 int errCode = E_OK; GetSyncDataWithQuery() local
709 int errCode = StartTransaction(TransactType::DEFERRED); OpenResultSet() local
742 int errCode = InitResultSet(queryObj, countStatement); OpenResultSet() local
797 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SYNC_ROWID_PREFIX_SQL, getResultRowIdStatement_); OpenResultSetForCacheRowIdMode() local
822 int errCode = E_OK; OpenResultSetForCacheRowIdMode() local
849 int errCode = ResetOrRegetStmt(dbHandle_, getResultRowIdStatement_, SELECT_SYNC_ROWID_PREFIX_SQL); ReloadResultSet() local
865 int errCode = E_OK; ReloadResultSet() local
899 int errCode = ReloadResultSet(keyPrefix); // Reuse this function(A convenience) ReloadResultSetForCacheRowIdMode() local
915 int errCode = ReloadResultSet(queryObj); // Reuse this function(A convenience) ReloadResultSetForCacheRowIdMode() local
934 int errCode = SQLiteUtils::StepWithRetry(getResultRowIdStatement_, isMemDb_); GetNextEntryFromResultSet() local
978 int errCode = E_OK; GetEntryByRowId() local
1006 int errCode = E_OK; CloseResultSet() local
1027 int errCode = SQLiteUtils::BeginTransaction(dbHandle_, type); StartTransaction() local
1041 int errCode = SQLiteUtils::CommitTransaction(dbHandle_); Commit() local
1054 int errCode = SQLiteUtils::RollbackTransaction(dbHandle_); Rollback() local
1071 int errCode = GetKvData(SingleVerDataType::LOCAL_TYPE_SQLITE, key, value, timestamp); CheckIfKeyExisted() local
1089 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_ENTRY_DEVICE, statement); GetDeviceIdentifier() local
1122 int errCode; PutIntoCommittedData() local
1142 int errCode = SQLiteUtils::GetStatement(dbHandle_, readSql, statements.queryStatement); PrepareForSavingData() local
1167 int errCode = -E_NOT_SUPPORT; PrepareForSavingData() local
1179 int errCode = E_OK; ResetForSavingData() local
1214 int errCode = BindSavedSyncData(statement, dataItem, hashKey, {origDev, devName}, isUpdate); SaveSyncDataToDatabase() local
1266 int errCode = SQLiteUtils::GetColumnBlobValue(statement, SYNC_RES_KEY_INDEX, itemGet.key); GetSyncDataItemExt() local
1279 ResetSaveSyncStatements(int errCode) ResetSaveSyncStatements() argument
1301 int errCode = GetSyncDataItemPre(dataItem, notify.getData, notify.hashKey); PrepareForNotifyConflictAndObserver() local
1360 int errCode = PrepareForNotifyConflictAndObserver(dataItem, deviceInfo, notify, isPermitForceWrite); SaveSyncDataItem() local
1390 int errCode = SQLiteUtils::GetStatement(dbHandle_, sqlStr, statement); GetAllMetaKeys() local
1404 int errCode = E_OK; GetAllSyncedEntries() local
1443 int errCode; GetAllEntries() local
1474 int errCode = SQLiteUtils::BindBlobToStatement(statement, hashKeyIndex, hashKey, false); BindSavedSyncData() local
1552 int errCode = ResetForSavingData(SingleVerDataType::SYNC_TYPE); Reset() local
1573 int errCode = DBCommon::CalcValueHash(itemPut.key, hashKey); GetSyncDataItemPre() local
1585 int errCode = SQLiteUtils::BindBlobToStatement(statement, 1, hashKey, false); // 1st arg. GetSyncDataPreByHashKey() local
1635 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); DeleteLocalDataInner() local
1667 int errCode = GetKvData(SingleVerDataType::LOCAL_TYPE_SQLITE, key, value, timestamp); DeleteLocalKvData() local
1680 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); EraseSyncData() local
1705 int errCode = E_OK; RemoveDeviceData() local
1728 int errCode = E_OK; StepForResultEntries() local
1756 int errCode = SQLiteUtils::BindInt64ToStatement(statement, BIND_SYNC_FLAG_INDEX, BindDevForSavedSyncData() local
1796 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_COUNT_SYNC_PREFIX_SQL, countStmt); InitResultSet() local
1840 int errCode = E_OK; InitResultSetCount() local
1856 int errCode = E_OK; InitResultSetContent() local
1883 int errCode = E_OK; InitResultSet() local
1909 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); UpdateLocalDataTimestamp() local
1921 int errCode = SQLiteUtils::GetColumnBlobValue(statement, SYNC_RES_KEY_INDEX, dataItem.key); GetOneRawDataItem() local
1968 int errCode; GetAllDataItems() local
1992 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SYNC_DATA_BY_ROWID_SQL, getResultEntryStatement_); OpenResultSetForCacheRowIdModeCommon() local
2019 int errCode = SQLiteUtils::StepWithRetry(getResultRowIdStatement_, isMemDb_); ResultSetLoadRowIdCache() local
2042 int errCode = E_OK; ResetStatement() local
2062 int errCode = saveLocalStatements_.ResetStatement(); FinalizeAllStatements() local
2148 int errCode = CreateFuncUpdateKey(context, &Translate, &CalHashKey); UpdateKey() local
2171 int errCode = sqlite3_create_function_v2(dbHandle_, FUNC_NAME_TRANSLATE_KEY, 1, SQLITE_UTF8 | SQLITE_DETERMINISTIC, CreateFuncUpdateKey() local
2248 int errCode = SQLiteUtils::BindInt64ToStatement(statement, BIND_SYNC_STAMP_INDEX, dataItem.timestamp); BindSyncDataTime() local
[all...]
H A Dsqlite_single_ver_storage_executor_extend.cpp42 int errCode = E_OK; in CloudExcuteRemoveOrUpdate() local
44 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in CloudExcuteRemoveOrUpdate()
45 if (errCode != E_OK) { in CloudExcuteRemoveOrUpdate()
46 return errCode; in CloudExcuteRemoveOrUpdate()
54 errCode = SQLiteUtils::BindBlobToStatement(statement, bindIndex, useVect, true); in CloudExcuteRemoveOrUpdate()
56 errCode = SQLiteUtils::BindTextToStatement(statement, bindIndex, user); in CloudExcuteRemoveOrUpdate()
58 if (errCode != E_OK) { in CloudExcuteRemoveOrUpdate()
59 LOGE("Failed to bind the removed device:%d", errCode); in CloudExcuteRemoveOrUpdate()
61 return errCode; in CloudExcuteRemoveOrUpdate()
67 errCode in CloudExcuteRemoveOrUpdate()
87 int errCode = E_OK; CloudCheckDataExist() local
140 int errCode = CloudExcuteRemoveOrUpdate(REMOVE_CLOUD_ALL_HWM_DATA_SQL, "", "", true); RemoveDeviceDataInner() local
164 int errCode = CloudExcuteRemoveOrUpdate(REMOVE_CLOUD_ALL_HWM_DATA_SQL, "", "", true); RemoveDeviceDataInner() local
185 int errCode = CloudExcuteRemoveOrUpdate(REMOVE_CLOUD_HWM_DATA_BY_USERID_SQL, "", RemoveDeviceDataWithUserInner() local
213 int errCode = CloudExcuteRemoveOrUpdate(REMOVE_CLOUD_HWM_DATA_BY_USERID_SQL, "", RemoveDeviceDataWithUserInner() local
242 int errCode = CloudCheckDataExist(SELECT_CLOUD_LOG_DATA_BY_DEVID_SQL, deviceName, "", isDataExist); RemoveDeviceData() local
257 int errCode = E_OK; RemoveDeviceData() local
277 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); GetEntries() local
314 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); PrepareForUnSyncTotalByTime() local
333 int errCode = SQLiteUtils::StepWithRetry(countStatement, isMemDb_); GetCountValue() local
355 int errCode = PrepareForUnSyncTotalByTime(begin, end, countStatement); GetUnSyncTotalByTimestamp() local
366 int errCode = PrepareForUnSyncTotalByTime(begin, end, countStatement, true); GetDeletedSyncTotalByTimestamp() local
376 int errCode = E_OK; GetSyncTotalWithQuery() local
394 int errCode = SQLiteUtils::CheckTableExists(dbHandle_, tableName, isCreate); RemoveCloudUploadFlag() local
[all...]
H A Dsqlite_single_ver_storage_executor_subscribe.cpp28 int errCode = E_OK; in CheckQueryObjectLegal() local
29 SqliteQueryHelper helper = queryObj.GetQueryHelper(errCode); in CheckQueryObjectLegal()
30 if (errCode != E_OK) { in CheckQueryObjectLegal()
31 LOGE("Get query helper failed [%d]!", errCode); in CheckQueryObjectLegal()
32 return errCode; in CheckQueryObjectLegal()
36 errCode = helper.GetQuerySyncStatement(dbHandle_, 0, INT64_MAX, statement); // (0, INT64_MAX):max range in CheckQueryObjectLegal()
42 return CheckCorruptedStatus(errCode); in CheckQueryObjectLegal()
48 int errCode = SQLiteUtils::StepWithRetry(stmt, isMemDb_); in CheckMissQueryDataItem() local
49 if (errCode == SQLiteUtils::MapSQLiteErrno(SQLITE_ROW)) { in CheckMissQueryDataItem()
52 errCode in CheckMissQueryDataItem()
77 int errCode = E_OK; CheckMissQueryDataItems() local
99 int errCode = E_OK; CheckDataWithQuery() local
155 int errCode = E_OK; AddSubscribeTrigger() local
191 int errCode = E_OK; RemoveSubscribeTrigger() local
211 int errCode = E_OK; RemoveTrigger() local
226 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); RemoveSubscribeTriggerWaterMark() local
253 int errCode = SQLiteUtils::GetStatement(dbHandle_, GET_SYNC_DATA_TIRGGER_SQL, stmt); GetTriggers() local
[all...]
H A Dsqlite_local_storage_executor.cpp50 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SQL, statement); in Get() local
51 if (errCode != E_OK) { // LCOV_EXCL_BR_LINE in Get()
52 return CheckCorruptedStatus(errCode); in Get()
55 errCode = SQLiteUtils::BindBlobToStatement(statement, SELECT_BIND_KEY_INDEX, key, false); in Get()
56 if (errCode != E_OK) { // LCOV_EXCL_BR_LINE in Get()
60 errCode = SQLiteUtils::StepWithRetry(statement); in Get()
61 if (errCode == SQLiteUtils::MapSQLiteErrno(SQLITE_DONE)) { // LCOV_EXCL_BR_LINE in Get()
62 errCode = -E_NOT_FOUND; in Get()
64 } else if (errCode != SQLiteUtils::MapSQLiteErrno(SQLITE_ROW)) { in Get()
68 errCode in Get()
77 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, CLEAR_SQL); Clear() local
85 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_BATCH_SQL, statement); GetEntries() local
138 int errCode = Put(entry.key, entry.value); PutBatch() local
157 int errCode = Delete(key); DeleteBatch() local
175 int errCode = SQLiteUtils::BeginTransaction(dbHandle_); StartTransaction() local
181 int errCode = SQLiteUtils::CommitTransaction(dbHandle_); Commit() local
187 int errCode = SQLiteUtils::RollbackTransaction(dbHandle_); RollBack() local
194 int errCode = SQLiteUtils::GetStatement(dbHandle_, INSERT_SQL, statement); Put() local
226 int errCode = SQLiteUtils::GetStatement(dbHandle_, DELETE_SQL, statement); Delete() local
[all...]
H A Dsqlite_cloud_kv_executor_utils.cpp32 auto [errCode, stmt] = token.GetCloudQueryStmt(db, data.isCloudForcePushStrategy, stepNext, data.mode); in GetCloudData()
33 if (errCode != E_OK) { in GetCloudData()
35 return errCode; in GetCloudData()
41 errCode = SQLiteUtils::StepNext(stmt, isMemory); in GetCloudData()
42 if (errCode != E_OK) { in GetCloudData()
43 errCode = (errCode == -E_FINISHED ? E_OK : errCode); in GetCloudData()
48 errCode = GetCloudDataForSync(config, recorder, stmt, data, detail); in GetCloudData()
50 } while (errCode in GetCloudData()
116 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::FLAG, extraLog, flag); GetCloudDataForSync() local
198 int errCode = GetCloudKvBlobData(CloudDbConstant::CLOUD_KV_FIELD_KEY, CLOUD_QUERY_KEY_INDEX, stmt, data, totalSize); GetCloudKvData() local
225 int errCode = SQLiteUtils::GetColumnBlobValue(stmt, index, blob); GetCloudKvBlobData() local
251 int &errCode = res.first; GetLogInfo() local
389 int errCode = ExecutePutCloudData(db, isMemory, downloadData, statisticMap); PutCloudData() local
406 int errCode = E_OK; ExecutePutCloudData() local
445 int errCode = SQLiteUtils::GetStatement(db, GetOperateLogSql(opType), logStmt); OperateCloudData() local
535 int errCode = SQLiteUtils::BindTextToStatement(logStmt, ++index, user); BindOnlyUpdateLogStmt() local
592 int errCode = BindInsertLogStmt(logStmt, user, dataItem); // insert or replace LOG table for insert DATA table. BindInsertStmt() local
602 int errCode = SQLiteUtils::BindTextToStatement(logStmt, BIND_INSERT_USER_INDEX, user); BindInsertLogStmt() local
632 int errCode = BindInsertLogStmt(logStmt, user, dataItem); // insert or replace LOG table for update DATA table. BindUpdateStmt() local
647 int errCode = SQLiteUtils::BindTextToStatement(logStmt, index++, dataItem.gid); BindUpdateLogStmt() local
680 int errCode = BindUpdateLogStmt(logStmt, user, dataItem); // update LOG table for delete DATA table. BindDeleteStmt() local
694 int errCode = BindSyncDataStmt(dataStmt, dataItem, isInsert, index); BindDataStmt() local
714 int errCode = SQLiteUtils::BindBlobToStatement(dataStmt, index++, dataItem.key); BindSyncDataStmt() local
763 int errCode = SQLiteUtils::BindInt64ToStatement(dataStmt, index++, dataItem.modifyTime); BindCloudDataStmt() local
777 int errCode = SQLiteUtils::StepNext(logStmt, isMemory); StepStmt() local
798 int errCode = FillCloudVersionRecord(param.first, opType, data); FillCloudLog() local
822 int errCode = SQLiteUtils::GetStatement(db, GetOperateLogSql(op), logStmt); OnlyUpdateLogTable() local
865 int errCode = SQLiteUtils::GetStatement(db, GetOperateLogSql(TransToOpType(type)), logStmt); FillCloudGid() local
921 int errCode = SQLiteUtils::GetStatement(db, GetOperateDataSql(opType), dataStmt); OnlyUpdateSyncData() local
1192 int errCode = SQLiteUtils::StepNext(stmt, isMemory); GetCloudVersionRecord() local
1232 int errCode = RuntimeContext::GetInstance()->GetLocalIdentity(hashDevice); BindVersionStmt() local
1256 int errCode = SQLiteUtils::GetStatement(db, sql, dataStmt); GetCloudVersionFromCloud() local
1294 int errCode = GetCloudKvBlobData(CloudDbConstant::CLOUD_KV_FIELD_KEY, CLOUD_QUERY_KEY_INDEX, stmt, data, totalSize); GetCloudVersionRecordData() local
1308 int errCode = SQLiteUtils::GetStatement(db, SELECT_COMPENSATE_SYNC_KEY_SQL, stmt); GetWaitCompensatedSyncDataPk() local
1345 int errCode = SQLiteUtils::GetStatement(db, SELECT_COMPENSATE_SYNC_USERID_SQL, stmt); GetWaitCompensatedSyncDataUserId() local
1382 int errCode = SqliteCloudKvExecutorUtils::GetWaitCompensatedSyncDataPk(db, isMemory, data); GetWaitCompensatedSyncData() local
1397 int errCode = E_OK; QueryCloudGid() local
1438 int errCode = E_OK; BindFillGidLogStmt() local
1473 int errCode = SQLiteUtils::GetStatement(param.first, CHECK_DATA_CHANGED, checkStmt); CheckDataChanged() local
1513 int errCode = SQLiteUtils::GetStatement(param.first, CHECK_DATA_DELETE, checkStmt); CheckDataDelete() local
1553 int errCode = SQLiteUtils::GetStatement(param.first, MARK_UPLOAD_SUCCESS, logStmt); MarkUploadSuccessInner() local
[all...]
H A Dsqlite_multi_ver_transaction.cpp148 int errCode = SQLiteUtils::OpenDatabase(option, db_); in Initialize() local
149 if (errCode != E_OK) { in Initialize()
150 LOGE("Init db error:%d", errCode); in Initialize()
151 return errCode; in Initialize()
182 int errCode = Get(key, valueRead); in Delete() local
183 if (errCode != E_OK) { in Delete()
184 return errCode; in Delete()
189 errCode = valueObject.SetValue(valueRead); in Delete()
190 if (errCode != E_OK) { in Delete()
191 return errCode; in Delete()
219 int errCode = valueObject.SetValue(emptyValue); Clear() local
242 int errCode = SQLiteUtils::GetStatement(db_, SELECT_ONE_SQL, statement); Get() local
264 int errCode = SQLiteUtils::GetStatement(db_, SELECT_BY_HASHKEY_VER_SQL, statement); GetValueForTrimSlice() local
305 int errCode = PrepareForGetEntries(keyPrefix, statements); GetEntries() local
358 int errCode = CheckIfNeedSaveRecord(entry, isNeedSave, disVal); CheckToSaveRecord() local
392 int errCode = Put(iter->key, iter->value); PutBatch() local
422 int errCode = CheckToSaveRecord(item, isNeedSave, values); PutBatch() local
452 int errCode = SQLiteUtils::GetStatement(db_, SELECT_ONE_VER_RAW_SQL, statement); GetDiffEntries() local
508 int errCode = SQLiteUtils::GetStatement(db_, sql, statement); GetMaxVersion() local
536 int errCode = SQLiteUtils::GetStatement(db_, DELETE_VER_SQL, statement); ClearEntriesByVersion() local
567 int errCode = SQLiteUtils::GetStatement(db_, SELECT_PRE_PUT_VER_DATA_SQL, statement); GetPrePutValues() local
614 int errCode = SQLiteUtils::GetStatement(db_, DELETE_PRE_PUT_VER_DATA_SQL, statement); RemovePrePutEntries() local
668 int errCode = SQLiteUtils::GetStatement(db_, SELECT_ONE_VER_RAW_SQL, statement); GetEntriesByVersion() local
702 int errCode = SQLiteUtils::GetStatement(db_, SELECT_ONE_VER_RAW_SQL, statement); GetEntriesByVersion() local
747 int errCode = SQLiteUtils::GetStatement(db_, SELECT_MAX_TIMESTAMP, statement); GetCurrentMaxTimestamp() local
774 int errCode = SQLiteUtils::GetStatement(db_, UPDATE_VERSION_TIMESTAMP, statement); UpdateTimestampByVersion() local
837 int errCode = SQLiteUtils::OpenDatabase(option, newConnection); Reset() local
859 int errCode = SQLiteUtils::GetStatement(db_, SELECT_OVERWRITTEN_CLEAR_TYPE, statement); GetOverwrittenClearTypeEntries() local
906 int errCode = SQLiteUtils::GetStatement(db_, SELECT_OVERWRITTEN_NO_CLEAR_TYPE, statement); GetOverwrittenNonClearTypeEntries() local
952 int errCode = SQLiteUtils::GetStatement(db_, DELETE_BY_VER_HASHKEY_SQL, statement); DeleteEntriesByHashKey() local
986 int errCode = SQLiteUtils::GetColumnBlobValue(statement, 1, keyEntry.value); GetRawMultiVerEntry() local
1019 int errCode = sqlite3_bind_int64(statement, 1, static_cast<int64_t>(version)); // only one parameter. GetRawDataByVersion() local
1049 GetDiffOperator(int errCode, uint64_t flag) GetDiffOperator() argument
1074 int errCode = SQLiteUtils::GetStatement(db_, INSERT_SQL, statement); AddRecord() local
1113 ClassifyDiffEntries(int errCode, uint64_t flag, const Value &value, MultiVerEntryData &item, MultiVerDiffData &data) const ClassifyDiffEntries() argument
1151 int errCode = SQLiteUtils::GetStatement(db_, SELECT_LATEST_CLEAR_ID, statement); GetClearId() local
1176 int errCode = sqlite3_bind_int64(statement, index, clearTime_); // bind the 1st for the clear time BindClearIdAndVersion() local
1207 int errCode = SQLiteUtils::BindBlobToStatement(statement, 1, key, false); // first argument is key BindQueryEntryArgs() local
1219 int errCode = SQLiteUtils::BindPrefixKey(statement, 1, key); // first argument is key BindQueryEntriesArgs() local
1232 int errCode = SQLiteUtils::BindBlobToStatement(statement, BIND_INSERT_KEY_INDEX, emptyKey, true); BindAddRecordKeysToStatement() local
1243 int errCode = SQLiteUtils::BindBlobToStatement(statement, BIND_INSERT_KEY_INDEX, key, false); BindAddRecordKeysToStatement() local
1263 int errCode = BindAddRecordKeysToStatement(statement, key, data); BindAddRecordArgs() local
1372 int errCode; CheckIfNeedSaveRecord() local
1439 int errCode = SQLiteUtils::GetStatement(db_, SELECT_ONE_BY_KEY_TIMESTAMP_SQL, statement); CheckIfNeedSaveRecord() local
1452 int errCode = SQLiteUtils::GetStatement(db_, SELECT_BATCH_SQL, statements.getEntriesStatement); PrepareForGetEntries() local
1477 int errCode = E_OK; ReleaseGetEntriesStatements() local
1486 int errCode = BindQueryEntryArgs(statement, hashKey); GetKeyAndValueByHashKey() local
1515 int errCode = SQLiteUtils::GetStatement(db_, SELECT_ONE_SQL, statement); GetOriginKeyValueByHash() local
[all...]
H A Dsqlite_utils.cpp163 int errCode = sqlite3_open_v2(fileUrl.c_str(), &dbTemp, flag, nullptr); in CreateDataBase() local
164 if (errCode != SQLITE_OK) { in CreateDataBase()
165 LOGE("[SQLite] open database failed: %d - sys err(%d)", errCode, errno); in CreateDataBase()
166 errCode = SQLiteUtils::MapSQLiteErrno(errCode); in CreateDataBase()
170 errCode = SetDataBaseProperty(dbTemp, properties, setWal, sqls); in CreateDataBase()
171 if (errCode != SQLITE_OK) { in CreateDataBase()
172 LOGE("[SQLite] SetDataBaseProperty failed: %d", errCode); in CreateDataBase()
177 if (errCode != E_OK && dbTemp != nullptr) { in CreateDataBase()
182 return errCode; in CreateDataBase()
197 int errCode = CreateDataBase(properties, dbTemp, setWal); OpenDatabase() local
241 int errCode = sqlite3_prepare_v2(db, sql.c_str(), NO_SIZE_LIMIT, &statement, nullptr); GetStatement() local
262 int errCode = sqlite3_bind_text(statement, index, str.c_str(), str.length(), SQLITE_TRANSIENT); BindTextToStatement() local
274 int errCode = sqlite3_bind_int64(statement, index, value); BindInt64ToStatement() local
296 int errCode; BindBlobToStatement() local
312 ResetStatement(sqlite3_stmt *&statement, bool isNeedFinalize, int &errCode) ResetStatement() argument
351 int errCode = E_OK; StepWithRetry() local
378 int errCode = BindBlobToStatement(statement, index, keyPrefix, true); BindPrefixKey() local
435 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); ExecuteRawSQL() local
465 int errCode = SetKeyInner(db, type, passwd, iterTimes); SetKey() local
486 int errCode = SQLiteUtils::ExecuteRawSQL(db, USER_VERSION_SQL); SetKey() local
560 int errCode = SQLiteUtils::ExecuteRawSQL(db, SHA256_ALGO_ATTACH_SQL); AttachNewDatabase() local
595 int errCode = SQLiteUtils::GetStatement(db, attachSql, statement); AttachNewDatabaseInner() local
634 int errCode = SQLiteUtils::OpenDatabase(metaProperties, db); CreateMetaDatabase() local
647 int errCode = SQLiteUtils::GetStatement(db, sql, statement); CheckIntegrity() local
691 int errCode = SQLiteUtils::GetStatement(db, sql, statement); AnalysisSchemaSqlAndTrigger() local
732 int errCode = SQLiteUtils::GetStatement(db, sql, statement); GetSchemaIndexList() local
766 int errCode = SQLiteUtils::GetStatement(db, sql, statement); AnalysisSchemaIndexDefine() local
795 int errCode = GetSchemaIndexList(db, tableName, indexList, uniqueList); AnalysisSchemaIndex() local
874 int errCode = SQLiteUtils::GetStatement(db, sql, statement); AnalysisSchemaFieldDefine() local
915 int errCode = AnalysisSchemaSqlAndTrigger(db, tableName, table, caseSensitive); AnalysisSchema() local
945 int errCode = AttachNewDatabase(db, type, passwd, newDbName); ExportDatabase() local
971 int errCode = sqlite3_rekey(db, static_cast<const void *>(passwd.GetData()), static_cast<int>(passwd.GetSize())); Rekey() local
1007 int errCode = sqlite3_open_v2(fileUrl.c_str(), &dbTemp, SQLITE_OPEN_URI | SQLITE_OPEN_READONLY, nullptr); GetVersion() local
1041 int errCode = sqlite3_prepare(db, strSql.c_str(), -1, &statement, nullptr); GetVersion() local
1068 int errCode = SQLiteUtils::GetStatement(db, sql, statement); GetJournalMode() local
1092 int errCode = SQLiteUtils::OpenDatabase(properties, db); SetUserVer() local
1122 MapSQLiteErrno(int errCode) MapSQLiteErrno() argument
1162 int errCode = sqlite3_busy_timeout(db, timeout); SetBusyTimeout() local
1177 int errCode = SQLiteUtils::OpenDatabase(option, db); ExportDatabase() local
1211 int errCode = GetStatement(db, sql, statement); SaveSchema() local
1250 int errCode = CheckTableExists(db, "meta_data", isExists); GetSchema() local
1324 int errCode = DecreaseIndex(db, name); ChangeIndex() local
1358 int errCode = sqlite3_create_function_v2(db, "calc_hash_key", 1, SQLITE_UTF8 | SQLITE_DETERMINISTIC, RegisterJsonFunctions() local
1409 int errCode = TimeHelper::GetSysCurrentRawTime(curTime); GetRawSysTime() local
1547 int errCode = SQLiteUtils::ExecuteRawSQL(db, sql); CreateSameStuTable() local
1566 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); CloneIndexes() local
1609 int errCode = GetStatement(db, sql, statement); GetRelationalSchema() local
1650 int errCode = GetStatement(db, sql, statement); GetLogTableVersion() local
1690 int errCode = sqlite3_create_function_v2(db, funcName.c_str(), nArg, SQLITE_UTF8 | SQLITE_DETERMINISTIC, uData, RegisterFunction() local
1709 int errCode = heapSchemaObj->ParseFromSchemaString(inSchema); RegisterFlatBufferFunction() local
1757 int errCode = SQLiteUtils::GetStatement(handle, UPDATE_META_SQL, stmt); UpdateMetaDataWithinTrigger() local
1790 int errCode = sqlite3_create_function_v2(db, DBConstant::UPDATE_META_FUNC.c_str(), RegisterMetaDataUpdateFunction() local
[all...]
H A Dsqlite_single_ver_natural_store.cpp52 void ProcessContinueToken(const DeviceID &deviceID, const std::vector<DataItem> &dataItems, int &errCode, in ProcessContinueToken() argument
55 if (errCode != -E_UNFINISHED) { // Error happened or get data finished. Token should be cleared. in ProcessContinueToken()
62 errCode = -E_INTERNAL_ERROR; in ProcessContinueToken()
78 void ProcessContinueToken(const std::vector<DataItem> &dataItems, int &errCode, in ProcessContinueToken() argument
81 ProcessContinueToken("", dataItems, errCode, token); in ProcessContinueToken()
87 void ProcessContinueTokenForQuerySync(const std::vector<DataItem> &dataItems, int &errCode, in ProcessContinueTokenForQuerySync() argument
90 if (errCode != -E_UNFINISHED) { // Error happened or get data finished. Token should be cleared. in ProcessContinueTokenForQuerySync()
97 errCode = -E_INTERNAL_ERROR; in ProcessContinueTokenForQuerySync()
137 int errCode = E_OK; in GetKvEntriesByDataItems() local
141 errCode in GetKvEntriesByDataItems()
196 int errCode = SQLiteUtils::SetUserVer(properties, version); SetUserVer() local
205 int errCode = InitStorageEngine(kvDBProp, isNeedUpdateSecOpt); InitDatabaseContext() local
215 int errCode; RegisterLifeCycleCallback() local
251 int errCode = runtimeCxt->ModifyTimer(lifeTimerId_, time); SetAutoLifeCycleTime() local
279 OriValueCanBeUse(int errCode) OriValueCanBeUse() argument
284 AmendValueShouldBeUse(int errCode) AmendValueShouldBeUse() argument
289 IsValueMismatched(int errCode) IsValueMismatched() argument
311 int errCode = valueObj.Parse(oriValue.data(), oriValue.data() + oriValue.size(), schemaObjRef.GetSkipSize()); CheckValueAndAmendIfNeed() local
335 int errCode = schemaObjRef.VerifyValue(sourceType, oriValue); CheckValueAndAmendIfNeed() local
352 int errCode = operation->RekeyRecover(kvDBProp); CheckDatabaseRecovery() local
385 int errCode = E_OK; GetAndInitStorageEngine() local
414 int errCode = CheckDatabaseRecovery(kvDBProp); Open() local
476 NewConnection(int &errCode) NewConnection() argument
535 int errCode = E_OK; GetMetaData() local
555 int errCode = SQLiteSingleVerNaturalStore::CheckDataStatus(key, value, false); PutMetaData() local
583 int errCode = E_OK; DeleteMetaData() local
608 int errCode = E_OK; GetAllMetaKeys() local
622 int errCode = CheckReadDataControlled(); GetSyncData() local
667 int errCode = E_OK; GetSyncData() local
696 int errCode = CheckReadDataControlled(); GetSyncData() local
735 int errCode = E_OK; GetSyncDataForQuerySync() local
788 int errCode = CheckReadDataControlled(); GetSyncDataNext() local
829 int errCode = E_OK; GetSyncDataNext() local
855 int errCode = E_OK; GetUnSyncTotal() local
872 int errCode = CheckReadDataControlled(); GetUnSyncTotal() local
942 int errCode = SaveSyncDataItems(query, dataItems, deviceInfo, true); // Current is true to check value content PutSyncDataWithQuery() local
955 int errCode = E_OK; GetMaxTimestamp() local
977 int errCode = E_OK; GetExistsDeviceList() local
1001 int errCode = GetHashDeviceId(deviceName, hashDeviceId); RemoveDeviceData() local
1035 int errCode = E_OK; RemoveDeviceDataInCacheMode() local
1053 int errCode = E_OK; RemoveDeviceDataNormally() local
1117 GetHandle(bool isWrite, int &errCode, OperatePerm perm) const GetHandle() argument
1170 int errCode = RegisterNotificationEventType(*event); RegisterNotification() local
1246 int errCode = E_OK; SaveSyncDataItems() local
1286 int errCode = SaveSyncItems(query, dataItems, deviceInfo, maxTimestamp, committedData); SaveSyncDataToMain() local
1301 int errCode = E_OK; SaveSyncItems() local
1353 int errCode = E_OK; SaveSyncDataToCacheDB() local
1376 int errCode = GetMetaData(key, timeOffset); GetTimestampFromDB() local
1431 int errCode = storageEngine_->InitSQLiteStorageEngine(poolSize, option, identifier); InitStorageEngine() local
1458 int errCode = storageEngine_->TryToDisable(false, OperatePerm::REKEY_MONOPOLIZE_PERM); Rekey() local
1511 int errCode = E_OK; Export() local
1551 int errCode = GetLocalIdentity(localDev); Import() local
1632 int errCode = remoteSchema.ParseFromSchemaString(schema); CheckCompatible() local
1725 int errCode = E_OK; GetSchema() local
1757 int errCode = GetSchema(savedSchemaObj); DecideReadOnlyBaseOnSchema() local
1776 int errCode = E_OK; InitialLocalDataTimestamp() local
1804 int errCode = -E_NOT_FOUND; GetKvDBSize() local
1839 int errCode = handle->StartTransaction(TransactType::IMMEDIATE); SaveSyncItemsInCacheMode() local
1889 int errCode = GetMetaData(key, value); GetDatabaseCreateTimestamp() local
1919 int errCode = PutMetaData(key, value, false); SaveCreateDBTime() local
1933 int errCode = E_OK; RemoveSubscribe() local
1970 int errCode = E_OK; RemoveAllSubscribe() local
2013 int errCode = GetLocalIdentity(outTarget); GetAndResizeLocalIdentity() local
[all...]
H A Dsqlite_single_ver_schema_database_upgrader.cpp31 int errCode = SQLiteUtils::GetSchema(db_, dbSchema); in GetDatabaseSchema() local
32 if (errCode != E_OK && errCode != -E_NOT_FOUND) { in GetDatabaseSchema()
33 LOGE("[SqlSingleSchemaUp][GetSchema] ErrCode=%d", errCode); in GetDatabaseSchema()
34 return errCode; in GetDatabaseSchema()
41 int errCode = SQLiteUtils::SaveSchema(db_, dbSchema); in SetDatabaseSchema() local
42 if (errCode != E_OK) { in SetDatabaseSchema()
43 LOGE("[SqlSingleSchemaUp][SetSchema] ErrCode=%d", errCode); in SetDatabaseSchema()
45 return errCode; in SetDatabaseSchema()
52 int errCode member
72 int errCode = valueObj.Parse(inValue.first, inValue.first + inValue.second, context.schema.GetSkipSize()); CheckGetForJsonSchema() local
118 int errCode = context.schema.VerifyValue(ValueSource::FROM_DBFILE, inValue); CheckGetForFlatBufferSchema() local
179 int errCode = sqlite3_create_function_v2(db_, FUNC_NAME_CHECK_AMEND_VALUE.c_str(), UpgradeValues() local
210 int errCode = SQLiteUtils::DecreaseIndex(db_, entry); UpgradeIndexes() local
217 int errCode = SQLiteUtils::ChangeIndex(db_, entry.first, entry.second, theType, skipSize); UpgradeIndexes() local
224 int errCode = SQLiteUtils::IncreaseIndex(db_, entry.first, entry.second, theType, skipSize); UpgradeIndexes() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_result_set.cpp57 int errCode = E_OK; in Open() local
58 handle_ = kvDB_->GetHandle(false, errCode); in Open()
60 LOGE("[RdSinResSet] Get handle failed, errCode=%d.", errCode); in Open()
61 return errCode; in Open()
65 errCode = handle_->OpenResultSet(key_, kvScanMode_, &resultSet_); in Open()
69 errCode = handle_->OpenResultSet(beginKey_, endKey_, &resultSet_); in Open()
75 if (errCode != E_OK) { in Open()
76 LOGE("[RdSinResSet] open result set failed, %d.", errCode); in Open()
78 return errCode; in Open()
87 int errCode = PreCheckResultSet(); Close() local
124 int errCode = PreCheckResultSet(); GetCount() local
156 int errCode = E_OK; Move() local
190 int errCode = PreCheckResultSet(); MoveToNext() local
229 int errCode = PreCheckResultSet(); MoveToPrev() local
262 int errCode = PreCheckResultSet(); MoveTo() local
284 int errCode = E_OK; MoveToFirst() local
302 int errCode = E_OK; MoveToLast() local
367 int errCode = PreCheckResultSet(); GetEntry() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/interface/src/
H A Ddocument_store.cpp42 int errCode = E_OK; in CreateCollection() local
43 if (!CheckCommon::CheckCollectionName(name, lowerCaseName, errCode)) { in CreateCollection()
44 GLOGE("Check collection name invalid. %d", errCode); in CreateCollection()
45 return errCode; in CreateCollection()
47 errCode = E_OK; in CreateCollection()
48 CollectionOption collOption = CollectionOption::ReadOption(option, errCode); in CreateCollection()
49 if (errCode != E_OK) { in CreateCollection()
50 GLOGE("Read collection option str failed. %d", errCode); in CreateCollection()
51 return errCode; in CreateCollection()
63 errCode in CreateCollection()
88 int errCode = E_OK; DropCollection() local
133 int errCode = E_OK; TranFilter() local
145 int errCode = E_OK; UpdateArgsCheck() local
177 int errCode = resultSet.GetValue(valueGotStr); GetUpDataRePlaceData() local
215 int errCode = executor_->StartTransaction(); UpdateDataIntoDB() local
260 int errCode = UpdateArgsCheck(collection, filter, update, flags); UpdateDocument() local
288 int errCode = E_OK; UpsertArgsCheck() local
308 int errCode = resultSet.GetValue(val); CheckUpsertConflict() local
324 int errCode = resultSet.GetValue(valStr); GetUpsertRePlaceData() local
361 int errCode = E_OK; InsertIdToDocument() local
389 int errCode = executor_->StartTransaction(); UpsertDataIntoDB() local
434 int errCode = E_OK; UpsertDocumentFormatCheck() local
448 int errCode = UpsertArgsCheck(collection, filter, document, flags); UpsertDocument() local
490 int errCode = E_OK; InsertArgsCheck() local
522 int errCode = InsertArgsCheck(collection, document, flags); InsertDocument() local
546 int errCode = E_OK; DeleteArgsCheck() local
569 int errCode = executor_->StartTransaction(); DeleteDataFromDB() local
598 int errCode = DeleteArgsCheck(collection, filter, flags); DeleteDocument() local
670 int errCode = E_OK; JudgeViewType() local
720 int errCode = E_OK; FindArgsCheck() local
738 int errCode = E_OK; FindProjectionInit() local
769 int errCode = E_OK; InitFindResultSet() local
804 int errCode = FindArgsCheck(collection, filter, projection, flags); FindDocument() local
898 IsCollectionExists(const std::string &collectionName, int &errCode) IsCollectionExists() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor.cpp126 int errCode = CloudStorageUtils::ConstraintsCheckForCloud(table, trimedSql); in CheckTableConstraint() local
127 if (errCode != E_OK) { in CheckTableConstraint()
128 LOGE("ConstraintsCheckForCloud failed, errCode = %d", errCode); in CheckTableConstraint()
129 return errCode; in CheckTableConstraint()
150 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetExistedDataTimeOffset() local
151 if (errCode != E_OK) { in GetExistedDataTimeOffset()
152 return errCode; in GetExistedDataTimeOffset()
154 errCode = SQLiteUtils::StepWithRetry(stmt, isMem); in GetExistedDataTimeOffset()
155 if (errCode in GetExistedDataTimeOffset()
168 int errCode = GetExistedDataTimeOffset(db, tableName, isMemDb_, timeOffset); GeneLogInfoForExistedData() local
216 int errCode = SQLiteUtils::AnalysisSchema(dbHandle_, tableName, table); CreateDistributedTable() local
274 int errCode = SQLiteUtils::AnalysisSchema(dbHandle_, tableName, newTableInfo); UpgradeDistributedTable() local
324 int errCode = SQLiteUtils::GetStatement(handle, checkSql, stmt); GetDeviceTableName() local
377 int errCode = E_OK; UpgradeFields() local
438 int errCode = E_OK; UpgradeIndexes() local
480 int errCode = GetDeviceTableName(dbHandle_, oldTableInfo.GetTableName(), {}, deviceTables); AlterAuxTableForUpgrade() local
508 int errCode = SQLiteUtils::BeginTransaction(dbHandle_, type); StartTransaction() local
529 int errCode = SQLiteUtils::RollbackTransaction(dbHandle_); Rollback() local
546 int errCode = SQLiteUtils::GetColumnBlobValue(logStatement, 1, dev); // 1 means dev index GetLogData() local
653 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_META_VALUE_SQL, statement); GetKvData() local
682 int errCode = SQLiteUtils::GetStatement(dbHandle_, INSERT_META_SQL, statement); PutKvData() local
712 int errCode = SQLiteUtils::GetStatement(dbHandle_, REMOVE_META_VALUE_SQL, statement); DeleteMetaData() local
739 int errCode = SQLiteUtils::GetStatement(dbHandle_, REMOVE_META_VALUE_BY_KEY_PREFIX_SQL, statement); DeleteMetaDataByPrefixKey() local
759 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_ALL_META_KEYS, statement); GetAllMetaKeys() local
775 int errCode = SQLiteUtils::BindBlobToStatement(queryStmt, 1, dataItem.hashKey); // 1 means hashkey index. GetLogInfoPre() local
799 int errCode = GetLogInfoPre(queryStmt, dataItem, logInfoGet); SaveSyncLog() local
835 int errCode = inserter.GetDeleteSyncDataStmt(dbHandle_, stmt); DeleteSyncDataItem() local
842 int errCode = SQLiteUtils::BindBlobToStatement(stmt, 1, dataItem.hashKey); // 1 means hash_key index DeleteSyncDataItem() local
873 int errCode = DeleteSyncDataItem(dataItem, inserter, saveStmt.rmDataStmt); SaveSyncDataItem() local
880 int errCode = inserter.BindInsertStatement(saveStmt.saveDataStmt, dataItem); SaveSyncDataItem() local
897 int errCode = inserter.GetDeleteLogStmt(dbHandle_, stmt); DeleteSyncLog() local
904 int errCode = SQLiteUtils::BindBlobToStatement(stmt, 1, dataItem.hashKey); // 1 means hashkey index DeleteSyncLog() local
927 int errCode = DeleteSyncDataItem(item, inserter, rmDataStmt); ProcessMissQueryData() local
938 int errCode = GetLogInfoPre(queryStmt, dataItem, logInfoGet); GetSyncDataPre() local
954 int errCode = GetSyncDataPre(dataItem, queryStmt, itemGet); CheckDataConflictDefeated() local
967 int errCode = CheckDataConflictDefeated(item, saveStmt.queryStmt, isDefeated); SaveSyncDataItem() local
991 int errCode = inserter.PrepareStatement(dbHandle_, saveStmt); SaveSyncDataItems() local
1017 int errCode = StartTransaction(TransactType::IMMEDIATE); SaveSyncItems() local
1023 int errCode = SetLogTriggerStatus(false); SaveSyncItems() local
1050 int errCode = GetLogData(stmt, data.logInfo); GetDataItemForSync() local
1078 int errCode = GetDataItemForSync(fullStmt, item, false); GetMissQueryData() local
1093 int errCode = SQLiteUtils::StepWithRetry(stmt, isMemDB); StepNext() local
1127 int errCode = GetDataItemForSync(queryStmt, item, isGettingDeletedData); GetQueryDataAndStepNext() local
1138 int errCode = GetMissQueryData(fullStmt, item); GetMissQueryDataAndStepNext() local
1154 int errCode = getStmt(dbHandle_, queryStmt, fullStmt, isGettingDeletedData); GetSyncDataByQuery() local
1203 int errCode = SQLiteUtils::GetJournalMode(dbHandle_, journalMode); CheckDBModeForRelational() local
1220 int errCode = GetDeviceTableName(dbHandle_, tableName, device, deviceTables); DeleteDistributedDeviceTable() local
1251 int errCode = SQLiteUtils::GetStatement(dbHandle_, deleteLogSql, deleteLogStmt); DeleteDistributedDeviceTableLog() local
1282 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, deleteSql); DeleteDistributedLogTable() local
1301 int errCode = GetKvData(key, value); IsTableOnceDropped() local
1320 int errCode = DeleteDistributedDeviceTable({}, tableName); // Clean the auxiliary tables for the dropped table CleanResourceForDroppedTable() local
1346 int errCode = SQLiteUtils::GetStatement(dbHandle_, checkSql, stmt); CheckAndCleanDistributedTable() local
1390 int errCode = SQLiteUtils::CreateSameStuTable(dbHandle_, baseTbl, deviceTableName); CreateDistributedDeviceTable() local
1411 int errCode = SQLiteUtils::AnalysisSchema(dbHandle_, table.GetTableName(), newTable); CheckQueryObjectLegal() local
1454 int errCode = SQLiteUtils::AnalysisSchema(dbHandle_, query.GetTableName(), newTable); CheckQueryObjectLegal() local
1468 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); GetMaxTimestamp() local
1492 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); SetLogTriggerStatus() local
1505 int errCode = SQLiteUtils::StepWithRetry(stmt, isMemDb); GetRowDatas() local
1547 int errCode = SQLiteUtils::SetAuthorizer(dbHandle_, &PermitSelect); ExecuteQueryBySqlStmt() local
1577 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, "SELECT count(*) FROM sqlite_master;"); CheckEncryptedOrCorrupted() local
1595 int errCode = E_OK; GetSyncCloudGid() local
1637 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::FLAG, extraLog, flag); GetCloudDataForSync() local
1682 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, cleanLogSql); CleanCloudDataOnLogTable() local
1718 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); CleanCloudDataAndLogOnUserTable() local
1747 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, cleanLogSql); ChangeCloudDataFlagOnLogTable() local
1761 int errCode = CreateFuncUpdateCursor(context, &UpdateCursor); SetDataOnUserTableWithLogicDelete() local
1803 int errCode = CreateFuncUpdateCursor(context, &UpdateCursor); SetDataOnShareTableWithLogicDelete() local
1846 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, selectStmt); GetCleanCloudDataKeys() local
1902 int errCode = AppendUpdateLogRecordWhereSqlCondition(tableSchema, vBucket, updateLogSql); GetUpdateLogRecordStatement() local
[all...]
H A Dsqlite_relational_database_upgrader.cpp38 int errCode = SQLiteUtils::GetLogTableVersion(db_, logTableVersion); in Upgrade() local
39 if (errCode != E_OK) { in Upgrade()
40 LOGW("[Relational][Upgrade] Get log table version return. %d", errCode); in Upgrade()
41 return (errCode == -E_NOT_FOUND) ? E_OK : errCode; in Upgrade()
47 errCode = BeginUpgrade(); in Upgrade()
48 if (errCode != E_OK) { in Upgrade()
49 LOGE("[Relational][Upgrade] Begin upgrade failed. err=%d", errCode); in Upgrade()
50 return errCode; in Upgrade()
53 errCode in Upgrade()
75 int errCode = SQLiteUtils::GetLogTableVersion(db_, logTableVersion); ExecuteUpgrade() local
123 int errCode = SQLiteUtils::CheckTableExists(db_, table.first, isExists); UpgradeTrigger() local
167 int errCode = UpgradeLogBaseOnVersion(logTableVersion, table.first); UpgradeLogTable() local
176 int errCode = UpgradeLogBaseOnVersion(logTableVersion, table.first); UpgradeLogTable() local
193 int errCode = SQLiteUtils::AnalysisSchemaFieldDefine(db_, logName, tableInfo); UpgradeLogBaseOnVersion() local
234 int errCode = SQLiteUtils::GetRelationalSchema(db_, schemaDefine); GetParseSchema() local
[all...]
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp40 int errCode = GetQueryInfoSql(tableSchema.name, vBucket, pkSet, assetFields, querySql); in GetInfoByPrimaryKeyOrGid() local
41 if (errCode != E_OK) { in GetInfoByPrimaryKeyOrGid()
42 LOGE("Get query log sql fail, %d", errCode); in GetInfoByPrimaryKeyOrGid()
43 return errCode; in GetInfoByPrimaryKeyOrGid()
46 errCode = GetPrimaryKeyHashValue(vBucket, tableSchema, dataInfoWithLog.logInfo.hashKey, true); in GetInfoByPrimaryKeyOrGid()
47 if (errCode != E_OK) { in GetInfoByPrimaryKeyOrGid()
48 LOGE("calc hash fail when get query log statement, errCode = %d", errCode); in GetInfoByPrimaryKeyOrGid()
49 return errCode; in GetInfoByPrimaryKeyOrGid()
53 errCode in GetInfoByPrimaryKeyOrGid()
115 int errCode = E_OK; GetInfoByStatement() local
166 int errCode = E_OK; GetPrimaryKeyHashValue() local
190 int errCode = SQLiteUtils::GetStatement(dbHandle_, querySql, selectStmt); GetQueryLogStatement() local
229 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid); GetQueryLogSql() local
255 int errCode = E_OK; ExecutePutCloudData() local
298 int errCode = SetLogTriggerStatus(false); DoCleanInner() local
336 int errCode = E_OK; DoCleanLogs() local
376 int errCode = sqlite3_create_function_v2(dbHandle_, sql.c_str(), 0, SQLITE_UTF8 | SQLITE_DIRECTONLY, CreateFuncUpdateCursor() local
390 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); GetCursor() local
420 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); SetCursor() local
455 int errCode = E_OK; DoCleanLogAndData() local
489 int errCode = E_OK; GetAssetOnTable() local
535 int errCode = E_OK; GetCloudAssetsOnTable() local
575 int errCode = E_OK; GetCloudAssets() local
604 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); SetCursorIncFlag() local
620 int errCode = SetLogTriggerStatus(false); PutCloudSyncData() local
646 int errCode = E_OK; InsertCloudData() local
688 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); InsertLogRecord() local
707 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, insertLogStmt); InsertLogRecord() local
744 int errCode = E_OK; BindValueToUpsertStatement() local
759 int errCode = SQLiteUtils::BindBlobToStatement(insertLogStmt, 12, hashKey); // 12 is hash_key BindStatusSubQueryHashKeyStatement() local
777 int errCode = GetPrimaryKeyHashValue(vBucket, tableSchema, hashKey); BindHashKeyAndGidToInsertLogStatement() local
824 int errCode = SQLiteUtils::BindInt64ToStatement(insertLogStmt, 1, rowid); BindValueToInsertLogStatement() local
928 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); GetUpdateDataTableStatement() local
971 int errCode = GetUpdateDataTableStatement(vBucket, tableSchema, updateStmt); UpdateCloudData() local
1007 int errCode = GetUpdateLogRecordStatement(tableSchema, vBucket, opType, updateColName, updateLogStmt); UpdateLogRecord() local
1036 int errCode = CloudStorageUtils::BindUpdateLogStmtFromVBucket(vBucket, tableSchema, colNames, updateLogStmt); BindValueToUpdateLogStatement() local
1057 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); GetDeleteStatementForCloudSync() local
1096 int errCode = GetDeleteStatementForCloudSync(tableSchema, pkSet, vBucket, deleteStmt); DeleteCloudData() local
1136 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, deleteSql); DeleteTableTrigger() local
1155 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); UpdateRecordStatus() local
1187 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, CloudStorageUtils::GetCursorIncSql(tableName)); LogicDeleteCloudData() local
1206 int errCode = GetKvData(key, cursor); InitCursorToMeta() local
1232 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); ReviseLocalModTime() local
1336 int errCode = SQLiteUtils::GetStatement(dbHandle_, queryAssetsSql, selectStmt); IsNeedUpdateAssetId() local
1372 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); MarkFlagAsConsistent() local
1407 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); FillCloudVersionForUpload() local
1432 int errCode = SQLiteRelationalUtils::QueryCount(dbHandle_, tableName, dataCount); CheckInventoryData() local
1444 int errCode = helper.GetCloudQueryStatement(false, dbHandle_, sql, stmt); GetUploadCountInner() local
1463 int errCode; GetUploadCount() local
1480 int errCode; GetAllUploadCount() local
1509 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); UpdateCloudLogGid() local
1525 int errCode = token.GetCloudStatement(dbHandle_, cloudDataResult, queryStmt, isStepNext); GetSyncCloudData() local
1553 int errCode = RuntimeContext::GetInstance()->BlobToAsset(std::get<Bytes>(cloudValue), asset); PutVBucketByType() local
1563 int errCode = RuntimeContext::GetInstance()->BlobToAssets(std::get<Bytes>(cloudValue), assets); PutVBucketByType() local
1580 int errCode = SQLiteUtils::StepWithRetry(stmt); GetAssetInfoOnTable() local
[all...]
H A Dsqlite_single_ver_relational_storage_extend_executor.cpp42 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gid); in GetQueryInfoSql() local
43 if (putDataMode_ == PutDataMode::SYNC && errCode != E_OK) { in GetQueryInfoSql()
45 return errCode; in GetQueryInfoSql()
80 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in GetFillDownloadAssetStatement() local
81 if (errCode != E_OK) { in GetFillDownloadAssetStatement()
82 LOGE("Get fill asset statement failed, %d.", errCode); in GetFillDownloadAssetStatement()
83 return errCode; in GetFillDownloadAssetStatement()
86 errCode = BindOneField(i + 1, vBucket, fields[i], stmt); in GetFillDownloadAssetStatement()
87 if (errCode != E_OK) { in GetFillDownloadAssetStatement()
88 SQLiteUtils::ResetStatement(stmt, true, errCode); in GetFillDownloadAssetStatement()
100 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, cloudGid); FillCloudAssetForDownload() local
154 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); IncreaseCursorOnAssetData() local
194 int errCode = E_OK; FillCloudAssetForUpload() local
258 int errCode = E_OK; BindUpdateVersionStatement() local
292 int errCode; InitFillUploadAssetStatement() local
334 int errCode = AnalysisTrackerTable(trackerTable, table); CreateTrackerTable() local
389 int errCode = GetKvData(schemaKey, schemaVal); // save schema to meta_data GetOrInitTrackerSchemaFromMeta() local
408 int errCode = SQLiteUtils::GetStatement(dbHandle_, condition.sql, statement); ExecuteSql() local
451 int errCode = SQLiteUtils::CheckTableExists(dbHandle_, logTableName, isExists); GetClearWaterMarkTables() local
495 int errCode = SetLogTriggerStatus(false); UpgradedLogForExistedData() local
514 int errCode = E_OK; CreateTempSyncTrigger() local
556 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); ClearAllTempSyncTrigger() local
586 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); CleanTrackerData() local
641 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, createTableSql); CreateSharedTable() local
652 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, deleteTableSql); DeleteTable() local
664 int errCode = E_OK; UpdateSharedTable() local
699 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, alterTableSql); AlterTableName() local
712 int errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::GID_FIELD, vBucket, gidStr); AppendUpdateLogRecordWhereSqlCondition() local
734 int errCode = E_OK; DoCleanShareTableDataAndLog() local
754 int errCode = E_OK; CleanShareTable() local
793 int errCode = E_OK; GetReferenceGid() local
819 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetReferenceGidInner() local
876 int errCode = E_OK; GetReferenceGidByStmt() local
941 int errCode = E_OK; BindStmtWithCloudGid() local
987 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); CleanExtendAndCursorForDeleteData() local
998 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); CheckIfExistUserTable() local
1033 int errCode = SetCursor(table, cursor + 1); GetCloudDeleteSql() local
1045 int errCode = E_OK; RemoveDataAndLog() local
1075 int errCode = SQLiteUtils::BindTextToStatement(stmt, 1, gid); // 1 means the gid index BindStmtWithCloudGidInner() local
1106 int errCode = GetCleanCloudDataKeys(logTableName, dataKeys, false); DoCleanAssetId() local
1122 int errCode = E_OK; CleanAssetId() local
1153 int errCode = E_OK; UpdateAssetIdOnUserTable() local
1198 int errCode = E_OK; GetAssetsAndUpdateAssetsId() local
1247 int errCode = SQLiteUtils::GetStatement(dbHandle_, cleanAssetIdSql, stmt); CleanAssetsIdOnUserTable() local
1323 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); InitGetAssetStmt() local
1348 int errCode = E_OK; FillHandleWithOpType() local
1399 int errCode = SQLiteUtils::StepWithRetry(selectStmt); GetAssetsByRowId() local
1428 int errCode = SQLiteUtils::BindTextToStatement(stmt, beginIndex, cloudGid); ExecuteFillDownloadAssetStatement() local
1475 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetAndBindFillUploadAssetStatement() local
1506 int errCode = UpdateAssetId(tableSchema, dataKey, vBucket); OnlyUpdateAssetId() local
1537 int errCode = RuntimeContext::GetInstance()->AssetToBlob(asset, blobValue); BindAssetToBlobStatement() local
1553 int errCode = RuntimeContext::GetInstance()->AssetsToBlob(assets, blobValue); BindAssetsToBlobStatement() local
1575 int errCode = BindAssetToBlobStatement(assetOfOneRecord[assetIndex], assetIndex + assetsIndex + 1, stmt); BindAssetFiledToBlobStatement() local
1585 int errCode = BindAssetsToBlobStatement(assetsOfOneRecord[assetsIndex], assetIndex + assetsIndex + 1, stmt); BindAssetFiledToBlobStatement() local
1599 int errCode = E_OK; UpdateAssetsIdForOneRecord() local
1626 int errCode = E_OK; UpdateAssetId() local
1739 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); UpdateRecordFlag() local
1779 int errCode = SQLiteUtils::GetStatement(dbHandle_, CloudStorageUtils::GetUpdateUploadFinishedSql(tableName), MarkFlagAsUploadFinished() local
1822 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); GetWaitCompensatedSyncDataPk() local
1856 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); ClearUnLockingStatus() local
1875 int errCode = E_OK; GetRecordFromStmt() local
1894 int errCode = E_OK; BindShareValueToInsertLogStatement() local
[all...]
H A Dsqlite_single_relational_storage_engine.cpp44 int errCode = CreateRelationalMetaTable(db); in Upgrade() local
45 if (errCode != E_OK) { in Upgrade()
46 LOGE("Create relational store meta table failed. err=%d", errCode); in Upgrade()
47 return errCode; in Upgrade()
56 int errCode = SQLiteUtils::RegisterCalcHash(db); in RegisterFunction() local
57 if (errCode != E_OK) { in RegisterFunction()
59 return errCode; in RegisterFunction()
62 errCode = SQLiteUtils::RegisterGetLastTime(db); in RegisterFunction()
63 if (errCode != E_OK) { in RegisterFunction()
65 return errCode; in RegisterFunction()
96 int errCode = SQLiteUtils::OpenDatabase(option_, db, false); CreateNewExecutor() local
158 int errCode = handle->PutKvData(schemaKey, schemaVal); // save schema to meta_data SaveSchemaToMetaTable() local
172 int errCode = handle->PutKvData(schemaKey, schemaVal); // save schema to meta_data SaveTrackerSchemaToMetaTable() local
186 int errCode = handle->PutKvData(key, value); SaveSyncTableTypeAndDropFlagToMeta() local
214 int errCode = UpgradeDistributedTable(tableName, schemaChanged, syncType); CreateDistributedTable() local
227 int errCode = CreateDistributedTable(tableName, isUpgraded, identity, schema, syncType); CreateDistributedTable() local
254 int errCode = CreateDistributedTable(handle, isUpgraded, "", table, schema); CreateDistributedSharedTable() local
268 int errCode = E_OK; CreateDistributedTable() local
312 int errCode = handle->CreateDistributedTable(mode, isUpgraded, identity, table, tableSyncType); CreateDistributedTable() local
341 int errCode = E_OK; UpgradeDistributedTable() local
382 int errCode = E_OK; CleanDistributedDeviceTable() local
448 int errCode = SQLiteUtils::ExecuteRawSQL(db, sql); CreateRelationalMetaTable() local
457 int errCode = E_OK; SetTrackerTable() local
512 int errCode = E_OK; CheckAndCacheTrackerSchema() local
546 int errCode = E_OK; GetOrInitTrackerSchemaFromMeta() local
582 int errCode = E_OK; SaveTrackerSchema() local
601 int errCode = E_OK; ExecuteSql() local
656 int errCode = CheckReference(tableReferenceProperty, schema); SetReference() local
695 int errCode = E_OK; CleanTrackerData() local
710 int errCode = E_OK; UpgradeSharedTable() local
743 int errCode = DoDeleteSharedTable(handle, deleteTableNames, schema); UpgradeSharedTableInner() local
779 int errCode = handle->DeleteTable(deleteTableNames); DoDeleteSharedTable() local
813 int errCode = handle->UpdateSharedTable(updateTableNames); DoUpdateSharedTable() local
837 int errCode = handle->AlterTableName(alterTableNames); DoAlterSharedTableName() local
892 int errCode = handle->CreateSharedTable(tableSchema); DoCreateSharedTable() local
928 int errCode = handle->DeleteMetaData(keys); UpdateKvData() local
947 int errCode = handle->CheckIfExistUserTable(tableSchema.sharedTableName); CheckIfExistUserTable() local
994 int errCode = handle->CheckAndCleanDistributedTable(tableNames, missingTrackerTables); CleanTrackerDeviceTable() local
1017 int errCode = E_OK; GenLogInfoForUpgrade() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/
H A Dmulti_ver_storage_executor.cpp61 int errCode = kvDataStorage_->PutMetaData(key, value); in PutMetaData() local
62 return CheckCorruptedStatus(errCode); in PutMetaData()
71 int errCode = kvDataStorage_->GetMetaData(key, value); in GetMetaData() local
72 return CheckCorruptedStatus(errCode); in GetMetaData()
82 int errCode = commitStorage_->GetLatestCommits(latestCommits); in GetDeviceLatestCommit() local
83 if (errCode != E_OK) { in GetDeviceLatestCommit()
84 LOGE("Get latest commits failed:%d", errCode); in GetDeviceLatestCommit()
85 return CheckCorruptedStatus(errCode); in GetDeviceLatestCommit()
120 int errCode = commitStorage_->GetCommitTree(latestCommits, commitTree); in GetCommitTree() local
121 if (errCode ! in GetCommitTree()
158 int errCode = E_OK; GetCommitData() local
272 int errCode; GetValueSliceInner() local
294 int errCode; PutValueSliceInner() local
317 int errCode; DeleteValueSliceInner() local
345 int errCode; StartSliceTransaction() local
362 int errCode = sliceTransaction_->CommitTransaction(); CommitSliceTransaction() local
379 int errCode = sliceTransaction_->RollbackTransaction(); RollbackSliceTransaction() local
397 int errCode = StartTransaction(); ReInitTransactionVersion() local
427 int errCode = valueObject.DeSerialData(item); AddSliceDataCount() local
451 int errCode = ReInitTransactionVersion(commit); PutCommitData() local
509 int errCode = MergeCommits(commits); MergeSyncCommit() local
516 int errCode = GetResolvedConflictEntries(commit, entries); MergeOneCommit() local
544 int errCode = StartTransaction(); MergeCommits() local
592 int errCode = E_OK; GetDiffEntries() local
640 int errCode = E_OK; Get() local
663 int errCode = E_OK; GetEntries() local
697 int errCode = TransferToSavedValue(value, savedValue); Put() local
711 int errCode = transaction_->Delete(key); Delete() local
721 int errCode = transaction_->Clear(); Clear() local
732 int errCode = dataStorage_->StartWrite(KvDataType::KV_DATA_SYNC_P2P, transaction); StartAllDbTransaction() local
786 int errCode = dataStorage_->StartWrite(KvDataType::KV_DATA_SYNC_P2P, transaction); StartTransaction() local
812 int errCode = transaction_->CommitTransaction(); CommitAllDbTransaction() local
854 int errCode = E_OK; CommitTransaction() local
893 int errCode = dataStorage_->RollbackWrite(transaction_); RollBackAllDbTransaction() local
930 int errCode = dataStorage_->RollbackWrite(transaction_); RollBackTransaction() local
957 int errCode = E_OK; InitCurrentReadVersion() local
982 int errCode; TransferDiffEntries() local
1014 int errCode = valueObject.DeSerialData(savedValue); TransferToUserValue() local
1049 int errCode = splitData.SegmentAndTransferValueToHash(value, partValues); TransferToValueObject() local
1080 int errCode = TransferToValueObject(value, valueObject); TransferToSavedValue() local
1101 int errCode = E_OK; GetResolvedConflictEntries() local
1125 int errCode = GetParentCommitId(commitId, startId, currentVersion); CommitNotifiedData() local
1148 int errCode = E_OK; GetParentCommitId() local
1177 int errCode = E_OK; FillAndCommitLogEntry() local
1224 int errCode = E_OK; FillCommitByForeign() local
1259 int errCode = E_OK; FillAndCommitLogEntry() local
1304 int errCode = dataStorage_->CommitWritePhaseOne(transaction_, multiVerTimestamp); CommitTransaction() local
1365 int errCode = E_OK; GetEntriesByVersion() local
1394 int errCode = E_OK; GetOverwrittenClearTypeEntries() local
1423 int errCode = E_OK; GetOverwrittenNonClearTypeEntries() local
1453 int errCode = transaction_->GetValueForTrimSlice(hashKey, version, savedValue); DeleteEntriesByHashKey() local
[all...]
H A Dmulti_ver_natural_store_connection.cpp43 int errCode = CheckDataStatus(key, {}, false); in Get() local
44 if (errCode != E_OK) { in Get()
45 return errCode; in Get()
55 auto handle = GetHandle(false, errCode); in Get()
57 return errCode; in Get()
60 errCode = handle->InitCurrentReadVersion(); in Get()
61 if (errCode == E_OK) { in Get()
62 errCode = handle->Get(key, value); in Get()
66 return errCode; in Get()
73 int errCode in Put() local
104 int errCode = CheckDataStatus(key, {}, true); Delete() local
136 int errCode = StartTransactionInner(isAuto); Clear() local
168 int errCode = E_OK; GetEntries() local
194 int errCode = StartTransactionInner(isAuto); PutBatch() local
229 int errCode = StartTransactionInner(isAuto); DeleteBatch() local
268 int errCode = E_OK; GetSnapshot() local
374 int errCode = writeHandle_->CommitTransaction(); CommitTransactionInner() local
390 int errCode = writeHandle_->RollBackTransaction(); RollBackTransactionInner() local
406 int errCode = E_OK; StartTransactionInner() local
443 int errCode = kvDB_->TryToDisableConnection(OperatePerm::REKEY_MONOPOLIZE_PERM); Rekey() local
476 int errCode = kvDB_->TryToDisableConnection(OperatePerm::IMPORT_MONOPOLIZE_PERM); Import() local
[all...]
/foundation/distributeddatamgr/relational_store/test/ndk/unittest/
H A Drdb_asset_test.cpp57 int errCode = 0; in SetUpTestCase() local
58 assetTestRdbStore_ = OH_Rdb_GetOrOpen(&config_, &errCode); in SetUpTestCase()
66 int errCode = OH_Rdb_Execute(assetTestRdbStore_, dropTableSql); in TearDownTestCase() local
67 EXPECT_EQ(errCode, 0); in TearDownTestCase()
68 errCode = OH_Rdb_CloseStore(assetTestRdbStore_); in TearDownTestCase()
69 EXPECT_EQ(errCode, 0); in TearDownTestCase()
70 errCode = OH_Rdb_DeleteStore(&config_); in TearDownTestCase()
71 EXPECT_EQ(errCode, 0); in TearDownTestCase()
86 int errCode = OH_Rdb_Execute(assetTestRdbStore_, createTableSql); in CreateAssetTable() local
87 EXPECT_EQ(errCode, RDB_O in CreateAssetTable()
103 int errCode = OH_Data_Asset_SetName(nullptr, nullptr); HWTEST_F() local
125 int errCode = OH_Data_Asset_SetUri(nullptr, nullptr); HWTEST_F() local
147 int errCode = OH_Data_Asset_SetPath(nullptr, nullptr); HWTEST_F() local
167 int errCode = OH_Data_Asset_SetCreateTime(nullptr, 1); HWTEST_F() local
189 int errCode = OH_Data_Asset_SetName(asset, "name"); HWTEST_F() local
215 int errCode = OH_Data_Asset_SetUri(asset, "uri"); HWTEST_F() local
241 int errCode = OH_Data_Asset_SetPath(asset, "path"); HWTEST_F() local
264 int errCode = OH_Data_Asset_GetCreateTime(nullptr, &createTime); HWTEST_F() local
277 int errCode = OH_Data_Asset_GetModifyTime(nullptr, &modifyTime); HWTEST_F() local
290 int errCode = OH_Data_Asset_GetSize(nullptr, &size); HWTEST_F() local
303 int errCode = OH_Data_Asset_GetStatus(nullptr, &status); HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/test/unittest/oh_adapter/
H A Ddocumentdb_json_common_test.cpp51 int errCode = E_OK; in HWTEST_F() local
52 JsonObject src = JsonObject::Parse(document, errCode); in HWTEST_F()
53 EXPECT_EQ(errCode, E_OK); in HWTEST_F()
54 JsonObject add = JsonObject::Parse(updateDoc, errCode); in HWTEST_F()
55 EXPECT_EQ(errCode, E_OK); in HWTEST_F()
60 JsonObject itemCase = src.FindItem({ "case", "field1" }, errCode); in HWTEST_F()
61 EXPECT_EQ(errCode, E_OK); in HWTEST_F()
64 JsonObject itemName = src.FindItem({ "name" }, errCode); in HWTEST_F()
65 EXPECT_EQ(errCode, E_OK); in HWTEST_F()
76 int errCode in HWTEST_F() local
100 int errCode = E_OK; HWTEST_F() local
122 int errCode = E_OK; HWTEST_F() local
136 int errCode = E_OK; HWTEST_F() local
155 int errCode = E_OK; HWTEST_F() local
174 int errCode = E_OK; HWTEST_F() local
193 int errCode = E_OK; HWTEST_F() local
212 int errCode = E_OK; HWTEST_F() local
231 int errCode = E_OK; HWTEST_F() local
246 int errCode = E_OK; HWTEST_F() local
260 int errCode = E_OK; HWTEST_F() local
274 int errCode = E_OK; HWTEST_F() local
288 int errCode = E_OK; HWTEST_F() local
305 int errCode = E_OK; HWTEST_F() local
325 int errCode = E_OK; HWTEST_F() local
337 int errCode = E_OK; HWTEST_F() local
349 int errCode = E_OK; HWTEST_F() local
361 int errCode = E_OK; HWTEST_F() local
373 int errCode = E_OK; HWTEST_F() local
385 int errCode = E_OK; HWTEST_F() local
397 int errCode = E_OK; HWTEST_F() local
409 int errCode = E_OK; HWTEST_F() local
421 int errCode = E_OK; HWTEST_F() local
433 int errCode = E_OK; HWTEST_F() local
445 int errCode = E_OK; HWTEST_F() local
457 int errCode = E_OK; HWTEST_F() local
469 int errCode = E_OK; HWTEST_F() local
480 int errCode = E_OK; HWTEST_F() local
491 int errCode = E_OK; HWTEST_F() local
502 int errCode = E_OK; HWTEST_F() local
514 int errCode = E_OK; HWTEST_F() local
526 int errCode = E_OK; HWTEST_F() local
538 int errCode = E_OK; HWTEST_F() local
549 int errCode = E_OK; HWTEST_F() local
565 int errCode = E_OK; HWTEST_F() local
585 int errCode = E_OK; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/upgrader/
H A Dsingle_ver_database_upgrader.cpp24 int errCode = GetDatabaseVersion(dbVersion_); in Upgrade() local
25 if (errCode != E_OK) { in Upgrade()
26 LOGE("[SingleUp][Upgrade] GetVersion error:%d.", errCode); in Upgrade()
27 return errCode; in Upgrade()
36 errCode = BeginUpgrade(); in Upgrade()
37 if (errCode != E_OK) { in Upgrade()
38 LOGE("[SingleUp][Upgrade] Begin error:%d.", errCode); in Upgrade()
39 return errCode; in Upgrade()
41 errCode = ExecuteUpgrade(); in Upgrade()
42 if (errCode ! in Upgrade()
[all...]
/foundation/communication/bluetooth/frameworks/cj/connection/src/
H A Dbluetooth_connection_ffi.cpp28 void FfiBluetoothConPairDevice(const char* deviceId, int32_t* errCode) in FfiBluetoothConPairDevice() argument
30 return ConnectionImpl::PairDevice(deviceId, errCode); in FfiBluetoothConPairDevice()
33 char* FfiBluetoothConGetRemoteDeviceName(const char* deviceId, int32_t* errCode) in FfiBluetoothConGetRemoteDeviceName() argument
35 return ConnectionImpl::GetRemoteDeviceName(deviceId, errCode); in FfiBluetoothConGetRemoteDeviceName()
38 DeviceClass FfiBluetoothConGetRemoteDeviceClass(const char* deviceId, int32_t* errCode) in FfiBluetoothConGetRemoteDeviceClass() argument
40 return ConnectionImpl::GetRemoteDeviceClass(deviceId, errCode); in FfiBluetoothConGetRemoteDeviceClass()
43 CArrString FfiBluetoothConGetRemoteProfileUuids(const char* deviceId, int32_t* errCode) in FfiBluetoothConGetRemoteProfileUuids() argument
45 return ConnectionImpl::GetRemoteProfileUuids(deviceId, errCode); in FfiBluetoothConGetRemoteProfileUuids()
48 char* FfiBluetoothConGetLocalName(int32_t* errCode) in FfiBluetoothConGetLocalName() argument
50 return ConnectionImpl::GetLocalName(errCode); in FfiBluetoothConGetLocalName()
53 FfiBluetoothConGetPairedDevices(int32_t* errCode) FfiBluetoothConGetPairedDevices() argument
58 FfiBluetoothConGetPairState(const char* deviceId, int32_t* errCode) FfiBluetoothConGetPairState() argument
63 FfiBluetoothConGetProfileConnectionState(int32_t profileId, int32_t* errCode) FfiBluetoothConGetProfileConnectionState() argument
68 FfiBluetoothConSetDevicePairingConfirmation(const char* deviceId, bool accept, int32_t* errCode) FfiBluetoothConSetDevicePairingConfirmation() argument
73 FfiBluetoothConSetDevicePinCode(const char* deviceId, const char* code, int32_t* errCode) FfiBluetoothConSetDevicePinCode() argument
78 FfiBluetoothConSetLocalName(const char* localName, int32_t* errCode) FfiBluetoothConSetLocalName() argument
83 FfiBluetoothConSetBluetoothScanMode(int32_t mode, int32_t duration, int32_t* errCode) FfiBluetoothConSetBluetoothScanMode() argument
88 FfiBluetoothConGetBluetoothScanMode(int32_t* errCode) FfiBluetoothConGetBluetoothScanMode() argument
93 FfiBluetoothConStartBluetoothDiscovery(int32_t* errCode) FfiBluetoothConStartBluetoothDiscovery() argument
98 FfiBluetoothConStopBluetoothDiscovery(int32_t* errCode) FfiBluetoothConStopBluetoothDiscovery() argument
103 FfiBluetoothConIsBluetoothDiscovering(int32_t* errCode) FfiBluetoothConIsBluetoothDiscovering() argument
108 FfiBluetoothConSetRemoteDeviceName(const char* deviceId, const char* name, int32_t* errCode) FfiBluetoothConSetRemoteDeviceName() argument
113 FfiBluetoothConGetRemoteDeviceBatteryInfo(const char* deviceId, int32_t* errCode) FfiBluetoothConGetRemoteDeviceBatteryInfo() argument
118 FfiBluetoothConOn(int32_t callbackType, void (*callback)(), int32_t* errCode) FfiBluetoothConOn() argument
[all...]
/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_store_concurrent_test.cpp82 int errCode = E_OK; in SetUpTestCase() local
86 RdbConcurrentTest::store = RdbHelper::GetRdbStore(config, 1, helper, errCode); in SetUpTestCase()
88 EXPECT_EQ(errCode, E_OK); in SetUpTestCase()
136 int errCode = Query(); in QueryThread() local
137 if (errCode != E_OK) { in QueryThread()
138 queryResult = errCode; in QueryThread()
155 int errCode = CheckResultSet(*resultSet); in Query() local
156 if (errCode != E_OK) { in Query()
157 return errCode; in Query()
171 int errCode in CheckResultSet() local
203 int errCode = resultSet.GetColumnIndex("id", columnIndex); CheckId() local
220 int errCode = resultSet.GetColumnIndex("name", columnIndex); CheckName() local
242 int errCode = resultSet.GetColumnIndex("age", columnIndex); CheckAge() local
264 int errCode = resultSet.GetColumnIndex("salary", columnIndex); CheckSalary() local
284 int errCode = resultSet.GetColumnIndex("blobType", columnIndex); CheckBlob() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/operation/
H A Dsingle_ver_database_oper.cpp42 int errCode = RuntimeContext::GetInstance()->SetSecurityOption(currentMetaPath, option); in SetSecOpt() local
43 if (errCode != E_OK && errCode != -E_NOT_SUPPORT) { in SetSecOpt()
44 return errCode; in SetSecOpt()
49 errCode = RuntimeContext::GetInstance()->SetSecurityOption(currentMainPath, option); in SetSecOpt()
50 if (errCode != E_OK && errCode != -E_NOT_SUPPORT) { in SetSecOpt()
51 return errCode; in SetSecOpt()
83 bool SingleVerDatabaseOper::RekeyPreHandle(const CipherPassword &passwd, int &errCode) in RekeyPreHandle() argument
86 errCode in RekeyPreHandle()
111 int errCode = GetCtrlFilePrefix(singleVerNaturalStore_->GetDbProperties(), filePrefix); BackupDb() local
150 int errCode = RekeyRecover(singleVerNaturalStore_->GetDbProperties()); CloseStorages() local
185 int errCode = SQLiteUtils::ExportDatabase(currentDb, cipherType, currPasswd, backupDbName, passwd); ExportMainDB() local
207 int errCode = SQLiteUtils::ExportDatabase(currentDb, CipherType::DEFAULT, CipherPassword(), ExportMetaDB() local
219 int errCode = ExportMainDB(currentDir, passwd, dbDir); ExportAllDatabases() local
239 int errCode = DBCommon::CopyFile(currentMainFile, backupMainFile); BackupDatabase() local
263 int errCode = OS::CreateFileByFileName(info.curValidFile); BackupCurrentDatabase() local
313 int errCode = DBCommon::RemoveAllFilesOfDirectory(info.currentDir, false); ClearCurrentDatabase() local
347 int errCode = E_OK; ImportUnpackedMainDatabase() local
373 int errCode = SQLiteUtils::ExportDatabase(unpackedMetaFile, CipherType::DEFAULT, CipherPassword(), ImportUnpackedMetaDatabase() local
387 int errCode = ClearCurrentDatabase(info); ImportUnpackedDatabase() local
442 int errCode = SQLiteUtils::ExportDatabase(currentMainDb, cipherType, currPasswd, backupMainDbName, passwd); RunExportLogic() local
480 int errCode = storageEngine_->InitSQLiteStorageEngine(poolSize, option, identify); InitStorageEngine() local
526 int errCode = SQLiteUtils::OpenDatabase(option, db); RunRekeyLogic() local
[all...]

Completed in 26 milliseconds

12345678910>>...74