Home
last modified time | relevance | path

Searched refs:statement (Results 1 - 25 of 61) sorted by relevance

123

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_sqlite_relational_utils_test.cpp54 void PrepareStatement(const std::string &sql, sqlite3_stmt *&statement, bool hasCloudDataTranslate);
91 void DistributedDBSqliteRelationalUtilsTest::PrepareStatement(const std::string &sql, sqlite3_stmt *&statement, in PrepareStatement() argument
94 ASSERT_EQ(SQLiteUtils::GetStatement(g_db, sql, statement), E_OK); in PrepareStatement()
105 EXPECT_EQ(SQLiteRelationalUtils::BindStatementByType(statement, 1, data["id"]), E_OK); // 1 is id cid in PrepareStatement()
106 EXPECT_EQ(SQLiteRelationalUtils::BindStatementByType(statement, 2, data["name"]), E_OK); // 2 is name cid in PrepareStatement()
107 EXPECT_EQ(SQLiteRelationalUtils::BindStatementByType(statement, 3, data["height"]), E_OK); // 3 is height cid in PrepareStatement()
108 EXPECT_EQ(SQLiteRelationalUtils::BindStatementByType(statement, 4, data["married"]), E_OK); // 4 is married cid in PrepareStatement()
109 EXPECT_EQ(SQLiteRelationalUtils::BindStatementByType(statement, 5, data["photo"]), E_OK); // 5 is photo cid in PrepareStatement()
111 EXPECT_EQ(SQLiteRelationalUtils::BindStatementByType(statement, 6, data["asset"]), E_OK); // 6 is asset cid in PrepareStatement()
112 EXPECT_EQ(SQLiteRelationalUtils::BindStatementByType(statement, in PrepareStatement()
133 sqlite3_stmt *statement = nullptr; HWTEST_F() local
173 sqlite3_stmt *statement = nullptr; HWTEST_F() local
202 sqlite3_stmt *statement = nullptr; HWTEST_F() local
[all...]
H A Ddistributeddb_storage_single_ver_upgrade_test.cpp153 sqlite3_stmt *statement = nullptr; in CreateDatabase() local
154 ASSERT_EQ(SQLiteUtils::GetStatement(db, insertLocalDataSql, statement), E_OK); in CreateDatabase()
155 ASSERT_NE(statement, nullptr); in CreateDatabase()
156 EXPECT_EQ(SQLiteUtils::BindBlobToStatement(statement, 1, g_origValue, false), E_OK); in CreateDatabase()
157 EXPECT_EQ(SQLiteUtils::StepWithRetry(statement, false), -SQLITE_DONE); in CreateDatabase()
158 EXPECT_EQ(sqlite3_finalize(statement), SQLITE_OK); in CreateDatabase()
165 sqlite3_stmt *statement = nullptr; in CheckSyncDataV1ToV2() local
166 ASSERT_EQ(SQLiteUtils::GetStatement(db, CHECK_V1_SYNC_UPGRADE, statement), E_OK); in CheckSyncDataV1ToV2()
167 ASSERT_NE(statement, nullptr); in CheckSyncDataV1ToV2()
168 ASSERT_EQ(SQLiteUtils::StepWithRetry(statement), SQLiteUtil in CheckSyncDataV1ToV2()
175 sqlite3_stmt *statement = nullptr; CheckSyncDataV2ToV3() local
186 sqlite3_stmt *statement = nullptr; CheckLocalDataV1ToV2() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/
H A Drd_sqlite_utils.cpp86 int RDSQLiteUtils::GetStatement(sqlite3 *db, const std::string &sql, sqlite3_stmt *&statement) in GetStatement() argument
89 GLOGE("Invalid db for get statement"); in GetStatement()
93 // Prepare the new statement only when the input parameter is not null in GetStatement()
94 if (statement != nullptr) { in GetStatement()
97 int errCode = sqlite3_prepare_v2(db, sql.c_str(), -1, &statement, nullptr); in GetStatement()
99 GLOGE("Prepare SQLite statement failed:%d", errCode); in GetStatement()
100 (void)RDSQLiteUtils::ResetStatement(statement, true); in GetStatement()
104 if (statement == nullptr) { in GetStatement()
111 int RDSQLiteUtils::StepWithRetry(sqlite3_stmt *statement) in StepWithRetry() argument
113 if (statement in StepWithRetry()
125 ResetStatement(sqlite3_stmt *&statement, bool finalize) ResetStatement() argument
152 BindBlobToStatement(sqlite3_stmt *statement, int index, const std::vector<uint8_t> &value) BindBlobToStatement() argument
168 GetColumnBlobValue(sqlite3_stmt *statement, int index, std::vector<uint8_t> &value) GetColumnBlobValue() argument
192 BindTextToStatement(sqlite3_stmt *statement, int index, const std::string &value) BindTextToStatement() argument
[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> &value);
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);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_local_storage_executor.cpp49 sqlite3_stmt *statement = nullptr; in Get() local
50 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SQL, statement); in Get()
55 errCode = SQLiteUtils::BindBlobToStatement(statement, SELECT_BIND_KEY_INDEX, key, false); in Get()
60 errCode = SQLiteUtils::StepWithRetry(statement); in Get()
68 errCode = SQLiteUtils::GetColumnBlobValue(statement, 0, value); in Get()
71 SQLiteUtils::ResetStatement(statement, true, errCode); in Get()
84 sqlite3_stmt *statement = nullptr; in GetEntries() local
85 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_BATCH_SQL, statement); in GetEntries()
91 errCode = SQLiteUtils::BindPrefixKey(statement, SELECT_BIND_KEY_INDEX, keyPrefix); // first arg is prefix key in GetEntries()
97 errCode = SQLiteUtils::StepWithRetry(statement); in GetEntries()
193 sqlite3_stmt *statement = nullptr; Put() local
225 sqlite3_stmt *statement = nullptr; Delete() local
[all...]
H A Dsqlite_single_ver_storage_executor_cache.cpp101 sqlite3_stmt *statement = nullptr; in RemoveDeviceDataInCacheMode() local
104 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in RemoveDeviceDataInCacheMode()
109 errCode = BindSyncDataInCacheMode(statement, dataItem, hashKey, recordVersion); in RemoveDeviceDataInCacheMode()
114 errCode = SQLiteUtils::StepWithRetry(statement, isMemDb_); in RemoveDeviceDataInCacheMode()
122 SQLiteUtils::ResetStatement(statement, true, errCode); in RemoveDeviceDataInCacheMode()
138 sqlite3_stmt *statement = nullptr; in GetMinVersionCacheData() local
139 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetMinVersionCacheData()
145 errCode = GetAllDataItems(statement, dataItems, minVerIncurCacheDb, true); in GetMinVersionCacheData()
150 SQLiteUtils::ResetStatement(statement, true, errCode); in GetMinVersionCacheData()
170 sqlite3_stmt *statement in MigrateRmDevData() local
229 sqlite3_stmt *statement = nullptr; GetMaxVersionInCacheDb() local
275 sqlite3_stmt *statement = migrateSyncStatements_.GetDataSaveStatement(isUpdate); MigrateDataItem() local
437 sqlite3_stmt *statement = nullptr; DelCacheDbDataByVersion() local
502 BindSyncDataInCacheMode(sqlite3_stmt *statement, const DataItem &dataItem, const Key &hashKey, uint64_t recordVersion) const BindSyncDataInCacheMode() argument
545 BindPrimaryKeySyncDataInCacheMode( sqlite3_stmt *statement, const Key &hashKey, uint64_t recordVersion) const BindPrimaryKeySyncDataInCacheMode() argument
560 BindTimestampSyncDataInCacheMode( sqlite3_stmt *statement, const DataItem &dataItem) const BindTimestampSyncDataInCacheMode() argument
576 BindDevSyncDataInCacheMode(sqlite3_stmt *statement, const std::string &origDev, const std::string &deviceName) const BindDevSyncDataInCacheMode() argument
669 auto statement = saveSyncStatements_.GetDataSaveStatement(false); SaveSyncDataToCacheDatabase() local
687 sqlite3_stmt *statement = nullptr; PutLocalDataToCacheDB() local
708 BindLocalDataInCacheMode(sqlite3_stmt *statement, const LocalDataItem &dataItem) const BindLocalDataInCacheMode() argument
788 sqlite3_stmt *statement = nullptr; GetMinTimestampInCacheDB() local
942 sqlite3_stmt *statement = nullptr; DeleteMetaData() local
969 sqlite3_stmt *statement = nullptr; DeleteMetaDataByPrefixKey() local
[all...]
H A Dsqlite_multi_ver_transaction.cpp240 sqlite3_stmt *statement = nullptr; in Get() local
242 int errCode = SQLiteUtils::GetStatement(db_, SELECT_ONE_SQL, statement); in Get()
254 errCode = GetKeyAndValueByHashKey(statement, hashKey, readKey, value, false); in Get()
256 SQLiteUtils::ResetStatement(statement, true, errCode); in Get()
262 sqlite3_stmt *statement = nullptr; in GetValueForTrimSlice() local
264 int errCode = SQLiteUtils::GetStatement(db_, SELECT_BY_HASHKEY_VER_SQL, statement); in GetValueForTrimSlice()
270 errCode = SQLiteUtils::BindBlobToStatement(statement, 1, hashKey, false); // bind the 1st para for hash key in GetValueForTrimSlice()
275 errCode = sqlite3_bind_int64(statement, 2, version); // bind the 2nd para for version in GetValueForTrimSlice()
281 errCode = SQLiteUtils::StepWithRetry(statement); in GetValueForTrimSlice()
290 operFlag = static_cast<uint64_t>(sqlite3_column_int64(statement, in GetValueForTrimSlice()
451 sqlite3_stmt *statement = nullptr; GetDiffEntries() local
507 sqlite3_stmt *statement = nullptr; GetMaxVersion() local
535 sqlite3_stmt *statement = nullptr; ClearEntriesByVersion() local
566 sqlite3_stmt *statement = nullptr; GetPrePutValues() local
613 sqlite3_stmt *statement = nullptr; RemovePrePutEntries() local
667 sqlite3_stmt *statement = nullptr; GetEntriesByVersion() local
701 sqlite3_stmt *statement = nullptr; GetEntriesByVersion() local
746 sqlite3_stmt *statement = nullptr; GetCurrentMaxTimestamp() local
773 sqlite3_stmt *statement = nullptr; UpdateTimestampByVersion() local
857 sqlite3_stmt *statement = nullptr; GetOverwrittenClearTypeEntries() local
904 sqlite3_stmt *statement = nullptr; GetOverwrittenNonClearTypeEntries() local
951 sqlite3_stmt *statement = nullptr; DeleteEntriesByHashKey() local
984 GetRawMultiVerEntry(sqlite3_stmt *statement, MultiVerEntryData &keyEntry) GetRawMultiVerEntry() argument
1015 GetRawDataByVersion(sqlite3_stmt *&statement, const Version &version, std::vector<MultiVerEntryData> &entries) GetRawDataByVersion() argument
1073 sqlite3_stmt *statement = nullptr; AddRecord() local
1150 sqlite3_stmt *statement = nullptr; GetClearId() local
1174 BindClearIdAndVersion(sqlite3_stmt *statement, int index) const BindClearIdAndVersion() argument
1204 BindQueryEntryArgs(sqlite3_stmt *statement, const Key &key) const BindQueryEntryArgs() argument
1215 BindQueryEntriesArgs(sqlite3_stmt *statement, const Key &key) const BindQueryEntriesArgs() argument
1227 BindAddRecordKeysToStatement(sqlite3_stmt *statement, const Key &key, const MultiVerEntryAuxData &data) BindAddRecordKeysToStatement() argument
1260 BindAddRecordArgs(sqlite3_stmt *statement, const Key &key, const Value &value, const MultiVerEntryAuxData &data) const BindAddRecordArgs() argument
1368 CheckIfNeedSaveRecord(sqlite3_stmt *statement, const MultiVerKvEntry *multiVerKvEntry, bool &isNeedSave, Value &origVal) const CheckIfNeedSaveRecord() argument
1438 sqlite3_stmt *statement = nullptr; CheckIfNeedSaveRecord() local
1483 GetKeyAndValueByHashKey(sqlite3_stmt *statement, const Key &hashKey, Key &key, Value &value, bool isNeedReadKey) const GetKeyAndValueByHashKey() argument
1514 sqlite3_stmt *statement = nullptr; GetOriginKeyValueByHash() local
[all...]
H A Dsqlite_utils.cpp231 int SQLiteUtils::GetStatement(sqlite3 *db, const std::string &sql, sqlite3_stmt *&statement) in GetStatement() argument
234 LOGE("Invalid db for statement"); in GetStatement()
237 // Prepare the new statement only when the input parameter is not null in GetStatement()
238 if (statement != nullptr) { in GetStatement()
241 int errCode = sqlite3_prepare_v2(db, sql.c_str(), NO_SIZE_LIMIT, &statement, nullptr); in GetStatement()
243 LOGE("Prepare SQLite statement failed:%d, sys:%d", errCode, errno); in GetStatement()
245 SQLiteUtils::ResetStatement(statement, true, errCode); in GetStatement()
249 if (statement == nullptr) { in GetStatement()
256 int SQLiteUtils::BindTextToStatement(sqlite3_stmt *statement, int index, const std::string &str) in BindTextToStatement() argument
258 if (statement in BindTextToStatement()
271 BindInt64ToStatement(sqlite3_stmt *statement, int index, int64_t value) BindInt64ToStatement() argument
283 BindBlobToStatement(sqlite3_stmt *statement, int index, const std::vector<uint8_t> &value, bool permEmpty) BindBlobToStatement() argument
312 ResetStatement(sqlite3_stmt *&statement, bool isNeedFinalize, int &errCode) ResetStatement() argument
345 StepWithRetry(sqlite3_stmt *statement, bool isMemDb) StepWithRetry() argument
370 BindPrefixKey(sqlite3_stmt *statement, int index, const Key &keyPrefix) BindPrefixKey() argument
505 GetColumnBlobValue(sqlite3_stmt *statement, int index, std::vector<uint8_t> &value) GetColumnBlobValue() argument
531 GetColumnTextValue(sqlite3_stmt *statement, int index, std::string &value) GetColumnTextValue() argument
594 sqlite3_stmt* statement = nullptr; AttachNewDatabaseInner() local
646 sqlite3_stmt *statement = nullptr; CheckIntegrity() local
690 sqlite3_stmt *statement = nullptr; AnalysisSchemaSqlAndTrigger() local
731 sqlite3_stmt *statement = nullptr; GetSchemaIndexList() local
765 sqlite3_stmt *statement = nullptr; AnalysisSchemaIndexDefine() local
837 SetFieldInfo(sqlite3_stmt *statement, TableInfo &table) SetFieldInfo() argument
873 sqlite3_stmt *statement = nullptr; AnalysisSchemaFieldDefine() local
1040 sqlite3_stmt *statement = nullptr; GetVersion() local
1067 sqlite3_stmt *statement = nullptr; GetJournalMode() local
1209 sqlite3_stmt *statement = nullptr; SaveSchema() local
1256 sqlite3_stmt *statement = nullptr; GetSchema() local
1607 sqlite3_stmt *statement = nullptr; GetRelationalSchema() local
1648 sqlite3_stmt *statement = nullptr; GetLogTableVersion() local
[all...]
H A Dsqlite_single_ver_storage_executor.cpp41 // Finish current statement and remade one in ResetOrRegetStmt()
51 int GetEntryFromStatement(bool isGetValue, sqlite3_stmt *statement, std::vector<Entry> &entries) in GetEntryFromStatement() argument
54 int errCode = SQLiteUtils::GetColumnBlobValue(statement, 0, entry.key); in GetEntryFromStatement()
59 errCode = SQLiteUtils::GetColumnBlobValue(statement, 1, entry.value); in GetEntryFromStatement()
125 sqlite3_stmt *statement = nullptr; in GetKvData() local
126 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetKvData()
131 errCode = SQLiteUtils::BindBlobToStatement(statement, 1, key, false); // first arg. in GetKvData()
136 errCode = SQLiteUtils::StepWithRetry(statement, isMemDb_); in GetKvData()
144 errCode = SQLiteUtils::GetColumnBlobValue(statement, 0, value); // only one result. in GetKvData()
148 timestamp = static_cast<Timestamp>(sqlite3_column_int64(statement, GET_KV_RES_LOCAL_TIME_INDE in GetKvData()
158 BindPutKvData(sqlite3_stmt *statement, const Key &key, const Value &value, Timestamp timestamp, SingleVerDataType type) BindPutKvData() argument
197 sqlite3_stmt *statement = nullptr; GetKvDataByHashKey() local
251 sqlite3_stmt *statement = nullptr; SaveKvData() local
324 sqlite3_stmt *statement = nullptr; GetEntries() local
351 sqlite3_stmt *statement = nullptr; GetEntries() local
420 sqlite3_stmt *statement = nullptr; InitCurrentMaxStamp() local
433 PrepareForSyncDataByTime(Timestamp begin, Timestamp end, sqlite3_stmt *&statement, bool getDeletedData) const PrepareForSyncDataByTime() argument
475 GetDataItemForSync(sqlite3_stmt *statement, DataItem &dataItem) GetDataItemForSync() argument
500 GetSyncDataItems(std::vector<DataItem> &dataItems, sqlite3_stmt *statement, size_t appendLength, const DataSizeSpecInfo &dataSizeInfo) const GetSyncDataItems() argument
540 sqlite3_stmt *statement = nullptr; GetSyncDataByTimestamp() local
554 sqlite3_stmt *statement = nullptr; GetDeletedSyncDataByTimestamp() local
1088 sqlite3_stmt *statement = nullptr; GetDeviceIdentifier() local
1208 auto statement = saveSyncStatements_.GetDataSaveStatement(isUpdate); SaveSyncDataToDatabase() local
1264 auto statement = isSyncMigrating_ ? migrateSyncStatements_.queryStatement : saveSyncStatements_.queryStatement; GetSyncDataItemExt() local
1388 sqlite3_stmt *statement = nullptr; GetAllMetaKeys() local
1405 sqlite3_stmt *statement = nullptr; GetAllSyncedEntries() local
1438 GetAllEntries(sqlite3_stmt *statement, std::vector<Entry> &entries) const GetAllEntries() argument
1470 BindSavedSyncData(sqlite3_stmt *statement, const DataItem &dataItem, const Key &hashKey, const SyncDataDevices &devices, bool isUpdate) BindSavedSyncData() argument
1584 auto statement = isSyncMigrating_ ? migrateSyncStatements_.queryStatement : saveSyncStatements_.queryStatement; GetSyncDataPreByHashKey() local
1634 sqlite3_stmt *statement = nullptr; DeleteLocalDataInner() local
1723 StepForResultEntries(bool isGetValue, sqlite3_stmt *statement, std::vector<Entry> &entries) const StepForResultEntries() argument
1753 BindDevForSavedSyncData(sqlite3_stmt *statement, const DataItem &dataItem, const std::string &origDev, const std::string &deviceName) BindDevForSavedSyncData() argument
1918 GetOneRawDataItem(sqlite3_stmt *statement, DataItem &dataItem, uint64_t &verInCurCacheDb, bool isCacheDb) const GetOneRawDataItem() argument
1962 GetAllDataItems(sqlite3_stmt *statement, std::vector<DataItem> &dataItems, uint64_t &verInCurCacheDb, bool isCacheDb) const GetAllDataItems() argument
2246 BindSyncDataTime(sqlite3_stmt *statement, const DataItem &dataItem, bool isUpdate) BindSyncDataTime() argument
[all...]
H A Dsqlite_meta_executor.cpp24 sqlite3_stmt *statement = nullptr; in GetMetaKeysByKeyPrefix() local
39 int errCode = SQLiteUtils::GetStatement(dbHandle, sqlStr, statement); in GetMetaKeysByKeyPrefix()
41 LOGE("[SqliteMetaExecutor] Get statement failed:%d", errCode); in GetMetaKeysByKeyPrefix()
47 errCode = SQLiteUtils::BindBlobToStatement(statement, 1, keyPrefix); // 1: bind index for prefix key in GetMetaKeysByKeyPrefix()
49 LOGE("[SqliteMetaExecutor] Bind statement failed:%d", errCode); 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 in GetAllKeys()
[all...]
H A Dsqlite_single_ver_storage_executor_extend.cpp43 sqlite3_stmt *statement = nullptr; in CloudExcuteRemoveOrUpdate() local
44 errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in CloudExcuteRemoveOrUpdate()
54 errCode = SQLiteUtils::BindBlobToStatement(statement, bindIndex, useVect, true); in CloudExcuteRemoveOrUpdate()
56 errCode = SQLiteUtils::BindTextToStatement(statement, bindIndex, user); in CloudExcuteRemoveOrUpdate()
60 SQLiteUtils::ResetStatement(statement, true, ret); in CloudExcuteRemoveOrUpdate()
67 errCode = SQLiteUtils::BindBlobToStatement(statement, bindIndex, devVect, true); // only one arg. 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 in CloudCheckDataExist() local
306 PrepareForUnSyncTotalByTime(Timestamp begin, Timestamp end, sqlite3_stmt *&statement, bool getDeletedData) const PrepareForUnSyncTotalByTime() argument
[all...]
H A Dsqlite_query_helper.cpp345 int SqliteQueryHelper::BindSyncDataCheckStmt(sqlite3_stmt *statement, const Key &hashKey) const in BindSyncDataCheckStmt() argument
347 if (statement == nullptr) { in BindSyncDataCheckStmt()
350 int index = 1; // bind statement start index 1 in BindSyncDataCheckStmt()
351 int errCode = SQLiteUtils::BindBlobToStatement(statement, index++, hashKey, false); in BindSyncDataCheckStmt()
353 LOGE("Get sync data check statement failed when bind hash key, errCode = %d", errCode); in BindSyncDataCheckStmt()
358 errCode = SQLiteUtils::BindPrefixKey(statement, index, prefixKey_); in BindSyncDataCheckStmt()
360 LOGE("Get sync data check statement failed when bind prefix key, errCode = %d", errCode); in BindSyncDataCheckStmt()
366 errCode = BindKeysToStmt(keys_, statement, index); in BindSyncDataCheckStmt()
368 SQLiteUtils::ResetStatement(statement, true, errCode); in BindSyncDataCheckStmt()
373 errCode = BindFieldValue(statement, objNod in BindSyncDataCheckStmt()
400 GetQuerySqlStatement(sqlite3 *dbHandle, const std::string &sql, sqlite3_stmt *&statement) GetQuerySqlStatement() argument
436 GetQuerySqlStatement(sqlite3 *dbHandle, bool onlyRowid, sqlite3_stmt *&statement) GetQuerySqlStatement() argument
554 BindTimeRange(sqlite3_stmt *&statement, int &index, uint64_t beginTime, uint64_t endTime) const BindTimeRange() argument
569 BindObjNodes(sqlite3_stmt *&statement, int &index) const BindObjNodes() argument
583 GetQuerySyncStatement(sqlite3 *dbHandle, uint64_t beginTime, uint64_t endTime, sqlite3_stmt *&statement, bool isCount) GetQuerySyncStatement() argument
729 BindFieldValue(sqlite3_stmt *statement, const QueryObjNode &queryNode, int &index) const BindFieldValue() argument
970 GetRelationalMissQueryStatement(sqlite3 *dbHandle, uint64_t beginTime, uint64_t endTime, const std::vector<std::string> &fieldNames, sqlite3_stmt *&statement) GetRelationalMissQueryStatement() argument
1062 GetRelationalQueryStatement(sqlite3 *dbHandle, uint64_t beginTime, uint64_t endTime, const std::vector<std::string> &fieldNames, sqlite3_stmt *&statement) GetRelationalQueryStatement() argument
1138 BindKeysToStmt(const std::set<Key> &keys, sqlite3_stmt *&statement, int &index) const BindKeysToStmt() argument
1235 GetCloudQueryStatement(bool useTimestampAlias, sqlite3 *dbHandle, std::string &sql, sqlite3_stmt *&statement) GetCloudQueryStatement() argument
[all...]
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,
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Dstep_result_set.cpp49 auto statement = GetStatement(); in StepResultSet() local
50 if (statement == nullptr) { in StepResultSet()
53 std::tie(lastErr_, rowCount_) = statement->Count(); in StepResultSet()
76 * Obtain session and prepare precompile statement for step query
97 auto [errCode, statement] = conn_->CreateStatement(sql_, conn_); in PrepareStep()
98 if (statement == nullptr || errCode != E_OK) { in PrepareStep()
103 if (!statement->ReadOnly()) { in PrepareStep()
109 errCode = statement->Bind(args_); in PrepareStep()
112 statement->Reset(); in PrepareStep()
113 statement in PrepareStep()
130 auto statement = GetStatement(); GetColumnNames() local
158 auto statement = GetStatement(); GetColumnType() local
221 auto statement = GetStatement(); GoToNextRow() local
306 auto statement = GetStatement(); Reset() local
331 auto statement = GetStatement(); GetSize() local
358 auto statement = GetStatement(); GetValueObject() local
[all...]
H A Dtrans_db.cpp65 auto [errCode, statement] = GetStatement(sql); in Insert()
66 if (statement == nullptr) { in Insert()
69 errCode = statement->Execute(args); in Insert()
73 rowid = statement->Changes() > 0 ? statement->LastInsertRowId() : -1; in Insert()
90 auto [errCode, statement] = GetStatement(sql); in BatchInsert()
91 if (statement == nullptr) { in BatchInsert()
95 errCode = statement->Execute(args); in BatchInsert()
139 auto [errCode, statement] = GetStatement(sql); in Update()
140 if (statement in Update()
[all...]
H A Dsqlite_shared_result_set.cpp51 auto [statement, errCode] = PrepareStep(); in SqliteSharedResultSet()
56 statement_ = statement; in SqliteSharedResultSet()
116 auto [errCode, statement] = conn_->CreateStatement(qrySql_, conn_); in PrepareStep()
117 if (statement == nullptr) { in PrepareStep()
119 return { statement, errCode }; in PrepareStep()
122 if (!statement->ReadOnly()) { in PrepareStep()
128 errCode = statement->Bind(bindArgs_); in PrepareStep()
131 statement->Reset(); in PrepareStep()
132 statement = nullptr; in PrepareStep()
136 return { statement, E_O in PrepareStep()
[all...]
H A Drdb_store_impl.cpp812 auto [err, statement] = GetStatement(GlobalExpr::PRAGMA_VERSION); in ModifyLockStatus()
813 if (statement == nullptr || err != E_OK) { in ModifyLockStatus()
816 int errCode = statement->ModifyLockStatus(predicates.GetTableName(), hashKeys, isLock); in ModifyLockStatus()
1012 auto [errCode, statement] = GetStatement(sql, connection); in BatchInsert()
1013 if (statement == nullptr) { in BatchInsert()
1017 auto errCode = statement->Execute(args); in BatchInsert()
1157 auto [errCode, statement] = BeginExecuteSql(sql); in ExecuteSql()
1158 if (statement == nullptr) { in ExecuteSql()
1161 errCode = statement->Execute(args); in ExecuteSql()
1171 statement in ExecuteSql()
1233 HandleDifferentSqlTypes(std::shared_ptr<Statement> statement, const std::string &sql, const ValueObject &object, int sqlType) HandleDifferentSqlTypes() argument
1564 SetDefaultEncryptSql( const std::shared_ptr<Statement> &statement, std::string sql, const RdbStoreConfig &config) SetDefaultEncryptSql() argument
[all...]
H A Dshare_block.cpp197 FillOneRowResult FillOneRow(AppDataFwk::SharedBlock *sharedBlock, sqlite3_stmt *statement, int numColumns, in FillOneRow() argument
209 int type = sqlite3_column_type(statement, i); in FillOneRow()
212 result = FillOneRowOfString(sharedBlock, statement, startPos, addedRows, i); in FillOneRow()
215 result = FillOneRowOfLong(sharedBlock, statement, startPos, addedRows, i); in FillOneRow()
218 result = FillOneRowOfFloat(sharedBlock, statement, startPos, addedRows, i); in FillOneRow()
221 result = FillOneRowOfBlob(sharedBlock, statement, startPos, addedRows, i); in FillOneRow()
224 result = FillOneRowOfNull(sharedBlock, statement, startPos, addedRows, i); in FillOneRow()
245 FillOneRowResult FillOneRowOfString(AppDataFwk::SharedBlock *sharedBlock, sqlite3_stmt *statement, int startPos, in FillOneRowOfString() argument
248 const char *text = reinterpret_cast<const char *>(sqlite3_column_text(statement, pos)); in FillOneRowOfString()
254 auto sizeIncludingNull = sqlite3_column_bytes(statement, po in FillOneRowOfString()
265 FillOneRowOfLong(AppDataFwk::SharedBlock *sharedBlock, sqlite3_stmt *statement, int startPos, int addedRows, int pos) FillOneRowOfLong() argument
278 FillOneRowOfFloat(AppDataFwk::SharedBlock *sharedBlock, sqlite3_stmt *statement, int startPos, int addedRows, int pos) FillOneRowOfFloat() argument
291 FillOneRowOfBlob(AppDataFwk::SharedBlock *sharedBlock, sqlite3_stmt *statement, int startPos, int addedRows, int pos) FillOneRowOfBlob() argument
318 FillOneRowOfNull(AppDataFwk::SharedBlock *sharedBlock, sqlite3_stmt *statement, int startPos, int addedRows, int pos) FillOneRowOfNull() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_relational_utils.cpp25 int SQLiteRelationalUtils::GetDataValueByType(sqlite3_stmt *statement, int cid, DataValue &value) in GetDataValueByType() argument
27 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()
42 errCode = SQLiteUtils::GetColumnBlobValue(statement, cid, blobValue); in GetDataValueByType()
62 (void)SQLiteUtils::GetColumnTextValue(statement, cid, str); in GetDataValueByType()
86 int SQLiteRelationalUtils::GetCloudValueByType(sqlite3_stmt *statement, int type, int cid, Type &cloudValue) in GetCloudValueByType() argument
88 if (statement in GetCloudValueByType()
162 BindStatementByType(sqlite3_stmt *statement, int cid, Type &typeVal) BindStatementByType() argument
198 BindExtendStatementByType(sqlite3_stmt *statement, int cid, Type &typeVal) BindExtendStatementByType() argument
[all...]
H A Dsqlite_relational_utils.h28 static int GetDataValueByType(sqlite3_stmt *statement, int cid, DataValue &value);
32 static int GetCloudValueByType(sqlite3_stmt *statement, int type, int cid, Type &cloudValue);
36 static int BindStatementByType(sqlite3_stmt *statement, int cid, Type &typeVal);
51 static int BindExtendStatementByType(sqlite3_stmt *statement, int cid, Type &typeVal);
/foundation/filemanagement/storage_service/services/storage_daemon/include/libfscrypt/
H A Dfscrypt_log.h34 #define FSCRYPT_ERROR_CHECK(ret, statement, format, ...) \
38 statement; \
42 #define FSCRYPT_CHECK(ret, statement) \
45 statement; \
/foundation/multimedia/av_codec/services/dfx/include/
H A Davcodec_xcollie.h60 #define COLLIE_LISTEN(statement, args...) { AVCodecXcollieTimer xCollie(args); statement; }
61 #define CLIENT_COLLIE_LISTEN(statement, name) { AVCodecXcollieTimer xCollie(name, false, false, 30); statement; }
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_kvstore_test.cpp582 sqlite3_stmt *statement = nullptr; in SetFlag() local
583 errCode = SQLiteUtils::GetStatement(db_, sql, statement); in SetFlag()
585 SQLiteUtils::ResetStatement(statement, true, errCode); in SetFlag()
588 errCode = SQLiteUtils::BindInt64ToStatement(statement, 1, static_cast<int64_t>(flag)); // 1st arg. in SetFlag()
590 errCode = SQLiteUtils::BindBlobToStatement(statement, 2, key, true); // 2nd arg. in SetFlag()
593 SQLiteUtils::ResetStatement(statement, true, errCode); in SetFlag()
595 EXPECT_EQ(SQLiteUtils::StepWithRetry(statement), SQLiteUtils::MapSQLiteErrno(SQLITE_DONE)); in SetFlag()
596 SQLiteUtils::ResetStatement(statement, true, errCode); in SetFlag()
612 sqlite3_stmt *statement = nullptr; in CheckFlag() local
613 errCode = SQLiteUtils::GetStatement(db_, sql, statement); in CheckFlag()
662 sqlite3_stmt *statement = nullptr; CheckWaterMark() local
703 sqlite3_stmt *statement = nullptr; SetDeviceId() local
740 sqlite3_stmt *statement = nullptr; CheckLogTable() local
782 sqlite3_stmt *statement = nullptr; ChangeUserId() local
820 sqlite3_stmt *statement = nullptr; ChangeHashKey() local
[all...]
/foundation/graphic/graphic_2d/rosen/modules/2d_graphics/include/utils/
H A Dtext_log.h150 #define TEXT_ERROR_CHECK(ret, statement, format, ...) \
154 statement; \
158 #define TEXT_INFO_CHECK(ret, statement, format, ...) \
162 statement; \
166 #define TEXT_CHECK(ret, statement) \
169 statement; \
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Dshare_block.h71 FillOneRowResult FillOneRowOfString(AppDataFwk::SharedBlock *sharedBlock, sqlite3_stmt *statement, int startPos,
73 FillOneRowResult FillOneRowOfLong(AppDataFwk::SharedBlock *sharedBlock, sqlite3_stmt *statement, int startPos,
75 FillOneRowResult FillOneRowOfFloat(AppDataFwk::SharedBlock *sharedBlock, sqlite3_stmt *statement, int startPos,
77 FillOneRowResult FillOneRowOfBlob(AppDataFwk::SharedBlock *sharedBlock, sqlite3_stmt *statement, int startPos,
79 FillOneRowResult FillOneRowOfNull(AppDataFwk::SharedBlock *sharedBlock, sqlite3_stmt *statement, int startPos,
81 FillOneRowResult FillOneRow(AppDataFwk::SharedBlock *sharedBlock, sqlite3_stmt *statement, int numColumns,

Completed in 19 milliseconds

123