| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_sqlite_utils_test.cpp | 88 NativeSqlite::ExecSql(g_db, "INSERT INTO t1 VALUES(?, ?)", [&blob](sqlite3_stmt *stmt) { in __anona04736ca0202()
94 NativeSqlite::ExecSql(g_db, "SELECT b FROM t1", nullptr, [](sqlite3_stmt *stmt) { in __anona04736ca0302()
117 NativeSqlite::ExecSql(g_db, "INSERT INTO t1 VALUES(?, ?)", [&blob](sqlite3_stmt *stmt) { in __anona04736ca0402()
123 NativeSqlite::ExecSql(g_db, "SELECT b FROM t1", nullptr, [&blob](sqlite3_stmt *stmt) { in __anona04736ca0502()
145 NativeSqlite::ExecSql(g_db, "INSERT INTO t1 VALUES(?, ?)", [&blob](sqlite3_stmt *stmt) { in __anona04736ca0602()
151 NativeSqlite::ExecSql(g_db, "SELECT b FROM t1", nullptr, [&blob](sqlite3_stmt *stmt) { in __anona04736ca0702()
174 NativeSqlite::ExecSql(g_db, "INSERT INTO t1 VALUES(?, ?)", [&text](sqlite3_stmt *stmt) { in __anona04736ca0802()
180 NativeSqlite::ExecSql(g_db, "SELECT b FROM t1", nullptr, [](sqlite3_stmt *stmt) { in __anona04736ca0902()
203 NativeSqlite::ExecSql(g_db, "INSERT INTO t1 VALUES(?, ?)", [&text](sqlite3_stmt *stmt) { in __anona04736ca0a02()
209 NativeSqlite::ExecSql(g_db, "SELECT b FROM t1", nullptr, [&text](sqlite3_stmt *stmt) { in __anona04736ca0b02()
[all …]
|
| H A D | distributeddb_relational_cloud_syncable_storage_test.cpp | 127 sqlite3_stmt *stmt = nullptr; in CreateAndInitUserTable() local
168 sqlite3_stmt *stmt = nullptr; in InitLogData() local
199 sqlite3_stmt *stmt = nullptr; in UpdateLogGidAndHashKey() local
342 sqlite3_stmt *stmt = nullptr; in UpdateLocalAsset() local
1083 sqlite3_stmt *stmt = nullptr; variable
1142 sqlite3_stmt *stmt = nullptr; variable
1193 sqlite3_stmt *stmt = nullptr; variable
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rd_utils.cpp | 122 int RdUtils::RdSqlReset(GRD_SqlStmt *stmt) in RdSqlReset()
133 int RdUtils::RdSqlFinalize(GRD_SqlStmt *stmt) in RdSqlFinalize()
243 int RdUtils::RdSqlBindNull(GRD_SqlStmt *stmt, uint32_t idx) in RdSqlBindNull()
288 int RdUtils::RdSqlStep(GRD_SqlStmt *stmt) in RdSqlStep()
299 int RdUtils::RdSqlColCnt(GRD_SqlStmt *stmt) in RdSqlColCnt()
321 int RdUtils::RdSqlColBytes(GRD_SqlStmt *stmt, uint32_t idx) in RdSqlColBytes()
332 char *RdUtils::RdSqlColName(GRD_SqlStmt *stmt, uint32_t idx) in RdSqlColName()
354 uint8_t *RdUtils::RdSqlColBlob(GRD_SqlStmt *stmt, uint32_t idx) in RdSqlColBlob()
365 char *RdUtils::RdSqlColText(GRD_SqlStmt *stmt, uint32_t idx) in RdSqlColText()
376 int RdUtils::RdSqlColInt(GRD_SqlStmt *stmt, uint32_t idx) in RdSqlColInt()
[all …]
|
| H A D | share_block.cpp | 109 int FillSharedBlockOpt(SharedBlockInfo *info, sqlite3_stmt *stmt) in FillSharedBlockOpt()
155 int FillSharedBlock(SharedBlockInfo *info, sqlite3_stmt *stmt) in FillSharedBlock()
194 void FillRow(SharedBlockInfo *info, sqlite3_stmt *stmt) in FillRow()
347 bool ResetStatement(SharedBlockInfo *info, sqlite3_stmt *stmt) in ResetStatement()
407 void DefFillRow(SharedBlockInfo *info, sqlite3_stmt *stmt) in DefFillRow()
|
| /ohos5.0/base/request/request/services/src/manage/scheduler/ |
| H A D | sql.rs | 100 let mut stmt = db in ut_start_pause_start() localVariable
113 let mut stmt = db in ut_start_pause_start() localVariable
127 let mut stmt = db in ut_start_pause_start() localVariable
167 let mut stmt = db in ut_pause() localVariable
208 let mut stmt = db in ut_stop() localVariable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/ |
| H A D | sqlite_store_executor_impl.cpp | 118 [key, value](sqlite3_stmt *stmt) { in PutData()
147 [key, value](sqlite3_stmt *stmt) { in InsertData()
174 [key](sqlite3_stmt *stmt) { in GetDataByKey()
178 [&value, &innerErrorCode](sqlite3_stmt *stmt, bool &isMatchOneData) { in GetDataByKey()
201 [key](sqlite3_stmt *stmt) { in GetDataById()
205 [&value, &innerErrorCode](sqlite3_stmt *stmt, bool &isMatchOneData) { in GetDataById()
255 [key](sqlite3_stmt *stmt) { in GetDataByFilter()
262 bool &isMatchOneData) { in GetDataByFilter()
305 [key](sqlite3_stmt *stmt) { in DelData()
384 [name](sqlite3_stmt *stmt) { in IsCollectionExists()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_storage_executor_subscribe.cpp | 45 int SQLiteSingleVerStorageExecutor::CheckMissQueryDataItem(sqlite3_stmt *stmt, const std::string &d… in CheckMissQueryDataItem()
74 int SQLiteSingleVerStorageExecutor::CheckMissQueryDataItems(sqlite3_stmt *&stmt, const SqliteQueryH… in CheckMissQueryDataItems()
115 sqlite3_stmt *stmt = nullptr; in CheckDataWithQuery() local
162 sqlite3_stmt *stmt = nullptr; in AddSubscribeTrigger() local
252 sqlite3_stmt *stmt = nullptr; in GetTriggers() local
|
| H A D | sqlite_cloud_kv_executor_utils.cpp | 134 void SqliteCloudKvExecutorUtils::GetCloudLog(sqlite3_stmt *stmt, VBucket &logInfo, in GetCloudLog()
164 void SqliteCloudKvExecutorUtils::GetCloudExtraLog(sqlite3_stmt *stmt, VBucket &flags) in GetCloudExtraLog()
179 int SqliteCloudKvExecutorUtils::GetCloudKvData(sqlite3_stmt *stmt, VBucket &data, uint32_t &totalSi… in GetCloudKvData()
248 sqlite3_stmt *stmt = nullptr; in GetLogInfo() local
337 DataInfoWithLog SqliteCloudKvExecutorUtils::FillLogInfoWithStmt(sqlite3_stmt *stmt) in FillLogInfoWithStmt()
1006 sqlite3_stmt *stmt = nullptr; in CountCloudDataInner() local
1063 sqlite3_stmt *stmt = nullptr; in CountAllCloudData() local
1134 sqlite3_stmt *stmt = nullptr; in GetLocalCloudVersionInner() local
1291 sqlite3_stmt *stmt = nullptr; in GetWaitCompensatedSyncDataPk() local
1328 sqlite3_stmt *stmt = nullptr; in GetWaitCompensatedSyncDataUserId() local
[all …]
|
| H A D | sqlite_single_ver_storage_executor_extend.cpp | 276 sqlite3_stmt *stmt = nullptr; in GetEntries() local
318 sqlite3_stmt *stmt = nullptr; in RemoveCloudUploadFlag() local
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_data_inserter.cpp | 110 int RelationalSyncDataInserter::GetInsertStatement(sqlite3 *db, sqlite3_stmt *&stmt) in GetInsertStatement()
138 int RelationalSyncDataInserter::BindInsertStatement(sqlite3_stmt *stmt, const DataItem &dataItem) in BindInsertStatement()
176 int RelationalSyncDataInserter::GetDeleteLogStmt(sqlite3 *db, sqlite3_stmt *&stmt) in GetDeleteLogStmt()
192 int RelationalSyncDataInserter::GetDeleteSyncDataStmt(sqlite3 *db, sqlite3_stmt *&stmt) in GetDeleteSyncDataStmt()
234 int RelationalSyncDataInserter::PrepareStatement(sqlite3 *db, SaveSyncDataStmt &stmt) in PrepareStatement()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/rdbmock/frameworks/native/rdb/ |
| H A D | mock.cpp | 41 …ribute__((visibility("default"))) int FillSharedBlockOpt(SharedBlockInfo *info, sqlite3_stmt *stmt) in FillSharedBlockOpt()
48 …attribute__((visibility("default"))) int FillSharedBlock(SharedBlockInfo *info, sqlite3_stmt *stmt) in FillSharedBlock()
55 …attribute__((visibility("default"))) bool ResetStatement(SharedBlockInfo *info, sqlite3_stmt *stmt) in ResetStatement()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_relational_utils.cpp | 75 std::vector<DataValue> SQLiteRelationalUtils::GetSelectValues(sqlite3_stmt *stmt) in GetSelectValues()
238 int SQLiteRelationalUtils::GetSelectVBucket(sqlite3_stmt *stmt, VBucket &bucket) in GetSelectVBucket()
270 int SQLiteRelationalUtils::GetTypeValByStatement(sqlite3_stmt *stmt, int cid, Type &typeVal) in GetTypeValByStatement()
316 int SQLiteRelationalUtils::GetBlobByStatement(sqlite3_stmt *stmt, int cid, Type &typeVal) in GetBlobByStatement()
366 sqlite3_stmt *stmt = nullptr; in SelectServerObserver() local
413 sqlite3_stmt *stmt = nullptr; in QueryCount() local
|
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 79 sqlite3_stmt *stmt = nullptr; in GetFillDownloadAssetStatement() local
136 sqlite3_stmt *stmt = nullptr; in FillCloudAssetForDownload() local
203 sqlite3_stmt *stmt = nullptr; in FillCloudAssetForUpload() local
256 sqlite3_stmt *&stmt) in BindUpdateVersionStatement()
554 sqlite3_stmt *stmt = nullptr; in ClearAllTempSyncTrigger() local
1143 sqlite3_stmt *stmt = nullptr; in UpdateAssetIdOnUserTable() local
1234 sqlite3_stmt *stmt = nullptr; in CleanAssetsIdOnUserTable() local
1273 sqlite3_stmt *stmt = nullptr; in GetAssetsByGidOrHashKey() local
1533 sqlite3_stmt *&stmt) in BindAssetToBlobStatement()
1549 sqlite3_stmt *&stmt) in BindAssetsToBlobStatement()
[all …]
|
| H A D | sqlite_single_ver_relational_continue_token.cpp | 90 int SQLiteSingleVerRelationalContinueToken::GetQuerySyncStatement(sqlite3 *db, sqlite3_stmt *&stmt) in GetQuerySyncStatement()
104 int SQLiteSingleVerRelationalContinueToken::GetMissQueryStatement(sqlite3 *db, sqlite3_stmt *&stmt) in GetMissQueryStatement()
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 152 sqlite3_stmt *stmt = nullptr; in GetExistedDataTimeOffset() local
352 sqlite3_stmt *stmt = nullptr; in GetDeviceTableName() local
850 RelationalSyncDataInserter &inserter, sqlite3_stmt *&stmt) in DeleteSyncDataItem()
912 RelationalSyncDataInserter &inserter, sqlite3_stmt *&stmt) in DeleteSyncLog()
1064 int SQLiteSingleVerRelationalStorageExecutor::GetDataItemForSync(sqlite3_stmt *stmt, DataItem &data… in GetDataItemForSync()
1106 int StepNext(bool isMemDB, sqlite3_stmt *stmt, Timestamp ×tamp) in StepNext()
1351 sqlite3_stmt *stmt = nullptr; in CheckAndCleanDistributedTable() local
1452 sqlite3_stmt *stmt = nullptr; in CheckQueryObjectLegal() local
1482 sqlite3_stmt *stmt = nullptr; in GetMaxTimestamp() local
1515 int GetRowDatas(sqlite3_stmt *stmt, bool isMemDb, std::vector<std::string> &colNames, in GetRowDatas()
[all …]
|
| /ohos5.0/base/security/asset/services/db_operator/src/ |
| H A D | table.rs | 207 let stmt = Statement::prepare(sql.as_str(), self.db)?; in exist() localVariable
302 let stmt = Statement::prepare(&sql, self.db)?; in insert_row() localVariable
328 let stmt = Statement::prepare(&sql, self.db)?; in delete_row() localVariable
351 let stmt = Statement::prepare(&sql, self.db)?; in delete_with_specific_cond() localVariable
379 let stmt = Statement::prepare(&sql, self.db)?; in update_row() localVariable
415 let stmt = Statement::prepare(&sql, self.db)?; in query_row() localVariable
452 let stmt = Statement::prepare(&sql, self.db)?; in count_datas() localVariable
|
| /ohos5.0/base/security/asset/services/db_operator/src/test/ |
| H A D | test_table.rs | 120 let stmt = Statement::prepare(sql, &db).unwrap(); in execute_sql() localVariable
166 let stmt = Statement::prepare("select id,alias from table_name where id < ?", &db).unwrap(); in single_data() localVariable
202 let stmt = Statement::prepare("insert into table_name values(?, ?)", &db).unwrap(); in multiple_data() localVariable
210 let stmt = Statement::prepare("select id,alias from table_name where id < ?", &db).unwrap(); in multiple_data() localVariable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_set_cloud_schema_test.cpp | 198 sqlite3_stmt *stmt = nullptr; in CheckSharedTable() local
220 sqlite3_stmt *stmt = nullptr; in CheckDistributedSharedTable() local
254 sqlite3_stmt *stmt = nullptr; in InsertLocalSharedTableRecords() local
1269 sqlite3_stmt *stmt = nullptr; variable
1401 sqlite3_stmt *stmt = nullptr; variable
1447 sqlite3_stmt *stmt = nullptr; variable
1644 sqlite3_stmt *stmt = nullptr; variable
1764 sqlite3_stmt *stmt = nullptr; variable
1808 sqlite3_stmt *stmt = nullptr; variable
|
| H A D | distributeddb_interfaces_relational_sync_test.cpp | 539 [](sqlite3_stmt *stmt) { in __anonf1fa0da11202()
543 }, [&resultTrigger](sqlite3_stmt *stmt) { in __anonf1fa0da11202()
567 int ret = RelationalTestUtils::ExecSql(db, insertSql, [&i, dataSize] (sqlite3_stmt *stmt) { in PrepareSyncData()
601 RelationalTestUtils::ExecSql(db, checkSql, nullptr, [keySet](sqlite3_stmt *stmt) { in CheckSyncData()
794 …ls::ExecSql(db, "select count(*) from " + deviceTableName + ";", nullptr, [] (sqlite3_stmt *stmt) { in __anonf1fa0da11e02()
802 …ls::ExecSql(db, "select count(*) from " + deviceTableName + ";", nullptr, [] (sqlite3_stmt *stmt) { in __anonf1fa0da11f02()
882 …TestUtils::ExecSql(db, "select * from " + deviceTableName + ";", nullptr, [] (sqlite3_stmt *stmt) { in __anonf1fa0da12202()
908 int ret = RelationalTestUtils::ExecSql(db, insertSql, [] (sqlite3_stmt *stmt) { in __anonf1fa0da12302()
1027 int ret = RelationalTestUtils::ExecSql(db, insertSql, nullptr, [&resCnt](sqlite3_stmt *stmt) { in __anonf1fa0da12702()
|
| H A D | distributeddb_interfaces_relational_routines_test.cpp | 124 RelationalTestUtils::ExecSql(db, checkSql, nullptr, [&logTime](sqlite3_stmt *stmt) { in __anon5008cf5d0202()
|
| H A D | distributeddb_interfaces_relational_tracker_table_test.cpp | 147 sqlite3_stmt *stmt = nullptr; in CheckExtendAndCursor() local
221 sqlite3_stmt *stmt = nullptr; in CheckDropTableAndReopenDb() local
561 sqlite3_stmt *stmt = nullptr; variable
885 sqlite3_stmt *stmt = nullptr; variable
1200 sqlite3_stmt *stmt = nullptr; variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_save_cloud_data_test.cpp | 179 sqlite3_stmt *stmt = nullptr; in PrepareDataBaseForAsset() local
873 int errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [] (sqlite3_stmt *stmt) { in __anon2ff534420202()
1113 int errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [&count] (sqlite3_stmt *stmt) { in __anon2ff534420302()
1208 int errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [&count] (sqlite3_stmt *stmt) { in __anon2ff534420402()
1276 int errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [&count] (sqlite3_stmt *stmt) { in DeleteWithPkTest()
1346 int errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [&count] (sqlite3_stmt *stmt) { in __anon2ff534420602()
1362 errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [&count] (sqlite3_stmt *stmt) { in __anon2ff534420702()
1504 int errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [] (sqlite3_stmt *stmt) { in __anon2ff534420a02()
1516 errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [] (sqlite3_stmt *stmt) { in __anon2ff534420b02()
1528 errCode = RelationalTestUtils::ExecSql(db, sql, nullptr, [] (sqlite3_stmt *stmt) { in __anon2ff534420c02()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | native_sqlite.cpp | 56 sqlite3_stmt *stmt = nullptr; in ExecSql() local
|
| /ohos5.0/foundation/communication/dsoftbus/core/common/include/ |
| H A D | sqlite3_utils.h | 41 sqlite3_stmt *stmt; member
|
| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | database.rs | 137 let mut stmt = self.inner.prepare(sql).unwrap(); in query_integer() localVariable
355 let mut stmt = self.inner.prepare(&sql).unwrap(); in get_task_info() localVariable
411 let mut stmt = self.inner.prepare(&sql).unwrap(); in get_task_config() localVariable
505 let mut stmt = self.inner.prepare(&sql).unwrap(); in get_task_qos_info() localVariable
529 let mut stmt = self.inner.prepare(&sql).unwrap(); in get_app_task_qos_infos_inner() localVariable
|