Home
last modified time | relevance | path

Searched refs:dbHandle_ (Results 1 - 19 of 19) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_storage_executor.cpp25 dbHandle_(dbHandle), in SQLiteStorageExecutor()
31 if (dbHandle_ != nullptr) { in ~SQLiteStorageExecutor()
32 (void)sqlite3_close_v2(dbHandle_); in ~SQLiteStorageExecutor()
33 dbHandle_ = nullptr; in ~SQLiteStorageExecutor()
39 if (dbHandle_ != nullptr) { in Reset()
41 sqlite3_db_release_memory(dbHandle_); in Reset()
49 if (dbHandle_ == nullptr) { in GetDbHandle()
53 dbHandle = dbHandle_; in GetDbHandle()
H A Dsqlite_local_storage_executor.cpp50 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SQL, statement); in Get()
77 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, CLEAR_SQL); in Clear()
85 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_BATCH_SQL, statement); in GetEntries()
175 int errCode = SQLiteUtils::BeginTransaction(dbHandle_); in StartTransaction()
181 int errCode = SQLiteUtils::CommitTransaction(dbHandle_); in Commit()
187 int errCode = SQLiteUtils::RollbackTransaction(dbHandle_); in RollBack()
194 int errCode = SQLiteUtils::GetStatement(dbHandle_, INSERT_SQL, statement); in Put()
226 int errCode = SQLiteUtils::GetStatement(dbHandle_, DELETE_SQL, statement); in Delete()
242 if (sqlite3_changes(dbHandle_) > 0) { // LCOV_EXCL_BR_LINE in Delete()
H A Dsqlite_single_ver_storage_executor.cpp126 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()
352 errCode = helper.GetQuerySqlStatement(dbHandle_, false, statement); in GetEntries()
363 if (dbHandle_ == nullptr) { in GetCount()
386 errCode = helper.GetQuerySqlStatement(dbHandle_, countSql, countStatement); in GetCount()
415 if (dbHandle_ == nullptr) { in InitCurrentMaxStamp()
421 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in InitCurrentMaxStamp()
436 if (dbHandle_ in PrepareForSyncDataByTime()
[all...]
H A Dsqlite_single_ver_storage_executor_subscribe.cpp36 errCode = helper.GetQuerySyncStatement(dbHandle_, 0, INT64_MAX, statement); // (0, INT64_MAX):max range in CheckQueryObjectLegal()
116 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); in CheckDataWithQuery()
163 errCode = SQLiteUtils::GetStatement(dbHandle_, "SELECT " + DBConstant::UPDATE_META_FUNC + "('K', 0);", stmt); in AddSubscribeTrigger()
180 errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); in AddSubscribeTrigger()
195 errCode = SQLiteUtils::DropTriggerByName(dbHandle_, trigger); in RemoveSubscribeTrigger()
213 errCode = SQLiteUtils::DropTriggerByName(dbHandle_, trigger); in RemoveTrigger()
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_single_ver_storage_executor_cache.cpp104 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()
209 int errCode = SQLiteUtils::AttachNewDatabase(dbHandle_, type, passwd, attachDbAbsPath, attachAsName); in AttachMainDbAndCacheDb()
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()
471 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); in VacuumLocalData()
493 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, migrateLocaldataSql); in MigrateLocalData()
608 errCode = SQLiteUtils::GetStatement(dbHandle_, sq in GetExpandedCheckSql()
[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()
309 if (dbHandle_ == nullptr) { in PrepareForUnSyncTotalByTime()
314 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in PrepareForUnSyncTotalByTime()
382 errCode = helper.GetQuerySyncStatement(dbHandle_, timeRange.first, timeRange.second, queryStmt, true); in GetSyncTotalWithQuery()
394 int errCode = SQLiteUtils::CheckTableExists(dbHandle_, tableName, isCreate); in RemoveCloudUploadFlag()
403 errCode = SQLiteUtils::GetStatement(dbHandle_, removeSql, stmt); in RemoveCloudUploadFlag()
H A Dsqlite_storage_executor.h36 sqlite3 *dbHandle_; member in DistributedDB::SQLiteStorageExecutor
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/
H A Dsqlite_store_executor_impl.cpp66 SqliteStoreExecutorImpl::SqliteStoreExecutorImpl(sqlite3 *handle) : dbHandle_(handle) {} in SqliteStoreExecutorImpl()
70 sqlite3_close_v2(dbHandle_); in ~SqliteStoreExecutorImpl()
71 dbHandle_ = nullptr; in ~SqliteStoreExecutorImpl()
94 return RDSQLiteUtils::BeginTransaction(dbHandle_, TransactType::IMMEDIATE); in StartTransaction()
99 return RDSQLiteUtils::CommitTransaction(dbHandle_); in Commit()
104 return RDSQLiteUtils::RollbackTransaction(dbHandle_); in Rollback()
109 if (dbHandle_ == nullptr) { in PutData()
117 dbHandle_, sql, in PutData()
138 if (dbHandle_ == nullptr) { in InsertData()
146 dbHandle_, sq in InsertData()
[all...]
H A Dsqlite_store_executor_impl.h56 sqlite3 *dbHandle_ = nullptr; member in DocumentDB::SqliteStoreExecutorImpl
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Drd_connection.cpp108 if (dbHandle_ != nullptr) { in ~RdConnection()
109 int errCode = RdUtils::RdDbClose(dbHandle_, 0); in ~RdConnection()
113 dbHandle_ = nullptr; in ~RdConnection()
155 errCode = RdUtils::RdDbOpen(dbPath.c_str(), configStr.c_str(), GRD_DB_OPEN_CREATE, &dbHandle_); in InnerOpen()
164 errCode = RdUtils::RdDbOpen(dbPath.c_str(), configStr.c_str(), GRD_DB_OPEN_CREATE, &dbHandle_); in InnerOpen()
186 return RdUtils::RdDbSetVersion(dbHandle_, GRD_CONFIG_USER_VERSION, value); in CreateStatement()
189 return RdUtils::RdDbGetVersion(dbHandle_, GRD_CONFIG_USER_VERSION, version); in CreateStatement()
191 int32_t ret = stmt->Prepare(dbHandle_, sql); in CreateStatement()
292 return RdUtils::RdDbBackup(dbHandle_, databasePath.c_str(), destEncryptKey); in Backup()
296 int32_t ret = RdUtils::RdDbBackup(dbHandle_, databasePat in Backup()
[all...]
H A Dsqlite_connection.cpp130 : dbHandle_(nullptr), isWriter_(isWriteConnection), isReadOnly_(false), maxVariableNumber_(0), filePath(""), in SqliteConnection()
239 maxVariableNumber_ = sqlite3_limit(dbHandle_, SQLITE_LIMIT_VARIABLE_NUMBER, -1); in InnerOpen()
271 int errCode = sqlite3_open_v2(dbPath.c_str(), &dbHandle_, openFileFlags, nullptr); in OpenDatabase()
335 int err = sqlite3_create_function_v2(dbHandle_, functionName.c_str(), argc, SQLITE_UTF8, function, in SetCustomScalarFunction()
353 auto errCode = RegDefaultFunctions(dbHandle_); in Configure()
399 return LoadExtension(config, dbHandle_); in Configure()
410 if (dbHandle_ != nullptr) { in ~SqliteConnection()
412 UnRegisterClientObserver(dbHandle_); in ~SqliteConnection()
415 UnregisterStoreObserver(dbHandle_); in ~SqliteConnection()
418 int errCode = sqlite3_close_v2(dbHandle_); in ~SqliteConnection()
[all...]
H A Drd_statement.cpp242 if (dbHandle_ == nullptr) { in Prepare()
245 return Prepare(dbHandle_, sql); in Prepare()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor.cpp211 if (dbHandle_ == nullptr) { in CreateDistributedTable()
216 int errCode = SQLiteUtils::AnalysisSchema(dbHandle_, tableName, table); in CreateDistributedTable()
224 errCode = SQLiteUtils::CheckTableEmpty(dbHandle_, tableName, isEmpty); in CreateDistributedTable()
244 errCode = tableManager->CreateRelationalLogTable(dbHandle_, table); in CreateDistributedTable()
252 errCode = GeneLogInfoForExistedData(dbHandle_, tableName, calPrimaryKeyHash, table); in CreateDistributedTable()
259 errCode = tableManager->AddRelationalLogTableTrigger(dbHandle_, table, identity); in CreateDistributedTable()
270 if (dbHandle_ == nullptr) { in UpgradeDistributedTable()
274 int errCode = SQLiteUtils::AnalysisSchema(dbHandle_, tableName, newTableInfo); in UpgradeDistributedTable()
480 int errCode = GetDeviceTableName(dbHandle_, oldTableInfo.GetTableName(), {}, deviceTables); in AlterAuxTableForUpgrade()
488 errCode = UpgradeFields(dbHandle_, deviceTable in AlterAuxTableForUpgrade()
[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()
327 return SQLiteRelationalUtils::AnalysisTrackerTable(dbHandle_, trackerTable, tableInfo); in AnalysisTrackerTable()
341 return tableManager->AddRelationalLogTableTrigger(dbHandle_, table, ""); in CreateTrackerTable()
345 errCode = tableManager->CreateRelationalLogTable(dbHandle_, table); in CreateTrackerTable()
362 errCode = GeneLogInfoForExistedData(dbHandle_, trackerTable.GetTableName(), calPrimaryKeyHash, table); in CreateTrackerTable()
371 errCode = tableManager->AddRelationalLogTableTrigger(dbHandle_, table, ""); in CreateTrackerTable()
408 int errCode = SQLiteUtils::GetStatement(dbHandle_, condition.sql, statement); in ExecuteSql()
451 int errCode = SQLiteUtils::CheckTableExists(dbHandle_, logTableName, isExists); in GetClearWaterMarkTables()
462 errCode = SQLiteUtils::CheckTableEmpty(dbHandle_, logTableNam in GetClearWaterMarkTables()
[all...]
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp176 int64_t rowid = SQLiteUtils::GetLastRowId(dbHandle_); in GetPrimaryKeyHashValue()
190 int errCode = SQLiteUtils::GetStatement(dbHandle_, querySql, selectStmt); in GetQueryLogStatement()
376 int errCode = sqlite3_create_function_v2(dbHandle_, sql.c_str(), 0, SQLITE_UTF8 | SQLITE_DIRECTONLY, in CreateFuncUpdateCursor()
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()
604 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); in SetCursorIncFlag()
655 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, insertStmt); in InsertCloudData()
695 errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sq in InsertLogRecord()
[all...]
/foundation/distributeddatamgr/relational_store/test/native/rdb/fuzztest/rdbrdutils_fuzzer/rddbopen_fuzzer/
H A Drddbopen_fuzzer.cpp92 GRD_DB *dbHandle_ = nullptr; in RdDbOpenFuzzer() local
93 RdUtils::RdDbOpen(reinterpret_cast<const char *>(data), reinterpret_cast<const char *>(data), unit32t, &dbHandle_); in RdDbOpenFuzzer() local
95 RdUtils::RdSqlPrepare(dbHandle_, reinterpret_cast<const char *>(data), size, &stmtHandle, nullptr); in RdDbOpenFuzzer()
108 RdUtils::RdDbClose(dbHandle_, unit32t); in RdDbOpenFuzzer()
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Drd_connection.h80 GRD_DB *dbHandle_ = nullptr; member in OHOS::NativeRdb::RdConnection
H A Drd_statement.h68 GRD_DB *dbHandle_ = nullptr; member in OHOS::NativeRdb::final
H A Dsqlite_connection.h144 sqlite3 *dbHandle_; member in OHOS::NativeRdb::SqliteConnection

Completed in 20 milliseconds