Home
last modified time | relevance | path

Searched refs:statement (Results 1 – 25 of 401) sorted by relevance

12345678910>>...17

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_multi_ver_transaction.cpp240 sqlite3_stmt *statement = nullptr; in Get() local
262 sqlite3_stmt *statement = nullptr; in GetValueForTrimSlice() local
451 sqlite3_stmt *statement = nullptr; in GetDiffEntries() local
507 sqlite3_stmt *statement = nullptr; in GetMaxVersion() local
535 sqlite3_stmt *statement = nullptr; in ClearEntriesByVersion() local
566 sqlite3_stmt *statement = nullptr; in GetPrePutValues() local
613 sqlite3_stmt *statement = nullptr; in RemovePrePutEntries() local
667 sqlite3_stmt *statement = nullptr; in GetEntriesByVersion() local
701 sqlite3_stmt *statement = nullptr; in GetEntriesByVersion() local
746 sqlite3_stmt *statement = nullptr; in GetCurrentMaxTimestamp() local
[all …]
H A Dsqlite_local_storage_executor.cpp49 sqlite3_stmt *statement = nullptr; in Get() local
60 errCode = SQLiteUtils::StepWithRetry(statement); in Get()
71 SQLiteUtils::ResetStatement(statement, true, errCode); in Get()
84 sqlite3_stmt *statement = nullptr; in GetEntries() local
97 errCode = SQLiteUtils::StepWithRetry(statement); in GetEntries()
126 SQLiteUtils::ResetStatement(statement, true, errCode); in GetEntries()
193 sqlite3_stmt *statement = nullptr; in Put() local
211 errCode = SQLiteUtils::StepWithRetry(statement); in Put()
219 SQLiteUtils::ResetStatement(statement, true, errCode); in Put()
225 sqlite3_stmt *statement = nullptr; in Delete() local
[all …]
H A Dsqlite_single_ver_storage_executor_cache.cpp101 sqlite3_stmt *statement = nullptr; in RemoveDeviceDataInCacheMode() local
138 sqlite3_stmt *statement = nullptr; in GetMinVersionCacheData() local
170 sqlite3_stmt *statement = nullptr; in MigrateRmDevData() local
229 sqlite3_stmt *statement = nullptr; in GetMaxVersionInCacheDb() local
276 if (statement == nullptr) { in MigrateDataItem()
437 sqlite3_stmt *statement = nullptr; in DelCacheDbDataByVersion() local
670 if (statement == nullptr) { in SaveSyncDataToCacheDatabase()
687 sqlite3_stmt *statement = nullptr; in PutLocalDataToCacheDB() local
788 sqlite3_stmt *statement = nullptr; in GetMinTimestampInCacheDB() local
942 sqlite3_stmt *statement = nullptr; in DeleteMetaData() local
[all …]
H A Dsqlite_single_ver_storage_executor.cpp125 sqlite3_stmt *statement = nullptr; in GetKvData() local
197 sqlite3_stmt *statement = nullptr; in GetKvDataByHashKey() local
251 sqlite3_stmt *statement = nullptr; in SaveKvData() local
324 sqlite3_stmt *statement = nullptr; in GetEntries() local
351 sqlite3_stmt *statement = nullptr; in GetEntries() local
420 sqlite3_stmt *statement = nullptr; in InitCurrentMaxStamp() local
540 sqlite3_stmt *statement = nullptr; in GetSyncDataByTimestamp() local
554 sqlite3_stmt *statement = nullptr; in GetDeletedSyncDataByTimestamp() local
1088 sqlite3_stmt *statement = nullptr; in GetDeviceIdentifier() local
1209 if (statement == nullptr) { in SaveSyncDataToDatabase()
[all …]
H A Dsqlite_utils.cpp245 if (statement != nullptr) { in GetStatement()
256 if (statement == nullptr) { in GetStatement()
265 if (statement == nullptr) { in BindTextToStatement()
293 if (statement == nullptr) { in BindBlobToStatement()
321 if (statement == nullptr) { in ResetStatement()
344 statement = nullptr; in ResetStatement()
354 if (statement == nullptr) { in StepWithRetry()
379 if (statement == nullptr) { in BindPrefixKey()
514 if (statement == nullptr) { in GetColumnBlobValue()
540 if (statement == nullptr) { in GetColumnTextValue()
[all …]
H A Dsqlite_single_ver_storage_executor_extend.cpp43 sqlite3_stmt *statement = nullptr; in CloudExcuteRemoveOrUpdate() local
60 SQLiteUtils::ResetStatement(statement, true, ret); in CloudExcuteRemoveOrUpdate()
70 SQLiteUtils::ResetStatement(statement, true, ret); in CloudExcuteRemoveOrUpdate()
74 errCode = SQLiteUtils::StepWithRetry(statement, isMemDb_); in CloudExcuteRemoveOrUpdate()
80 SQLiteUtils::ResetStatement(statement, true, ret); in CloudExcuteRemoveOrUpdate()
88 sqlite3_stmt *statement = nullptr; in CloudCheckDataExist() local
99 SQLiteUtils::ResetStatement(statement, true, ret); in CloudCheckDataExist()
128 SQLiteUtils::ResetStatement(statement, true, ret); in CloudCheckDataExist()
131 SQLiteUtils::ResetStatement(statement, true, ret); in CloudCheckDataExist()
283 sqlite3_stmt *statement = stmt; in GetEntries() local
[all …]
H A Dsqlite_query_helper.cpp346 if (statement == nullptr) { in BindSyncDataCheckStmt()
365 errCode = BindKeysToStmt(keys_, statement, index); in BindSyncDataCheckStmt()
418 errCode = BindKeysToStmt(keys_, statement, index); in GetQuerySqlStatement()
581 sqlite3_stmt *&statement) in GetQuerySyncStatement() argument
624 errCode = BindObjNodes(statement, index); in GetQuerySyncStatement()
636 errCode = BindObjNodes(statement, index); in GetQuerySyncStatement()
1098 errCode = BindObjNodes(statement, index); in GetRelationalQueryStatement()
1118 errCode = BindObjNodes(statement, index); in GetRelationalQueryStatement()
1239 std::string &sql, sqlite3_stmt *&statement) in GetCloudQueryStatement() argument
1254 errCode = BindObjNodes(statement, index); in GetCloudQueryStatement()
[all …]
H A Dsqlite_meta_executor.cpp24 sqlite3_stmt *statement = nullptr; in GetMetaKeysByKeyPrefix() local
39 int errCode = SQLiteUtils::GetStatement(dbHandle, sqlStr, statement); in GetMetaKeysByKeyPrefix()
47 …errCode = SQLiteUtils::BindBlobToStatement(statement, 1, keyPrefix); // 1: bind index for prefix k… in GetMetaKeysByKeyPrefix()
50 SQLiteUtils::ResetStatement(statement, true, errCode); in GetMetaKeysByKeyPrefix()
55 errCode = GetAllKeys(statement, isMemDb, keys); in GetMetaKeysByKeyPrefix()
56 SQLiteUtils::ResetStatement(statement, true, errCode); in GetMetaKeysByKeyPrefix()
67 int SqliteMetaExecutor::GetAllKeys(sqlite3_stmt *statement, bool isMemDb, std::vector<Key> &keys) in GetAllKeys() argument
69 if (statement == nullptr) { in GetAllKeys()
74 errCode = SQLiteUtils::StepWithRetry(statement, isMemDb); in GetAllKeys()
77 errCode = SQLiteUtils::GetColumnBlobValue(statement, 0, key); in GetAllKeys()
H A Dsqlite_query_helper.h74 int GetQuerySqlStatement(sqlite3 *dbHandle, bool onlyRowid, sqlite3_stmt *&statement);
75 int GetQuerySqlStatement(sqlite3 *dbHandle, const std::string &sql, sqlite3_stmt *&statement);
79 …rySyncStatement(sqlite3 *dbHandle, uint64_t beginTime, uint64_t endTime, sqlite3_stmt *&statement);
81 int BindSyncDataCheckStmt(sqlite3_stmt *statement, const Key &hashKey) const;
99 const std::vector<std::string> &fieldNames, sqlite3_stmt *&statement);
103 const std::vector<std::string> &fieldNames, sqlite3_stmt *&statement);
113 sqlite3_stmt *&statement);
146 int BindFieldValue(sqlite3_stmt *statement, const QueryObjNode &queryNode, int &index) const;
152 …int BindTimeRange(sqlite3_stmt *&statement, int &index, uint64_t beginTime, uint64_t endTime) cons…
153 int BindObjNodes(sqlite3_stmt *&statement, int &index) const;
H A Dsqlite_multi_ver_transaction.h104 int CheckIfNeedSaveRecord(sqlite3_stmt *statement, const MultiVerKvEntry *multiVerKvEntry,
121 static int GetRawMultiVerEntry(sqlite3_stmt *statement, MultiVerEntryData &keyEntry);
123 static int GetRawDataByVersion(sqlite3_stmt *&statement, const Version &version,
128 static int BindAddRecordKeysToStatement(sqlite3_stmt *statement, const Key &key,
138 int BindClearIdAndVersion(sqlite3_stmt *statement, int index) const;
140 int BindQueryEntryArgs(sqlite3_stmt *statement, const Key &key) const;
142 int BindQueryEntriesArgs(sqlite3_stmt *statement, const Key &key) const;
144 int BindAddRecordArgs(sqlite3_stmt *statement, const Key &key, const Value &value,
160 int GetKeyAndValueByHashKey(sqlite3_stmt *statement, const Key &hashKey, Key &key, Value &value,
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_sqlite_relational_utils_test.cpp133 sqlite3_stmt *statement = nullptr; variable
173 sqlite3_stmt *statement = nullptr; variable
174 PrepareStatement(sql, statement, false);
176 SQLiteUtils::ResetStatement(statement, true, errCode);
177 ASSERT_EQ(statement, nullptr);
202 sqlite3_stmt *statement = nullptr; variable
203 PrepareStatement(sql, statement, true);
206 SQLiteUtils::ResetStatement(statement, true, errCode);
207 ASSERT_EQ(statement, nullptr);
218 SQLiteUtils::ResetStatement(statement, true, errCode);
[all …]
H A Ddistributeddb_storage_single_ver_upgrade_test.cpp153 sqlite3_stmt *statement = nullptr; in CreateDatabase() local
155 ASSERT_NE(statement, nullptr); in CreateDatabase()
158 EXPECT_EQ(sqlite3_finalize(statement), SQLITE_OK); in CreateDatabase()
165 sqlite3_stmt *statement = nullptr; in CheckSyncDataV1ToV2() local
167 ASSERT_NE(statement, nullptr); in CheckSyncDataV1ToV2()
169 ASSERT_EQ(sqlite3_column_int64(statement, 0), sqlite3_column_int64(statement, 1)); in CheckSyncDataV1ToV2()
170 ASSERT_EQ(sqlite3_finalize(statement), SQLITE_OK); in CheckSyncDataV1ToV2()
175 sqlite3_stmt *statement = nullptr; in CheckSyncDataV2ToV3() local
177 ASSERT_NE(statement, nullptr); in CheckSyncDataV2ToV3()
186 sqlite3_stmt *statement = nullptr; in CheckLocalDataV1ToV2() local
[all …]
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Dstep_result_set.cpp50 if (statement == nullptr) { in StepResultSet()
82 if (statement == nullptr) { in InitRowCount()
102 statement->Reset(); in InitRowCount()
142 statement->Reset(); in PrepareStep()
143 statement = nullptr; in PrepareStep()
161 if (statement == nullptr) { in GetColumnNames()
189 if (statement == nullptr) { in GetColumnType()
252 if (statement == nullptr) { in GoToNextRow()
337 if (statement != nullptr) { in Reset()
362 if (statement == nullptr) { in GetSize()
[all …]
H A Drd_result_set.cpp64 if (statement == nullptr) { in GetColumnNames()
69 errCode = statement->Step(); in GetColumnNames()
103 if (statement == nullptr) { in GetColumnType()
180 if (statement == nullptr) { in GoToNextRow()
184 errCode = statement->Step(); in GoToNextRow()
224 if (statement == nullptr) { in PrepareStep()
230 statement = nullptr; in PrepareStep()
237 statement = nullptr; in PrepareStep()
262 if (statement != nullptr) { in FinishStep()
325 if (statement == nullptr) { in GetSize()
[all …]
H A Dtrans_db.cpp66 if (statement == nullptr) { in Insert()
69 errCode = statement->Execute(args); in Insert()
73 rowid = statement->Changes() > 0 ? statement->LastInsertRowId() : -1; in Insert()
91 if (statement == nullptr) { in BatchInsert()
140 if (statement == nullptr) { in Update()
164 if (statement == nullptr) { in Delete()
167 errCode = statement->Execute(args); in Delete()
171 deletedRows = statement->Changes(); in Delete()
208 errCode = statement->Execute(args); in Execute()
215 int64_t outValue = statement->Changes() > 0 ? statement->LastInsertRowId() : -1; in Execute()
[all …]
H A Dsqlite_shared_result_set.cpp51 auto [statement, errCode] = PrepareStep(); in SqliteSharedResultSet()
56 statement_ = statement; in SqliteSharedResultSet()
92 if (statement == nullptr) { in PrepareStep()
94 return { statement, errCode }; in PrepareStep()
97 if (!statement->ReadOnly()) { in PrepareStep()
103 errCode = statement->Bind(bindArgs_); in PrepareStep()
106 statement->Reset(); in PrepareStep()
107 statement = nullptr; in PrepareStep()
111 return { statement, E_OK }; in PrepareStep()
124 auto [statement, errCode] = PrepareStep(); in GetColumnNames()
[all …]
H A Drdb_store_impl.cpp1173 if (statement == nullptr) { in ExecuteSql()
1186 statement->Reset(); in ExecuteSql()
1189 statement = nullptr; in ExecuteSql()
1197 statement = nullptr; in ExecuteSql()
1253 int64_t outValue = statement->Changes() > 0 ? statement->LastInsertRowId() : -1; in HandleDifferentSqlTypes()
1274 statement->Reset(); in HandleDifferentSqlTypes()
1293 if (statement == nullptr) { in ExecuteAndGetLong()
1310 if (statement == nullptr) { in ExecuteAndGetString()
1341 outValue = statement->Changes() > 0 ? statement->LastInsertRowId() : -1; in ExecuteForLastInsertedRowId()
1570 statement = nullptr; in BeginExecuteSql()
[all …]
H A Dshare_block.cpp228 int type = sqlite3_column_type(statement, i); in FillOneRow()
234 result = FillOneRowOfLong(sharedBlock, statement, startPos, addedRows, i); in FillOneRow()
237 result = FillOneRowOfFloat(sharedBlock, statement, startPos, addedRows, i); in FillOneRow()
240 result = FillOneRowOfBlob(sharedBlock, statement, startPos, addedRows, i); in FillOneRow()
243 result = FillOneRowOfNull(sharedBlock, statement, startPos, addedRows, i); in FillOneRow()
272 auto sizeIncludingNull = sqlite3_column_bytes(statement, pos) + 1; in FillOneRowOfString()
286 int64_t value = sqlite3_column_int64(statement, pos); in FillOneRowOfLong()
299 double value = sqlite3_column_double(statement, pos); in FillOneRowOfFloat()
313 auto *declType = sqlite3_column_decltype(statement, pos); in FillOneRowOfBlob()
324 const void *blob = sqlite3_column_blob(statement, pos); in FillOneRowOfBlob()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/
H A Drd_sqlite_utils.cpp94 if (statement != nullptr) { in GetStatement()
104 if (statement == nullptr) { in GetStatement()
113 if (statement == nullptr) { in StepWithRetry()
117 int errCode = sqlite3_step(statement); in StepWithRetry()
127 if (statement == nullptr) { in ResetStatement()
133 errCode = sqlite3_reset(statement); in ResetStatement()
139 (void)sqlite3_clear_bindings(statement); in ResetStatement()
148 statement = nullptr; in ResetStatement()
154 if (statement == nullptr) { in BindBlobToStatement()
170 if (statement == nullptr) { in GetColumnBlobValue()
[all …]
H A Drd_sqlite_utils.h35 static int GetStatement(sqlite3 *db, const std::string &sql, sqlite3_stmt *&statement);
36 static int StepWithRetry(sqlite3_stmt *statement);
37 static int ResetStatement(sqlite3_stmt *&statement, bool finalize);
39 …static int BindBlobToStatement(sqlite3_stmt *statement, int index, const std::vector<uint8_t> &val…
40 static int GetColumnBlobValue(sqlite3_stmt *statement, int index, std::vector<uint8_t> &value);
42 static int BindTextToStatement(sqlite3_stmt *statement, int index, const std::string &value);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_relational_utils.cpp27 if (statement == nullptr || cid < 0 || cid >= sqlite3_column_count(statement)) { in GetDataValueByType()
32 int storageType = sqlite3_column_type(statement, cid); in GetDataValueByType()
35 value = static_cast<int64_t>(sqlite3_column_int64(statement, cid)); in GetDataValueByType()
38 value = sqlite3_column_double(statement, cid); in GetDataValueByType()
62 (void)SQLiteUtils::GetColumnTextValue(statement, cid, str); in GetDataValueByType()
88 if (statement == nullptr || cid < 0 || cid >= sqlite3_column_count(statement)) { in GetCloudValueByType()
91 switch (sqlite3_column_type(statement, cid)) { in GetCloudValueByType()
101 cloudValue = sqlite3_column_double(statement, cid); in GetCloudValueByType()
125 (void)SQLiteUtils::GetColumnTextValue(statement, cid, str); in GetCloudValueByType()
191 errCode = BindExtendStatementByType(statement, cid, typeVal); in BindStatementByType()
[all …]
/ohos5.0/base/startup/init/services/log/
H A Dinit_log.h84 #define INIT_ERROR_CHECK(ret, statement, format, ...) \ argument
88 statement; \
92 #define INIT_INFO_CHECK(ret, statement, format, ...) \ argument
96 statement; \
100 #define INIT_WARNING_CHECK(ret, statement, format, ...) \ argument
104 statement; \
108 #define INIT_CHECK(ret, statement) \ argument
111 statement; \
/ohos5.0/base/security/access_token/services/privacymanager/src/database/
H A Dpermission_used_record_db.cpp138 auto statement = Prepare(prepareSql); in Add() local
146 int32_t ret = statement.Step(); in Add()
151 statement.Reset(); in Add()
180 auto statement = Prepare(prepareSql); in Remove() local
184 int32_t ret = statement.Step(); in Remove()
208 auto statement = Prepare(prepareSql); in FindByConditions() local
220 value.Put(statement.GetColumnName(i), statement.GetValue(i, true)); in FindByConditions()
222 value.Put(statement.GetColumnName(i), statement.GetValue(i, false)); in FindByConditions()
313 auto statement = Prepare(prepareSql); in Update() local
323 int32_t ret = statement.Step(); in Update()
[all …]
/ohos5.0/base/startup/init/interfaces/innerkits/include/
H A Dbeget_ext.h127 #define BEGET_ERROR_CHECK(ret, statement, format, ...) \ argument
130 statement; \
133 #define BEGET_INFO_CHECK(ret, statement, format, ...) \ argument
136 statement; \
139 #define BEGET_WARNING_CHECK(ret, statement, format, ...) \ argument
142 statement; \
145 #define BEGET_CHECK(ret, statement) \ argument
147 statement; \
/ohos5.0/foundation/filemanagement/storage_service/services/storage_daemon/include/libfscrypt/
H A Dfscrypt_log.h28 #define FSCRYPT_ERROR_CHECK(ret, statement, format, ...) \ argument
32 statement; \
36 #define FSCRYPT_CHECK(ret, statement) \ argument
39 statement; \

12345678910>>...17