Home
last modified time | relevance | path

Searched refs:SqliteUtils (Results 1 - 24 of 24) sorted by relevance

/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_utils_test.cpp50 EXPECT_EQ(true, SqliteUtils::IsSpecial(5)); in HWTEST_F()
51 EXPECT_EQ(true, SqliteUtils::IsSpecial(6)); in HWTEST_F()
52 EXPECT_EQ(true, SqliteUtils::IsSpecial(7)); in HWTEST_F()
83 EXPECT_EQ(0, SqliteUtils::GetFileSize("")); in HWTEST_F()
93 EXPECT_EQ(0, SqliteUtils::GetFileSize("act.txt")); in HWTEST_F()
103 EXPECT_EQ(SqliteUtils::STATEMENT_SELECT, SqliteUtils::GetSqlStatementType("select * from text")); in HWTEST_F()
104 EXPECT_EQ(SqliteUtils::STATEMENT_UPDATE, SqliteUtils::GetSqlStatementType("update test set id = ?")); in HWTEST_F()
105 EXPECT_EQ(SqliteUtils in HWTEST_F()
[all...]
H A Dsqlite_utils_test.cpp44 EXPECT_EQ(SqliteUtils::Anonymous("30005245854585524412855412_rdb_test.db"), "***5412_rdb_test.db"); in HWTEST_F()
49 EXPECT_EQ(SqliteUtils::Anonymous("rdb_test_30005245854585524412855412.db"), "rdb_test_***5412.db"); in HWTEST_F()
54 EXPECT_EQ(SqliteUtils::Anonymous("rdb_30005245854585524412855412_test.db"), "rdb_***5412_test.db"); in HWTEST_F()
59 EXPECT_EQ(SqliteUtils::Anonymous("rdb_300052_test.db"), "rdb_***052_test.db"); in HWTEST_F()
64 EXPECT_EQ(SqliteUtils::Anonymous("rdb_30005_test.db"), "rdb_30005_test.db"); in HWTEST_F()
69 EXPECT_EQ(SqliteUtils::Anonymous("rdb_3000523_test.db"), "rdb_***0523_test.db"); in HWTEST_F()
74 EXPECT_EQ(SqliteUtils::Anonymous( in HWTEST_F()
82 SqliteUtils::Anonymous("file /data/stage/database/rdb/ddddddd/30005245854585524412855412_rdb_test.db"), in HWTEST_F()
88 EXPECT_EQ(SqliteUtils::Anonymous( in HWTEST_F()
95 EXPECT_EQ(SqliteUtils in HWTEST_F()
[all...]
H A Drdb_double_write_test.cpp800 SqliteUtils::DeleteFile(DATABASE_NAME); in HWTEST_F()
801 SqliteUtils::DeleteFile(DATABASE_NAME + "-shm"); in HWTEST_F()
802 SqliteUtils::DeleteFile(DATABASE_NAME + "-wal"); in HWTEST_F()
H A Drdb_store_rekey_test.cpp319 SqliteUtils::DeleteFile(keyPath); in HWTEST_F()
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Dsqlite_utils.h27 class SqliteUtils { class
73 { "ALT", SqliteUtils::STATEMENT_DDL },
74 { "ATT", SqliteUtils::STATEMENT_ATTACH },
75 { "BEG", SqliteUtils::STATEMENT_BEGIN },
76 { "COM", SqliteUtils::STATEMENT_COMMIT },
77 { "CRE", SqliteUtils::STATEMENT_DDL },
78 { "DEL", SqliteUtils::STATEMENT_UPDATE },
79 { "DET", SqliteUtils::STATEMENT_DETACH },
80 { "DRO", SqliteUtils::STATEMENT_DDL },
81 { "END", SqliteUtils
[all...]
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Dsqlite_utils.cpp15 #define LOG_TAG "SqliteUtils"
46 constexpr SqliteUtils::SqlType SqliteUtils::SQL_TYPE_MAP[];
47 constexpr const char *SqliteUtils::ON_CONFLICT_CLAUSE[];
49 int SqliteUtils::GetSqlStatementType(const std::string &sql) in GetSqlStatementType()
74 std::string SqliteUtils::StrToUpper(std::string s) in StrToUpper()
80 void SqliteUtils::Replace(std::string &src, const std::string &rep, const std::string &dst) in Replace()
92 bool SqliteUtils::IsSupportSqlForExecute(int sqlType) in IsSupportSqlForExecute()
98 bool SqliteUtils::IsSqlReadOnly(int sqlType) in IsSqlReadOnly()
103 bool SqliteUtils
[all...]
H A Drdb_service_proxy.cpp25 using SqliteUtils = OHOS::NativeRdb::SqliteUtils;
119 status, param.bundleName_.c_str(), SqliteUtils::Anonymous(param.storeName_).c_str()); in DoSync()
153 param.bundleName_.c_str(), SqliteUtils::Anonymous(param.storeName_).c_str(), option.seqNum); in DoAsync()
166 SqliteUtils::Anonymous(param.storeName_).c_str()); in DoAsync()
171 SqliteUtils::Anonymous(param.storeName_).c_str(), asyncOption.seqNum); in DoAsync()
188 status, param.bundleName_.c_str(), SqliteUtils::Anonymous(param.storeName_).c_str(), type); in SetDistributedTables()
229 LOG_ERROR("duplicate observer, storeName:%{public}s", SqliteUtils::Anonymous(key).c_str()); in Subscribe()
246 status, param.bundleName_.c_str(), SqliteUtils::Anonymous(param.storeName_).c_str()); in DoSubscribe()
279 SqliteUtils in DoUnSubscribe()
[all...]
H A Drdb_sql_utils.cpp56 SqliteUtils::Anonymous(databaseDirectory).c_str()); in CreateDirectory()
86 SqliteUtils::Anonymous(baseDir).c_str(), SqliteUtils::Anonymous(name).c_str(), in GetDefaultDatabasePath()
87 SqliteUtils::Anonymous(customDir).c_str()); in GetDefaultDatabasePath()
101 SqliteUtils::Anonymous(baseDir).c_str(), SqliteUtils::Anonymous(name).c_str()); in GetDefaultDatabasePath()
H A Dtrans_db.cpp38 auto conflictClause = SqliteUtils::GetConflictClause(static_cast<int>(resolution)); in Insert()
100 SqliteUtils::Anonymous(name_).c_str(), table.c_str(), args.size()); in BatchInsert()
111 auto clause = SqliteUtils::GetConflictClause(static_cast<int>(resolution)); in Update()
197 int sqlType = SqliteUtils::GetSqlStatementType(sql); in Execute()
198 if (!SqliteUtils::IsSupportSqlForExecute(sqlType) && !SqliteUtils::IsSpecial(sqlType)) { in Execute()
214 if (sqlType == SqliteUtils::STATEMENT_INSERT) { in Execute()
219 if (sqlType == SqliteUtils::STATEMENT_UPDATE) { in Execute()
224 if (sqlType == SqliteUtils::STATEMENT_PRAGMA) { in Execute()
230 if (sqlType == SqliteUtils in Execute()
[all...]
H A Drdb_helper.cpp83 LOG_ERROR("Store to delete doesn't exist, path %{public}s", SqliteUtils::Anonymous(dbFileName).c_str()); in DeleteRdbStore()
91 DeleteRdbStore(SqliteUtils::GetSlavePath(dbFileName)); in DeleteRdbStore()
101 errCodeSqlite, errCodeVector, SqliteUtils::Anonymous(dbFileName).c_str()); in DeleteRdbStore()
113 LOG_ERROR("not exist, path %{public}s", SqliteUtils::Anonymous(dbFile).c_str()); in DeleteRdbStore()
120 LOG_INFO("Delete rdb store, path %{public}s", SqliteUtils::Anonymous(dbFile).c_str()); in DeleteRdbStore()
H A Drdb_store_manager.cpp76 config.GetBundleName().c_str(), config.GetModuleName().c_str(), SqliteUtils::Anonymous(path).c_str(), in GetStoreFromCache()
80 Connection::Collect(config), SqliteUtils::Anonymous(config.GetName())) in GetStoreFromCache()
113 SqliteUtils::Anonymous(config.GetName()).c_str(), config.GetSecurityLevel(), errCode); in GetRdbStore()
124 SqliteUtils::Anonymous(config.GetName()).c_str(), SqliteUtils::Anonymous(config.GetPath()).c_str(), in GetRdbStore()
139 LOG_WARN("Config has no bundleName, path: %{public}s", SqliteUtils::Anonymous(path).c_str()); in IsConfigInvalidChanged()
143 LOG_WARN("Not found config cache, path: %{public}s", SqliteUtils::Anonymous(path).c_str()); in IsConfigInvalidChanged()
156 SqliteUtils::Anonymous(path).c_str(), tempParam.level_, param.level_, tempParam.area_, param.area_, in IsConfigInvalidChanged()
281 SqliteUtils::Anonymous(param.storeName_).c_str(), err); in Delete()
310 SqliteUtils in Collector()
[all...]
H A Drdb_store_impl.cpp128 SqliteUtils::Anonymous(param.storeName_).c_str()); in AfterOpen()
140 SqliteUtils::Anonymous(param.storeName_).c_str()); in AfterOpen()
153 if (SqliteUtils::StrToUpper(columnName) == ROW_ID) { in GetModifyTime()
216 SqliteUtils::Anonymous(table).c_str(), isReadOnly_, config_.GetDBType()); in CleanDirtyData()
221 LOG_ERROR("db is busy. table:%{public}s", SqliteUtils::Anonymous(table).c_str()); in CleanDirtyData()
474 SqliteUtils::Anonymous(config_.GetName()).c_str(), errCode); in SubscribeLocalDetail()
607 SqliteUtils::Anonymous(config_.GetName()).c_str(), errCode); in UnsubscribeLocalDetail()
778 SqliteUtils::Replace(whereClause, SqliteUtils::REP, logTable + "."); in GetHashKeyForLockRow()
889 LOG_ERROR("database corrupt, rebuild database %{public}s", SqliteUtils in RdbStoreImpl()
[all...]
H A Dsqlite_connection.cpp89 SqliteUtils::DeleteFile(path + suffix.suffix_); in Delete()
143 bool isSlaveLockExist = SqliteUtils::TryAccessSlaveLock(config_.GetPath(), false, false); in CreateSlaveConnection()
144 bool hasFailure = SqliteUtils::TryAccessSlaveLock(config_.GetPath(), false, false, true); in CreateSlaveConnection()
151 Reportor::FormatBrief(bugInfo, SqliteUtils::Anonymous(config.GetName())).c_str(), in CreateSlaveConnection()
157 SqliteUtils::TryAccessSlaveLock(config_.GetPath(), false, true, true); in CreateSlaveConnection()
165 SqliteUtils::TryAccessSlaveLock(config_.GetPath(), false, true, true); in CreateSlaveConnection()
167 LOG_WARN("slave corrupt, rebuild:%{public}s", SqliteUtils::Anonymous(config.GetPath()).c_str()); in CreateSlaveConnection()
176 SqliteUtils::Anonymous(config.GetPath()).c_str()); in CreateSlaveConnection()
186 RdbStoreConfig rdbStoreConfig(SqliteUtils::GetSlavePath(rdbConfig.GetPath())); in GetSlaveRdbStoreConfig()
193 rdbStoreConfig.SetName(SqliteUtils in GetSlaveRdbStoreConfig()
[all...]
H A Dsqlite_global_config.cpp67 LOG_INFO("Error(%{public}d) %{public}s ", err, SqliteUtils::Anonymous(msg).c_str()); in Log()
70 LOG_WARN("WARNING(%{public}d) %{public}s ", err, SqliteUtils::Anonymous(msg).c_str()); in Log()
73 SqliteUtils::Anonymous(msg).c_str()); in Log()
119 SqliteUtils::Anonymous(config.GetName()).c_str(), config.GetRoleType()); in GetDbPath()
H A Drdb_security_manager.cpp182 LOG_INFO("begin keyFile%{public}s.", SqliteUtils::Anonymous(keyFile).c_str()); in SaveSecretKeyToFile()
205 LOG_INFO("begin keyPath:%{public}s.", SqliteUtils::Anonymous(keyPath).c_str()); in SaveSecretKeyToDisk()
440 LOG_ERROR("mkdir error:%{public}d, dbDir:%{public}s", errno, SqliteUtils::Anonymous(fileDir).c_str()); in InitPath()
449 LOG_ERROR("Not exists. errno:%{public}d, file:%{public}s", errno, SqliteUtils::Anonymous(keyFile).c_str()); in LoadSecretKeyFromFile()
474 LOG_DEBUG("begin keyPath:%{public}s.", SqliteUtils::Anonymous(keyPath).c_str()); in LoadSecretKeyFromDisk()
552 SqliteUtils::DeleteFile(keyFiles.GetKeyFile(PUB_KEY_FILE)); in DelAllKeyFiles()
553 SqliteUtils::DeleteFile(keyFiles.GetKeyFile(PUB_KEY_FILE_NEW_KEY)); in DelAllKeyFiles()
565 SqliteUtils::DeleteFile(keyFiles.GetKeyFile(keyFileType)); in DelKeyFile()
604 SqliteUtils::RenameFile(reKeyFile, keyFile); in ChangeKeyFile()
631 SqliteUtils in RestoreKeyFile()
[all...]
H A Dsqlite_sql_builder.cpp218 SqliteUtils::Replace(field, SqliteUtils::REP, ""); in BuildCursorQueryString()
219 SqliteUtils::Replace(sql, table + "." + DistributedRdb::Field::SHARING_RESOURCE_FIELD, in BuildCursorQueryString()
235 SqliteUtils::Replace(whereClause, SqliteUtils::REP, logName + "."); in BuildCursorQueryString()
239 SqliteUtils::Replace(order, SqliteUtils::REP, logName + "."); in BuildCursorQueryString()
276 SqliteUtils::Replace(whereClause, SqliteUtils::REP, logName + "."); in BuildLockRowQueryString()
281 SqliteUtils in BuildLockRowQueryString()
[all...]
H A Dstep_result_set.cpp66 totalCost, acquireCost, prepareCost, countCost, rowCount_, SqliteUtils::Anonymous(sql_).c_str()); in StepResultSet()
90 auto type = SqliteUtils::GetSqlStatementType(sql_); in PrepareStep()
91 if (type == SqliteUtils::STATEMENT_ERROR) { in PrepareStep()
92 LOG_ERROR("invalid sql_ %{public}s!", SqliteUtils::Anonymous(sql_).c_str()); in PrepareStep()
104 LOG_ERROR("failed, %{public}s is not query sql!", SqliteUtils::Anonymous(sql_).c_str()); in PrepareStep()
H A Dsqlite_shared_result_set.cpp68 SqliteUtils::Anonymous(path).c_str()); in SqliteSharedResultSet()
109 auto type = SqliteUtils::GetSqlStatementType(qrySql_); in PrepareStep()
110 if (type == SqliteUtils::STATEMENT_ERROR) { in PrepareStep()
123 LOG_ERROR("failed, %{public}s is not query sql!", SqliteUtils::Anonymous(qrySql_).c_str()); in PrepareStep()
H A Dsqlite_statement.cpp110 SqliteUtils::Anonymous(config_->GetName()).c_str()); in PrintInfoForDbError()
127 "open db file failed: %{public}s, errno is %{public}d", SqliteUtils::Anonymous(fileName).c_str(), errno); in ReadFile2Buffer()
208 SqliteUtils::TryAccessSlaveLock(config_->GetPath(), false, true, true); in Prepare()
249 SqliteUtils::TryAccessSlaveLock(config_->GetPath(), false, true, true); in Bind()
367 int sqlType = SqliteUtils::GetSqlStatementType(sql_); in Execute()
368 if (sqlType != SqliteUtils::STATEMENT_COMMIT && sqlType != SqliteUtils::STATEMENT_ROLLBACK) { in Execute()
388 SqliteUtils::TryAccessSlaveLock(config_->GetPath(), false, true, true); in Execute()
480 auto declType = SqliteUtils::StrToUpper(std::string(decl)); in GetColumnType()
H A Dconnection_pool.cpp69 SqliteUtils::Anonymous(dbPath).c_str(), config.GetDBType(), config.GetHaMode(), config.IsEncrypt(), in Create()
71 Reportor::FormatBrief(Connection::Collect(config), SqliteUtils::Anonymous(config.GetName())).c_str()); in Create()
91 static_cast<uint32_t>(rebuiltType), SqliteUtils::Anonymous(storeConfig.GetName()).c_str(), in HandleDataCorruption()
389 if (SqliteUtils::IsSlaveDbName(backupPath) && config_.GetHaMode() != HAMode::SINGLE) { in RestoreByDbSqliteType()
403 LOG_ERROR("backup file is corrupted, %{public}s", SqliteUtils::Anonymous(backupPath).c_str()); in RestoreMasterDb()
406 SqliteUtils::DeleteFile(backupPath + "-shm"); in RestoreMasterDb()
407 SqliteUtils::DeleteFile(backupPath + "-wal"); in RestoreMasterDb()
419 if (!SqliteUtils::CopyFile(backupPath, newPath)) { in RestoreMasterDb()
H A Dabs_result_set.cpp263 LOG_ERROR("Get(%{public}d, %{public}s)->ret %{public}d", index, SqliteUtils::Anonymous(name).c_str(), ret); in GetRow()
396 SqliteUtils::Replace(lowerName, SqliteUtils::REP, ""); in GetColumnIndex()
410 LOG_ERROR("failed, columnName is: %{public}s", SqliteUtils::Anonymous(columnName).c_str()); in GetColumnIndex()
H A Drd_statement.cpp144 readOnly_ = SqliteUtils::GetSqlStatementType(newSql) == SqliteUtils::STATEMENT_SELECT; in Prepare()
H A Drdb_store.cpp98 if (column.find(SqliteUtils::REP) != std::string::npos) { in ColHasSpecificField()
/foundation/distributeddatamgr/relational_store/frameworks/native/dfx/src/
H A Drdb_fault_hiview_reporter.cpp55 SqliteUtils::Anonymous(eventInfoAppend.storeName).c_str(), in ReportFault()
71 SqliteUtils::Anonymous(eventInfo.storeName).c_str(), eventInfo.errorCode, eventInfoAppend.appendix.c_str()); in ReportRestore()
140 SqliteUtils::Anonymous(flagFilename).c_str(), errno); in CreateCorruptedFlag()
155 SqliteUtils::Anonymous(flagFilename).c_str(), errno); in DeleteCorruptedFlag()
238 return SqliteUtils::Anonymous(eventInfo.storeName); in GetBundleName()

Completed in 20 milliseconds