IdoCheckTask: de-couple MySQL and Postgres schema versions

lib/db_ido/dbconnection.hpp

@@ -12,7 +12,6 @@
 #include <boost/thread/once.hpp>
 #include <mutex>
 
-#define IDO_CURRENT_SCHEMA_VERSION "1.14.3"
 #define IDO_COMPAT_SCHEMA_VERSION "1.14.3"
 
 namespace icinga
@@ -30,6 +29,8 @@ public:
 
 	static void InitializeDbTimer();
 
+	virtual const char * GetLatestSchemaVersion() const noexcept = 0;
+
 	void SetConfigHash(const DbObject::Ptr& dbobj, const String& hash);
 	void SetConfigHash(const DbType::Ptr& type, const DbReference& objid, const String& hash);
 	String GetConfigHash(const DbObject::Ptr& dbobj) const;

lib/db_ido/idochecktask.cpp

@@ -140,9 +140,9 @@ void IdoCheckTask::ScriptFunc(const Checkable::Ptr& checkable, const CheckResult
 	String schema_version = conn->GetSchemaVersion();
 	std::ostringstream msgbuf;
 
-	if (Utility::CompareVersion(IDO_CURRENT_SCHEMA_VERSION, schema_version) < 0) {
+	if (Utility::CompareVersion(conn->GetLatestSchemaVersion(), schema_version) < 0) {
 		msgbuf << "Outdated schema version: '" << schema_version << "'. Latest version: '"
-		    << IDO_CURRENT_SCHEMA_VERSION << "'."
+		    << conn->GetLatestSchemaVersion() << "'."
 		    << " Queries per second: " << std::fixed << std::setprecision(3) << qps
 		    << " Pending queries: " << std::fixed << std::setprecision(3) << pendingQueries << ".";
 

lib/db_ido_mysql/idomysqlconnection.cpp

@@ -21,6 +21,11 @@ using namespace icinga;
 REGISTER_TYPE(IdoMysqlConnection);
 REGISTER_STATSFUNCTION(IdoMysqlConnection, &IdoMysqlConnection::StatsFunc);
 
+const char * IdoMysqlConnection::GetLatestSchemaVersion() const noexcept
+{
+	return "1.14.3";
+}
+
 void IdoMysqlConnection::OnConfigLoaded()
 {
 	ObjectImpl<IdoMysqlConnection>::OnConfigLoaded();

lib/db_ido_mysql/idomysqlconnection.hpp

@@ -37,6 +37,8 @@ public:
 
 	static void StatsFunc(const Dictionary::Ptr& status, const Array::Ptr& perfdata);
 
+	const char * GetLatestSchemaVersion() const noexcept override;
+
 	int GetPendingQueryCount() const override;
 
 protected:

lib/db_ido_pgsql/idopgsqlconnection.cpp

@@ -23,6 +23,11 @@ REGISTER_TYPE(IdoPgsqlConnection);
 
 REGISTER_STATSFUNCTION(IdoPgsqlConnection, &IdoPgsqlConnection::StatsFunc);
 
+const char * IdoPgsqlConnection::GetLatestSchemaVersion() const noexcept
+{
+	return "1.14.3";
+}
+
 IdoPgsqlConnection::IdoPgsqlConnection()
 {
 	m_QueryQueue.SetName("IdoPgsqlConnection, " + GetName());

lib/db_ido_pgsql/idopgsqlconnection.hpp

@@ -30,6 +30,8 @@ public:
 
 	static void StatsFunc(const Dictionary::Ptr& status, const Array::Ptr& perfdata);
 
+	const char * GetLatestSchemaVersion() const noexcept override;
+
 	int GetPendingQueryCount() const override;
 
 protected: