]> git.lizzy.rs Git - dragonfireclient.git/blobdiff - src/database/database-postgresql.h
Verify database connection on interval (#9665)
[dragonfireclient.git] / src / database / database-postgresql.h
index db0b505c9cbc3836176a5380513f9865d346d6a0..5a8b89a515b2b862b9a472369ba794084dfac407 100644 (file)
@@ -32,12 +32,13 @@ class Database_PostgreSQL: public Database
        Database_PostgreSQL(const std::string &connect_string);
        ~Database_PostgreSQL();
 
+       virtual void pingDatabase();
+
        void beginSave();
        void endSave();
 
        bool initialized() const;
 
-
 protected:
        // Conversion helpers
        inline int pg_to_int(PGresult *res, int row, int col)
@@ -82,7 +83,6 @@ class Database_PostgreSQL: public Database
        }
 
        void createTableIfNotExists(const std::string &table_name, const std::string &definition);
-       void verifyDatabase();
 
        // Database initialization
        void connectToDatabase();
@@ -113,6 +113,8 @@ class MapDatabasePostgreSQL : private Database_PostgreSQL, public MapDatabase
        MapDatabasePostgreSQL(const std::string &connect_string);
        virtual ~MapDatabasePostgreSQL() = default;
 
+       virtual void pingDatabase() { Database_PostgreSQL::pingDatabase(); }
+
        bool saveBlock(const v3s16 &pos, const std::string &data);
        void loadBlock(const v3s16 &pos, std::string *block);
        bool deleteBlock(const v3s16 &pos);
@@ -132,6 +134,8 @@ class PlayerDatabasePostgreSQL : private Database_PostgreSQL, public PlayerDatab
        PlayerDatabasePostgreSQL(const std::string &connect_string);
        virtual ~PlayerDatabasePostgreSQL() = default;
 
+       virtual void pingDatabase() { Database_PostgreSQL::pingDatabase(); }
+
        void savePlayer(RemotePlayer *player);
        bool loadPlayer(RemotePlayer *player, PlayerSAO *sao);
        bool removePlayer(const std::string &name);