Home
last modified time | relevance | path

Searched refs:GetStatement (Results 1 - 25 of 64) sorted by relevance

123

/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Dstep_result_set.cpp49 auto statement = GetStatement(); in StepResultSet()
130 auto statement = GetStatement(); in GetColumnNames()
158 auto statement = GetStatement(); in GetColumnType()
221 auto statement = GetStatement(); in GoToNextRow()
306 auto statement = GetStatement(); in Reset()
331 auto statement = GetStatement(); in GetSize()
358 auto statement = GetStatement(); in GetValueObject()
369 std::shared_ptr<Statement> StepResultSet::GetStatement() in GetStatement() function in OHOS::NativeRdb::StepResultSet
H A Dtrans_db.cpp65 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 Drdb_store_impl.cpp812 auto [err, statement] = GetStatement(GlobalExpr::PRAGMA_VERSION); in ModifyLockStatus()
1012 auto [errCode, statement] = GetStatement(sql, connection); in BatchInsert()
1212 auto [errCode, statement] = GetStatement(sql, connect); in Execute()
1313 auto [errCode, statement] = GetStatement(sql, false); in ExecuteForLastInsertedRowId()
1348 auto [errCode, statement] = GetStatement(sql, false); in ExecuteForChangedRowCount()
1553 return GetStatement(sql, true); in BeginExecuteSql()
1772 auto [errCode, statement] = GetStatement(GlobalExpr::PRAGMA_VERSION, isReadOnly_); in GetVersion()
1794 auto [errCode, statement] = GetStatement(sql); in SetVersion()
1813 auto [errCode, statement] = GetStatement(transaction.GetTransactionStr()); in BeginTransaction()
1882 auto [errCode, statement] = GetStatement(transactio in RollBack()
2243 std::pair<int32_t, std::shared_ptr<Statement>> RdbStoreImpl::GetStatement( GetStatement() function in RdbStoreImpl
2252 std::pair<int32_t, std::shared_ptr<Statement>> RdbStoreImpl::GetStatement(const std::string& sql, bool read) const GetStatement() function in RdbStoreImpl
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_local_storage_executor.cpp50 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 Dsqlite_single_ver_storage_executor_cache.cpp104 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in RemoveDeviceDataInCacheMode()
139 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetMinVersionCacheData()
141 LOGE("GetStatement fail when get min version cache data! errCode = [%d]", errCode); in GetMinVersionCacheData()
171 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in MigrateRmDevData()
173 LOGE("GetStatement fail when remove device data migrating-data to main! errCode = [%d]", errCode); in MigrateRmDevData()
239 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetMaxVersionInCacheDb()
241 LOGE("GetStatement fail when get max version in cache db"); in GetMaxVersionInCacheDb()
277 LOGE("GetStatement fail when put migrating-data to main! "); in MigrateDataItem()
320 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in CheckDataWithQuery()
438 int errCode = SQLiteUtils::GetStatement(dbHandle in DelCacheDbDataByVersion()
[all...]
H A Dsqlite_single_ver_storage_executor_subscribe.cpp116 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in CheckDataWithQuery()
163 errCode = SQLiteUtils::GetStatement(dbHandle_, "SELECT " + DBConstant::UPDATE_META_FUNC + "('K', 0);", stmt); 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 Dsqlite_multi_ver_transaction.cpp242 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()
567 int errCode = SQLiteUtils::GetStatement(db_, SELECT_PRE_PUT_VER_DATA_SQL, statement); in GetPrePutValues()
614 int errCode = SQLiteUtils::GetStatement(db_, DELETE_PRE_PUT_VER_DATA_SQL, statement); in RemovePrePutEntries()
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 in GetCurrentMaxTimestamp()
[all...]
H A Dsqlite_single_ver_storage_executor_extend.cpp44 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()
314 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in PrepareForUnSyncTotalByTime()
403 errCode = SQLiteUtils::GetStatement(dbHandle_, removeSql, stmt); in RemoveCloudUploadFlag()
H A Dsqlite_single_ver_storage_executor.cpp43 errCode = SQLiteUtils::GetStatement(db, sql, stmt); in ResetOrRegetStmt()
126 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetKvData()
200 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SYNC_HASH_SQL, statement); in GetKvDataByHashKey()
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()
581 int errCode = SQLiteUtils::GetStatement(db, SELECT_SYNC_MODIFY_SQL, stmt); in GetFullDataStatement()
797 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SYNC_ROWID_PREFIX_SQL, getResultRowIdStatement_); in OpenResultSetForCacheRowIdMode()
1089 int errCode = SQLiteUtils::GetStatement(dbHandle in GetDeviceIdentifier()
[all...]
H A Dsqlite_query_helper.cpp402 int errCode = SQLiteUtils::GetStatement(dbHandle, sql, statement); in GetQuerySqlStatement()
444 errCode = SQLiteUtils::GetStatement(dbHandle, sql, statement); in GetQuerySqlStatement()
484 errCode = SQLiteUtils::GetStatement(dbHandle, countSql, countStmt); in GetCountSqlStatement()
599 errCode = SQLiteUtils::GetStatement(dbHandle, sql, statement); in GetQuerySyncStatement()
980 errCode = SQLiteUtils::GetStatement(dbHandle, sql, statement); in GetRelationalMissQueryStatement()
1083 errCode = SQLiteUtils::GetStatement(dbHandle, sql, statement); in GetRelationalQueryStatement()
1245 errCode = SQLiteUtils::GetStatement(dbHandle, sql, statement); in GetCloudQueryStatement()
1273 errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetKvCloudQueryStmt()
1344 int errCode = SQLiteUtils::GetStatement(dbHandle, sql, stmt); in GetAndBindGidKvCloudQueryStatement()
1371 int errCode = SQLiteUtils::GetStatement(d in GetCountKvCloudDataStatement()
[all...]
H A Dsqlite_cloud_kv_executor_utils.cpp296 errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetLogInfoStmt()
445 int errCode = SQLiteUtils::GetStatement(db, GetOperateLogSql(opType), logStmt); in OperateCloudData()
451 errCode = SQLiteUtils::GetStatement(db, GetOperateDataSql(opType), dataStmt); in OperateCloudData()
822 int errCode = SQLiteUtils::GetStatement(db, GetOperateLogSql(op), logStmt); in OnlyUpdateLogTable()
865 int errCode = SQLiteUtils::GetStatement(db, GetOperateLogSql(TransToOpType(type)), logStmt); in FillCloudGid()
921 int errCode = SQLiteUtils::GetStatement(db, GetOperateDataSql(opType), dataStmt); in OnlyUpdateSyncData()
1024 errCode = SQLiteUtils::GetStatement(db, sql, stmt); in CountCloudDataInner()
1110 errCode = SQLiteUtils::GetStatement(db, GetOperateDataSql(opType), dataStmt); in FillCloudVersionRecord()
1152 errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetLocalCloudVersionInner()
1256 int errCode = SQLiteUtils::GetStatement(d in GetCloudVersionFromCloud()
[all...]
H A Dsqlite_utils.cpp231 int SQLiteUtils::GetStatement(sqlite3 *db, const std::string &sql, sqlite3_stmt *&statement) in GetStatement() function in DistributedDB::SQLiteUtils
435 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in ExecuteRawSQL()
595 int errCode = SQLiteUtils::GetStatement(db, attachSql, statement); in AttachNewDatabaseInner()
647 int errCode = SQLiteUtils::GetStatement(db, sql, statement); in CheckIntegrity()
691 int errCode = SQLiteUtils::GetStatement(db, sql, statement); in AnalysisSchemaSqlAndTrigger()
732 int errCode = SQLiteUtils::GetStatement(db, sql, statement); in GetSchemaIndexList()
766 int errCode = SQLiteUtils::GetStatement(db, sql, statement); in AnalysisSchemaIndexDefine()
874 int errCode = SQLiteUtils::GetStatement(db, sql, statement); in AnalysisSchemaFieldDefine()
1068 int errCode = SQLiteUtils::GetStatement(db, sql, statement); in GetJournalMode()
1211 int errCode = GetStatement(d in SaveSchema()
[all...]
H A Dsqlite_meta_executor.cpp39 int errCode = SQLiteUtils::GetStatement(dbHandle, sqlStr, statement); in GetMetaKeysByKeyPrefix()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_data_inserter.cpp131 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()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_continue_token.cpp34 int SQLiteSingleVerRelationalContinueToken::GetStatement(sqlite3 *db, sqlite3_stmt *&queryStmt, sqlite3_stmt *&fullStmt, in GetStatement() function in DistributedDB::SQLiteSingleVerRelationalContinueToken
118 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetDeletedDataStmt()
H A Dsqlite_single_ver_relational_continue_token.h35 int GetStatement(sqlite3 *db, sqlite3_stmt *&queryStmt, sqlite3_stmt *&fullStmt, bool &isGettingDeletedData);
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp190 int errCode = SQLiteUtils::GetStatement(dbHandle_, querySql, selectStmt); in GetQueryLogStatement()
390 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in GetCursor()
420 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in SetCursor()
495 errCode = SQLiteUtils::GetStatement(dbHandle_, queryAssetSql, selectStmt); in GetAssetOnTable()
541 errCode = SQLiteUtils::GetStatement(dbHandle_, queryAssetsSql, selectStmt); in GetCloudAssetsOnTable()
655 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, insertStmt); in InsertCloudData()
707 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, insertLogStmt); in InsertLogRecord()
946 errCode = SQLiteUtils::GetStatement(dbHandle_, updateSql, updateStmt); in GetUpdateDataTableStatement()
1070 errCode = SQLiteUtils::GetStatement(dbHandle_, deleteSql, deleteStmt); in GetDeleteStatementForCloudSync()
1155 int errCode = SQLiteUtils::GetStatement(dbHandle in UpdateRecordStatus()
[all...]
H A Dsqlite_single_ver_relational_storage_extend_executor.cpp80 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in GetFillDownloadAssetStatement()
154 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in IncreaseCursorOnAssetData()
408 int errCode = SQLiteUtils::GetStatement(dbHandle_, condition.sql, statement); in ExecuteSql()
556 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in ClearAllTempSyncTrigger()
586 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in CleanTrackerData()
757 errCode = SQLiteUtils::GetStatement(dbHandle_, delDataSql, statement); in CleanShareTable()
772 errCode = SQLiteUtils::GetStatement(dbHandle_, delLogSql, statement); in CleanShareTable()
819 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetReferenceGidInner()
998 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in CheckIfExistUserTable()
1167 errCode = SQLiteUtils::GetStatement(dbHandle in UpdateAssetIdOnUserTable()
[all...]
H A Dsqlite_single_ver_relational_storage_executor.cpp150 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetExistedDataTimeOffset()
324 int errCode = SQLiteUtils::GetStatement(handle, checkSql, stmt); in GetDeviceTableName()
653 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_META_VALUE_SQL, statement); in GetKvData()
682 int errCode = SQLiteUtils::GetStatement(dbHandle_, INSERT_META_SQL, statement); in PutKvData()
712 int errCode = SQLiteUtils::GetStatement(dbHandle_, REMOVE_META_VALUE_SQL, statement); in DeleteMetaData()
739 int errCode = SQLiteUtils::GetStatement(dbHandle_, REMOVE_META_VALUE_BY_KEY_PREFIX_SQL, statement); in DeleteMetaDataByPrefixKey()
759 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_ALL_META_KEYS, statement); in GetAllMetaKeys()
1251 int errCode = SQLiteUtils::GetStatement(dbHandle_, deleteLogSql, deleteLogStmt); in DeleteDistributedDeviceTableLog()
1346 int errCode = SQLiteUtils::GetStatement(dbHandle_, checkSql, stmt); in CheckAndCleanDistributedTable()
1468 int errCode = SQLiteUtils::GetStatement(dbHandle in GetMaxTimestamp()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/
H A Drd_sqlite_utils.h35 static int GetStatement(sqlite3 *db, const std::string &sql, sqlite3_stmt *&statement);
H A Drd_sqlite_utils.cpp86 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()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_sqlite_relational_utils_test.cpp94 ASSERT_EQ(SQLiteUtils::GetStatement(g_db, sql, statement), E_OK); in PrepareStatement()
216 ASSERT_EQ(SQLiteUtils::GetStatement(g_db, sql, statement), E_OK); in HWTEST_F()
H A Ddistributeddb_storage_single_ver_upgrade_test.cpp154 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()
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Dstep_result_set.h53 std::shared_ptr<Statement> GetStatement();
H A Dtrans_db.h40 std::pair<int32_t, std::shared_ptr<Statement>> GetStatement(const std::string &sql) const;

Completed in 31 milliseconds

123