From 5c66bf5e099871c4d1e6e9c1a1acc0aa4484186a Mon Sep 17 00:00:00 2001
From: Tara <39621793+Tara8573@users.noreply.github.com>
Date: Thu, 24 Sep 2026 21:30:42 +0800
Subject: [PATCH] feat(postgres): browse PostgreSQL event triggers

---
 .../objects/EventTriggerDetailsDialog.vue     | 132 ++++++++++++++++++
 .../src/components/sidebar/ConnectionTree.vue |  25 ++++
 .../sidebar/SidebarTreeRuntimeHost.vue        |  16 ++-
 .../src/components/sidebar/TreeItem.vue       |   4 +
 apps/desktop/src/i18n/locales/az.ts           |  13 ++
 apps/desktop/src/i18n/locales/en.ts           |  13 ++
 apps/desktop/src/i18n/locales/es.ts           |  13 ++
 apps/desktop/src/i18n/locales/it.ts           |  13 ++
 apps/desktop/src/i18n/locales/ja.ts           |  13 ++
 apps/desktop/src/i18n/locales/ko.ts           |  13 ++
 apps/desktop/src/i18n/locales/pt-BR.ts        |  13 ++
 apps/desktop/src/i18n/locales/ru.ts           |  13 ++
 apps/desktop/src/i18n/locales/tr.ts           |  13 ++
 apps/desktop/src/i18n/locales/zh-CN.ts        |  13 ++
 apps/desktop/src/i18n/locales/zh-TW.ts        |  13 ++
 apps/desktop/src/lib/backend/api.ts           |   1 +
 apps/desktop/src/lib/backend/http.ts          |   5 +
 apps/desktop/src/lib/backend/tauri.ts         |   5 +
 .../lib/sidebar/treeLoadedChildrenMarker.ts   |   2 +-
 apps/desktop/src/lib/sidebar/treeNodeClick.ts |   6 +-
 apps/desktop/src/lib/sidebar/treeNodeGroup.ts |   1 +
 apps/desktop/src/lib/sidebar/treeNodeIcon.ts  |   4 +
 .../connectionStore.metadataLoading.spec.ts   |   6 +-
 apps/desktop/src/stores/connectionStore.ts    |  48 +++++++
 apps/desktop/src/types/database.ts            |  16 ++-
 .../dbx-core/assets/docs-export.manifest.json |   2 +-
 crates/dbx-core/src/schema/kingbase.rs        |  61 ++++++++
 crates/dbx-core/src/schema/mod.rs             |  35 +++++
 crates/dbx-drivers/src/db/postgres.rs         |  82 ++++++++++-
 crates/dbx-types/src/types.rs                 |  27 ++++
 crates/dbx-web/src/main.rs                    |   1 +
 crates/dbx-web/src/routes/schema.rs           |  11 ++
 src-tauri/src/commands/schema.rs              |   9 ++
 src-tauri/src/lib.rs                          |   1 +
 34 files changed, 632 insertions(+), 11 deletions(-)
 create mode 100644 apps/desktop/src/components/objects/EventTriggerDetailsDialog.vue

diff --git a/apps/desktop/src/components/objects/EventTriggerDetailsDialog.vue b/apps/desktop/src/components/objects/EventTriggerDetailsDialog.vue
new file mode 100644
index 0000000000..40763abd09
--- /dev/null
+++ b/apps/desktop/src/components/objects/EventTriggerDetailsDialog.vue
@@ -0,0 +1,132 @@
+<script setup lang="ts">
+import { computed, ref } from "vue";
+import { Package } from "@lucide/vue";
+import { useI18n } from "vue-i18n";
+import { Button } from "@/components/ui/button";
+import { Dialog, DialogContent, DialogFooter, DialogHeader, DialogTitle } from "@/components/ui/dialog";
+import type { EventTriggerInfo, TreeNode } from "@/types/database";
+
+const { t } = useI18n();
+
+const props = defineProps<{
+  node: TreeNode;
+}>();
+
+const open = ref(false);
+
+const trigger = computed<EventTriggerInfo>(() => {
+  const meta = props.node.meta as EventTriggerInfo | undefined;
+  return {
+    name: meta?.name || props.node.label,
+    event: meta?.event || "-",
+    owner: meta?.owner || null,
+    function: meta?.function || null,
+    enabled: meta?.enabled || null,
+    tags: meta?.tags || null,
+    comment: meta?.comment || null,
+    source: meta?.source || null,
+  };
+});
+
+const enabledLabel = computed(() => {
+  // PostgreSQL `evtenabled` 状态码映射为原生 DDL 术语（符合详情面板 value 不本地化的惯例）。
+  switch (trigger.value.enabled) {
+    case "O":
+      return "Origin";
+    case "A":
+      return "Always";
+    case "R":
+      return "Replica";
+    case "D":
+      return "Disabled";
+    default:
+      return trigger.value.enabled || "-";
+  }
+});
+
+// `evttags` 为空表示无 WHEN 限制、对所有命令标签触发，用 PG 原生术语 `ALL` 表示（value 不本地化）。
+const tagsLabel = computed(() => (trigger.value.tags?.length ? trigger.value.tags.join(", ") : "ALL"));
+
+// DDL source: prefer the server's `pg_get_eventtriggerdef` reconstruction;
+// fall back to a field-driven rebuild when that function is unavailable
+// (stripped PostgreSQL-compatible kernels hit the sourceless listing path
+// and `source` comes back NULL, so the dialog would otherwise show no DDL).
+const ddlSource = computed(() => {
+  if (trigger.value.source) return trigger.value.source;
+  // 触发器名加双引号，防需引用的标识符（大小写敏感/关键字/特殊字符）。
+  const quotedName = `"${trigger.value.name}"`;
+  let ddl = `CREATE EVENT TRIGGER ${quotedName} ON ${trigger.value.event}`;
+  if (trigger.value.tags?.length) {
+    ddl += `\n  WHEN TAG IN (${trigger.value.tags.map((tag) => `'${tag}'`).join(", ")})`;
+  }
+  if (trigger.value.function) {
+    ddl += `\n  EXECUTE FUNCTION ${trigger.value.function}`;
+  }
+  ddl += ";";
+  const enabled = trigger.value.enabled;
+  if (enabled && enabled !== "O") {
+    const alter = enabled === "D" ? "DISABLE" : enabled === "A" ? "ENABLE ALWAYS" : enabled === "R" ? "ENABLE REPLICA" : null;
+    if (alter) ddl += `\n\nALTER EVENT TRIGGER ${quotedName} ${alter};`;
+  }
+  return ddl;
+});
+
+function show() {
+  open.value = true;
+}
+
+defineExpose({ show });
+</script>
+
+<template>
+  <Dialog v-model:open="open">
+    <DialogContent class="sm:max-w-2xl">
+      <DialogHeader>
+        <DialogTitle class="flex min-w-0 items-center gap-2 pr-8">
+          <Package class="h-4 w-4 shrink-0 text-violet-500" />
+          <span class="truncate">{{ t("eventTrigger.detailsTitle") }}</span>
+        </DialogTitle>
+      </DialogHeader>
+
+      <dl class="overflow-hidden rounded-md border text-sm">
+        <div class="grid grid-cols-[7rem_minmax(0,1fr)] border-b px-3 py-2.5">
+          <dt class="text-muted-foreground">{{ t("eventTrigger.name") }}</dt>
+          <dd class="min-w-0 break-words font-medium">{{ trigger.name }}</dd>
+        </div>
+        <div class="grid grid-cols-[7rem_minmax(0,1fr)] border-b px-3 py-2.5">
+          <dt class="text-muted-foreground">{{ t("eventTrigger.event") }}</dt>
+          <dd class="min-w-0 break-words font-mono text-xs">{{ trigger.event }}</dd>
+        </div>
+        <div class="grid grid-cols-[7rem_minmax(0,1fr)] border-b px-3 py-2.5">
+          <dt class="text-muted-foreground">{{ t("eventTrigger.owner") }}</dt>
+          <dd class="min-w-0 break-words">{{ trigger.owner || "-" }}</dd>
+        </div>
+        <div class="grid grid-cols-[7rem_minmax(0,1fr)] border-b px-3 py-2.5">
+          <dt class="text-muted-foreground">{{ t("eventTrigger.function") }}</dt>
+          <dd class="min-w-0 break-words font-mono text-xs">{{ trigger.function || "-" }}</dd>
+        </div>
+        <div class="grid grid-cols-[7rem_minmax(0,1fr)] border-b px-3 py-2.5">
+          <dt class="text-muted-foreground">{{ t("eventTrigger.enabled") }}</dt>
+          <dd class="min-w-0 break-words">{{ enabledLabel }}</dd>
+        </div>
+        <div class="grid grid-cols-[7rem_minmax(0,1fr)] border-b px-3 py-2.5">
+          <dt class="text-muted-foreground">{{ t("eventTrigger.tags") }}</dt>
+          <dd class="min-w-0 break-words">{{ tagsLabel }}</dd>
+        </div>
+        <div class="grid grid-cols-[7rem_minmax(0,1fr)] px-3 py-2.5">
+          <dt class="text-muted-foreground">{{ t("structureEditor.comment") }}</dt>
+          <dd class="min-w-0 whitespace-pre-wrap break-words">{{ trigger.comment || "-" }}</dd>
+        </div>
+      </dl>
+
+      <div v-if="ddlSource" class="mt-2">
+        <div class="mb-1 text-xs text-muted-foreground">{{ t("eventTrigger.definition") }}</div>
+        <pre class="max-h-64 overflow-auto rounded-md border bg-muted/30 p-3 text-xs"><code>{{ ddlSource }}</code></pre>
+      </div>
+
+      <DialogFooter>
+        <Button variant="outline" @click="open = false">{{ t("common.close") }}</Button>
+      </DialogFooter>
+    </DialogContent>
+  </Dialog>
+</template>
diff --git a/apps/desktop/src/components/sidebar/ConnectionTree.vue b/apps/desktop/src/components/sidebar/ConnectionTree.vue
index f9b5080d05..c6f682c6f4 100644
--- a/apps/desktop/src/components/sidebar/ConnectionTree.vue
+++ b/apps/desktop/src/components/sidebar/ConnectionTree.vue
@@ -9,6 +9,7 @@ import { useSettingsStore } from "@/stores/settingsStore";
 import { useToast } from "@/composables/useToast";
 import type { ColumnInfo, ObjectSourceKind, QueryTab, TableInfo, TableNameFilter, TreeNode, TreeNodeType } from "@/types/database";
 import type { ElasticsearchIndexMetadataKind } from "@/lib/backend/tauri";
