1 files changed, 10 insertions, 0 deletions
diff --git a/lib/output/pq/updateDatabase.cpp b/lib/output/pq/updateDatabase.cpp
index c43d8e4..9db672d 100644
--- a/lib/output/pq/updateDatabase.cpp
+++ b/lib/output/pq/updateDatabase.cpp
@@ -20,6 +20,7 @@
 #include <output/pq/sql/selectSourceSchema.h>
 #include <output/pq/sql/selectTables.h>
 #include <output/pq/sql/updateSourcePosition.h>
+#include <output/pq/sql/updateSourceRotate.h>
 #include <row.h>
 #include <stdexcept>
 #include <streamSupport.h>
@@ -384,4 +385,13 @@ namespace MyGrate::Output::Pq {
 			afterEvent(e);
 		}
 	}
+
+	void
+	UpdateDatabase::rotate(MariaDB_Event_Ptr e)
+	{
+		if ((e->flags & LOG_EVENT_ARTIFICIAL_F) == 0) {
+			output::pq::sql::updateSourceRotate::execute(
+					this, *e->event.rotate.filename, e->event.rotate.position, source);
+		}
+	}
 }