| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | step_result_set.cpp | 49 auto statement = GetStatement(); in StepResultSet()
81 auto statement = GetStatement(); in InitRowCount()
160 auto statement = GetStatement(); in GetColumnNames()
188 auto statement = GetStatement(); in GetColumnType()
251 auto statement = GetStatement(); in GoToNextRow()
336 auto statement = GetStatement(); in Reset()
361 auto statement = GetStatement(); in GetSize()
388 auto statement = GetStatement(); in GetValueObject()
399 std::shared_ptr<Statement> StepResultSet::GetStatement() in GetStatement() function in OHOS::NativeRdb::StepResultSet
|
| H A D | rd_result_set.cpp | 63 auto [statement, connection] = GetStatement(); in GetColumnNames()
102 auto [statement, connection] = GetStatement(); in GetColumnType()
179 auto [statement, conn] = GetStatement(); in GoToNextRow()
261 auto [statement, connection] = GetStatement(); in FinishStep()
324 auto [statement, conn] = GetStatement(); in GetSize()
352 auto [statement, conn] = GetStatement(); in GetValueObject()
369 …ir<std::shared_ptr<RdbStatement>, std::shared_ptr<RdbConnection>> RdSharedResultSet::GetStatement() in GetStatement() function in OHOS::NativeRdb::RdSharedResultSet
|
| H A D | trans_db.cpp | 65 auto [errCode, statement] = GetStatement(sql); in Insert()
90 auto [errCode, statement] = GetStatement(sql); in BatchInsert()
139 auto [errCode, statement] = GetStatement(sql); in Update()
163 auto [errCode, statement] = GetStatement(sql); in Delete()
203 auto [errCode, statement] = GetStatement(sql); in Execute()
261 std::pair<int32_t, std::shared_ptr<Statement>> TransDB::GetStatement(const std::string &sql) const in GetStatement() function in OHOS::NativeRdb::TransDB
|
| H A D | rdb_store_impl.cpp | 813 auto [err, statement] = GetStatement(GlobalExpr::PRAGMA_VERSION); in ModifyLockStatus()
1021 auto [errCode, statement] = GetStatement(sql, connection); in BatchInsert()
1227 auto [errCode, statement] = GetStatement(sql, connect); in Execute()
1328 auto [errCode, statement] = GetStatement(sql, false); in ExecuteForLastInsertedRowId()
1363 auto [errCode, statement] = GetStatement(sql, false); in ExecuteForChangedRowCount()
1572 return GetStatement(sql, true); in BeginExecuteSql()
1813 auto [errCode, statement] = GetStatement(sql); in SetVersion()
1901 auto [errCode, statement] = GetStatement(transaction.GetRollbackStr()); in RollBack()
1953 auto [ret, statement] = GetStatement(sql, connection); in ExecuteByTrxId()
1999 auto [errCode, statement] = GetStatement(sqlStr); in Commit()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_data_inserter.cpp | 131 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetInsertStatement()
185 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetDeleteLogStmt()
201 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetDeleteSyncDataStmt()
215 int errCode = SQLiteUtils::GetStatement(db, sql, logStmt); in GetSaveLogStatement()
226 errCode = SQLiteUtils::GetStatement(db, selectSql, queryStmt); in GetSaveLogStatement()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_multi_ver_transaction.cpp | 242 int errCode = SQLiteUtils::GetStatement(db_, SELECT_ONE_SQL, statement); in Get()
264 int errCode = SQLiteUtils::GetStatement(db_, SELECT_BY_HASHKEY_VER_SQL, statement); in GetValueForTrimSlice()
452 int errCode = SQLiteUtils::GetStatement(db_, SELECT_ONE_VER_RAW_SQL, statement); in GetDiffEntries()
508 int errCode = SQLiteUtils::GetStatement(db_, sql, statement); in GetMaxVersion()
536 int errCode = SQLiteUtils::GetStatement(db_, DELETE_VER_SQL, statement); in ClearEntriesByVersion()
668 int errCode = SQLiteUtils::GetStatement(db_, SELECT_ONE_VER_RAW_SQL, statement); in GetEntriesByVersion()
702 int errCode = SQLiteUtils::GetStatement(db_, SELECT_ONE_VER_RAW_SQL, statement); in GetEntriesByVersion()
747 int errCode = SQLiteUtils::GetStatement(db_, SELECT_MAX_TIMESTAMP, statement); in GetCurrentMaxTimestamp()
1074 int errCode = SQLiteUtils::GetStatement(db_, INSERT_SQL, statement); in AddRecord()
1151 int errCode = SQLiteUtils::GetStatement(db_, SELECT_LATEST_CLEAR_ID, statement); in GetClearId()
[all …]
|
| H A D | sqlite_local_storage_executor.cpp | 50 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SQL, statement); in Get()
85 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_BATCH_SQL, statement); in GetEntries()
194 int errCode = SQLiteUtils::GetStatement(dbHandle_, INSERT_SQL, statement); in Put()
226 int errCode = SQLiteUtils::GetStatement(dbHandle_, DELETE_SQL, statement); in Delete()
|
| H A D | sqlite_single_ver_storage_executor_cache.cpp | 104 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in RemoveDeviceDataInCacheMode()
139 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetMinVersionCacheData()
171 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in MigrateRmDevData()
239 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetMaxVersionInCacheDb()
320 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in CheckDataWithQuery()
438 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in DelCacheDbDataByVersion()
608 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in GetExpandedCheckSql()
688 int errCode = SQLiteUtils::GetStatement(dbHandle_, INSERT_CACHE_LOCAL_SQL, statement); in PutLocalDataToCacheDB()
789 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetMinTimestampInCacheDB()
944 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in DeleteMetaData()
[all …]
|
| H A D | sqlite_single_ver_storage_executor.cpp | 43 errCode = SQLiteUtils::GetStatement(db, sql, stmt); in ResetOrRegetStmt()
126 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetKvData()
259 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in SaveKvData()
325 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetEntries()
421 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in InitCurrentMaxStamp()
441 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in PrepareForSyncDataByTime()
1391 int errCode = SQLiteUtils::GetStatement(dbHandle_, sqlStr, statement); in GetAllMetaKeys()
1410 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetAllSyncedEntries()
1418 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetAllSyncedEntries()
1636 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in DeleteLocalDataInner()
[all …]
|
| H A D | sqlite_single_ver_storage_executor_subscribe.cpp | 116 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in CheckDataWithQuery()
163 …errCode = SQLiteUtils::GetStatement(dbHandle_, "SELECT " + DBConstant::UPDATE_META_FUNC + "('K', 0… in AddSubscribeTrigger()
226 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in RemoveSubscribeTriggerWaterMark()
253 int errCode = SQLiteUtils::GetStatement(dbHandle_, GET_SYNC_DATA_TIRGGER_SQL, stmt); in GetTriggers()
|
| H A D | sqlite_single_ver_storage_executor_extend.cpp | 44 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in CloudExcuteRemoveOrUpdate()
89 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in CloudCheckDataExist()
277 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in GetEntries()
319 errCode = SQLiteUtils::GetStatement(dbHandle_, removeSql, stmt); in RemoveCloudUploadFlag()
|
| H A D | sqlite_utils.cpp | 442 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in ExecuteRawSQL()
654 int errCode = SQLiteUtils::GetStatement(db, sql, statement); in CheckIntegrity()
698 int errCode = SQLiteUtils::GetStatement(db, sql, statement); in AnalysisSchemaSqlAndTrigger()
739 int errCode = SQLiteUtils::GetStatement(db, sql, statement); in GetSchemaIndexList()
773 int errCode = SQLiteUtils::GetStatement(db, sql, statement); in AnalysisSchemaIndexDefine()
1218 int errCode = GetStatement(db, sql, statement); in SaveSchema()
1265 errCode = GetStatement(db, sql, statement); in GetSchema()
1573 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in CloneIndexes()
1616 int errCode = GetStatement(db, sql, statement); in GetRelationalSchema()
1657 int errCode = GetStatement(db, sql, statement); in GetLogTableVersion()
[all …]
|
| H A D | sqlite_cloud_kv_executor_utils.cpp | 279 errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetLogInfoStmt()
428 int errCode = SQLiteUtils::GetStatement(db, GetOperateLogSql(opType), logStmt); in OperateCloudData()
434 errCode = SQLiteUtils::GetStatement(db, GetOperateDataSql(opType), dataStmt); in OperateCloudData()
805 int errCode = SQLiteUtils::GetStatement(db, GetOperateLogSql(op), logStmt); in OnlyUpdateLogTable()
904 int errCode = SQLiteUtils::GetStatement(db, GetOperateDataSql(opType), dataStmt); in OnlyUpdateSyncData()
1007 errCode = SQLiteUtils::GetStatement(db, sql, stmt); in CountCloudDataInner()
1093 errCode = SQLiteUtils::GetStatement(db, GetOperateDataSql(opType), dataStmt); in FillCloudVersionRecord()
1135 errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetLocalCloudVersionInner()
1240 int errCode = SQLiteUtils::GetStatement(db, sql, dataStmt); in GetCloudVersionFromCloud()
1292 int errCode = SQLiteUtils::GetStatement(db, SELECT_COMPENSATE_SYNC_KEY_SQL, stmt); in GetWaitCompensatedSyncDataPk()
[all …]
|
| H A D | sqlite_query_helper.cpp | 401 int errCode = SQLiteUtils::GetStatement(dbHandle, sql, statement); in GetQuerySqlStatement()
443 errCode = SQLiteUtils::GetStatement(dbHandle, sql, statement); in GetQuerySqlStatement()
483 errCode = SQLiteUtils::GetStatement(dbHandle, countSql, countStmt); in GetCountSqlStatement()
596 errCode = SQLiteUtils::GetStatement(dbHandle, sql, statement); in GetQuerySyncStatement()
978 errCode = SQLiteUtils::GetStatement(dbHandle, sql, statement); in GetRelationalMissQueryStatement()
1081 errCode = SQLiteUtils::GetStatement(dbHandle, sql, statement); in GetRelationalQueryStatement()
1248 errCode = SQLiteUtils::GetStatement(dbHandle, sql, statement); in GetCloudQueryStatement()
1276 errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetKvCloudQueryStmt()
1347 int errCode = SQLiteUtils::GetStatement(dbHandle, sql, stmt); in GetAndBindGidKvCloudQueryStatement()
1374 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetCountKvCloudDataStatement()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 80 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in GetFillDownloadAssetStatement()
154 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in IncreaseCursorOnAssetData()
556 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in ClearAllTempSyncTrigger()
592 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in CleanTrackerData()
807 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetReferenceGidInner()
986 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in CheckIfExistUserTable()
1311 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in InitGetAssetStmt()
1679 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in UpdateAssetsIdForOneRecord()
1816 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in UpdateRecordFlag()
1899 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in GetWaitCompensatedSyncDataPk()
[all …]
|
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 190 int errCode = SQLiteUtils::GetStatement(dbHandle_, querySql, selectStmt); in GetQueryLogStatement()
389 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in GetCursor()
419 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in SetCursor()
654 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, insertStmt); in InsertCloudData()
706 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, insertLogStmt); in InsertLogRecord()
945 errCode = SQLiteUtils::GetStatement(dbHandle_, updateSql, updateStmt); in GetUpdateDataTableStatement()
1069 errCode = SQLiteUtils::GetStatement(dbHandle_, deleteSql, deleteStmt); in GetDeleteStatementForCloudSync()
1154 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in UpdateRecordStatus()
1344 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in MarkFlagAsConsistent()
1379 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in FillCloudVersionForUpload()
[all …]
|
| H A D | sqlite_single_ver_relational_continue_token.cpp | 34 int SQLiteSingleVerRelationalContinueToken::GetStatement(sqlite3 *db, sqlite3_stmt *&queryStmt, sql… in GetStatement() function in DistributedDB::SQLiteSingleVerRelationalContinueToken
118 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetDeletedDataStmt()
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 153 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetExistedDataTimeOffset()
353 int errCode = SQLiteUtils::GetStatement(handle, checkSql, stmt); in GetDeviceTableName()
671 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_META_VALUE_SQL, statement); in GetKvData()
700 int errCode = SQLiteUtils::GetStatement(dbHandle_, INSERT_META_SQL, statement); in PutKvData()
777 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_ALL_META_KEYS, statement); in GetAllMetaKeys()
1269 int errCode = SQLiteUtils::GetStatement(dbHandle_, deleteLogSql, deleteLogStmt); in DeleteDistributedDeviceTableLog()
1352 int errCode = SQLiteUtils::GetStatement(dbHandle_, checkSql, stmt); in CheckAndCleanDistributedTable()
1483 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in GetMaxTimestamp()
1568 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in ExecuteQueryBySqlStmt()
1822 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, selectStmt); in GetCleanCloudDataKeys()
[all …]
|
| H A D | sqlite_single_ver_relational_continue_token.h | 35 …int GetStatement(sqlite3 *db, sqlite3_stmt *&queryStmt, sqlite3_stmt *&fullStmt, bool &isGettingDe…
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_sqlite_relational_utils_test.cpp | 94 ASSERT_EQ(SQLiteUtils::GetStatement(g_db, sql, statement), E_OK); in PrepareStatement()
216 ASSERT_EQ(SQLiteUtils::GetStatement(g_db, sql, statement), E_OK);
|
| H A D | distributeddb_storage_single_ver_upgrade_test.cpp | 154 ASSERT_EQ(SQLiteUtils::GetStatement(db, insertLocalDataSql, statement), E_OK); in CreateDatabase()
166 ASSERT_EQ(SQLiteUtils::GetStatement(db, CHECK_V1_SYNC_UPGRADE, statement), E_OK); in CheckSyncDataV1ToV2()
176 ASSERT_EQ(SQLiteUtils::GetStatement(db, CHECK_V2_SYNC_UPGRADE, statement), E_OK); in CheckSyncDataV2ToV3()
187 ASSERT_EQ(SQLiteUtils::GetStatement(db, CHECK_V1_LOCAL_UPGRADE, statement), E_OK); in CheckLocalDataV1ToV2()
|
| H A D | distributeddb_relational_cloud_syncable_storage_test.cpp | 128 ASSERT_EQ(SQLiteUtils::GetStatement(db, sql, stmt), E_OK); in CreateAndInitUserTable()
170 EXPECT_EQ(SQLiteUtils::GetStatement(db, sql, stmt), E_OK); in InitLogData()
200 EXPECT_EQ(SQLiteUtils::GetStatement(db, sql, stmt), E_OK); in UpdateLogGidAndHashKey()
343 ASSERT_EQ(SQLiteUtils::GetStatement(db, sql, stmt), E_OK); in UpdateLocalAsset()
1084 …ASSERT_EQ(SQLiteUtils::GetStatement(db, "SELECT timestamp, hash_key FROM " + DBCommon::GetLogTable…
1117 …ASSERT_EQ(SQLiteUtils::GetStatement(db, "SELECT assert, asserts FROM " + g_tableName + " WHERE row…
1143 …ASSERT_EQ(SQLiteUtils::GetStatement(db, "SELECT timestamp FROM " + DBCommon::GetLogTableName(g_tab…
1194 …ASSERT_EQ(SQLiteUtils::GetStatement(db, "SELECT timestamp FROM " + DBCommon::GetLogTableName(g_tab…
1263 int errCode = SQLiteUtils::GetStatement(db, querysql, statement);
1319 int errCode = SQLiteUtils::GetStatement(db, querysql, statement);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/ |
| H A D | rd_sqlite_utils.cpp | 86 int RDSQLiteUtils::GetStatement(sqlite3 *db, const std::string &sql, sqlite3_stmt *&statement) in GetStatement() function in DocumentDB::RDSQLiteUtils
251 int errCode = RDSQLiteUtils::GetStatement(db, sql, stmt); in ExecSql()
|
| H A D | rd_sqlite_utils.h | 35 static int GetStatement(sqlite3 *db, const std::string &sql, sqlite3_stmt *&statement);
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A D | step_result_set.h | 53 std::shared_ptr<Statement> GetStatement();
|