fix(broker/unified_sql): broker could not insert tag in resources_tag…

…s table REFS:MON-21877
centreon · Feb 7, 2024 · 0e7eee0 · 0e7eee0
1 parent 56b8953
commit 0e7eee0
Show file tree

Hide file tree

Showing 4 changed files with 868 additions and 849 deletions.
diff --git a/broker/unified_sql/inc/com/centreon/broker/unified_sql/stream.hh b/broker/unified_sql/inc/com/centreon/broker/unified_sql/stream.hh
@@ -293,8 +293,7 @@ class stream : public io::stream {
 
   database::mysql_stmt _severity_insert;
   database::mysql_stmt _severity_update;
-  database::mysql_stmt _tag_insert;
-  database::mysql_stmt _tag_update;
+  database::mysql_stmt _tag_insert_update;
   database::mysql_stmt _tag_delete;
   database::mysql_stmt _resources_tags_insert;
   database::mysql_stmt _resources_host_insert;
@@ -359,9 +358,11 @@ class stream : public io::stream {
   void _process_responsive_instance(const std::shared_ptr<io::data>& d);
 
   void _process_pb_host(const std::shared_ptr<io::data>& d);
+  uint64_t _process_pb_host_in_resources(const Host& h, int32_t conn);
   void _process_pb_host_status(const std::shared_ptr<io::data>& d);
   void _process_pb_adaptive_host(const std::shared_ptr<io::data>& d);
   void _process_pb_service(const std::shared_ptr<io::data>& d);
+  uint64_t _process_pb_service_in_resources(const Service& s, int32_t conn);
   void _process_pb_adaptive_service(const std::shared_ptr<io::data>& d);
   void _process_pb_service_status(const std::shared_ptr<io::data>& d);
   void _process_severity(const std::shared_ptr<io::data>& d);