Home
last modified time | relevance | path

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

/ohos5.0/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_utils_test.cpp110 EXPECT_EQ(SqliteUtils::STATEMENT_BEGIN, SqliteUtils::GetSqlStatementType("SAVEPOINT 1"));
111 EXPECT_EQ(SqliteUtils::STATEMENT_COMMIT, SqliteUtils::GetSqlStatementType("END TRANSACTION"));
112 EXPECT_EQ(SqliteUtils::STATEMENT_COMMIT, SqliteUtils::GetSqlStatementType("COMMIT"));
113 EXPECT_EQ(SqliteUtils::STATEMENT_ROLLBACK, SqliteUtils::GetSqlStatementType("ROLLBACK"));
115 EXPECT_EQ(SqliteUtils::STATEMENT_DDL, SqliteUtils::GetSqlStatementType("CREATE TABLE"));
116 EXPECT_EQ(SqliteUtils::STATEMENT_DDL, SqliteUtils::GetSqlStatementType("CREATE TRIGGER"));
117 EXPECT_EQ(SqliteUtils::STATEMENT_DDL, SqliteUtils::GetSqlStatementType("DROP TABLE"));
118 EXPECT_EQ(SqliteUtils::STATEMENT_DDL, SqliteUtils::GetSqlStatementType("ALTER TABLE"));
121 EXPECT_EQ(SqliteUtils::STATEMENT_OTHER, SqliteUtils::GetSqlStatementType("SAZZZZZZZ"));
122 EXPECT_EQ(SqliteUtils::STATEMENT_OTHER, SqliteUtils::GetSqlStatementType("SAAAAAAAA"));
[all …]
H A Dsqlite_utils_test.cpp59 EXPECT_EQ(SqliteUtils::Anonymous("rdb_300052_test.db"), "rdb_***052_test.db");
64 EXPECT_EQ(SqliteUtils::Anonymous("rdb_30005_test.db"), "rdb_***005_test.db");
69 EXPECT_EQ(SqliteUtils::Anonymous("rdb_3000523_test.db"), "rdb_***0523_test.db");
74 EXPECT_EQ(SqliteUtils::Anonymous(
88 EXPECT_EQ(SqliteUtils::Anonymous(
101 EXPECT_EQ(SqliteUtils::Anonymous("30005245854585524412855412.db"), "***5412.db");
111 EXPECT_EQ(SqliteUtils::Anonymous("123edf4.db"), "***edf4.db");
116 EXPECT_EQ(SqliteUtils::Anonymous("K123edfK.db"), "K***edfK.db");
121 EXPECT_EQ(SqliteUtils::Anonymous("K23edfK.db"), "K***edfK.db");
126 EXPECT_EQ(SqliteUtils::Anonymous("__23edf__.db"), "__***edf__.db");
[all …]
H A Drdb_double_write_test.cpp801 SqliteUtils::DeleteFile(DATABASE_NAME);
802 SqliteUtils::DeleteFile(DATABASE_NAME + "-shm");
803 SqliteUtils::DeleteFile(DATABASE_NAME + "-wal");
H A Drdb_store_rekey_test.cpp322 SqliteUtils::DeleteFile(keyPath);
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Dsqlite_utils.h27 class SqliteUtils {
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 },
86 { "SAV", SqliteUtils::STATEMENT_BEGIN },
[all …]
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Dsqlite_utils.cpp46 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()
92 bool SqliteUtils::IsSupportSqlForExecute(int sqlType) in IsSupportSqlForExecute()
98 bool SqliteUtils::IsSqlReadOnly(int sqlType) in IsSqlReadOnly()
103 bool SqliteUtils::IsSpecial(int sqlType) in IsSpecial()
119 bool SqliteUtils::DeleteFile(const std::string &filePath) in DeleteFile()
242 ssize_t SqliteUtils::GetFileSize(const std::string &fileName) in GetFileSize()
255 bool SqliteUtils::IsSlaveDbName(const std::string &fileName) in IsSlaveDbName()
[all …]
H A Drdb_service_proxy.cpp25 using SqliteUtils = OHOS::NativeRdb::SqliteUtils; typedef
279 SqliteUtils::Anonymous(param.storeName_).c_str()); in DoUnSubscribe()
294 SqliteUtils::Anonymous(device).c_str()); in RemoteQuery()
331 SqliteUtils::Anonymous(param.storeName_).c_str()); in BeforeOpen()
347 SqliteUtils::Anonymous(param.storeName_).c_str()); in AfterOpen()
358 SqliteUtils::Anonymous(param.storeName_).c_str()); in Delete()
387 SqliteUtils::Anonymous(param.storeName_).c_str()); in RegisterAutoSyncCallback()
415 SqliteUtils::Anonymous(param.storeName_).c_str()); in DoRegister()
425 SqliteUtils::Anonymous(param.storeName_).c_str()); in UnregisterAutoSyncCallback()
453 SqliteUtils::Anonymous(param.storeName_).c_str()); in DoUnRegister()
[all …]
H A Dsqlite_connection.cpp89 SqliteUtils::DeleteFile(path + suffix.suffix_); in Delete()
176 SqliteUtils::Anonymous(config.GetPath()).c_str()); in CreateSlaveConnection()
257 SqliteUtils::Anonymous(config.GetName()).c_str(), in InnerOpen()
959 SqliteUtils::Anonymous(table).c_str(), cursor); in CleanDirtyData()
975 ssize_t size = SqliteUtils::GetFileSize(walName); in TryCheckPoint()
994 SqliteUtils::Anonymous(walName).c_str()); in TryCheckPoint()
1007 ssize_t fileSize = SqliteUtils::GetFileSize(walName); in LimitWalSize()
1010 SqliteUtils::Anonymous(walName).c_str(), fileSize); in LimitWalSize()
1070 SqliteUtils::Anonymous(newAsset.name).c_str()); in MergeAsset()
1231 SqliteUtils::Anonymous(databasePath).c_str(), isAsync); in Backup()
[all …]
H A Drdb_store_impl.cpp779 SqliteUtils::Replace(whereClause, SqliteUtils::REP, logTable + "."); in GetHashKeyForLockRow()
893 SqliteUtils::Anonymous(name_).c_str()); in RdbStoreImpl()
920 SqliteUtils::Anonymous(path_).c_str()); in RdbStoreImpl()
1185 if (sqlType == SqliteUtils::STATEMENT_DDL) { in ExecuteSql()
1198 …if (errCode == E_OK && (sqlType == SqliteUtils::STATEMENT_UPDATE || sqlType == SqliteUtils::STATEM… in ExecuteSql()
1252 if (sqlType == SqliteUtils::STATEMENT_INSERT) { in HandleDifferentSqlTypes()
1273 if (sqlType == SqliteUtils::STATEMENT_DDL) { in HandleDifferentSqlTypes()
1456 SqliteUtils::DeleteFile(backupFilePath); in Backup()
1471 SqliteUtils::DeleteFile(tempPath); in Backup()
1554 if (SqliteUtils::IsSpecial(type)) { in BeginExecuteSql()
[all …]
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::STATEMENT_DDL) { in Execute()
236 … SqliteUtils::Anonymous(name_).c_str(), vSchema_, static_cast<int64_t>(version), sql.c_str()); in Execute()
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 Drdb_store_manager.cpp77 …config.GetBundleName().c_str(), config.GetModuleName().c_str(), SqliteUtils::Anonymous(path).c_str… in GetStoreFromCache()
80 …Reportor::FormatBrief(Connection::Collect(config), SqliteUtils::Anonymous(config.GetName())).c_str… in GetStoreFromCache()
108 …LOG_ERROR("GetRdbStore fail path:%{public}s, rc=%{public}d", SqliteUtils::Anonymous(path).c_str(),… in GetRdbStore()
116 … SqliteUtils::Anonymous(modifyConfig.GetName()).c_str(), modifyConfig.GetSecurityLevel(), errCode); in GetRdbStore()
127 SqliteUtils::Anonymous(modifyConfig.GetName()).c_str(), in GetRdbStore()
128 SqliteUtils::Anonymous(modifyConfig.GetPath()).c_str(), errCode); in GetRdbStore()
142 … LOG_WARN("Config has no bundleName, path: %{public}s", SqliteUtils::Anonymous(path).c_str()); in IsConfigInvalidChanged()
146 LOG_WARN("Not found config cache, path: %{public}s", SqliteUtils::Anonymous(path).c_str()); in IsConfigInvalidChanged()
160 …SqliteUtils::Anonymous(path).c_str(), tempParam.level_, param.level_, tempParam.area_, param.area_, in IsConfigInvalidChanged()
287 SqliteUtils::Anonymous(param.storeName_).c_str(), err); in Delete()
[all …]
H A Drdb_helper.cpp83 …LOG_ERROR("Store to delete doesn't exist, path %{public}s", SqliteUtils::Anonymous(dbFileName).c_s… 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_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()
442 …LOG_ERROR("mkdir error:%{public}d, dbDir:%{public}s", errno, SqliteUtils::Anonymous(fileDir).c_str… in InitPath()
476 LOG_DEBUG("begin keyPath:%{public}s.", SqliteUtils::Anonymous(keyPath).c_str()); in LoadSecretKeyFromDisk()
555 SqliteUtils::DeleteFile(keyFiles.GetKeyFile(PUB_KEY_FILE)); in DelAllKeyFiles()
556 SqliteUtils::DeleteFile(keyFiles.GetKeyFile(PUB_KEY_FILE_NEW_KEY)); in DelAllKeyFiles()
568 SqliteUtils::DeleteFile(keyFiles.GetKeyFile(keyFileType)); in DelKeyFile()
607 SqliteUtils::RenameFile(reKeyFile, keyFile); in ChangeKeyFile()
634 SqliteUtils::DeleteFile(keyFile); in RestoreKeyFile()
635 SqliteUtils::DeleteFile(reKeyFile); in RestoreKeyFile()
[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 Dsqlite_sql_builder.cpp258 SqliteUtils::Replace(field, SqliteUtils::REP, ""); in BuildCursorQueryString()
259 SqliteUtils::Replace(sql, table + "." + DistributedRdb::Field::SHARING_RESOURCE_FIELD, in BuildCursorQueryString()
275 SqliteUtils::Replace(whereClause, SqliteUtils::REP, logTable + "."); in BuildCursorQueryString()
279 SqliteUtils::Replace(order, SqliteUtils::REP, logTable + "."); in BuildCursorQueryString()
315 SqliteUtils::Replace(whereClause, SqliteUtils::REP, logTable + "."); in BuildLockRowQueryString()
320 SqliteUtils::Replace(order, SqliteUtils::REP, logTable + "."); in BuildLockRowQueryString()
H A Dstep_result_set.cpp70 … totalCost, acquireCost, prepareCost, countCost, rowCount_, SqliteUtils::Anonymous(sql_).c_str()); in StepResultSet()
120 auto type = SqliteUtils::GetSqlStatementType(sql_); in PrepareStep()
121 if (type == SqliteUtils::STATEMENT_ERROR) { in PrepareStep()
122 LOG_ERROR("invalid sql_ %{public}s!", SqliteUtils::Anonymous(sql_).c_str()); in PrepareStep()
134 LOG_ERROR("failed, %{public}s is not query sql!", SqliteUtils::Anonymous(sql_).c_str()); in PrepareStep()
H A Dsqlite_statement.cpp112 SqliteUtils::Anonymous(config_->GetName()).c_str()); in PrintInfoForDbError()
129 …"open db file failed: %{public}s, errno is %{public}d", SqliteUtils::Anonymous(fileName).c_str(), … in ReadFile2Buffer()
210 SqliteUtils::TryAccessSlaveLock(config_->GetPath(), false, true, true); in Prepare()
250 SqliteUtils::TryAccessSlaveLock(config_->GetPath(), false, true, true); in Bind()
355 int sqlType = SqliteUtils::GetSqlStatementType(sql_); in Execute()
356 … if (sqlType != SqliteUtils::STATEMENT_COMMIT && sqlType != SqliteUtils::STATEMENT_ROLLBACK) { in Execute()
376 SqliteUtils::TryAccessSlaveLock(config_->GetPath(), false, true, true); in Execute()
468 auto declType = SqliteUtils::StrToUpper(std::string(decl)); in GetColumnType()
H A Dsqlite_shared_result_set.cpp68 SqliteUtils::Anonymous(path).c_str()); in SqliteSharedResultSet()
84 auto type = SqliteUtils::GetSqlStatementType(qrySql_); in PrepareStep()
85 if (type == SqliteUtils::STATEMENT_ERROR) { in PrepareStep()
98 LOG_ERROR("failed, %{public}s is not query sql!", SqliteUtils::Anonymous(qrySql_).c_str()); in PrepareStep()
H A Dconnection_pool.cpp67 …errCode, config.GetBundleName().c_str(), SqliteUtils::Anonymous(dbPath).c_str(), config.GetDBType(… in Create()
70 …Reportor::FormatBrief(Connection::Collect(config), SqliteUtils::Anonymous(config.GetName())).c_str… in Create()
95 … static_cast<uint32_t>(rebuiltType), SqliteUtils::Anonymous(storeConfig.GetName()).c_str(), in HandleDataCorruption()
404 if (SqliteUtils::IsSlaveDbName(backupPath) && config_.GetHaMode() != HAMode::SINGLE) { in RestoreByDbSqliteType()
418 … LOG_ERROR("backup file is corrupted, %{public}s", SqliteUtils::Anonymous(backupPath).c_str()); in RestoreMasterDb()
421 SqliteUtils::DeleteFile(backupPath + "-shm"); in RestoreMasterDb()
422 SqliteUtils::DeleteFile(backupPath + "-wal"); in RestoreMasterDb()
433 bool copyRet = SqliteUtils::CopyFile(backupPath, newPath); in RestoreMasterDb()
451 SqliteUtils::Anonymous(backupPath).c_str()); in RestoreMasterDb()
H A Dabs_result_set.cpp263 …LOG_ERROR("Get(%{public}d, %{public}s)->ret %{public}d", index, SqliteUtils::Anonymous(name).c_str… 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_result_set.cpp208 if (SqliteUtils::GetSqlStatementType(sql_) != SqliteUtils::STATEMENT_SELECT) { in PrepareStep()
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()
/ohos5.0/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… 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()