diff --git a/server/modules/monitor/galeramon.c b/server/modules/monitor/galeramon.c
index 06a6e6de8..e1ddc1217 100644
--- a/server/modules/monitor/galeramon.c
+++ b/server/modules/monitor/galeramon.c
@@ -372,6 +372,13 @@ char 			*server_string;
 	if (mysql_query(database->con, "SHOW STATUS LIKE 'wsrep_local_state'") == 0
 		&& (result = mysql_store_result(database->con)) != NULL)
 	{
+		if(mysql_field_count(database->con) < 2)
+		{
+		    mysql_free_result(result);
+		    skygw_log_write(LE,"Error: Malformed result for \"SHOW STATUS LIKE 'wsrep_local_state'\"");
+		    return;
+		}
+
 		while ((row = mysql_fetch_row(result)))
 		{
 			if (strcmp(row[1], "4") == 0) 
@@ -398,6 +405,14 @@ char 			*server_string;
 		&& (result = mysql_store_result(database->con)) != NULL)
 	{
 		long local_index = -1;
+
+		if(mysql_field_count(database->con) < 2)
+		{
+		    mysql_free_result(result);
+		    skygw_log_write(LE,"Error: Malformed result for \"SHOW STATUS LIKE 'wsrep_local_index'\"");
+		    return;
+		}
+
 		while ((row = mysql_fetch_row(result)))
 		{
 			local_index = strtol(row[1], NULL, 10);
diff --git a/server/modules/monitor/mmmon.c b/server/modules/monitor/mmmon.c
index 545a77ca2..970fd0d31 100644
--- a/server/modules/monitor/mmmon.c
+++ b/server/modules/monitor/mmmon.c
@@ -366,7 +366,14 @@ char 		  *server_string;
                 && (result = mysql_store_result(database->con)) != NULL)
         {
                 long server_id = -1;
-                
+
+		if(mysql_field_count(database->con) != 1)
+		{
+		    mysql_free_result(result);
+		    skygw_log_write(LE,"Error: Malformed result for 'SELECT @@server_id'.");
+		    return;
+		}
+
                 while ((row = mysql_fetch_row(result)))
                 {
                         server_id = strtol(row[0], NULL, 10);
@@ -392,7 +399,15 @@ char 		  *server_string;
 		{
 			int i = 0;
 			long master_id = -1;
-			
+
+			if(mysql_field_count(database->con) < 42)
+			{
+			    mysql_free_result(result);
+			    skygw_log_write(LE,"Error: SHOW ALL SLAVES STATUS "
+				    "returned less than the expected amount of rows.");
+			    return;
+			}
+
 			while ((row = mysql_fetch_row(result)))
 			{
 				/* get Slave_IO_Running and Slave_SQL_Running values*/
@@ -431,7 +446,15 @@ char 		  *server_string;
 			&& (result = mysql_store_result(database->con)) != NULL)
 		{
 			long master_id = -1;
-			
+
+			if(mysql_field_count(database->con) < 40)
+			{
+			    mysql_free_result(result);
+			    skygw_log_write(LE,"Error: SHOW SLAVE STATUS "
+				    "returned less than the expected amount of rows.");
+			    return;
+			}
+
 			while ((row = mysql_fetch_row(result)))
 			{
 				/* get Slave_IO_Running and Slave_SQL_Running values*/
@@ -463,6 +486,12 @@ char 		  *server_string;
 	if (mysql_query(database->con, "SHOW GLOBAL VARIABLES LIKE 'read_only'") == 0
 		&& (result = mysql_store_result(database->con)) != NULL)
 	{
+		if(mysql_field_count(database->con) < 2)
+		{
+		    mysql_free_result(result);
+		    skygw_log_write(LE,"Error: Malformed result for \"SHOW GLOBAL VARIABLES LIKE 'read_only'\"");
+		    return;
+		}
 
 		while ((row = mysql_fetch_row(result)))
 		{
diff --git a/server/modules/monitor/mysql_mon.c b/server/modules/monitor/mysql_mon.c
index e310e2ede..4c5f57ab6 100644
--- a/server/modules/monitor/mysql_mon.c
+++ b/server/modules/monitor/mysql_mon.c
@@ -408,6 +408,12 @@ char 		  *server_string;
                 && (result = mysql_store_result(database->con)) != NULL)
         {
                 long server_id = -1;
+		if(mysql_field_count(database->con) != 1)
+		{
+		    mysql_free_result(result);
+		    skygw_log_write(LE,"Error: Malformed result for 'SELECT @@server_id'.");
+		    return;
+		}
                 while ((row = mysql_fetch_row(result)))
                 {
                         server_id = strtol(row[0], NULL, 10);
@@ -433,6 +439,15 @@ char 		  *server_string;
 		{
 			int i = 0;
 			long master_id = -1;
+
+			if(mysql_field_count(database->con) < 42)
+			{
+			    mysql_free_result(result);
+			    skygw_log_write(LE,"Error: SHOW ALL SLAVES STATUS "
+				    "returned less than the expected amount of rows.");
+			    return;
+			}
+
 			while ((row = mysql_fetch_row(result)))
 			{
 				/* get Slave_IO_Running and Slave_SQL_Running values*/
@@ -471,6 +486,14 @@ char 		  *server_string;
 			&& (result = mysql_store_result(database->con)) != NULL)
 		{
 			long master_id = -1;
+			if(mysql_field_count(database->con) < 40)
+			{
+			    mysql_free_result(result);
+			    skygw_log_write(LE,"Error: SHOW SLAVE STATUS "
+				    "returned less than the expected amount of rows.");
+			    return;
+			}
+
 			while ((row = mysql_fetch_row(result)))
 			{
 				/* get Slave_IO_Running and Slave_SQL_Running values*/
diff --git a/server/modules/monitor/ndbclustermon.c b/server/modules/monitor/ndbclustermon.c
index 9561e275e..ed218d43e 100644
--- a/server/modules/monitor/ndbclustermon.c
+++ b/server/modules/monitor/ndbclustermon.c
@@ -323,6 +323,13 @@ char 			*server_string;
 	if (mysql_query(database->con, "SHOW STATUS LIKE 'Ndb_number_of_ready_data_nodes'") == 0
 		&& (result = mysql_store_result(database->con)) != NULL)
 	{
+		if(mysql_field_count(database->con) < 2)
+		{
+		    mysql_free_result(result);
+		    skygw_log_write(LE,"Error: Malformed result for \"SHOW STATUS LIKE 'Ndb_number_of_ready_data_nodes'\"");
+		    return;
+		}
+
 		while ((row = mysql_fetch_row(result)))
 		{
 			if (atoi(row[1]) > 0)
@@ -335,6 +342,13 @@ char 			*server_string;
 	if (mysql_query(database->con, "SHOW STATUS LIKE 'Ndb_cluster_node_id'") == 0
 		&& (result = mysql_store_result(database->con)) != NULL)
 	{
+		if(mysql_field_count(database->con) < 2)
+		{
+		    mysql_free_result(result);
+		    skygw_log_write(LE,"Error: Malformed result for \"SHOW STATUS LIKE 'Ndb_cluster_node_id'\"");
+		    return;
+		}
+
 		long cluster_node_id = -1;
 		while ((row = mysql_fetch_row(result)))
 		{