mirror of
https://github.com/HikikoMarmy/Champions-Reborn-Server.git
synced 2026-04-05 08:59:54 -03:00
Database Management for RTA.
This commit is contained in:
HikikoMarmy
539
Database/Database.cpp
Normal file
539
Database/Database.cpp
Normal file
@@ -0,0 +1,539 @@
|
||||
#include "Database.h"
|
||||
|
||||
#include "../../Crypto/PasswordHash.h"
|
||||
#include "../../Game/RealmCharacter.h"
|
||||
#include "../../Game/RealmCharacterMetaKV.h"
|
||||
#include "../logging.h"
|
||||
|
||||
Database::Database()
|
||||
{
|
||||
if( sqlite3_open( "./database/game.db", &m_db ) != SQLITE_OK )
|
||||
{
|
||||
throw std::runtime_error( "Failed to open DB: " + std::string( sqlite3_errmsg( m_db ) ) );
|
||||
}
|
||||
|
||||
CreateTables();
|
||||
PrepareStatements();
|
||||
}
|
||||
|
||||
Database::~Database()
|
||||
{
|
||||
FinalizeStatements();
|
||||
if( m_db )
|
||||
sqlite3_close( m_db );
|
||||
}
|
||||
|
||||
void Database::CreateTables()
|
||||
{
|
||||
Execute( "CREATE TABLE IF NOT EXISTS RealmUsers ("
|
||||
"account_id INTEGER PRIMARY KEY AUTOINCREMENT,"
|
||||
"username TEXT UNIQUE NOT NULL,"
|
||||
"password TEXT NOT NULL,"
|
||||
"email_address TEXT NOT NULL,"
|
||||
"date_of_birth NOT NULL,"
|
||||
"chat_handle TEXT NOT NULL)" );
|
||||
|
||||
Execute( "CREATE TABLE IF NOT EXISTS RealmCharacters ("
|
||||
"account_id INTEGER NOT NULL,"
|
||||
"character_id INTEGER PRIMARY KEY AUTOINCREMENT,"
|
||||
"meta_data BLOB NOT NULL,"
|
||||
"character_data BLOB NOT NULL,"
|
||||
"inventory_data BLOB)" );
|
||||
|
||||
Execute( "CREATE TABLE IF NOT EXISTS RealmSession ("
|
||||
"account_id INTEGER NOT NULL,"
|
||||
"session_id TEXT NOT NULL UNIQUE,"
|
||||
"ip_address TEXT NOT NULL,"
|
||||
"expire_time INTEGER NOT NULL,"
|
||||
"PRIMARY KEY(session_id))");
|
||||
}
|
||||
|
||||
void Database::PrepareStatements()
|
||||
{
|
||||
const std::vector<std::pair<QueryID, const char *>> queries = {
|
||||
{ QueryID::CreateAccount,
|
||||
"INSERT INTO RealmUsers (username, password, email_address, date_of_birth, chat_handle ) VALUES (?, ?, ?, ?, ?);" },
|
||||
|
||||
{ QueryID::VerifyAccount,
|
||||
"SELECT account_id, username, password FROM RealmUsers WHERE username = ?;" },
|
||||
|
||||
{ QueryID::CreateSession,
|
||||
"INSERT INTO RealmSession (account_id, session_id, ip_address, expire_time) VALUES (?, ?, ?, ?);" },
|
||||
|
||||
{ QueryID::UpdateSession,
|
||||
"UPDATE RealmSession SET expire_time = ? WHERE session_id = ?;" },
|
||||
|
||||
{ QueryID::DeleteSession,
|
||||
"DELETE FROM RealmSession WHERE session_id = ?;" },
|
||||
|
||||
{ QueryID::GetSession,
|
||||
"SELECT account_id, expire_time FROM RealmSession WHERE session_id = ? AND ip_address = ?;" },
|
||||
|
||||
{ QueryID::CreateNewCharacter,
|
||||
"INSERT INTO RealmCharacters (account_id, meta_data, character_data) VALUES (?, ?, ?);" },
|
||||
|
||||
{ QueryID::SaveCharacter,
|
||||
"UPDATE RealmCharacters SET meta_data = ?, character_data = ? WHERE account_id = ? AND character_id = ?;" },
|
||||
|
||||
{ QueryID::SaveInventory,
|
||||
"UPDATE RealmCharacters SET inventory_data = ? WHERE account_id = ? AND character_id = ?;" },
|
||||
|
||||
{ QueryID::LoadCharacter,
|
||||
"SELECT character_id, meta_data, character_data, inventory_data FROM RealmCharacters WHERE account_id = ? AND character_id = ?;" },
|
||||
|
||||
{ QueryID::LoadAllCharacterMetaData,
|
||||
"SELECT character_id, meta_data FROM RealmCharacters WHERE account_id = ? ORDER BY character_id;" }
|
||||
};
|
||||
|
||||
try
|
||||
{
|
||||
for( const auto &[id, sql] : queries )
|
||||
{
|
||||
sqlite3_stmt *stmt = nullptr;
|
||||
if( sqlite3_prepare_v2( m_db, sql, -1, &stmt, nullptr ) != SQLITE_OK )
|
||||
{
|
||||
throw std::runtime_error( "Failed to prepare statement: " + std::string( sqlite3_errmsg( m_db ) ) );
|
||||
}
|
||||
m_statements[ id ] = stmt;
|
||||
}
|
||||
}
|
||||
catch( const std::exception &e )
|
||||
{
|
||||
FinalizeStatements();
|
||||
Log::Error( "Database error: " + std::string( e.what() ) );
|
||||
}
|
||||
}
|
||||
|
||||
void Database::FinalizeStatements()
|
||||
{
|
||||
if( m_db == nullptr )
|
||||
return;
|
||||
|
||||
for( const auto &[id, stmt] : m_statements )
|
||||
{
|
||||
if( stmt ) sqlite3_finalize( stmt );
|
||||
}
|
||||
m_statements.clear();
|
||||
}
|
||||
|
||||
void Database::Execute( const char *sql )
|
||||
{
|
||||
try
|
||||
{
|
||||
char *errMsg = nullptr;
|
||||
if( sqlite3_exec( m_db, sql, nullptr, nullptr, &errMsg ) != SQLITE_OK )
|
||||
{
|
||||
std::string error = "SQL execution failed: " + std::string( errMsg );
|
||||
sqlite3_free( errMsg );
|
||||
throw std::runtime_error( error );
|
||||
}
|
||||
}
|
||||
catch( const std::exception &e )
|
||||
{
|
||||
Log::Error( "Database error: " + std::string( e.what() ) );
|
||||
}
|
||||
}
|
||||
|
||||
int64_t Database::CreateNewAccount( const std::string &username,
|
||||
const std::string &password,
|
||||
const std::string &email_address,
|
||||
const std::string &date_of_birth,
|
||||
const std::string &chat_handle )
|
||||
{
|
||||
try
|
||||
{
|
||||
auto hashedPassword = HashPassword( password, 1000, 32 );
|
||||
auto stmt = m_statements[ QueryID::CreateAccount ];
|
||||
|
||||
sqlite3_reset( stmt );
|
||||
sqlite3_clear_bindings( stmt );
|
||||
|
||||
sqlite3_bind_text( stmt, 1, username.c_str(), -1, SQLITE_TRANSIENT );
|
||||
sqlite3_bind_text( stmt, 2, hashedPassword.c_str(), -1, SQLITE_TRANSIENT );
|
||||
sqlite3_bind_text( stmt, 3, email_address.c_str(), -1, SQLITE_TRANSIENT );
|
||||
sqlite3_bind_text( stmt, 4, date_of_birth.c_str(), -1, SQLITE_TRANSIENT );
|
||||
sqlite3_bind_text( stmt, 5, chat_handle.c_str(), -1, SQLITE_TRANSIENT );
|
||||
|
||||
if( sqlite3_step( stmt ) != SQLITE_DONE )
|
||||
{
|
||||
throw std::runtime_error( "Insert failed: " + std::string( sqlite3_errmsg( m_db ) ) );
|
||||
}
|
||||
|
||||
return sqlite3_last_insert_rowid( m_db );
|
||||
}
|
||||
catch( const std::exception &e )
|
||||
{
|
||||
throw std::runtime_error( "Database error: " + std::string( e.what() ) );
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
int64_t Database::VerifyAccount( const std::string &username, const std::string &password )
|
||||
{
|
||||
try
|
||||
{
|
||||
auto stmt = m_statements[ QueryID::VerifyAccount ];
|
||||
|
||||
sqlite3_reset( stmt );
|
||||
sqlite3_clear_bindings( stmt );
|
||||
|
||||
sqlite3_bind_text( stmt, 1, username.c_str(), -1, SQLITE_TRANSIENT );
|
||||
|
||||
// Execute the statement
|
||||
if( sqlite3_step( stmt ) == SQLITE_ROW )
|
||||
{
|
||||
int64_t accountId = sqlite3_column_int64( stmt, 0 );
|
||||
const char *dbUsername = reinterpret_cast< const char * >( sqlite3_column_text( stmt, 1 ) );
|
||||
const char *dbPassword = reinterpret_cast< const char * >( sqlite3_column_text( stmt, 2 ) );
|
||||
|
||||
if( username == dbUsername && VerifyPassword( password, dbPassword ) )
|
||||
{
|
||||
Log::Debug( "Account verified: %s (ID: %lld)", username.c_str(), accountId );
|
||||
return accountId;
|
||||
}
|
||||
else
|
||||
{
|
||||
Log::Error( "Invalid credentials for account ID: %lld", accountId );
|
||||
return -1;
|
||||
}
|
||||
}
|
||||
else if( sqlite3_step( stmt ) == SQLITE_DONE )
|
||||
{
|
||||
return -1; // No matching account found
|
||||
}
|
||||
else
|
||||
{
|
||||
throw std::runtime_error( "Query failed: " + std::string( sqlite3_errmsg( m_db ) ) );
|
||||
}
|
||||
}
|
||||
catch( const std::exception &e )
|
||||
{
|
||||
Log::Error( "Database error: " + std::string( e.what() ) );
|
||||
}
|
||||
|
||||
return -1;
|
||||
|
||||
}
|
||||
|
||||
bool Database::CreateSession(const int64_t account_id, const std::wstring& session_id, const std::string& ip_address)
|
||||
{
|
||||
try
|
||||
{
|
||||
auto stmt = m_statements[ QueryID::CreateSession ];
|
||||
auto sessionId = Util::WideToUTF8( session_id );
|
||||
|
||||
sqlite3_reset( stmt );
|
||||
sqlite3_clear_bindings( stmt );
|
||||
|
||||
sqlite3_bind_int64( stmt, 1, account_id );
|
||||
sqlite3_bind_text( stmt, 2, sessionId.c_str(), -1, SQLITE_TRANSIENT );
|
||||
sqlite3_bind_text( stmt, 3, ip_address.c_str(), -1, SQLITE_TRANSIENT );
|
||||
sqlite3_bind_int64( stmt, 4, time( nullptr ) + 300 ); // Session expires in 5 minutes
|
||||
|
||||
if( sqlite3_step( stmt ) != SQLITE_DONE )
|
||||
{
|
||||
Log::Error( "SQLite insert failed: %s", sqlite3_errmsg( m_db ) );
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
catch( const std::exception &e )
|
||||
{
|
||||
Log::Error( "Database error: " + std::string( e.what() ) );
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
bool Database::UpdateSession(const std::wstring& session_id)
|
||||
{
|
||||
try
|
||||
{
|
||||
auto stmt = m_statements[ QueryID::UpdateSession ];
|
||||
auto sessionId = Util::WideToUTF8( session_id );
|
||||
|
||||
sqlite3_reset( stmt );
|
||||
sqlite3_clear_bindings( stmt );
|
||||
|
||||
sqlite3_bind_int64(stmt, 1, time(nullptr) + 300); // Extend session by 5 minutes
|
||||
sqlite3_bind_text(stmt, 2, sessionId.c_str(), -1, SQLITE_TRANSIENT);
|
||||
|
||||
if (sqlite3_step(stmt) != SQLITE_DONE)
|
||||
{
|
||||
Log::Error("SQLite update failed: %s", sqlite3_errmsg(m_db));
|
||||
return false;
|
||||
}
|
||||
|
||||
Log::Debug("Session updated: %s", session_id.c_str());
|
||||
return true;
|
||||
}
|
||||
catch (const std::exception& e)
|
||||
{
|
||||
Log::Error("Database error: " + std::string(e.what()));
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
bool Database::DeleteSession(const std::wstring& session_id)
|
||||
{
|
||||
try
|
||||
{
|
||||
auto stmt = m_statements[ QueryID::DeleteSession ];
|
||||
auto sessionId = Util::WideToUTF8( session_id );
|
||||
|
||||
sqlite3_reset( stmt );
|
||||
sqlite3_clear_bindings( stmt );
|
||||
|
||||
sqlite3_bind_text( stmt, 1, sessionId.c_str(), -1, SQLITE_TRANSIENT );
|
||||
|
||||
if( sqlite3_step( stmt ) != SQLITE_DONE )
|
||||
{
|
||||
Log::Error( "SQLite delete failed: %s", sqlite3_errmsg( m_db ) );
|
||||
return false;
|
||||
}
|
||||
|
||||
Log::Debug( "Session deleted: %s", session_id.c_str() );
|
||||
return true;
|
||||
}
|
||||
catch( const std::exception &e )
|
||||
{
|
||||
Log::Error( "Database error: " + std::string( e.what() ) );
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
int64_t Database::GetSession(std::wstring& session_id, std::string& ip_address)
|
||||
{
|
||||
try
|
||||
{
|
||||
auto stmt = m_statements[ QueryID::GetSession ];
|
||||
auto sessionId = Util::WideToUTF8( session_id );
|
||||
|
||||
sqlite3_reset( stmt );
|
||||
sqlite3_clear_bindings( stmt );
|
||||
|
||||
sqlite3_bind_text( stmt, 1, sessionId.c_str(), -1, SQLITE_TRANSIENT );
|
||||
sqlite3_bind_text( stmt, 2, ip_address.c_str(), -1, SQLITE_TRANSIENT );
|
||||
|
||||
if( sqlite3_step( stmt ) == SQLITE_ROW )
|
||||
{
|
||||
int64_t account_id = sqlite3_column_int64( stmt, 0 );
|
||||
int64_t expire_time = sqlite3_column_int64( stmt, 1 );
|
||||
|
||||
if( expire_time > time( nullptr ) )
|
||||
{
|
||||
Log::Debug( "Session found: %s for account ID: %lld", session_id.c_str(), account_id );
|
||||
return account_id;
|
||||
}
|
||||
else
|
||||
{
|
||||
Log::Error( "Session expired: %s", session_id.c_str() );
|
||||
return -1; // Session expired
|
||||
}
|
||||
}
|
||||
else if( sqlite3_step( stmt ) == SQLITE_DONE )
|
||||
{
|
||||
Log::Error( "No session found for ID: %s", session_id.c_str() );
|
||||
return -1; // No session found
|
||||
}
|
||||
else
|
||||
{
|
||||
throw std::runtime_error("Query failed: " + std::string(sqlite3_errmsg(m_db)));
|
||||
}
|
||||
}
|
||||
catch( const std::exception &e )
|
||||
{
|
||||
Log::Error( "Database error: " + std::string( e.what() ) );
|
||||
}
|
||||
|
||||
return -1;
|
||||
}
|
||||
|
||||
int32_t Database::CreateNewCharacter( const int64_t account_id,
|
||||
const std::vector< uint8_t > &meta_data,
|
||||
const std::vector< uint8_t > &character_blob )
|
||||
{
|
||||
try
|
||||
{
|
||||
auto stmt = m_statements[ QueryID::CreateNewCharacter ];
|
||||
|
||||
sqlite3_reset( stmt );
|
||||
sqlite3_clear_bindings( stmt );
|
||||
|
||||
sqlite3_bind_int64( stmt, 1, account_id );
|
||||
sqlite3_bind_blob( stmt, 2, meta_data.data(), static_cast< int >( meta_data.size() ), SQLITE_STATIC );
|
||||
sqlite3_bind_blob( stmt, 3, character_blob.data(), static_cast< int >( character_blob.size() ), SQLITE_STATIC );
|
||||
|
||||
int rc = sqlite3_step( stmt );
|
||||
if( rc != SQLITE_DONE )
|
||||
{
|
||||
Log::Error( "SQLite insert failed: %s", sqlite3_errmsg( m_db ) );
|
||||
return -1;
|
||||
}
|
||||
|
||||
auto character_id = sqlite3_last_insert_rowid( m_db );
|
||||
return static_cast< int32_t >( character_id );
|
||||
}
|
||||
catch( const std::exception &e )
|
||||
{
|
||||
Log::Error( "Database error: " + std::string( e.what() ) );
|
||||
}
|
||||
|
||||
return -1;
|
||||
}
|
||||
|
||||
bool Database::SaveCharacter( const int64_t account_id,
|
||||
const int32_t character_id,
|
||||
const std::vector< uint8_t > &meta_data,
|
||||
const std::vector< uint8_t > &character_blob )
|
||||
{
|
||||
try
|
||||
{
|
||||
auto stmt = m_statements[ QueryID::SaveCharacter ];
|
||||
sqlite3_reset( stmt );
|
||||
sqlite3_clear_bindings( stmt );
|
||||
|
||||
sqlite3_bind_blob(stmt, 1, meta_data.data(), static_cast<int>(meta_data.size()), SQLITE_STATIC);
|
||||
sqlite3_bind_blob( stmt, 2, character_blob.data(), static_cast< int >( character_blob.size() ), SQLITE_STATIC );
|
||||
sqlite3_bind_int64( stmt, 3, account_id );
|
||||
sqlite3_bind_int( stmt, 4, character_id );
|
||||
|
||||
if( sqlite3_step( stmt ) != SQLITE_DONE )
|
||||
{
|
||||
throw std::runtime_error( "Update failed: " + std::string( sqlite3_errmsg( m_db ) ) );
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
catch( const std::exception &e )
|
||||
{
|
||||
Log::Error( "Database error: " + std::string( e.what() ) );
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
bool Database::SaveInventory( const int64_t account_id,
|
||||
const int32_t character_id,
|
||||
const std::vector< uint8_t > &inventory_blob )
|
||||
{
|
||||
try
|
||||
{
|
||||
auto stmt = m_statements[ QueryID::SaveInventory ];
|
||||
sqlite3_reset( stmt );
|
||||
sqlite3_clear_bindings( stmt );
|
||||
|
||||
sqlite3_bind_blob( stmt, 1, inventory_blob.data(), static_cast< int >( inventory_blob.size() ), SQLITE_STATIC );
|
||||
sqlite3_bind_int64( stmt, 2, account_id );
|
||||
sqlite3_bind_int( stmt, 3, character_id );
|
||||
|
||||
if( sqlite3_step( stmt ) != SQLITE_DONE )
|
||||
{
|
||||
throw std::runtime_error( "Update failed: " + std::string( sqlite3_errmsg( m_db ) ) );
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
catch( const std::exception &e )
|
||||
{
|
||||
Log::Error( "Database error: " + std::string( e.what() ) );
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
std::map< int32_t, RealmCharacterMetaData > Database::LoadCharacterList( const int64_t account_id )
|
||||
{
|
||||
// Character ID, Meta Data
|
||||
std::map< int32_t, RealmCharacterMetaData > result;
|
||||
|
||||
try
|
||||
{
|
||||
auto stmt = m_statements[ QueryID::LoadAllCharacterMetaData ];
|
||||
sqlite3_reset( stmt );
|
||||
sqlite3_clear_bindings( stmt );
|
||||
|
||||
sqlite3_bind_int64( stmt, 1, account_id );
|
||||
|
||||
while( sqlite3_step( stmt ) == SQLITE_ROW )
|
||||
{
|
||||
const auto character_id = sqlite3_column_int( stmt, 0 );
|
||||
const auto *meta_data_blob = static_cast< const uint8_t * >( sqlite3_column_blob( stmt, 1 ) );
|
||||
const auto meta_data_size = sqlite3_column_bytes( stmt, 1 );
|
||||
|
||||
if( meta_data_blob == nullptr || meta_data_size == 0 )
|
||||
{
|
||||
Log::Error( "Character ID %d has no metadata", character_id );
|
||||
continue;
|
||||
}
|
||||
|
||||
RealmCharacterMetaData meta_data( std::vector< uint8_t >( meta_data_blob, meta_data_blob + meta_data_size ) );
|
||||
|
||||
result[ character_id ] = meta_data;
|
||||
}
|
||||
}
|
||||
catch( const std::exception &e )
|
||||
{
|
||||
Log::Error( "Database error: " + std::string( e.what() ) );
|
||||
result.clear();
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
sptr_realm_character Database::LoadCharacterData( const int64_t account_id, const int32_t character_id )
|
||||
{
|
||||
try
|
||||
{
|
||||
auto data = std::make_shared< RealmCharacter >();
|
||||
auto stmt = m_statements[ QueryID::LoadCharacter ];
|
||||
sqlite3_reset( stmt );
|
||||
sqlite3_clear_bindings( stmt );
|
||||
|
||||
sqlite3_bind_int64( stmt, 1, account_id );
|
||||
sqlite3_bind_int( stmt, 2, character_id );
|
||||
|
||||
if( sqlite3_step( stmt ) == SQLITE_ROW )
|
||||
{
|
||||
const auto *meta_data_blob = static_cast< const uint8_t * >( sqlite3_column_blob( stmt, 1 ) );
|
||||
const auto meta_data_size = sqlite3_column_bytes( stmt, 1 );
|
||||
|
||||
if( meta_data_blob && meta_data_size > 0 )
|
||||
{
|
||||
data->SetMetaData( std::vector< uint8_t >( meta_data_blob, meta_data_blob + meta_data_size ) );
|
||||
}
|
||||
|
||||
const auto *character_blob = static_cast< const uint8_t * >( sqlite3_column_blob( stmt, 2 ) );
|
||||
const auto character_size = sqlite3_column_bytes( stmt, 2 );
|
||||
|
||||
if( character_blob && character_size > 0 )
|
||||
{
|
||||
data->SetCharacterData( std::vector< uint8_t >( character_blob, character_blob + character_size ) );
|
||||
}
|
||||
|
||||
const auto *inventory_blob = static_cast< const uint8_t * >( sqlite3_column_blob( stmt, 3 ) );
|
||||
const auto inventory_size = sqlite3_column_bytes( stmt, 3 );
|
||||
|
||||
if( inventory_blob && inventory_size > 0 )
|
||||
{
|
||||
data->SetInventoryData( std::vector< uint8_t >( inventory_blob, inventory_blob + inventory_size ) );
|
||||
}
|
||||
|
||||
Log::Debug( "Character data loaded for account ID: %lld and character ID: %d", account_id, character_id );
|
||||
return data;
|
||||
}
|
||||
else
|
||||
{
|
||||
Log::Error( "No character data found for account ID: %lld and character ID: %d", account_id, character_id );
|
||||
}
|
||||
}
|
||||
catch( const std::exception &e )
|
||||
{
|
||||
Log::Error( "Database error: " + std::string( e.what() ) );
|
||||
}
|
||||
|
||||
return nullptr;
|
||||
}
|
||||
89
Database/Database.h
Normal file
89
Database/Database.h
Normal file
@@ -0,0 +1,89 @@
|
||||
#pragma once
|
||||
|
||||
#include <memory>
|
||||
#include <mutex>
|
||||
#include <string>
|
||||
#include <vector>
|
||||
#include <map>
|
||||
#include <sqlite3.h>
|
||||
|
||||
#include "../../Game/RealmCharacter.h"
|
||||
#include "../../Game/RealmCharacterMetaKV.h"
|
||||
|
||||
enum class QueryID {
|
||||
CreateAccount,
|
||||
VerifyAccount,
|
||||
|
||||
CreateSession,
|
||||
UpdateSession,
|
||||
DeleteSession,
|
||||
GetSession,
|
||||
|
||||
CreateNewCharacter,
|
||||
SaveCharacter,
|
||||
SaveInventory,
|
||||
|
||||
LoadCharacter,
|
||||
LoadAllCharacterMetaData,
|
||||
};
|
||||
|
||||
class Database {
|
||||
private:
|
||||
static inline std::unique_ptr<Database> m_instance;
|
||||
static inline std::mutex m_mutex;
|
||||
|
||||
sqlite3* m_db = nullptr;
|
||||
std::unordered_map< QueryID, sqlite3_stmt * > m_statements;
|
||||
|
||||
public:
|
||||
static Database &Get()
|
||||
{
|
||||
std::lock_guard<std::mutex> lock( m_mutex );
|
||||
if( !m_instance )
|
||||
m_instance.reset( new Database() );
|
||||
return *m_instance;
|
||||
}
|
||||
|
||||
Database( const Database & ) = delete;
|
||||
Database &operator=( const Database & ) = delete;
|
||||
|
||||
Database();
|
||||
~Database();
|
||||
|
||||
public:
|
||||
int64_t CreateNewAccount( const std::string &username,
|
||||
const std::string &password,
|
||||
const std::string &email_address,
|
||||
const std::string &date_of_birth,
|
||||
const std::string &chat_handle );
|
||||
|
||||
int64_t VerifyAccount( const std::string &username, const std::string &password );
|
||||
|
||||
bool CreateSession( const int64_t account_id, const std::wstring &session_id, const std::string &ip_address );
|
||||
bool UpdateSession( const std::wstring &session_id );
|
||||
bool DeleteSession( const std::wstring &session_id );
|
||||
int64_t GetSession(std::wstring& session_id, std::string& ip_address);
|
||||
|
||||
int32_t CreateNewCharacter( const int64_t account_id,
|
||||
const std::vector< uint8_t > &meta_data,
|
||||
const std::vector< uint8_t > &character_blob );
|
||||
|
||||
bool SaveCharacter( const int64_t account_id,
|
||||
const int32_t character_id,
|
||||
const std::vector< uint8_t > &meta_data,
|
||||
const std::vector< uint8_t > &character_blob );
|
||||
|
||||
bool SaveInventory( const int64_t account_id,
|
||||
const int32_t character_id,
|
||||
const std::vector< uint8_t > &inventory_data );
|
||||
|
||||
std::map< int32_t, RealmCharacterMetaData > LoadCharacterList( const int64_t account_id );
|
||||
|
||||
sptr_realm_character LoadCharacterData( const int64_t account_id, const int32_t character_id );
|
||||
|
||||
private:
|
||||
void CreateTables();
|
||||
void PrepareStatements();
|
||||
void FinalizeStatements();
|
||||
void Execute( const char *sql );
|
||||
};
|
||||
Reference in New Issue
Block a user