+import { listEventTriggers } from "@/lib/backend/api";
 import {
   filterLocallySearchedTables,
   createSidebarSearchSubtreePreserver,
@@ -68,6 +69,7 @@ import SidebarTreeItemDialogs from "./SidebarTreeItemDialogs.vue";
 import SidebarTableVGroupDialog from "./SidebarTableVGroupDialog.vue";
 import InstallExtensionDialog from "@/components/objects/InstallExtensionDialog.vue";
 import ExtensionDetailsDialog from "@/components/objects/ExtensionDetailsDialog.vue";
+import EventTriggerDetailsDialog from "@/components/objects/EventTriggerDetailsDialog.vue";
 import { RecycleScroller } from "vue-virtual-scroller";
 import "vue-virtual-scroller/dist/vue-virtual-scroller.css";
 import LightDropdown from "@/components/ui/LightDropdown.vue";
@@ -133,6 +135,8 @@ const sidebarInstallExtensionTarget = ref<TreeNode | null>(null);
 const sidebarInstallExtensionDialogRef = ref<InstanceType<typeof InstallExtensionDialog> | null>(null);
 const sidebarExtensionDetailsTarget = ref<TreeNode | null>(null);
 const sidebarExtensionDetailsDialogRef = ref<InstanceType<typeof ExtensionDetailsDialog> | null>(null);
+const sidebarEventTriggerDetailsTarget = ref<TreeNode | null>(null);
+const sidebarEventTriggerDetailsDialogRef = ref<InstanceType<typeof EventTriggerDetailsDialog> | null>(null);
 const sidebarTreeRuntimeHostRef = ref<SidebarTreeRuntimeHostInstance | null>(null);
 const sidebarTreeRuntime = createSidebarTreeRuntime();
 const sidebarTreeRuntimeInitialNode: TreeNode = { id: "__sidebar-runtime__", label: "", type: "connection-group" };
@@ -2038,6 +2042,25 @@ async function openSidebarExtensionDetails(node: TreeNode) {
   sidebarExtensionDetailsDialogRef.value?.show();
 }
 
+async function openSidebarEventTriggerDetails(node: TreeNode) {
+  sidebarEventTriggerDetailsTarget.value = createSidebarActionTarget(node);
+  await nextTick();
+  sidebarEventTriggerDetailsDialogRef.value?.show();
+  // 打开详情时静默拉取最新事件触发器数据，只更新当前节点的 meta 与对话框，
+  // 不重建整个侧边栏列表（避免每次打开都强制刷新触发器列表）。
+  if (!node.connectionId || !node.database) return;
+  try {
+    const triggers = await listEventTriggers(node.connectionId, node.database);
+    const fresh = triggers.find((et) => et.name === node.label);
+    if (fresh) {
+      node.meta = fresh;
+      sidebarEventTriggerDetailsTarget.value = createSidebarActionTarget({ ...node, meta: fresh });
+    }
+  } catch {
+    // 拉取失败时保留首次打开的缓存值。
+  }
+}
+
 function beginSidebarAction(): number {
   sidebarActionGeneration += 1;
   sidebarDdlOpen.value = false;
@@ -2557,6 +2580,7 @@ defineExpose({ focusSearch, createNewGroup, collapseAllTreeNodes, locateTabInSid
       @open-dialog-controller="updateSidebarTreeItemDialogController"
       @open-install-extension="openSidebarInstallExtension"
       @open-extension-details="openSidebarExtensionDetails"
+      @open-event-trigger-details="openSidebarEventTriggerDetails"
     />
     <div class="connection-tree-search sticky top-0 z-10 bg-background px-2 py-1">
       <div class="relative flex items-center gap-1">
@@ -2884,6 +2908,7 @@ defineExpose({ focusSearch, createNewGroup, collapseAllTreeNodes, locateTabInSid
     <SidebarTableVGroupDialog @created="focusCreatedTableVGroup" />
     <InstallExtensionDialog v-if="sidebarInstallExtensionTarget" ref="sidebarInstallExtensionDialogRef" :node="sidebarInstallExtensionTarget" @close="refreshSidebarActionTarget" @changed="refreshSidebarActionTarget" />
     <ExtensionDetailsDialog v-if="sidebarExtensionDetailsTarget" ref="sidebarExtensionDetailsDialogRef" :node="sidebarExtensionDetailsTarget" />
+    <EventTriggerDetailsDialog v-if="sidebarEventTriggerDetailsTarget" ref="sidebarEventTriggerDetailsDialogRef" :node="sidebarEventTriggerDetailsTarget" />
     <div v-if="store.treeNodes.length === 0" class="px-3 py-8 text-center text-muted-foreground text-xs">
       {{ t("sidebar.noConnections") }}
     </div>
diff --git a/apps/desktop/src/components/sidebar/SidebarTreeRuntimeHost.vue b/apps/desktop/src/components/sidebar/SidebarTreeRuntimeHost.vue
index d6df948163..b3130b82bf 100644
--- a/apps/desktop/src/components/sidebar/SidebarTreeRuntimeHost.vue
+++ b/apps/desktop/src/components/sidebar/SidebarTreeRuntimeHost.vue
@@ -481,6 +481,7 @@ const emit = defineEmits<{
   "open-dialog-controller": [controller: Record<string, any> | null];
   "open-install-extension": [node: TreeNode];
   "open-extension-details": [node: TreeNode];
+  "open-event-trigger-details": [node: TreeNode];
 }>();
 
 const {
@@ -751,6 +752,7 @@ const groupTypes: Set<TreeNodeType> = new Set([
   "group-types",
   "group-partitions",
   "group-extensions",
+  "group-event-triggers",
   "group-tablespaces",
   "group-datafiles",
 ]);
@@ -890,7 +892,7 @@ async function toggle(requestId = beginNavigationRequest()) {
     return;
   }
 
-  if (node.type === "group-extensions" && connectionStore.canUseLoadedTreeNodeToggle(node)) {
+  if ((node.type === "group-extensions" || node.type === "group-event-triggers") && connectionStore.canUseLoadedTreeNodeToggle(node)) {
     node.isExpanded = !node.isExpanded;
     if (wasExpanded && shouldReleaseCollapsedTreeNodeChildren()) connectionStore.releaseCollapsedTreeNodeChildren(node.id);
     emitNodeToggled(node, wasExpanded);
@@ -1100,6 +1102,8 @@ async function toggle(requestId = beginNavigationRequest()) {
       await connectionStore.loadSubpartitions(node.connectionId, node.database, node.tableName, node.schema, node.id, node.catalog);
     } else if (node.type === "group-extensions" && node.connectionId && hasTreeNodeDatabaseContext(node)) {
       await connectionStore.refreshTreeNode(node);
+    } else if (node.type === "group-event-triggers" && node.connectionId && hasTreeNodeDatabaseContext(node)) {
+      await connectionStore.refreshTreeNode(node);
     }
     emitNodeToggled(node, wasExpanded);
   } catch (e: any) {
@@ -1152,6 +1156,8 @@ function runRowClickAction(clickDetail: number, requestId: number) {
     openObjectSourceDialog(false);
   } else if (action === "open-extension-details") {
     emit("open-extension-details", node);
+  } else if (action === "open-event-trigger-details") {
+    emit("open-event-trigger-details", node);
   } else if (action === "open-saved-sql") {
     void openSavedSqlFile();
   } else if (isDocumentBrowserTreeNode(node.type)) {
@@ -1558,6 +1564,8 @@ function onDoubleClick(event: MouseEvent) {
     openObjectSourceDialog(false);
   } else if (action === "open-extension-details") {
     emit("open-extension-details", activeNode.value);
+  } else if (action === "open-event-trigger-details") {
+    emit("open-event-trigger-details", activeNode.value);
   } else if (action === "open-saved-sql") {
     openSavedSqlFile();
   } else if (action === "toggle" && (activeNode.value.type === "mongo-gridfs" || isDocumentBrowserTreeNode(activeNode.value.type))) {
@@ -6161,6 +6169,12 @@ function buildSpecialSidebarMenu(context: SidebarMenuFactoryContext): boolean {
     items.push({ label: t("contextMenu.copyName"), action: copyName, icon: Copy, shortcut: shortcutCopyName.value });
     return true;
   }
+  if (node.type === "event-trigger") {
+    items.push({ label: t("eventTrigger.viewDetails"), action: () => emit("open-event-trigger-details", node), icon: Info });
+    items.push({ label: "", separator: true });
+    items.push({ label: t("contextMenu.copyName"), action: copyName, icon: Copy, shortcut: shortcutCopyName.value });
+    return true;
+  }
   return false;
 }
 
diff --git a/apps/desktop/src/components/sidebar/TreeItem.vue b/apps/desktop/src/components/sidebar/TreeItem.vue
index 8760f1fbf1..0bde483b91 100644
--- a/apps/desktop/src/components/sidebar/TreeItem.vue
+++ b/apps/desktop/src/components/sidebar/TreeItem.vue
@@ -417,12 +417,16 @@ function getIconInfo(node: TreeNode): { icon: any; colorClass: string } | null {
       return { icon: node.isExpanded ? FolderOpen : FolderClosed, colorClass: "text-green-400" };
     case "group-extensions":
       return { icon: Package, colorClass: "text-violet-500" };
+    case "group-event-triggers":
+      return { icon: Package, colorClass: "text-violet-500" };
     case "group-tablespaces":
       return { icon: Database, colorClass: "text-orange-500" };
     case "group-datafiles":
       return { icon: node.isExpanded ? FolderOpen : FolderClosed, colorClass: "text-slate-500" };
     case "extension":
       return { icon: Package, colorClass: "text-violet-400" };
+    case "event-trigger":
+      return { icon: Package, colorClass: "text-violet-400" };
     case "load-more":
       return { icon: Plus, colorClass: "text-primary" };
     default:
diff --git a/apps/desktop/src/i18n/locales/az.ts b/apps/desktop/src/i18n/locales/az.ts
index 0e671647dd..9acd500af5 100644
--- a/apps/desktop/src/i18n/locales/az.ts
+++ b/apps/desktop/src/i18n/locales/az.ts
@@ -3895,7 +3895,20 @@ export default withEnglishFallback({
     loadMore: "Daha çox yüklə...",
     objectBrowser: "Obyekt brauzerində bax ({count})",
     extensions: "Genişləndirmələr",
+    eventTriggers: "Hadisə tetikleyiciləri",
   },
+  eventTrigger: {
+    detailsTitle: "Hadisə tetikleyicisi detalı",
+    viewDetails: "Detalları gör",
+    name: "Ad",
+    event: "Hadisə",
+    owner: "Sahib",
+    function: "Funksiya",
+    enabled: "Aktiv",
+    tags: "Etiketlər",
+    definition: "Tərif",
+  },
+
   extension: {
     manageTitle: "Genişləndirmələri idarə et",
     installTitle: "Genişləndirmə quraşdır",
diff --git a/apps/desktop/src/i18n/locales/en.ts b/apps/desktop/src/i18n/locales/en.ts
index 0d16b454b8..7f2dd317c3 100644
--- a/apps/desktop/src/i18n/locales/en.ts
+++ b/apps/desktop/src/i18n/locales/en.ts
@@ -4279,7 +4279,20 @@ export default {
     loadMore: "Load more...",
     objectBrowser: "Browse in Object Browser ({count})",
     extensions: "Extensions",
+    eventTriggers: "Event Triggers",
   },
+  eventTrigger: {
+    detailsTitle: "Event Trigger Details",
+    viewDetails: "View details",
+    name: "Name",
+    event: "Event",
+    owner: "Owner",
+    function: "Function",
+    enabled: "Enabled",
+    tags: "Tags",
+    definition: "Definition",
+  },
+
   extension: {
     manageTitle: "Manage Extensions",
     installTitle: "Install Extension",
diff --git a/apps/desktop/src/i18n/locales/es.ts b/apps/desktop/src/i18n/locales/es.ts
index 2e41eb2f09..7d26e0c5b3 100644
--- a/apps/desktop/src/i18n/locales/es.ts
+++ b/apps/desktop/src/i18n/locales/es.ts
@@ -4148,6 +4148,7 @@ export default withEnglishFallback({
     loadMore: "Cargar más...",
     objectBrowser: "Explorar en el navegador de objetos ({count})",
     extensions: "Extensiones",
+    eventTriggers: "Disparadores de eventos",
     types: "tipo",
     gridfs: "GridFS",
     buckets: "Buckets",
@@ -9051,6 +9052,18 @@ export default withEnglishFallback({
     fileUploaded: "Archivo {fileName} subido.",
     fileDeleted: "Archivo {fileName} eliminado.",
   },
+  eventTrigger: {
+    detailsTitle: "Detalles del disparador de eventos",
+    viewDetails: "Ver detalles",
+    name: "Nombre",
+    event: "Evento",
+    owner: "Propietario",
+    function: "Función",
+    enabled: "Habilitado",
+    tags: "Etiquetas",
+    definition: "Definición",
+  },
+
   extension: {
     installTitle: "Instalar extensión",
     manageTitle: "Administrar extensión",
diff --git a/apps/desktop/src/i18n/locales/it.ts b/apps/desktop/src/i18n/locales/it.ts
index a4956a0245..68f239a5de 100644
--- a/apps/desktop/src/i18n/locales/it.ts
+++ b/apps/desktop/src/i18n/locales/it.ts
@@ -4070,6 +4070,7 @@ export default withEnglishFallback({
     loadMore: "Carica altro...",
     objectBrowser: "Sfoglia in Esplora Oggetti ({count})",
     extensions: "Estensioni",
+    eventTriggers: "Trigger di evento",
     types: "Tipi",
     gridfs: "GridFS",
     buckets: "Buckets",
@@ -8976,6 +8977,18 @@ export default withEnglishFallback({
     fileUploaded: "{fileName} caricato.",
     fileDeleted: "{fileName} eliminato.",
   },
+  eventTrigger: {
+    detailsTitle: "Dettagli trigger di evento",
+    viewDetails: "Visualizza dettagli",
+    name: "Nome",
+    event: "Evento",
+    owner: "Proprietario",
+    function: "Funzione",
+    enabled: "Abilitato",
+    tags: "Tag",
+    definition: "Definizione",
+  },
+
   extension: {
     installTitle: "Installa estensione",
     manageTitle: "Gestisci estensioni",
diff --git a/apps/desktop/src/i18n/locales/ja.ts b/apps/desktop/src/i18n/locales/ja.ts
index 07f8d570a8..2c886f5c1c 100644
--- a/apps/desktop/src/i18n/locales/ja.ts
+++ b/apps/desktop/src/i18n/locales/ja.ts
@@ -4095,6 +4095,7 @@ export default withEnglishFallback({
     linkedServers: "リンクサーバー",
     materializedViews: "マテリアライズドビュー",
     extensions: "拡張機能",
+    eventTriggers: "イベントトリガー",
     types: "タイプ",
     gridfs: "GridFS",
     buckets: "バケット",
@@ -9025,6 +9026,18 @@ export default withEnglishFallback({
     fileUploaded: "{fileName} をアップロードしました。",
     fileDeleted: "{fileName} を削除しました。",
   },
+  eventTrigger: {
+    detailsTitle: "イベントトリガーの詳細",
+    viewDetails: "詳細を表示",
+    name: "名前",
+    event: "イベント",
+    owner: "所有者",
+    function: "関数",
+    enabled: "有効",
+    tags: "タグ",
+    definition: "定義",
+  },
+
   extension: {
     installTitle: "拡張機能のインストール",
     manageTitle: "拡張機能の管理",
diff --git a/apps/desktop/src/i18n/locales/ko.ts b/apps/desktop/src/i18n/locales/ko.ts
index 4698aa7f7b..e7062045fe 100644
--- a/apps/desktop/src/i18n/locales/ko.ts
+++ b/apps/desktop/src/i18n/locales/ko.ts
@@ -3960,7 +3960,20 @@ export default withEnglishFallback({
     loadMore: "더 불러오기...",
     objectBrowser: "객체 브라우저에서 탐색 ({count})",
     extensions: "확장",
+    eventTriggers: "이벤트 트리거",
   },
+  eventTrigger: {
+    detailsTitle: "이벤트 트리거 세부 정보",
+    viewDetails: "세부 정보 보기",
+    name: "이름",
+    event: "이벤트",
+    owner: "소유자",
+    function: "함수",
+    enabled: "활성화됨",
+    tags: "태그",
+    definition: "정의",
+  },
+
   extension: {
     manageTitle: "확장 관리",
     installTitle: "확장 설치",
diff --git a/apps/desktop/src/i18n/locales/pt-BR.ts b/apps/desktop/src/i18n/locales/pt-BR.ts
index 99971a30b0..7a8275e677 100644
--- a/apps/desktop/src/i18n/locales/pt-BR.ts
+++ b/apps/desktop/src/i18n/locales/pt-BR.ts
@@ -4072,6 +4072,7 @@ export default withEnglishFallback({
     loadMore: "Carregar mais...",
     objectBrowser: "Navegar no Navegador de Objetos ({count})",
     extensions: "Extensões",
+    eventTriggers: "Gatilhos de evento",
     types: "Tipos",
     gridfs: "GridFS",
     buckets: "Buckets",
@@ -8977,6 +8978,18 @@ export default withEnglishFallback({
     fileUploaded: "Arquivo {fileName} enviado.",
     fileDeleted: "Arquivo {fileName} excluído.",
   },
+  eventTrigger: {
+    detailsTitle: "Detalhes do gatilho de evento",
+    viewDetails: "Ver detalhes",
+    name: "Nome",
+    event: "Evento",
+    owner: "Proprietário",
+    function: "Função",
+    enabled: "Habilitado",
+    tags: "Etiquetas",
+    definition: "Definição",
+  },
+
   extension: {
     installTitle: "Instalar extensão",
     manageTitle: "Gerenciar extensão",
diff --git a/apps/desktop/src/i18n/locales/ru.ts b/apps/desktop/src/i18n/locales/ru.ts
index b541908af8..93f66c79eb 100644
--- a/apps/desktop/src/i18n/locales/ru.ts
+++ b/apps/desktop/src/i18n/locales/ru.ts
@@ -4137,7 +4137,20 @@ export default withEnglishFallback({
     loadMore: "Загрузить ещё...",
     objectBrowser: "Открыть в обозревателе объектов ({count})",
     extensions: "Расширения",
+    eventTriggers: "Триггеры событий",
   },
+  eventTrigger: {
+    detailsTitle: "Сведения о триггере события",
+    viewDetails: "Просмотреть сведения",
+    name: "Имя",
+    event: "Событие",
+    owner: "Владелец",
+    function: "Функция",
+    enabled: "Включено",
+    tags: "Теги",
+    definition: "Определение",
+  },
+
   extension: {
     manageTitle: "Управление расширениями",
     installTitle: "Установить расширение",
diff --git a/apps/desktop/src/i18n/locales/tr.ts b/apps/desktop/src/i18n/locales/tr.ts
index cbe6ad7684..297e733cae 100644
--- a/apps/desktop/src/i18n/locales/tr.ts
+++ b/apps/desktop/src/i18n/locales/tr.ts
@@ -3867,7 +3867,20 @@ export default withEnglishFallback({
     loadMore: "Daha fazla yükle...",
     objectBrowser: "Nesne Gezgininde Gözat ({count})",
     extensions: "Uzantılar",
+    eventTriggers: "Olay tetikleyicileri",
   },
+  eventTrigger: {
+    detailsTitle: "Olay tetikleyici ayrıntıları",
+    viewDetails: "Ayrıntıları gör",
+    name: "Ad",
+    event: "Olay",
+    owner: "Sahip",
+    function: "Fonksiyon",
+    enabled: "Etkin",
+    tags: "Etiketler",
+    definition: "Tanım",
+  },
+
   extension: {
     manageTitle: "Uzantıları Yönet",
     installTitle: "Uzantı Kur",
diff --git a/apps/desktop/src/i18n/locales/zh-CN.ts b/apps/desktop/src/i18n/locales/zh-CN.ts
index 86f7d01478..8ea124f95f 100644
--- a/apps/desktop/src/i18n/locales/zh-CN.ts
+++ b/apps/desktop/src/i18n/locales/zh-CN.ts
@@ -4189,7 +4189,20 @@ export default withEnglishFallback({
     loadMore: "加载更多...",
     objectBrowser: "在对象浏览器中查看 ({count})",
     extensions: "扩展",
+    eventTriggers: "事件触发器",
   },
+  eventTrigger: {
+    detailsTitle: "事件触发器详情",
+    viewDetails: "查看详情",
+    name: "名称",
+    event: "事件",
+    owner: "所有者",
+    function: "函数",
+    enabled: "启用状态",
+    tags: "标签",
+    definition: "定义",
+  },
+
   extension: {
     installTitle: "安装扩展",
     manageTitle: "管理扩展",
diff --git a/apps/desktop/src/i18n/locales/zh-TW.ts b/apps/desktop/src/i18n/locales/zh-TW.ts
index daff6e3e9f..8d6898a864 100644
--- a/apps/desktop/src/i18n/locales/zh-TW.ts
+++ b/apps/desktop/src/i18n/locales/zh-TW.ts
@@ -4070,6 +4070,7 @@ export default withEnglishFallback({
     loadMore: "載入更多...",
     objectBrowser: "在物件瀏覽器中檢視 ({count})",
     extensions: "擴展",
+    eventTriggers: "事件觸發器",
     types: "類型",
     gridfs: "GridFS",
     buckets: "Buckets",
@@ -8973,6 +8974,18 @@ export default withEnglishFallback({
     fileUploaded: "已上傳 {fileName}。",
     fileDeleted: "已刪除 {fileName}。",
   },
+  eventTrigger: {
+    detailsTitle: "事件觸發器詳情",
+    viewDetails: "查看詳情",
+    name: "名稱",
+    event: "事件",
+    owner: "擁有者",
+    function: "函式",
+    enabled: "啟用狀態",
+    tags: "標籤",
+    definition: "定義",
+  },
+
   extension: {
     installTitle: "安裝擴展",
     manageTitle: "管理擴展",
diff --git a/apps/desktop/src/lib/backend/api.ts b/apps/desktop/src/lib/backend/api.ts
index feab2aa52e..0229743827 100644
--- a/apps/desktop/src/lib/backend/api.ts
+++ b/apps/desktop/src/lib/backend/api.ts
@@ -244,6 +244,7 @@ export const listOwners = forward("listOwners");
 export const getTableOwner = forward("getTableOwner");
 export const listExtensions = forward("listExtensions");
 export const listAvailableExtensions = forward("listAvailableExtensions");
+export const listEventTriggers = forward("listEventTriggers");
 export const prepareSchemaDiff = forward("prepareSchemaDiff");
 export const generateSchemaSyncSql = forward("generateSchemaSyncSql");
 export const generateSchemaSyncPlan = forward("generateSchemaSyncPlan");
diff --git a/apps/desktop/src/lib/backend/http.ts b/apps/desktop/src/lib/backend/http.ts
index 0e715f130f..f35e64ddf3 100644
--- a/apps/desktop/src/lib/backend/http.ts
+++ b/apps/desktop/src/lib/backend/http.ts
@@ -52,6 +52,7 @@ import type {
   PartitionInfo,
   SubpartitionInfo,
   ExtensionInfo,
+  EventTriggerInfo,
   FunctionInfo,
   SequenceInfo,
   RuleInfo,
@@ -1333,6 +1334,10 @@ export async function listAvailableExtensions(connectionId: string, database: st
   return get(`/api/schema/available-extensions?${qs({ connection_id: connectionId, database })}`);
 }
 
+export async function listEventTriggers(connectionId: string, database: string): Promise<EventTriggerInfo[]> {
+  return get(`/api/schema/event-triggers?${qs({ connection_id: connectionId, database })}`);
+}
+
 export async function listDialectDataTypes(dialectName: string): Promise<string[]> {
   return get(`/api/dialect/data-types?${qs({ dialect_name: dialectName })}`);
 }
diff --git a/apps/desktop/src/lib/backend/tauri.ts b/apps/desktop/src/lib/backend/tauri.ts
index 5800bd9b46..01ab1fef8d 100644
--- a/apps/desktop/src/lib/backend/tauri.ts
+++ b/apps/desktop/src/lib/backend/tauri.ts
@@ -91,6 +91,7 @@ import type {
   RuleInfo,
   OwnerInfo,
   ExtensionInfo,
+  EventTriggerInfo,
   QueryResult,
   SqlReferenceAnalysis,
   DatabaseType,
@@ -2401,6 +2402,10 @@ export async function listAvailableExtensions(connectionId: string, database: st
   return invoke("list_available_extensions", { connectionId, database });
 }
 
+export async function listEventTriggers(connectionId: string, database: string): Promise<EventTriggerInfo[]> {
+  return invoke("list_event_triggers", { connectionId, database });
+}
+
 // --- Docs ---
 
 export async function collectDocsSnapshot(connectionId: string, database: string, schemas: string[], tables: string[], projectName?: string): Promise<SchemaSnapshot> {
diff --git a/apps/desktop/src/lib/sidebar/treeLoadedChildrenMarker.ts b/apps/desktop/src/lib/sidebar/treeLoadedChildrenMarker.ts
index 6f56b9cd4b..35075444b1 100644
--- a/apps/desktop/src/lib/sidebar/treeLoadedChildrenMarker.ts
+++ b/apps/desktop/src/lib/sidebar/treeLoadedChildrenMarker.ts
@@ -13,7 +13,7 @@ export function treeNodeLoadedChildrenContentPresent(node: TreeNode, sidebarObje
     // Grouped mode always materializes object-group placeholders; empty means a stale shell.
     return sidebarObjectDisplay === "simple";
   }
-  if (objectTypesForGroupNode(node.type) || TABLE_STRUCTURE_GROUP_TYPES.has(node.type) || node.type === "group-extensions" || node.type === "group-tablespaces" || node.type === "group-datafiles") {
+  if (objectTypesForGroupNode(node.type) || TABLE_STRUCTURE_GROUP_TYPES.has(node.type) || node.type === "group-extensions" || node.type === "group-event-triggers" || node.type === "group-tablespaces" || node.type === "group-datafiles") {
     return true;
   }
   return childCount > 0;
diff --git a/apps/desktop/src/lib/sidebar/treeNodeClick.ts b/apps/desktop/src/lib/sidebar/treeNodeClick.ts
index 40e5cb866a..bf7e58484e 100644
--- a/apps/desktop/src/lib/sidebar/treeNodeClick.ts
+++ b/apps/desktop/src/lib/sidebar/treeNodeClick.ts
@@ -2,8 +2,8 @@ import type { DatabaseType, ObjectSourceKind, TreeNode, TreeNodeType } from "@/t
 import { customTypeCapabilities, supportsTypeObjectSource } from "@/lib/database/databaseObjectCapabilities";
 import { matchesShortcut, type ShortcutLikeEvent } from "@/lib/editor/keyboardShortcuts";
 
-export type TreeNodeRowAction = "open-data" | "open-source" | "open-extension-details" | "open-saved-sql" | "open-object-browser" | "open-object-browser-and-expand" | "toggle" | "none";
-export type TreeNodeRowDoubleClickAction = "open-data" | "activate-data" | "open-database-browser" | "open-object-browser" | "open-object-browser-and-expand" | "open-source" | "open-extension-details" | "open-saved-sql" | "toggle" | "none";
+export type TreeNodeRowAction = "open-data" | "open-source" | "open-extension-details" | "open-event-trigger-details" | "open-saved-sql" | "open-object-browser" | "open-object-browser-and-expand" | "toggle" | "none";
+export type TreeNodeRowDoubleClickAction = "open-data" | "activate-data" | "open-database-browser" | "open-object-browser" | "open-object-browser-and-expand" | "open-source" | "open-extension-details" | "open-event-trigger-details" | "open-saved-sql" | "toggle" | "none";
 export type SidebarSelectionCopyAction = "copy-name" | "none";
 export type SidebarActivation = "single" | "double";
 
@@ -137,6 +137,7 @@ export function treeNodeRowAction(type: TreeNodeType, canExpand: boolean, activa
     return canExpand ? "open-object-browser-and-expand" : "open-object-browser";
   }
   if (type === "extension") return "open-extension-details";
+  if (type === "event-trigger") return "open-event-trigger-details";
   if (savedSqlNodeTypes.has(type)) return "open-saved-sql";
   if (dataNodeTypes.has(type)) return "open-data";
   // PostgreSQL-family custom types: open read-only details (toggle when expandable).
@@ -169,6 +170,7 @@ export function treeNodeRowDoubleClickAction(type: TreeNodeType, canOpenObjectBr
     }
     if (canOpenObjectBrowser && type === "object-browser") return "open-object-browser";
     if (type === "extension") return "open-extension-details";
+    if (type === "event-trigger") return "open-event-trigger-details";
     if (dataNodeTypes.has(type)) return "open-data";
     if (type === "type" && customTypeCapabilities(dbType).details) return canExpand ? "toggle" : "none";
     if (sourceNodeTypes.has(type) && canOpenTreeNodeSource(type, dbType)) return "open-source";
diff --git a/apps/desktop/src/lib/sidebar/treeNodeGroup.ts b/apps/desktop/src/lib/sidebar/treeNodeGroup.ts
index c383a722f1..e218f027d7 100644
--- a/apps/desktop/src/lib/sidebar/treeNodeGroup.ts
+++ b/apps/desktop/src/lib/sidebar/treeNodeGroup.ts
@@ -23,6 +23,7 @@ const treeGroupNodeTypes = new Set<TreeNodeType>([
   "group-types",
   "group-partitions",
   "group-extensions",
+  "group-event-triggers",
   "group-tablespaces",
   "group-datafiles",
   "type-attributes",
diff --git a/apps/desktop/src/lib/sidebar/treeNodeIcon.ts b/apps/desktop/src/lib/sidebar/treeNodeIcon.ts
index 72e34d4c95..8f7dee9d8f 100644
--- a/apps/desktop/src/lib/sidebar/treeNodeIcon.ts
+++ b/apps/desktop/src/lib/sidebar/treeNodeIcon.ts
@@ -152,8 +152,12 @@ export function getTreeNodeIconInfo(node: TreeNode): TreeNodeIconInfo | null {
       return { icon: node.isExpanded ? FolderOpen : FolderClosed, colorClass: "text-green-400" };
     case "group-extensions":
       return { icon: Package, colorClass: "text-violet-500" };
+    case "group-event-triggers":
+      return { icon: Package, colorClass: "text-violet-500" };
     case "extension":
       return { icon: Package, colorClass: "text-violet-400" };
+    case "event-trigger":
+      return { icon: Package, colorClass: "text-violet-400" };
     case "load-more":
       return { icon: Plus, colorClass: "text-primary" };
     default:
diff --git a/apps/desktop/src/stores/__tests__/connectionStore.metadataLoading.spec.ts b/apps/desktop/src/stores/__tests__/connectionStore.metadataLoading.spec.ts
index ed62a4849b..20dd7c904d 100644
--- a/apps/desktop/src/stores/__tests__/connectionStore.metadataLoading.spec.ts
+++ b/apps/desktop/src/stores/__tests__/connectionStore.metadataLoading.spec.ts
@@ -1307,7 +1307,7 @@ describe("connectionStore metadata loading", () => {
     await store.loadSchemas(connection.id, "app", { force: true });
 
     expect(store.connectionErrors[connection.id]).toBeUndefined();
-    expect(store.treeNodes[0]?.children?.[0]?.children?.map((node) => node.label)).toEqual(["public", "tree.extensions", "tree.queries"]);
+    expect(store.treeNodes[0]?.children?.[0]?.children?.map((node) => node.label)).toEqual(["public", "tree.extensions", "tree.eventTriggers", "tree.queries"]);
   });
 
   it("preserves the last successful tree snapshot when a forced metadata refresh fails", async () => {
@@ -1424,7 +1424,7 @@ describe("connectionStore metadata loading", () => {
     await olderRefresh;
 
     expect(listSchemaInfos).toHaveBeenCalledTimes(2);
-    expect(databaseNode.children?.map((node) => node.label)).toEqual(["latest", "tree.extensions", "tree.queries"]);
+    expect(databaseNode.children?.map((node) => node.label)).toEqual(["latest", "tree.extensions", "tree.eventTriggers", "tree.queries"]);
   });
 
   it("does not let an older refresh failure overwrite a newer successful refresh", async () => {
@@ -1480,7 +1480,7 @@ describe("connectionStore metadata loading", () => {
     rejectOlderMetadata(new Error("connection closed"));
     await expect(olderRefresh).rejects.toThrow("connection closed");
 
-    expect(databaseNode.children?.map((node) => node.label)).toEqual(["latest", "tree.extensions", "tree.queries"]);
+    expect(databaseNode.children?.map((node) => node.label)).toEqual(["latest", "tree.extensions", "tree.eventTriggers", "tree.queries"]);
     expect(store.connectionErrors[connection.id]).toBeUndefined();
     expect(store.connectedIds.has(connection.id)).toBe(true);
   });
diff --git a/apps/desktop/src/stores/connectionStore.ts b/apps/desktop/src/stores/connectionStore.ts
index bef7654b8b..871887d255 100644
--- a/apps/desktop/src/stores/connectionStore.ts
+++ b/apps/desktop/src/stores/connectionStore.ts
@@ -2286,6 +2286,50 @@ export const useConnectionStore = defineStore("connection", () => {
     };
   }
 
+  function buildEventTriggersNode(connectionId: string, database: string): TreeNode {
+    return {
+      id: `${connectionId}:${database}:__event_triggers`,
+      label: "tree.eventTriggers",
+      type: "group-event-triggers",
+      connectionId,
+      database,
+      isExpanded: false,
+      children: [],
+    };
+  }
+
+  async function loadEventTriggers(connectionId: string, database: string) {
+    const node = findNode(treeNodes.value, `${connectionId}:${database}:__event_triggers`);
+    if (!node) return;
+    let load = beginTreeNodeLoad(node);
+    try {
+      await ensureConnected(connectionId);
+      load = reclaimTreeNodeLoad(load, node);
+      if (useCachedChildren(node, undefined, load)) return;
+      const triggers = await withMetadataLoadTimeout(connectionId, api.listEventTriggers(connectionId, database), "event-triggers");
+      const children: TreeNode[] = triggers.map((et) => ({
+        id: `${node.id}:${et.name}`,
+        label: et.name,
+        type: "event-trigger" as const,
+        connectionId,
+        database,
+        comment: et.comment ?? null,
+        meta: et,
+        isExpanded: false,
+      }));
+      const targetNode = treeNodeLoadTarget(load);
+      if (!targetNode) return;
+      setChildren(targetNode, children);
+      targetNode.objectCount = children.length;
+      targetNode.isExpanded = true;
+    } catch (e) {
+      recordMetadataLoadError(connectionId, e, load);
+      throw e;
+    } finally {
+      finishTreeNodeLoad(load);
+    }
+  }
+
   function objectGroupCacheKey(node: TreeNode): string {
     const config = node.connectionId ? getConfig(node.connectionId) : undefined;
     const objectTreeProfileCacheKey = driverProfileObjectTreeProfileForConnection(config)?.cacheKey;
@@ -5867,6 +5911,7 @@ export const useConnectionStore = defineStore("connection", () => {
           }
           if (isPostgresLikeForExtensions(getConfig(connectionId)?.db_type)) {
             children.push(buildExtensionManagementNode(connectionId, database));
+            children.push(buildEventTriggersNode(connectionId, database));
           }
           if (isSidebarSearchQueryChanged(options)) return;
           const targetNode = treeNodeLoadTarget(load);
@@ -6302,6 +6347,7 @@ export const useConnectionStore = defineStore("connection", () => {
             });
             if (!schema && isPostgresLikeForExtensions(config?.db_type)) {
               children.push(buildExtensionManagementNode(connectionId, database));
+              children.push(buildEventTriggersNode(connectionId, database));
             }
           }
           if (isTreeLoadSearchChanged(searchFilter, options)) return;
@@ -7467,6 +7513,8 @@ export const useConnectionStore = defineStore("connection", () => {
       node.isExpanded = true;
     } else if (node.type === "group-extensions" && node.connectionId && hasTreeNodeDatabaseContext(node)) {
       await loadExtensions(node.connectionId, node.database || "");
+    } else if (node.type === "group-event-triggers" && node.connectionId && hasTreeNodeDatabaseContext(node)) {
+      await loadEventTriggers(node.connectionId, node.database || "");
     }
   }
 
diff --git a/apps/desktop/src/types/database.ts b/apps/desktop/src/types/database.ts
index 1cb8756f3b..25c144585a 100644
--- a/apps/desktop/src/types/database.ts
+++ b/apps/desktop/src/types/database.ts
@@ -1185,6 +1185,18 @@ export interface ExtensionInfo {
   schema?: string | null;
 }
 
+/** PostgreSQL event trigger metadata (`pg_event_trigger`). Database-level DDL trigger. */
+export interface EventTriggerInfo {
+  name: string;
+  event: string;
+  owner?: string | null;
+  function?: string | null;
+  enabled?: string | null;
+  tags?: string[] | null;
+  comment?: string | null;
+  source?: string | null;
+}
+
 export interface OwnerInfo {
   object_name: string;
   object_type: string;
@@ -1524,9 +1536,11 @@ export type TreeNodeType =
   | "group-packages"
   | "group-partitions"
   | "group-extensions"
+  | "group-event-triggers"
   | "group-tablespaces"
   | "group-datafiles"
   | "extension"
+  | "event-trigger"
   | "object-browser"
   | "user-admin"
   | "dameng-users"
@@ -1653,7 +1667,7 @@ export interface TreeNode {
   vgroupId?: string;
   /** 投影时盖章的分组类别（tables/views/…），供拖拽落点 O(1) 类别判定。 */
   vgroupKind?: string;
-  meta?: ColumnInfo | IndexInfo | ForeignKeyInfo | TriggerInfo | ConstraintInfo | PartitionInfo | SubpartitionInfo | ExtensionInfo | VectorCollectionMeta | MongoCollectionMeta | CustomTypeTreeMemberMeta;
+  meta?: ColumnInfo | IndexInfo | ForeignKeyInfo | TriggerInfo | ConstraintInfo | PartitionInfo | SubpartitionInfo | ExtensionInfo | EventTriggerInfo | VectorCollectionMeta | MongoCollectionMeta | CustomTypeTreeMemberMeta;
   loadMore?: {
     parentId: string;
     offset: number;
diff --git a/crates/dbx-core/assets/docs-export.manifest.json b/crates/dbx-core/assets/docs-export.manifest.json
index cc8ce77b21..80a175a9ad 100644
--- a/crates/dbx-core/assets/docs-export.manifest.json
+++ b/crates/dbx-core/assets/docs-export.manifest.json
@@ -50,4 +50,4 @@
     "@vue/shared": "3.5.35",
     "marked": "18.0.4"
   }
-}
+}
\ No newline at end of file
diff --git a/crates/dbx-core/src/schema/kingbase.rs b/crates/dbx-core/src/schema/kingbase.rs
index e6611d2427..f52beac99c 100644
--- a/crates/dbx-core/src/schema/kingbase.rs
+++ b/crates/dbx-core/src/schema/kingbase.rs
@@ -138,6 +138,67 @@ pub(super) async fn list_available_extensions(
     Ok(extension_infos_from_query_result(result, false))
 }
 
+/// Lists event triggers over a Kingbase agent connection. KingbaseES ships
+/// `pg_event_trigger`, so the same catalog query works; the sys/pg catalog
+/// fallback mirrors `list_extensions`. `tags`/`source` are not fetched over the
+/// agent path (text[] marshalling + `pg_get_eventtriggerdef` availability vary),
+/// so the details dialog's field-driven DDL rebuild covers them.
+pub(super) async fn list_event_triggers(
+    client: Arc<db::agent_driver::PooledAgentClient>,
+    database: &str,
+    timeout_duration: Option<Duration>,
+) -> Result<Vec<db::EventTriggerInfo>, String> {
+    let result = query_result_with_catalog_fallback(
+        client,
+        database,
+        event_triggers_sql(ExtensionCatalog::Sys),
+        event_triggers_sql(ExtensionCatalog::Pg),
+        10_000,
+        timeout_duration,
+    )
+    .await?;
+    Ok(event_trigger_infos_from_query_result(result))
+}
+
+fn event_triggers_sql(catalog: ExtensionCatalog) -> String {
+    let cat = catalog.catalog_name();
+    format!(
+        "SELECT e.evtname, \
+         e.evtevent, \
+         COALESCE(r.rolname, '') AS owner, \
+         COALESCE(format('%I.%I(%s)', pn.nspname, p.proname, pg_get_function_arguments(p.oid)), '') AS function, \
+         e.evtenabled::text AS enabled, \
+         NULL::text AS tags, \
+         obj_description(e.oid, 'pg_event_trigger') AS comment, \
+         NULL::text AS source \
+         FROM {cat}.pg_event_trigger e \
+         LEFT JOIN {cat}.pg_roles r ON r.oid = e.evtowner \
+         LEFT JOIN {cat}.pg_proc p ON p.oid = e.evtfoid \
+         LEFT JOIN {cat}.pg_namespace pn ON pn.oid = p.pronamespace \
+         ORDER BY e.evtname"
+    )
+}
+
+fn event_trigger_infos_from_query_result(result: db::QueryResult) -> Vec<db::EventTriggerInfo> {
+    result
+        .rows
+        .into_iter()
+        .filter_map(|row| {
+            let name = query_result_cell_string(&row, 0)?;
+            Some(db::EventTriggerInfo {
+                name,
+                event: query_result_cell_string(&row, 1).unwrap_or_default(),
+                owner: query_result_cell_string(&row, 2).filter(|s| !s.is_empty()),
+                function: query_result_cell_string(&row, 3).filter(|s| !s.is_empty()),
+                enabled: query_result_cell_string(&row, 4).filter(|s| !s.is_empty()),
+                tags: None,
+                comment: query_result_cell_string(&row, 6).filter(|s| !s.is_empty()),
+                source: None,
+            })
+        })
+        .collect()
+}
+
 fn extension_infos_from_query_result(result: db::QueryResult, include_schema: bool) -> Vec<db::ExtensionInfo> {
     result
         .rows
diff --git a/crates/dbx-core/src/schema/mod.rs b/crates/dbx-core/src/schema/mod.rs
index a84036484f..f4e04e010e 100644
--- a/crates/dbx-core/src/schema/mod.rs
+++ b/crates/dbx-core/src/schema/mod.rs
@@ -8361,6 +8361,41 @@ pub async fn list_extensions_core(
     .await
 }
 
+pub async fn list_event_triggers_core(
+    state: &AppState,
+    connection_id: &str,
+    database: &str,
+) -> Result<Vec<db::EventTriggerInfo>, String> {
+    retry_metadata_connection(state, connection_id, Some(database), || async {
+        let pool_key = state.get_or_create_metadata_pool_for_session(connection_id, Some(database), None).await?;
+        let db_config = connection_config(state, connection_id).await;
+        if db_config.as_ref().is_some_and(|config| config.db_type == DatabaseType::Kingbase) {
+            let pool_handle = state.pool_handle(&pool_key).await;
+            if let Some(client) = extract_pool!(pool_handle.as_ref(), Agent) {
+                return kingbase::list_event_triggers(client, database, agent_metadata_timeout(db_config.as_ref()))
+                    .await;
+            }
+        }
+
+        // HighGo, Vastbase, and other PostgreSQL-compatible catalogs exposed
+        // through Agent pools still ship pg_event_trigger natively, so reuse
+        // the native metadata fallback used for extension metadata.
+        if let Some(config) = agent_postgres_extension_fallback_config(db_config.as_ref()) {
+            if let Some(pool) = native_postgres_metadata_pool(state, connection_id, database, config).await? {
+                return db::postgres::list_event_triggers(&pool).await;
+            }
+        }
+
+        let pool = clone_metadata_pool(state, &pool_key).await.ok_or("Pool not found")?;
+
+        match &pool {
+            PoolKind::Postgres(p) => db::postgres::list_event_triggers(p).await,
+            _ => Ok(vec![]),
+        }
+    })
+    .await
+}
+
 pub async fn list_available_extensions_core(
     state: &AppState,
     connection_id: &str,
diff --git a/crates/dbx-drivers/src/db/postgres.rs b/crates/dbx-drivers/src/db/postgres.rs
index 86986edf21..f932259d37 100644
--- a/crates/dbx-drivers/src/db/postgres.rs
+++ b/crates/dbx-drivers/src/db/postgres.rs
@@ -36,8 +36,8 @@ use crate::types::{
     ColumnInfo, ColumnMetadataCapabilities, CompletionAssistantCandidate, CompletionAssistantCandidateKind,
     CompletionAssistantMatchMode, CompletionAssistantObjectKind, CompletionAssistantRequest,
     CompletionAssistantResponse, ConstraintInfo, CustomTypeDdl, CustomTypeDetails, CustomTypeDomainConstraint,
-    CustomTypeKind, CustomTypeMember, CustomTypeProperties, DatabaseInfo, DatabaseStorageInfo, ExtensionInfo,
-    ForeignKeyInfo, FunctionInfo, IndexInfo, ObjectInfo, ObjectStatistics, OwnerInfo, PgPartitionBound,
+    CustomTypeKind, CustomTypeMember, CustomTypeProperties, DatabaseInfo, DatabaseStorageInfo, EventTriggerInfo,
+    ExtensionInfo, ForeignKeyInfo, FunctionInfo, IndexInfo, ObjectInfo, ObjectStatistics, OwnerInfo, PgPartitionBound,
     PgPartitionKind, PgPartitionNode, PgTablePartitioning, QueryMessage, QueryResult, RuleInfo, SchemaInfo,
     SequenceInfo, SpatialColumnBuilder, TableInfo, TriggerInfo,
 };
@@ -9760,6 +9760,84 @@ pub async fn list_available_extensions(pool: &Pool) -> Result<Vec<ExtensionInfo>
         .collect())
 }
 
+fn postgres_event_trigger_catalog_exists_sql() -> &'static str {
+    "SELECT EXISTS ( \
+       SELECT 1 FROM pg_catalog.pg_class c \
+       JOIN pg_catalog.pg_namespace n ON n.oid = c.relnamespace \
+       WHERE n.nspname = 'pg_catalog' AND c.relname = 'pg_event_trigger' \
+     )"
+}
+
+async fn postgres_event_trigger_catalog_exists(client: &deadpool_postgres::Client) -> Result<bool, String> {
+    let row = postgres_query_one_cached(client, postgres_event_trigger_catalog_exists_sql(), &[])
+        .await
+        .map_err(|e| e.to_string())?;
+    Ok(pg_row_try_bool(&row, 0).unwrap_or(false))
+}
+
+fn postgres_event_triggers_sql() -> &'static str {
+    "SELECT e.evtname, \
+       e.evtevent, \
+       COALESCE(r.rolname, '') AS owner, \
+       COALESCE(format('%I.%I(%s)', pn.nspname, p.proname, pg_get_function_identity_arguments(p.oid)), '') AS function, \
+       e.evtenabled::text AS enabled, \
+       e.evttags AS tags, \
+       obj_description(e.oid, 'pg_event_trigger') AS comment, \
+       pg_get_eventtriggerdef(e.oid) AS source \
+     FROM pg_catalog.pg_event_trigger e \
+     LEFT JOIN pg_catalog.pg_roles r ON r.oid = e.evtowner \
+     LEFT JOIN pg_catalog.pg_proc p ON p.oid = e.evtfoid \
+     LEFT JOIN pg_catalog.pg_namespace pn ON pn.oid = p.pronamespace \
+     ORDER BY e.evtname"
+}
+
+fn postgres_event_triggers_sourceless_sql() -> &'static str {
+    "SELECT e.evtname, \
+       e.evtevent, \
+       COALESCE(r.rolname, '') AS owner, \
+       COALESCE(format('%I.%I(%s)', pn.nspname, p.proname, pg_get_function_arguments(p.oid)), '') AS function, \
+       e.evtenabled::text AS enabled, \
+       e.evttags AS tags, \
+       obj_description(e.oid, 'pg_event_trigger') AS comment, \
+       NULL::text AS source \
+     FROM pg_catalog.pg_event_trigger e \
+     LEFT JOIN pg_catalog.pg_roles r ON r.oid = e.evtowner \
+     LEFT JOIN pg_catalog.pg_proc p ON p.oid = e.evtfoid \
+     LEFT JOIN pg_catalog.pg_namespace pn ON pn.oid = p.pronamespace \
+     ORDER BY e.evtname"
+}
+
+/// Lists PostgreSQL event triggers (`pg_event_trigger`). Event triggers are
+/// database-level objects, so the query takes no schema parameter. Stripped
+/// PostgreSQL-compatible kernels that lack the catalog report an empty list,
+/// and servers that expose the catalog without `pg_get_eventtriggerdef` fall
+/// back to a sourceless listing so the trigger identity is still visible.
+pub async fn list_event_triggers(pool: &Pool) -> Result<Vec<EventTriggerInfo>, String> {
+    let client = checkout_postgres_client(pool, None, super::connection_timeout()).await?;
+    if !postgres_event_trigger_catalog_exists(&client).await.unwrap_or(false) {
+        return Ok(Vec::new());
+    }
+    let rows = match postgres_query_cached(&client, postgres_event_triggers_sql(), &[]).await {
+        Ok(rows) => rows,
+        Err(primary_error) => postgres_query_cached(&client, postgres_event_triggers_sourceless_sql(), &[])
+            .await
+            .map_err(|fallback_error| format!("{primary_error}; sourceless fallback failed: {fallback_error}"))?,
+    };
+    Ok(rows
+        .iter()
+        .map(|row| EventTriggerInfo {
+            name: pg_row_try_string(row, 0),
+            event: pg_row_try_string(row, 1),
+            owner: row.try_get::<_, Option<String>>(2).ok().flatten().filter(|s| !s.is_empty()),
+            function: row.try_get::<_, Option<String>>(3).ok().flatten().filter(|s| !s.is_empty()),
+            enabled: row.try_get::<_, Option<String>>(4).ok().flatten().filter(|s| !s.is_empty()),
+            tags: row.try_get::<_, Option<Vec<String>>>(5).ok().flatten(),
+            comment: row.try_get::<_, Option<String>>(6).ok().flatten().filter(|s| !s.is_empty()),
+            source: row.try_get::<_, Option<String>>(7).ok().flatten().filter(|s| !s.is_empty()),
+        })
+        .collect())
+}
+
 pub async fn list_owners(pool: &Pool, schema: &str) -> Result<Vec<OwnerInfo>, String> {
     let client = checkout_postgres_client(pool, None, super::connection_timeout()).await?;
     let rows = postgres_query_cached(&client, POSTGRES_OWNERS_SQL, &[&schema]).await.map_err(|e| e.to_string())?;
diff --git a/crates/dbx-types/src/types.rs b/crates/dbx-types/src/types.rs
index a2396875c7..72b20ddaed 100644
--- a/crates/dbx-types/src/types.rs
+++ b/crates/dbx-types/src/types.rs
@@ -145,6 +145,33 @@ pub struct ExtensionInfo {
     pub schema: Option<String>,
 }
 
+/// A PostgreSQL event trigger (`pg_event_trigger`). Event triggers fire on DDL
+/// commands at the database level, independent of any schema. This is distinct
+/// from MySQL events (`MysqlEventInfo`) and per-table triggers (`TriggerInfo`).
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct EventTriggerInfo {
+    pub name: String,
+    /// DDL event: ddl_command_start | ddl_command_end | sql_drop | table_rewrite.
+    pub event: String,
+    /// Owner role name.
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub owner: Option<String>,
+    /// `schema.function(args)` executed by the trigger.
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub function: Option<String>,
+    /// Session replica status char: O | A | R | D.
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub enabled: Option<String>,
+    /// Command tags in the WHEN clause (NULL = all tags).
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub tags: Option<Vec<String>>,
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub comment: Option<String>,
+    /// `pg_get_eventtriggerdef` reconstruction of the CREATE statement.
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub source: Option<String>,
+}
+
 #[derive(Debug, Clone, Default, Serialize, Deserialize)]
 pub struct ObjectStatistics {
     pub name: String,
diff --git a/crates/dbx-web/src/main.rs b/crates/dbx-web/src/main.rs
index 0186a14cf5..40f6c511ac 100644
--- a/crates/dbx-web/src/main.rs
+++ b/crates/dbx-web/src/main.rs
@@ -600,6 +600,7 @@ async fn serve() {
         .route("/schema/table-owner", get(routes::schema::get_table_owner))
         .route("/schema/extensions", get(routes::schema::list_extensions))
         .route("/schema/available-extensions", get(routes::schema::list_available_extensions))
+        .route("/schema/event-triggers", get(routes::schema::list_event_triggers))
         .route("/schema/ddl", get(routes::schema::get_ddl))
         .route("/docs/snapshot", post(routes::docs::collect_snapshot))
         .route("/docs/annotations/load", post(routes::docs::load_annotations))
diff --git a/crates/dbx-web/src/routes/schema.rs b/crates/dbx-web/src/routes/schema.rs
index e457eaa184..851f629b8c 100644
--- a/crates/dbx-web/src/routes/schema.rs
+++ b/crates/dbx-web/src/routes/schema.rs
@@ -889,6 +889,17 @@ pub async fn list_available_extensions(
     Ok(Json(serde_json::to_value(result).map_err(|e| AppError::from(e.to_string()))?))
 }
 
+pub async fn list_event_triggers(
+    State(state): State<Arc<WebState>>,
+    Query(q): Query<SchemaQuery>,
+) -> Result<Json<serde_json::Value>, AppError> {
+    let database = q.database.as_deref().unwrap_or("");
+    let result = dbx_core::schema::list_event_triggers_core(&state.app, &q.connection_id, database)
+        .await
+        .map_err(AppError::from)?;
+    Ok(Json(serde_json::to_value(result).map_err(|e| AppError::from(e.to_string()))?))
+}
+
 #[cfg(test)]
 mod tests {
     use super::*;
diff --git a/src-tauri/src/commands/schema.rs b/src-tauri/src/commands/schema.rs
index d6f55662de..259130579f 100644
--- a/src-tauri/src/commands/schema.rs
+++ b/src-tauri/src/commands/schema.rs
@@ -674,3 +674,12 @@ pub async fn list_available_extensions(
 ) -> Result<Vec<db::ExtensionInfo>, String> {
     dbx_core::schema::list_available_extensions_core(&state, &connection_id, &database).await
 }
+
+#[tauri::command]
+pub async fn list_event_triggers(
+    state: State<'_, Arc<AppState>>,
+    connection_id: String,
+    database: String,
+) -> Result<Vec<db::EventTriggerInfo>, String> {
+    dbx_core::schema::list_event_triggers_core(&state, &connection_id, &database).await
+}
diff --git a/src-tauri/src/lib.rs b/src-tauri/src/lib.rs
index 1caedaf3c1..3518e478da 100644
--- a/src-tauri/src/lib.rs
+++ b/src-tauri/src/lib.rs
@@ -2029,6 +2029,7 @@ pub fn run() {
             commands::schema::get_table_owner,
             commands::schema::list_extensions,
             commands::schema::list_available_extensions,
+            commands::schema::list_event_triggers,
             commands::schema_diff::prepare_schema_diff,
             commands::schema_diff::generate_schema_sync_sql,
             commands::schema_diff::generate_schema_sync_plan,