Home
last modified time | relevance | path

Searched refs:sqlite3 (Results 1 – 25 of 144) sorted by relevance

123456

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_utils.h85 static int CommitTransaction(sqlite3 *db);
87 static int RollbackTransaction(sqlite3 *db);
113 static int SetUserVer(sqlite3 *db, int version);
129 static int RegisterJsonFunctions(sqlite3 *db);
147 static int RegisterCalcHash(sqlite3 *db);
149 static int RegisterGetSysTime(sqlite3 *db);
151 static int RegisterGetLastTime(sqlite3 *db);
153 static int RegisterGetRawSysTime(sqlite3 *db);
177 static void ExecuteCheckPoint(sqlite3 *db);
181 static int SetPersistWalMode(sqlite3 *db);
[all …]
H A Dsqlite_cloud_kv_executor_utils.h31 using DBParam = std::pair<sqlite3 *, bool>;
32 using FillGidParam = std::pair<sqlite3 *, bool>;
39 static int PutCloudData(sqlite3 *db, bool isMemory, DownloadData &downloadData);
44 …static std::pair<int, int64_t> CountCloudData(sqlite3 *db, bool isMemory, const Timestamp &timesta…
52 static int GetCloudVersionFromCloud(sqlite3 *db, bool isMemory, const std::string &user,
55 static int GetWaitCompensatedSyncDataPk(sqlite3 *db, bool isMemory, std::vector<VBucket> &data);
59 static int GetWaitCompensatedSyncData(sqlite3 *db, bool isMemory, std::vector<VBucket> &data,
86 static int ExecutePutCloudData(sqlite3 *db, bool isMemory, DownloadData &downloadData,
89 static int OperateCloudData(sqlite3 *db, bool isMemory, int index, OpType opType,
141 static int FillCloudVersionRecord(sqlite3 *db, OpType opType, const CloudSyncData &data);
[all …]
H A Dsqlite_single_ver_storage_engine.h66 …virtual StorageExecutor *NewSQLiteStorageExecutor(sqlite3 *dbHandle, bool isWrite, bool isMemDb) o…
68 int Upgrade(sqlite3 *db) override;
77 int EndCreateExecutor(sqlite3 *db, bool isWrite, bool isDetachMeta);
99 int TryToOpenMainDatabase(bool isWrite, sqlite3 *&db);
100 int GetCacheDbHandle(sqlite3 *&db);
101 int GetDbHandle(bool isWrite, const SecurityOption &secOpt, sqlite3 *&dbHandle);
102 int AttachMetaDatabase(sqlite3 *dbHandle, const OpenDbProperties &option) const;
104 int AttachMainDbAndCacheDb(sqlite3 *dbHandle, EngineState stateBeforeMigrate) const;
105 void RegisterFunctionIfNeed(sqlite3 *dbHandle) const;
106 int TryAttachMetaDb(const SecurityOption &existedSecOpt, sqlite3 *&dbHandle, bool &isAttachMeta,
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);
76 int GetCountSqlStatement(sqlite3 *dbHandle, sqlite3_stmt *&countStmt);
79 …int GetQuerySyncStatement(sqlite3 *dbHandle, uint64_t beginTime, uint64_t endTime, sqlite3_stmt *&…
98 int GetRelationalMissQueryStatement(sqlite3 *dbHandle, uint64_t beginTime, uint64_t endTime,
102 int GetRelationalQueryStatement(sqlite3 *dbHandle, uint64_t beginTime, uint64_t endTime,
112 …int GetCloudQueryStatement(bool useTimestampAlias, sqlite3 *dbHandle, uint64_t beginTime, std::str…
115 …int GetAndBindGidKvCloudQueryStatement(const std::string &user, sqlite3 *dbHandle, sqlite3_stmt *&…
117 …int GetCountKvCloudDataStatement(sqlite3 *db, bool forcePush, const CloudWaterType mode, sqlite3_s…
119 …std::pair<int, int64_t> BindCountKvCloudDataStatement(sqlite3 *db, bool isMemory, const Timestamp …
[all …]
H A Dsqlite_utils.cpp203 sqlite3 *dbTemp = nullptr; in OpenDatabase()
425 int SQLiteUtils::CommitTransaction(sqlite3 *db) in CommitTransaction()
430 int SQLiteUtils::RollbackTransaction(sqlite3 *db) in RollbackTransaction()
640 sqlite3 *db = nullptr; in CreateMetaDatabase()
1011 sqlite3 *dbTemp = nullptr; in GetVersion()
1098 sqlite3 *db = nullptr; in SetUserVer()
1183 sqlite3 *db = nullptr; in ExportDatabase()
1391 int SQLiteUtils::RegisterCalcHash(sqlite3 *db) in RegisterCalcHash()
1447 sqlite3 *db = static_cast<sqlite3 *>(sqlite3_user_data(ctx)); in CloudDataChangedServerObserver()
2267 int64_t SQLiteUtils::GetLastRowId(sqlite3 *db) in GetLastRowId()
[all …]
H A Dsqlite_log_table_manager.h32 …int AddRelationalLogTableTrigger(sqlite3 *db, const TableInfo &table, const std::string &identity);
34 int CreateRelationalLogTable(sqlite3 *db, const TableInfo &table);
36 static int CreateKvSyncLogTable(sqlite3 *db);
49 static int UpgradeKvSyncLogTable(const std::string &tableName, sqlite3 *db);
50 static int CreateKvCloudFlagIndex(const std::string &tableName, sqlite3 *db);
H A Dsqlite_storage_executor.h26 SQLiteStorageExecutor(sqlite3 *dbHandle, bool writable, bool isMemDb);
33 int GetDbHandle(sqlite3 *&dbHandle) const;
36 sqlite3 *dbHandle_;
H A Dsqlite_log_table_manager.cpp19 int SqliteLogTableManager::AddRelationalLogTableTrigger(sqlite3 *db, const TableInfo &table, in AddRelationalLogTableTrigger()
46 int SqliteLogTableManager::CreateRelationalLogTable(sqlite3 *db, const TableInfo &table) in CreateRelationalLogTable()
80 int SqliteLogTableManager::CreateKvSyncLogTable(sqlite3 *db) in CreateKvSyncLogTable()
122 int SqliteLogTableManager::UpgradeKvSyncLogTable(const std::string &tableName, sqlite3 *db) in UpgradeKvSyncLogTable()
142 int SqliteLogTableManager::CreateKvCloudFlagIndex(const std::string &tableName, sqlite3 *db) in CreateKvCloudFlagIndex()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/relational/
H A Drelational_store_client.h27 typedef struct sqlite3 sqlite3; typedef
36 DB_API DistributedDB::DBStatus RegisterClientObserver(sqlite3 *db, const ClientObserver &clientObse…
38 DB_API DistributedDB::DBStatus UnRegisterClientObserver(sqlite3 *db);
40 DB_API DistributedDB::DBStatus RegisterStoreObserver(sqlite3 *db, const std::shared_ptr<StoreObserv…
42 DB_API DistributedDB::DBStatus UnregisterStoreObserver(sqlite3 *db,
45 DB_API DistributedDB::DBStatus UnregisterStoreObserver(sqlite3 *db);
47 DB_API DistributedDB::DBStatus DropLogicDeletedData(sqlite3 *db, const std::string &tableName, uint…
50 sqlite3 *db);
53 sqlite3 *db);
H A Drelational_store_sqlite_ext.h29 int (*open)(const char *, sqlite3 **);
30 int (*open16)(const void *, sqlite3 **);
31 int (*open_v2)(const char *, sqlite3 **, int, const char *);
/ohos5.0/foundation/distributeddatamgr/relational_store/rdbmock/frameworks/native/rdb/
H A Drelational_store_client.h37 DistributedDB::DBStatus UnRegisterClientObserver(sqlite3 *db);
39 DistributedDB::DBStatus RegisterStoreObserver(sqlite3 *db,
42 DistributedDB::DBStatus UnregisterStoreObserver(sqlite3 *db,
45 DistributedDB::DBStatus UnregisterStoreObserver(sqlite3 *db);
48 const std::string &tableName, const std::vector<std::vector<uint8_t>> &hashKey, sqlite3 *db);
51 const std::string &tableName, const std::vector<std::vector<uint8_t>> &hashKey, sqlite3 *db);
52 DistributedDB::DBStatus DropLogicDeletedData(sqlite3* db,
H A Dmock.cpp69 __attribute__((visibility("default"))) DBStatus UnRegisterClientObserver(sqlite3 *db) in UnRegisterClientObserver()
74 __attribute__((visibility("default"))) DBStatus RegisterStoreObserver(sqlite3 *db, in RegisterStoreObserver()
80 __attribute__((visibility("default"))) DBStatus UnregisterStoreObserver(sqlite3 *db, in UnregisterStoreObserver()
86 __attribute__((visibility("default"))) DBStatus UnregisterStoreObserver(sqlite3 *db) in UnregisterStoreObserver()
92 const std::vector<std::vector<uint8_t>> &hashKey, sqlite3 *db) in Lock()
98 const std::string &tableName, const std::vector<std::vector<uint8_t>> &hashKey, sqlite3 *db) in UnLock()
103 __attribute__((visibility("default"))) DBStatus DropLogicDeletedData(sqlite3 *db, const std::string… in DropLogicDeletedData()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/
H A Drd_sqlite_utils.h33 static int CreateDataBase(const std::string &path, int flag, sqlite3 *&db);
35 static int GetStatement(sqlite3 *db, const std::string &sql, sqlite3_stmt *&statement);
44 static int BeginTransaction(sqlite3 *db, TransactType type = TransactType::DEFERRED);
45 static int CommitTransaction(sqlite3 *db);
46 static int RollbackTransaction(sqlite3 *db);
48 static int ExecSql(sqlite3 *db, const std::string &sql);
49 …static int ExecSql(sqlite3 *db, const std::string &sql, const std::function<int(sqlite3_stmt *)> &…
H A Drd_sqlite_utils.cpp59 int RDSQLiteUtils::CreateDataBase(const std::string &path, int flag, sqlite3 *&db) in CreateDataBase()
86 int RDSQLiteUtils::GetStatement(sqlite3 *db, const std::string &sql, sqlite3_stmt *&statement) in GetStatement()
207 int RDSQLiteUtils::BeginTransaction(sqlite3 *db, TransactType type) in BeginTransaction()
216 int RDSQLiteUtils::CommitTransaction(sqlite3 *db) in CommitTransaction()
221 int RDSQLiteUtils::RollbackTransaction(sqlite3 *db) in RollbackTransaction()
226 int RDSQLiteUtils::ExecSql(sqlite3 *db, const std::string &sql) in ExecSql()
242 int RDSQLiteUtils::ExecSql(sqlite3 *db, const std::string &sql, const std::function<int(sqlite3_stm… in ExecSql()
/ohos5.0/base/security/asset/services/db_operator/src/
H A Dsqlite3_wrapper.c23 return sqlite3_open(fileName, (sqlite3 **)ppDb); in SqliteOpen()
28 return sqlite3_close_v2((sqlite3 *)db); in SqliteCloseV2()
33 return sqlite3_exec((sqlite3 *)db, zSql, NULL, NULL, pzErrMsg); in SqliteExec()
48 return sqlite3_changes((sqlite3 *)db); in SqliteChanges()
53 return sqlite3_prepare_v2((sqlite3 *)db, zSql, -1, (sqlite3_stmt **)ppStmt, pzTail); in SqlitePrepareV2()
68 return sqlite3_errmsg((sqlite3 *)db); in SqliteErrMsg()
118 return sqlite3_key((sqlite3 *)db, pKey, nKey); in SqliteKey()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_store_sqlite_ext.cpp490 int RegisterCalcHash(sqlite3 *db) in RegisterCalcHash()
652 sqlite3 *db = static_cast<sqlite3 *>(sqlite3_user_data(ctx)); in CloudDataChangedObserver()
745 sqlite3 *db = static_cast<sqlite3 *>(sqlite3_user_data(ctx)); in DataChangedObserver()
999 sqlite3 *db = static_cast<sqlite3 *>(data); in RollbackHookCallback()
1016 int RegisterGetSysTime(sqlite3 *db) in RegisterGetSysTime()
1023 int RegisterGetLastTime(sqlite3 *db) in RegisterGetLastTime()
1030 int RegisterGetRawSysTime(sqlite3 *db) in RegisterGetRawSysTime()
1440 sqlite3 *db, bool isLock) in HandleDataLock()
1536 int CreateTempTrigger(sqlite3 *db) in CreateTempTrigger()
1752 sqlite3 *db) in Lock()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_continue_token.h35 …int GetStatement(sqlite3 *db, sqlite3_stmt *&queryStmt, sqlite3_stmt *&fullStmt, bool &isGettingDe…
43 …int GetCloudStatement(sqlite3 *db, CloudSyncData &cloudDataResult, sqlite3_stmt *&queryStmt, bool …
48 int GetQuerySyncStatement(sqlite3 *db, sqlite3_stmt *&stmt);
49 int GetDeletedDataStmt(sqlite3 *db, sqlite3_stmt *&stmt) const;
50 int GetMissQueryStatement(sqlite3 *db, sqlite3_stmt *&stmt);
H A Dsqlite_relational_utils.h40 static bool GetDbFileName(sqlite3 *db, std::string &fileName);
42 static int SelectServerObserver(sqlite3 *db, const std::string &tableName, bool isChanged);
47 …static int AnalysisTrackerTable(sqlite3 *db, const TrackerTable &trackerTable, TableInfo &tableInf…
49 static int QueryCount(sqlite3 *db, const std::string &tableName, int64_t &count);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_db_sync_utils_test.h49 static void CreateUserDBAndTable(sqlite3 *&db, std::string sql);
60 static void DeleteUserTableRecord(sqlite3 *&db, int64_t begin, int64_t count);
78 …static void CheckDownloadResult(sqlite3 *&db, std::vector<int64_t> expectCounts, const std::string…
80 static void CheckLocalRecordNum(sqlite3 *&db, const std::string &tableName, int count);
88 static void CheckCount(sqlite3 *db, const std::string &sql, int64_t count);
90 static void GetHashKey(const std::string &tableName, const std::string &condition, sqlite3 *db,
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_data_inserter.h66 int PrepareStatement(sqlite3 *db, SaveSyncDataStmt &stmt);
67 int GetDeleteLogStmt(sqlite3 *db, sqlite3_stmt *&stmt);
68 int GetDeleteSyncDataStmt(sqlite3 *db, sqlite3_stmt *&stmt);
72 int GetInsertStatement(sqlite3 *db, sqlite3_stmt *&stmt);
74 int GetSaveLogStatement(sqlite3 *db, sqlite3_stmt *&logStmt, sqlite3_stmt *&queryStmt);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/include/
H A Ddistributed_rdb_tools.h98 static bool InitSqlite3Store(sqlite3 *&db, const RdbParameters &param);
99 static bool InitTableDataAndTrigger(const sqlite3 *&db) ;
100 static bool AlterTableAttributes(const sqlite3 *&db);
101 static bool Sqlite3ExecOpration(const sqlite3 *&db, cont char *&sql_name);
102 static void CloseSqlite3Store(sqlite3 *&db);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_tools_unit_test.h338 static sqlite3 *CreateDataBase(const std::string &dbUri);
339 static int ExecSql(sqlite3 *db, const std::string &sql);
340 …static int ExecSql(sqlite3 *db, const std::string &sql, const std::function<int (sqlite3_stmt *)> …
342 static void CreateDeviceTable(sqlite3 *db, const std::string &table, const std::string &device);
343 static int CheckSqlResult(sqlite3 *db, const std::string &sql, bool &result);
344 static int CheckTableRecords(sqlite3 *db, const std::string &table);
345 static int GetMetaData(sqlite3 *db, const DistributedDB::Key &key, DistributedDB::Value &value);
346 …static int SetMetaData(sqlite3 *db, const DistributedDB::Key &key, const DistributedDB::Value &val…
350 static int SelectData(sqlite3 *db, const DistributedDB::TableSchema &schema,
356 …static std::vector<DistributedDB::Assets> GetAllAssets(sqlite3 *db, const DistributedDB::TableSche…
[all …]
H A Dnative_sqlite.h30 static sqlite3 *CreateDataBase(const std::string &dbUri);
32 static int ExecSql(sqlite3 *db, const std::string &sql);
34 …static int ExecSql(sqlite3 *db, const std::string &sql, const std::function<int (sqlite3_stmt *)> …
H A Dnative_sqlite.cpp19 sqlite3 *NativeSqlite::CreateDataBase(const std::string &dbUri) in CreateDataBase()
22 sqlite3 *db = nullptr; in CreateDataBase()
34 int NativeSqlite::ExecSql(sqlite3 *db, const std::string &sql) in ExecSql()
48 int NativeSqlite::ExecSql(sqlite3 *db, const std::string &sql, const std::function<int (sqlite3_stm… in ExecSql()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/
H A Ddistributed_rdb_tools.cpp123 bool DistributedRdbTools::InitSqlite3Store(sqlite3 *&db, const RdbParameters &param) in InitSqlite3Store()
141 void SqliteExecSql(sqlite3 *db, const char *sql) in SqliteExecSql()
154 bool DistributedRdbTools::InitTableDataAndTrigger(const sqlite3 *&db) in InitTableDataAndTrigger()
178 bool DistributedRdbTools::AlterTableAttributes(const sqlite3 *&db) in AlterTableAttributes()
224 bool DistributedRdbTools::Sqlite3ExecOpration(const sqlite3 *&db, cont char *&sql_name) in Sqlite3ExecOpration()
238 void DistributedRdbTools::CloseSqlite3Store(sqlite3 *&db) in CloseSqlite3Store()

123456