mirror of
https://github.com/EQEmu/Server.git
synced 2026-03-03 19:52:26 +00:00
dadc1b2843
Add common expedition base class Use repository for zone and world expedition caching World now stores members and leader as Member objects instead of ids This improves readability of the caching methods and lets world cache expedition dzs and members like zone. World also now caches expeditions as unique_ptr which will be necessary for future dz callback lambdas that capture 'this' so addresses don't change on cache vector resizes.
329 lines
8.0 KiB
C++
329 lines
8.0 KiB
C++
/**
|
|
* DO NOT MODIFY THIS FILE
|
|
*
|
|
* This repository was automatically generated and is NOT to be modified directly.
|
|
* Any repository modifications are meant to be made to the repository extending the base.
|
|
* Any modifications to base repositories are to be made by the generator only
|
|
*
|
|
* @generator ./utils/scripts/generators/repository-generator.pl
|
|
* @docs https://eqemu.gitbook.io/server/in-development/developer-area/repositories
|
|
*/
|
|
|
|
#ifndef EQEMU_BASE_EXPEDITION_LOCKOUTS_REPOSITORY_H
|
|
#define EQEMU_BASE_EXPEDITION_LOCKOUTS_REPOSITORY_H
|
|
|
|
#include "../../database.h"
|
|
#include "../../string_util.h"
|
|
|
|
class BaseExpeditionLockoutsRepository {
|
|
public:
|
|
struct ExpeditionLockouts {
|
|
int id;
|
|
int expedition_id;
|
|
std::string event_name;
|
|
std::string expire_time;
|
|
int duration;
|
|
std::string from_expedition_uuid;
|
|
};
|
|
|
|
static std::string PrimaryKey()
|
|
{
|
|
return std::string("id");
|
|
}
|
|
|
|
static std::vector<std::string> Columns()
|
|
{
|
|
return {
|
|
"id",
|
|
"expedition_id",
|
|
"event_name",
|
|
"expire_time",
|
|
"duration",
|
|
"from_expedition_uuid",
|
|
};
|
|
}
|
|
|
|
static std::string ColumnsRaw()
|
|
{
|
|
return std::string(implode(", ", Columns()));
|
|
}
|
|
|
|
static std::string TableName()
|
|
{
|
|
return std::string("expedition_lockouts");
|
|
}
|
|
|
|
static std::string BaseSelect()
|
|
{
|
|
return fmt::format(
|
|
"SELECT {} FROM {}",
|
|
ColumnsRaw(),
|
|
TableName()
|
|
);
|
|
}
|
|
|
|
static std::string BaseInsert()
|
|
{
|
|
return fmt::format(
|
|
"INSERT INTO {} ({}) ",
|
|
TableName(),
|
|
ColumnsRaw()
|
|
);
|
|
}
|
|
|
|
static ExpeditionLockouts NewEntity()
|
|
{
|
|
ExpeditionLockouts entry{};
|
|
|
|
entry.id = 0;
|
|
entry.expedition_id = 0;
|
|
entry.event_name = "";
|
|
entry.expire_time = "";
|
|
entry.duration = 0;
|
|
entry.from_expedition_uuid = "";
|
|
|
|
return entry;
|
|
}
|
|
|
|
static ExpeditionLockouts GetExpeditionLockoutsEntry(
|
|
const std::vector<ExpeditionLockouts> &expedition_lockoutss,
|
|
int expedition_lockouts_id
|
|
)
|
|
{
|
|
for (auto &expedition_lockouts : expedition_lockoutss) {
|
|
if (expedition_lockouts.id == expedition_lockouts_id) {
|
|
return expedition_lockouts;
|
|
}
|
|
}
|
|
|
|
return NewEntity();
|
|
}
|
|
|
|
static ExpeditionLockouts FindOne(
|
|
Database& db,
|
|
int expedition_lockouts_id
|
|
)
|
|
{
|
|
auto results = db.QueryDatabase(
|
|
fmt::format(
|
|
"{} WHERE id = {} LIMIT 1",
|
|
BaseSelect(),
|
|
expedition_lockouts_id
|
|
)
|
|
);
|
|
|
|
auto row = results.begin();
|
|
if (results.RowCount() == 1) {
|
|
ExpeditionLockouts entry{};
|
|
|
|
entry.id = atoi(row[0]);
|
|
entry.expedition_id = atoi(row[1]);
|
|
entry.event_name = row[2] ? row[2] : "";
|
|
entry.expire_time = row[3] ? row[3] : "";
|
|
entry.duration = atoi(row[4]);
|
|
entry.from_expedition_uuid = row[5] ? row[5] : "";
|
|
|
|
return entry;
|
|
}
|
|
|
|
return NewEntity();
|
|
}
|
|
|
|
static int DeleteOne(
|
|
Database& db,
|
|
int expedition_lockouts_id
|
|
)
|
|
{
|
|
auto results = db.QueryDatabase(
|
|
fmt::format(
|
|
"DELETE FROM {} WHERE {} = {}",
|
|
TableName(),
|
|
PrimaryKey(),
|
|
expedition_lockouts_id
|
|
)
|
|
);
|
|
|
|
return (results.Success() ? results.RowsAffected() : 0);
|
|
}
|
|
|
|
static int UpdateOne(
|
|
Database& db,
|
|
ExpeditionLockouts expedition_lockouts_entry
|
|
)
|
|
{
|
|
std::vector<std::string> update_values;
|
|
|
|
auto columns = Columns();
|
|
|
|
update_values.push_back(columns[1] + " = " + std::to_string(expedition_lockouts_entry.expedition_id));
|
|
update_values.push_back(columns[2] + " = '" + EscapeString(expedition_lockouts_entry.event_name) + "'");
|
|
update_values.push_back(columns[3] + " = '" + EscapeString(expedition_lockouts_entry.expire_time) + "'");
|
|
update_values.push_back(columns[4] + " = " + std::to_string(expedition_lockouts_entry.duration));
|
|
update_values.push_back(columns[5] + " = '" + EscapeString(expedition_lockouts_entry.from_expedition_uuid) + "'");
|
|
|
|
auto results = db.QueryDatabase(
|
|
fmt::format(
|
|
"UPDATE {} SET {} WHERE {} = {}",
|
|
TableName(),
|
|
implode(", ", update_values),
|
|
PrimaryKey(),
|
|
expedition_lockouts_entry.id
|
|
)
|
|
);
|
|
|
|
return (results.Success() ? results.RowsAffected() : 0);
|
|
}
|
|
|
|
static ExpeditionLockouts InsertOne(
|
|
Database& db,
|
|
ExpeditionLockouts expedition_lockouts_entry
|
|
)
|
|
{
|
|
std::vector<std::string> insert_values;
|
|
|
|
insert_values.push_back(std::to_string(expedition_lockouts_entry.id));
|
|
insert_values.push_back(std::to_string(expedition_lockouts_entry.expedition_id));
|
|
insert_values.push_back("'" + EscapeString(expedition_lockouts_entry.event_name) + "'");
|
|
insert_values.push_back("'" + EscapeString(expedition_lockouts_entry.expire_time) + "'");
|
|
insert_values.push_back(std::to_string(expedition_lockouts_entry.duration));
|
|
insert_values.push_back("'" + EscapeString(expedition_lockouts_entry.from_expedition_uuid) + "'");
|
|
|
|
auto results = db.QueryDatabase(
|
|
fmt::format(
|
|
"{} VALUES ({})",
|
|
BaseInsert(),
|
|
implode(",", insert_values)
|
|
)
|
|
);
|
|
|
|
if (results.Success()) {
|
|
expedition_lockouts_entry.id = results.LastInsertedID();
|
|
return expedition_lockouts_entry;
|
|
}
|
|
|
|
expedition_lockouts_entry = NewEntity();
|
|
|
|
return expedition_lockouts_entry;
|
|
}
|
|
|
|
static int InsertMany(
|
|
Database& db,
|
|
std::vector<ExpeditionLockouts> expedition_lockouts_entries
|
|
)
|
|
{
|
|
std::vector<std::string> insert_chunks;
|
|
|
|
for (auto &expedition_lockouts_entry: expedition_lockouts_entries) {
|
|
std::vector<std::string> insert_values;
|
|
|
|
insert_values.push_back(std::to_string(expedition_lockouts_entry.id));
|
|
insert_values.push_back(std::to_string(expedition_lockouts_entry.expedition_id));
|
|
insert_values.push_back("'" + EscapeString(expedition_lockouts_entry.event_name) + "'");
|
|
insert_values.push_back("'" + EscapeString(expedition_lockouts_entry.expire_time) + "'");
|
|
insert_values.push_back(std::to_string(expedition_lockouts_entry.duration));
|
|
insert_values.push_back("'" + EscapeString(expedition_lockouts_entry.from_expedition_uuid) + "'");
|
|
|
|
insert_chunks.push_back("(" + implode(",", insert_values) + ")");
|
|
}
|
|
|
|
std::vector<std::string> insert_values;
|
|
|
|
auto results = db.QueryDatabase(
|
|
fmt::format(
|
|
"{} VALUES {}",
|
|
BaseInsert(),
|
|
implode(",", insert_chunks)
|
|
)
|
|
);
|
|
|
|
return (results.Success() ? results.RowsAffected() : 0);
|
|
}
|
|
|
|
static std::vector<ExpeditionLockouts> All(Database& db)
|
|
{
|
|
std::vector<ExpeditionLockouts> all_entries;
|
|
|
|
auto results = db.QueryDatabase(
|
|
fmt::format(
|
|
"{}",
|
|
BaseSelect()
|
|
)
|
|
);
|
|
|
|
all_entries.reserve(results.RowCount());
|
|
|
|
for (auto row = results.begin(); row != results.end(); ++row) {
|
|
ExpeditionLockouts entry{};
|
|
|
|
entry.id = atoi(row[0]);
|
|
entry.expedition_id = atoi(row[1]);
|
|
entry.event_name = row[2] ? row[2] : "";
|
|
entry.expire_time = row[3] ? row[3] : "";
|
|
entry.duration = atoi(row[4]);
|
|
entry.from_expedition_uuid = row[5] ? row[5] : "";
|
|
|
|
all_entries.push_back(entry);
|
|
}
|
|
|
|
return all_entries;
|
|
}
|
|
|
|
static std::vector<ExpeditionLockouts> GetWhere(Database& db, std::string where_filter)
|
|
{
|
|
std::vector<ExpeditionLockouts> all_entries;
|
|
|
|
auto results = db.QueryDatabase(
|
|
fmt::format(
|
|
"{} WHERE {}",
|
|
BaseSelect(),
|
|
where_filter
|
|
)
|
|
);
|
|
|
|
all_entries.reserve(results.RowCount());
|
|
|
|
for (auto row = results.begin(); row != results.end(); ++row) {
|
|
ExpeditionLockouts entry{};
|
|
|
|
entry.id = atoi(row[0]);
|
|
entry.expedition_id = atoi(row[1]);
|
|
entry.event_name = row[2] ? row[2] : "";
|
|
entry.expire_time = row[3] ? row[3] : "";
|
|
entry.duration = atoi(row[4]);
|
|
entry.from_expedition_uuid = row[5] ? row[5] : "";
|
|
|
|
all_entries.push_back(entry);
|
|
}
|
|
|
|
return all_entries;
|
|
}
|
|
|
|
static int DeleteWhere(Database& db, std::string where_filter)
|
|
{
|
|
auto results = db.QueryDatabase(
|
|
fmt::format(
|
|
"DELETE FROM {} WHERE {}",
|
|
TableName(),
|
|
where_filter
|
|
)
|
|
);
|
|
|
|
return (results.Success() ? results.RowsAffected() : 0);
|
|
}
|
|
|
|
static int Truncate(Database& db)
|
|
{
|
|
auto results = db.QueryDatabase(
|
|
fmt::format(
|
|
"TRUNCATE TABLE {}",
|
|
TableName()
|
|
)
|
|
);
|
|
|
|
return (results.Success() ? results.RowsAffected() : 0);
|
|
}
|
|
|
|
};
|
|
|
|
#endif //EQEMU_BASE_EXPEDITION_LOCKOUTS_REPOSITORY_H
|