Page MenuHomePhorge
Files F33087669

D14844.1768459181.diff
No OneTemporary
Actions

Size
13 KB
Referenced Files
None
Subscribers
None

D14844.1768459181.diff
View Options

diff --git a/native/cpp/CommonCpp/DatabaseManagers/SQLiteQueryExecutor.cpp b/native/cpp/CommonCpp/DatabaseManagers/SQLiteQueryExecutor.cpp
--- a/native/cpp/CommonCpp/DatabaseManagers/SQLiteQueryExecutor.cpp
+++ b/native/cpp/CommonCpp/DatabaseManagers/SQLiteQueryExecutor.cpp
@@ -173,8 +173,12 @@
}
void SQLiteQueryExecutor::removeAllMessages() const {
- static std::string removeAllMessagesSQL = "DELETE FROM messages;";
- removeAllEntities(this->getConnection(), removeAllMessagesSQL);
+ constexpr std::string_view tables[] = {"messages", "backup_messages"};
+ for (const auto &table : tables) {
+ std::string removeAllMessagesSQL =
+ "DELETE FROM " + std::string(table) + ";";
+ removeAllEntities(this->getConnection(), removeAllMessagesSQL);
+ }
}
std::string SQLiteQueryExecutor::getThickThreadTypesList() const {
@@ -276,12 +280,15 @@
return;
}
- std::stringstream removeMessagesByKeysSQLStream;
- removeMessagesByKeysSQLStream << "DELETE FROM messages "
- "WHERE id IN "
- << getSQLStatementArray(ids.size()) << ";";
- removeEntitiesByKeys(
- this->getConnection(), removeMessagesByKeysSQLStream.str(), ids);
+ constexpr std::string_view tables[] = {"messages", "backup_messages"};
+ for (const auto &table : tables) {
+ std::stringstream removeMessagesByKeysSQLStream;
+ removeMessagesByKeysSQLStream << "DELETE FROM " << table << " "
+ << "WHERE id IN "
+ << getSQLStatementArray(ids.size()) << ";";
+ removeEntitiesByKeys(
+ this->getConnection(), removeMessagesByKeysSQLStream.str(), ids);
+ }
}
void SQLiteQueryExecutor::removeMessagesForThreads(
@@ -290,14 +297,16 @@
return;
}
- std::stringstream removeMessagesByKeysSQLStream;
- removeMessagesByKeysSQLStream << "DELETE FROM messages "
- "WHERE thread IN "
- << getSQLStatementArray(threadIDs.size())
- << ";";
+ constexpr std::string_view tables[] = {"messages", "backup_messages"};
+ for (const auto &table : tables) {
+ std::stringstream removeMessagesByKeysSQLStream;
+ removeMessagesByKeysSQLStream
+ << "DELETE FROM " << table << " "
+ << "WHERE thread IN " << getSQLStatementArray(threadIDs.size()) << ";";
- removeEntitiesByKeys(
- this->getConnection(), removeMessagesByKeysSQLStream.str(), threadIDs);
+ removeEntitiesByKeys(
+ this->getConnection(), removeMessagesByKeysSQLStream.str(), threadIDs);
+ }
}
void SQLiteQueryExecutor::replaceMessage(const Message &message) const {
@@ -398,8 +407,11 @@
}
void SQLiteQueryExecutor::removeAllMedia() const {
- static std::string removeAllMediaSQL = "DELETE FROM media;";
- removeAllEntities(this->getConnection(), removeAllMediaSQL);
+ constexpr std::string_view tables[] = {"media", "backup_media"};
+ for (const auto &table : tables) {
+ std::string removeAllMediaSQL = "DELETE FROM " + std::string(table) + ";";
+ removeAllEntities(this->getConnection(), removeAllMediaSQL);
+ }
}
void SQLiteQueryExecutor::removeMediaForMessages(
@@ -408,21 +420,26 @@
return;
}
- std::stringstream removeMediaByKeysSQLStream;
- removeMediaByKeysSQLStream << "DELETE FROM media "
- "WHERE container IN "
- << getSQLStatementArray(msgIDs.size()) << ";";
+ constexpr std::string_view tables[] = {"media", "backup_media"};
+ for (const auto &table : tables) {
+ std::stringstream removeMediaByKeysSQLStream;
+ removeMediaByKeysSQLStream << "DELETE FROM " << table << " "
+ << "WHERE container IN "
+ << getSQLStatementArray(msgIDs.size()) << ";";
- removeEntitiesByKeys(
- this->getConnection(), removeMediaByKeysSQLStream.str(), msgIDs);
+ removeEntitiesByKeys(
+ this->getConnection(), removeMediaByKeysSQLStream.str(), msgIDs);
+ }
}
void SQLiteQueryExecutor::removeMediaForMessage(std::string msgID) const {
- static std::string removeMediaByKeySQL =
- "DELETE FROM media "
- "WHERE container IN (?);";
- std::vector<std::string> keys = {msgID};
- removeEntitiesByKeys(this->getConnection(), removeMediaByKeySQL, keys);
+ constexpr std::string_view tables[] = {"media", "backup_media"};
+ for (const auto &table : tables) {
+ std::string removeMediaByKeySQL =
+ "DELETE FROM " + std::string(table) + +" " + "WHERE container IN (?);";
+ std::vector<std::string> keys = {msgID};
+ removeEntitiesByKeys(this->getConnection(), removeMediaByKeySQL, keys);
+ }
}
void SQLiteQueryExecutor::removeMediaForThreads(
@@ -431,13 +448,16 @@
return;
}
- std::stringstream removeMediaByKeysSQLStream;
- removeMediaByKeysSQLStream << "DELETE FROM media "
- "WHERE thread IN "
- << getSQLStatementArray(threadIDs.size()) << ";";
+ constexpr std::string_view tables[] = {"media", "backup_media"};
+ for (const auto &table : tables) {
+ std::stringstream removeMediaByKeysSQLStream;
+ removeMediaByKeysSQLStream << "DELETE FROM " << table << " "
+ << "WHERE thread IN "
+ << getSQLStatementArray(threadIDs.size()) << ";";
- removeEntitiesByKeys(
- this->getConnection(), removeMediaByKeysSQLStream.str(), threadIDs);
+ removeEntitiesByKeys(
+ this->getConnection(), removeMediaByKeysSQLStream.str(), threadIDs);
+ }
}
void SQLiteQueryExecutor::replaceMedia(const Media &media) const {
@@ -469,9 +489,13 @@
}
void SQLiteQueryExecutor::removeAllMessageStoreThreads() const {
- static std::string removeAllMessageStoreThreadsSQL =
- "DELETE FROM message_store_threads;";
- removeAllEntities(this->getConnection(), removeAllMessageStoreThreadsSQL);
+ constexpr std::string_view tables[] = {
+ "message_store_threads", "backup_message_store_threads"};
+ for (const auto &table : tables) {
+ std::string removeAllMessageStoreThreadsSQL =
+ "DELETE FROM " + std::string(table) + ";";
+ removeAllEntities(this->getConnection(), removeAllMessageStoreThreadsSQL);
+ }
}
void SQLiteQueryExecutor::removeMessageStoreThreads(
@@ -480,16 +504,19 @@
return;
}
- std::stringstream removeMessageStoreThreadsByKeysSQLStream;
- removeMessageStoreThreadsByKeysSQLStream
- << "DELETE FROM message_store_threads "
- "WHERE id IN "
- << getSQLStatementArray(ids.size()) << ";";
+ constexpr std::string_view tables[] = {
+ "message_store_threads", "backup_message_store_threads"};
+ for (const auto &table : tables) {
+ std::stringstream removeMessageStoreThreadsByKeysSQLStream;
+ removeMessageStoreThreadsByKeysSQLStream
+ << "DELETE FROM " << table << " "
+ << "WHERE id IN " << getSQLStatementArray(ids.size()) << ";";
- removeEntitiesByKeys(
- this->getConnection(),
- removeMessageStoreThreadsByKeysSQLStream.str(),
- ids);
+ removeEntitiesByKeys(
+ this->getConnection(),
+ removeMessageStoreThreadsByKeysSQLStream.str(),
+ ids);
+ }
}
std::vector<MessageStoreThread>
@@ -513,13 +540,16 @@
return;
}
- std::stringstream removeThreadsByKeysSQLStream;
- removeThreadsByKeysSQLStream << "DELETE FROM threads "
- "WHERE id IN "
- << getSQLStatementArray(ids.size()) << ";";
+ constexpr std::string_view tables[] = {"threads", "backup_threads"};
+ for (const auto &table : tables) {
+ std::stringstream removeThreadsByKeysSQLStream;
+ removeThreadsByKeysSQLStream << "DELETE FROM " << table << " "
+ << "WHERE id IN "
+ << getSQLStatementArray(ids.size()) << ";";
- removeEntitiesByKeys(
- this->getConnection(), removeThreadsByKeysSQLStream.str(), ids);
+ removeEntitiesByKeys(
+ this->getConnection(), removeThreadsByKeysSQLStream.str(), ids);
+ }
};
void SQLiteQueryExecutor::replaceThread(const Thread &thread) const {
@@ -534,8 +564,11 @@
};
void SQLiteQueryExecutor::removeAllThreads() const {
- static std::string removeAllThreadsSQL = "DELETE FROM threads;";
- removeAllEntities(this->getConnection(), removeAllThreadsSQL);
+ constexpr std::string_view tables[] = {"threads", "backup_threads"};
+ for (const auto &table : tables) {
+ std::string removeAllThreadsSQL = "DELETE FROM " + std::string(table) + ";";
+ removeAllEntities(this->getConnection(), removeAllThreadsSQL);
+ }
};
void SQLiteQueryExecutor::replaceReport(const Report &report) const {
@@ -873,9 +906,13 @@
}
void SQLiteQueryExecutor::removeAllThreadActivityEntries() const {
- static std::string removeAllThreadActivityEntriesSQL =
- "DELETE FROM thread_activity;";
- removeAllEntities(this->getConnection(), removeAllThreadActivityEntriesSQL);
+ constexpr std::string_view tables[] = {
+ "thread_activity", "backup_thread_activity"};
+ for (const auto &table : tables) {
+ std::string removeAllThreadActivityEntriesSQL =
+ "DELETE FROM " + std::string(table) + ";";
+ removeAllEntities(this->getConnection(), removeAllThreadActivityEntriesSQL);
+ }
}
void SQLiteQueryExecutor::removeThreadActivityEntries(
@@ -884,16 +921,19 @@
return;
}
- std::stringstream removeThreadActivityEntriesByKeysSQLStream;
- removeThreadActivityEntriesByKeysSQLStream << "DELETE FROM thread_activity "
- "WHERE id IN "
- << getSQLStatementArray(ids.size())
- << ";";
+ constexpr std::string_view tables[] = {
+ "thread_activity", "backup_thread_activity"};
+ for (const auto &table : tables) {
+ std::stringstream removeThreadActivityEntriesByKeysSQLStream;
+ removeThreadActivityEntriesByKeysSQLStream
+ << "DELETE FROM " << table << " "
+ << "WHERE id IN " << getSQLStatementArray(ids.size()) << ";";
- removeEntitiesByKeys(
- this->getConnection(),
- removeThreadActivityEntriesByKeysSQLStream.str(),
- ids);
+ removeEntitiesByKeys(
+ this->getConnection(),
+ removeThreadActivityEntriesByKeysSQLStream.str(),
+ ids);
+ }
}
std::vector<ThreadActivityEntry>
@@ -913,8 +953,11 @@
}
void SQLiteQueryExecutor::removeAllEntries() const {
- static std::string removeAllEntriesSQL = "DELETE FROM entries;";
- removeAllEntities(this->getConnection(), removeAllEntriesSQL);
+ constexpr std::string_view tables[] = {"entries", "backup_entries"};
+ for (const auto &table : tables) {
+ std::string removeAllEntriesSQL = "DELETE FROM " + std::string(table) + ";";
+ removeAllEntities(this->getConnection(), removeAllEntriesSQL);
+ }
}
void SQLiteQueryExecutor::removeEntries(
@@ -923,12 +966,15 @@
return;
}
- std::stringstream removeEntriesByKeysSQLStream;
- removeEntriesByKeysSQLStream << "DELETE FROM entries "
- "WHERE id IN "
- << getSQLStatementArray(ids.size()) << ";";
- removeEntitiesByKeys(
- this->getConnection(), removeEntriesByKeysSQLStream.str(), ids);
+ constexpr std::string_view tables[] = {"entries", "backup_entries"};
+ for (const auto &table : tables) {
+ std::stringstream removeEntriesByKeysSQLStream;
+ removeEntriesByKeysSQLStream << "DELETE FROM " << table << " "
+ << "WHERE id IN "
+ << getSQLStatementArray(ids.size()) << ";";
+ removeEntitiesByKeys(
+ this->getConnection(), removeEntriesByKeysSQLStream.str(), ids);
+ }
}
std::vector<EntryInfo> SQLiteQueryExecutor::getAllEntries() const {
@@ -953,20 +999,29 @@
return;
}
- std::stringstream removeLocalMessageInfosByKeysSQLStream;
- removeLocalMessageInfosByKeysSQLStream << "DELETE FROM message_store_local "
- "WHERE id IN "
- << getSQLStatementArray(ids.size())
- << ";";
+ constexpr std::string_view tables[] = {
+ "message_store_local", "backup_message_store_local"};
+ for (const auto &table : tables) {
+ std::stringstream removeLocalMessageInfosByKeysSQLStream;
+ removeLocalMessageInfosByKeysSQLStream
+ << "DELETE FROM " << table << " "
+ << "WHERE id IN " << getSQLStatementArray(ids.size()) << ";";
- removeEntitiesByKeys(
- this->getConnection(), removeLocalMessageInfosByKeysSQLStream.str(), ids);
+ removeEntitiesByKeys(
+ this->getConnection(),
+ removeLocalMessageInfosByKeysSQLStream.str(),
+ ids);
+ }
}
void SQLiteQueryExecutor::removeAllMessageStoreLocalMessageInfos() const {
- static std::string removeAllLocalMessageInfosSQL =
- "DELETE FROM message_store_local;";
- removeAllEntities(this->getConnection(), removeAllLocalMessageInfosSQL);
+ constexpr std::string_view tables[] = {
+ "message_store_local", "backup_message_store_local"};
+ for (const auto &table : tables) {
+ std::string removeAllLocalMessageInfosSQL =
+ "DELETE FROM " + std::string(table) + ";";
+ removeAllEntities(this->getConnection(), removeAllLocalMessageInfosSQL);
+ }
}
std::vector<LocalMessageInfo>
diff --git a/web/shared-worker/_generated/comm_query_executor.wasm b/web/shared-worker/_generated/comm_query_executor.wasm
index 0000000000000000000000000000000000000000..0000000000000000000000000000000000000000
GIT binary patch
literal 0
Hc$@<O00001
literal 0
Hc$@<O00001

File Metadata

Mime Type
text/plain
Expires
Thu, Jan 15, 6:39 AM (9 h, 35 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5936553
Default Alt Text
D14844.1768459181.diff (13 KB)

Event Timeline