From 868502326c7d993d646d87f4b2509c5f8ae90de5 Mon Sep 17 00:00:00 2001
From: zipg <geeky@foxmail.com>
Date: Sat, 15 Aug 2026 21:55:37 +0800
Subject: [PATCH] feat(kyuubi): add native connection support

---
 agents/drivers/hive-go/connector.go           |   6 +-
 agents/drivers/hive-go/connector_test.go      |   9 ++
 agents/drivers/hive-go/main.go                |   6 +-
 agents/drivers/hive-go/metadata.go            |  26 +++++-
 agents/drivers/hive-go/metadata_test.go       |  72 +++++++++++++++
 apps/desktop/public/icons/database/kyuubi.png | Bin 0 -> 13227 bytes
 .../connection/ConnectionDialog.vue           |  13 +--
 .../src/components/icons/DatabaseIcon.spec.ts |  11 +++
 .../src/components/icons/DatabaseIcon.vue     |   1 +
 .../connectionAttemptTimeout.spec.ts          |   4 +
 .../connection/connectionPassword.spec.ts     |  11 +++
 .../__tests__/table/tableSelectSql.spec.ts    |   4 +
 .../__tests__/agentDriverInstallHint.spec.ts  |   4 +-
 .../lib/connection/agentDriverInstallHint.ts  |   2 +-
 .../connection/connectionAttemptTimeout.ts    |   1 +
 .../src/lib/connection/connectionPassword.ts  |   8 +-
 .../__tests__/transferObjectKinds.spec.ts     |   2 +-
 .../lib/database/databaseCapabilitySets.ts    |   1 +
 .../lib/database/databaseNamespaceCreation.ts |   1 +
 .../database/databaseObjectCapabilities.ts    |   1 +
 .../lib/database/databasePropertyEditing.ts   |   1 +
 .../database/databaseTableDataCapabilities.ts |  11 +++
 apps/desktop/src/lib/database/jdbcDialect.ts  |   2 +-
 apps/desktop/src/lib/table/tableSelectSql.ts  |  14 ++-
 apps/desktop/src/stores/connectionStore.ts    |   1 +
 apps/desktop/src/types/database.ts            |   1 +
 .../assets/database-drivers.manifest.json     |  30 +++++++
 crates/dbx-core/src/agent_catalog.rs          |  13 +++
 crates/dbx-core/src/connection.rs             |   1 +
 crates/dbx-core/src/db_admin_sql.rs           |  46 +++++++---
 crates/dbx-core/src/models/connection.rs      |  33 +++++++
 .../dbx-core/src/sql_dialect/capabilities.rs  |   1 +
 .../dbx-core/src/sql_dialect/ddl_profile.rs   |   6 +-
 .../dbx-core/src/sql_dialect/identifiers.rs   |   2 +
 .../dbx-core/src/sql_dialect/table_select.rs  |   2 +-
 crates/dbx-core/src/table_import.rs           |   6 +-
 crates/dbx-core/src/transfer.rs               |  82 +++++++++++++-----
 .../dbx-core/tests/database_capabilities.rs   |  21 +++++
 38 files changed, 402 insertions(+), 54 deletions(-)
 create mode 100644 apps/desktop/public/icons/database/kyuubi.png

diff --git a/agents/drivers/hive-go/connector.go b/agents/drivers/hive-go/connector.go
index c232d08df8..ce745c1827 100644
--- a/agents/drivers/hive-go/connector.go
+++ b/agents/drivers/hive-go/connector.go
@@ -89,7 +89,7 @@ func newDiscoveryConnector(config connectionConfig) *discoveryConnector {
 				BrowserResponsePort:        config.BrowserResponsePort,
 				BrowserResponseTimeout:     config.BrowserResponseTimeout,
 				BrowserDisableSSLCheck:     config.BrowserDisableSSLCheck,
-				WaitForNonQueryCompletion:  strings.EqualFold(config.DatabaseType, "impala"),
+				WaitForNonQueryCompletion:  waitsForNonQueryCompletion(config.DatabaseType),
 			})
 		},
 		driver:        &gohive.Driver{},
@@ -98,6 +98,10 @@ func newDiscoveryConnector(config connectionConfig) *discoveryConnector {
 	}
 }
 
+func waitsForNonQueryCompletion(databaseType string) bool {
+	return strings.EqualFold(databaseType, "impala") || strings.EqualFold(databaseType, "kyuubi")
+}
+
 func gssapiOptionsFromKerberos(config kerberosConfig) gosasl.GSSAPIOptions {
 	return gosasl.GSSAPIOptions{
 		ConfigPath:       config.ConfigPath,
diff --git a/agents/drivers/hive-go/connector_test.go b/agents/drivers/hive-go/connector_test.go
index 89a2d35310..af9678152a 100644
--- a/agents/drivers/hive-go/connector_test.go
+++ b/agents/drivers/hive-go/connector_test.go
@@ -114,6 +114,15 @@ func TestNormalizeHiveAuth(t *testing.T) {
 	}
 }
 
+func TestWaitsForKyuubiAndImpalaNonQueryCompletion(t *testing.T) {
+	if !waitsForNonQueryCompletion("kyuubi") || !waitsForNonQueryCompletion("KYUUBI") || !waitsForNonQueryCompletion("impala") {
+		t.Fatal("Kyuubi and Impala must wait for asynchronous non-query operations")
+	}
+	if waitsForNonQueryCompletion("hive") {
+		t.Fatal("Hive must retain its existing non-query behavior")
+	}
+}
+
 func TestKerberosServiceForEndpoint(t *testing.T) {
 	target := endpoint{Host: "hs2.example.com", Port: 10000, Principal: "hive/hs2.example.com@EXAMPLE.COM"}
 	discovered := connectionConfig{Kerberos: kerberosConfig{Service: "hive"}}
diff --git a/agents/drivers/hive-go/main.go b/agents/drivers/hive-go/main.go
index 7ad269e491..6af04f087c 100644
--- a/agents/drivers/hive-go/main.go
+++ b/agents/drivers/hive-go/main.go
@@ -431,7 +431,11 @@ func (server *server) dispatch(method string, params map[string]json.RawMessage)
 	case "list_constraints", "list_partitions", "list_subpartitions":
 		return []any{}, false, nil
 	case "get_object_source":
-		result, err := server.getTableDDL(stringParam(params, "schema"), firstNonEmpty(stringParam(params, "name"), stringParam(params, "table")))
+		result, err := server.getObjectSource(
+			stringParam(params, "schema"),
+			firstNonEmpty(stringParam(params, "name"), stringParam(params, "table")),
+			stringParam(params, "object_type"),
+		)
 		return result, false, err
 	case "get_table_ddl":
 		result, err := server.getTableDDL(stringParam(params, "schema"), stringParam(params, "table"))
diff --git a/agents/drivers/hive-go/metadata.go b/agents/drivers/hive-go/metadata.go
index 8fb1ff97a9..bc0dcf1c1b 100644
--- a/agents/drivers/hive-go/metadata.go
+++ b/agents/drivers/hive-go/metadata.go
@@ -40,6 +40,13 @@ type objectInfo struct {
 	Valid      *bool   `json:"valid,omitempty"`
 }
 
+type objectSource struct {
+	Name       string  `json:"name"`
+	ObjectType string  `json:"object_type"`
+	Schema     *string `json:"schema"`
+	Source     string  `json:"source"`
+}
+
 type columnInfo struct {
 	Name                   string  `json:"name"`
 	DataType               string  `json:"data_type"`
@@ -200,7 +207,11 @@ func (server *server) connectionInfo() (map[string]any, error) {
 	productName := "Apache Hive"
 	compatibilityMode := "hive"
 	driverName := "DBX Hive Go Agent"
-	if strings.EqualFold(server.params.DatabaseType, "impala") || strings.Contains(strings.ToLower(version), "impalad version") {
+	if strings.EqualFold(server.params.DatabaseType, "kyuubi") {
+		productName = "Apache Kyuubi"
+		compatibilityMode = "kyuubi"
+		driverName = "DBX Kyuubi Go Agent"
+	} else if strings.EqualFold(server.params.DatabaseType, "impala") || strings.Contains(strings.ToLower(version), "impalad version") {
 		productName = "Apache Impala"
 		compatibilityMode = "impala"
 		driverName = "DBX Impala Go Agent"
@@ -573,6 +584,19 @@ func (server *server) getTableDDL(schema, table string) (string, error) {
 	return strings.Join(lines, "\n") + "\n", nil
 }
 
+func (server *server) getObjectSource(schema, name, objectType string) (objectSource, error) {
+	source, err := server.getTableDDL(schema, name)
+	if err != nil {
+		return objectSource{}, err
+	}
+	return objectSource{
+		Name:       name,
+		ObjectType: strings.ToUpper(objectType),
+		Schema:     optionalString(schema),
+		Source:     source,
+	}, nil
+}
+
 func (server *server) getExplainInfo(sqlText string) (string, error) {
 	sqlText = trimStatementSQL(sqlText)
 	if sqlText == "" {
diff --git a/agents/drivers/hive-go/metadata_test.go b/agents/drivers/hive-go/metadata_test.go
index c9bba860b9..a6c114de1c 100644
--- a/agents/drivers/hive-go/metadata_test.go
+++ b/agents/drivers/hive-go/metadata_test.go
@@ -3,6 +3,7 @@ package main
 import (
 	"context"
 	"database/sql/driver"
+	"encoding/json"
 	"errors"
 	"reflect"
 	"strings"
@@ -20,6 +21,77 @@ func TestShowTablesRowName(t *testing.T) {
 	}
 }
 
+func TestKyuubiConnectionInfoReportsNativeIdentity(t *testing.T) {
+	behavior := &scriptedBehavior{
+		query: func(ctx context.Context, query string) (driver.Rows, error) {
+			switch query {
+			case "SELECT VERSION()":
+				return newScriptedRows(ctx, []string{"version"}, []string{"STRING"}, [][]driver.Value{{"3.5.8"}}), nil
+			case "SELECT CURRENT_USER()":
+				return newScriptedRows(ctx, []string{"current_user"}, []string{"STRING"}, [][]driver.Value{{"dbx"}}), nil
+			default:
+				return nil, errors.New("unexpected query: " + query)
+			}
+		},
+	}
+	server := newScriptedServer(t, behavior)
+	server.params.DatabaseType = "kyuubi"
+	server.config.Username = "fallback"
+
+	info, err := server.connectionInfo()
+	if err != nil {
+		t.Fatal(err)
+	}
+	if info["compatibilityMode"] != "kyuubi" || info["username"] != "dbx" || info["version"] != "3.5.8" {
+		t.Fatalf("unexpected Kyuubi connection info: %#v", info)
+	}
+	databaseInfo, ok := info["databaseInfo"].(map[string]string)
+	if !ok || databaseInfo["productName"] != "Apache Kyuubi" || databaseInfo["driverName"] != "DBX Kyuubi Go Agent" {
+		t.Fatalf("unexpected Kyuubi database identity: %#v", info["databaseInfo"])
+	}
+}
+
+func TestGetObjectSourceReturnsProtocolObject(t *testing.T) {
+	behavior := &scriptedBehavior{
+		query: func(ctx context.Context, query string) (driver.Rows, error) {
+			if query != "SHOW CREATE TABLE `dbx_kyuubi_demo`.`high_value_orders`" {
+				t.Fatalf("unexpected query: %q", query)
+			}
+			return newScriptedRows(
+				ctx,
+				[]string{"createtab_stmt"},
+				[]string{"STRING"},
+				[][]driver.Value{
+					{"CREATE VIEW dbx_kyuubi_demo.high_value_orders"},
+					{"AS SELECT id, customer, amount FROM dbx_kyuubi_demo.orders WHERE amount >= 50"},
+				},
+			), nil
+		},
+	}
+	server := newScriptedServer(t, behavior)
+	defer server.disconnect()
+
+	result, _, err := server.dispatch("get_object_source", map[string]json.RawMessage{
+		"schema":      json.RawMessage(`"dbx_kyuubi_demo"`),
+		"name":        json.RawMessage(`"high_value_orders"`),
+		"object_type": json.RawMessage(`"VIEW"`),
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+	source, ok := result.(objectSource)
+	if !ok {
+		t.Fatalf("get_object_source returned %T instead of objectSource", result)
+	}
+	if source.Name != "high_value_orders" || source.ObjectType != "VIEW" || source.Schema == nil || *source.Schema != "dbx_kyuubi_demo" {
+		t.Fatalf("unexpected object source metadata: %#v", source)
+	}
+	expected := "CREATE VIEW dbx_kyuubi_demo.high_value_orders\nAS SELECT id, customer, amount FROM dbx_kyuubi_demo.orders WHERE amount >= 50\n"
+	if source.Source != expected {
+		t.Fatalf("unexpected object source DDL: %q", source.Source)
+	}
+}
+
 func TestListDatabasesUsesShowDatabasesBeforeHiveServerMetadata(t *testing.T) {
 	behavior := &scriptedBehavior{
 		query: func(ctx context.Context, sql string) (driver.Rows, error) {
diff --git a/apps/desktop/public/icons/database/kyuubi.png b/apps/desktop/public/icons/database/kyuubi.png
new file mode 100644
index 0000000000000000000000000000000000000000..36c5b798c04bb1337dbcdd83750284a9a79e5023
GIT binary patch
literal 13227
zcmc&*<zG}?xIGiV01`t;N_VFqIUwELjRJy%wB%3{N{N8<&_jcO(j_Po(kUt3NH>@F
z{t@?n+ULXh?Ogkb^{gGOrJ;z2Lx}?b0G_gvoDKkh9zH<;4D+Eeb4S|&fS|jwoQ$6D
z>|UV%rx!214qOio#`71);!C$n_tQX_Bq2*WeA-N6E3qu0=zlmrsABUhgdNA(*1f_$
z{3!3Himg(u96>Yjck?O89KKDaAnf6ifrGFKA}N~6no6(uZ}%(3><_MgJ`>jUT<=jk
z_tc-dtI#jYr4^oEygYMlKgWE88P;jVNB)1^P~zZd?RnvK_=Ovu)Q2rPvD)(qMI#lv
zcDy0k3RP5qk3c9j95mHl{O;hF0^vJWNHbR%+b-Zh(DCQHCN{|ZL(X!IT2aM(<LUrW
zeNT&HCi8j#Z&V^jV@DZVjc*N#h}hVq(jXO+h2=5!Vf<O!6wpGvv>A+nBto5idZYk2
zF&?TQ+&&*ftFOC<p>1jtvMW(zdNuOO9$G5wuXvF>fU_3UCpLxLC4mTOUL3X(0~tN-
z9wN9MNDV^H>L3%XsI<n9HOtv|9l+a5K#GGK$w&pX;12gccNdW5BL`(7hmUEH-sQtx
zINd+4YyW)O4B*RV@3;iA!4qbgjojE^MIACWIxQ&7___Xb;lRz->_ay;zc(i|_{(Ky
z_h3|M42C}KFhdv(^X8Du1v^HAeaEjbJ+9wX7lBXkjX4xB6@Yj7*nyr#GOY?(1CMeT
zImmENE&+48j;}5@c3`l+9z*9NSx{N(n>;bjzkCD*XU`_S->EDs#<bD2k_mS3Gjs#p
zQ7B+to_<&xIIrG5Puo0WE|xC)M#Qj#{P5@l@W@NH25ZSr-E#lnz$VU;NiLP`5Dfag
zXU(E*MG>Qd{uQRA<kY3^8S~qiATd+{3c_d+g?|L7;g9v;=zZIs^XL<*knXdBpXX!)
z0(@Y;T<L;60*kxb@86w&G0!g>S;7&PpXe5-S-U=Rr0C@$Eyp@M$zvDj5-8aLH*5yS
z=P&5d)X42Unv4Ga-C%K3t`tY<I;z93kPvtXyyG3&jU=*c>Z~wiPVn>A1WurQs6z%;
zmn?dXSzv?8cqv{P24_#eYVfupL}E<5LA1*Z^DdZh%=yW$9?2Pm&~TPn^MM^4I~S!T
z<|eh1Q`tAwL$-07(q74s_LtUwqFK@MbI#8UAsRP~AkuCLgH0qn36f>HC$~3SG-vxT
z)q`UtX9ca!g|;XBDv&(fQQlH_?zYD!@ko42`^s+tX|GlLq6G^73sA$r7$L(NP{Lel
zsLF6~<(B{sk*D5<w-o74R?y)&%63;@G$V_vZlQ=5Um@A^cBv@*AI`&qFp?#F1{FeU
z4HD4m8-2e7C0e*vh#mo(HYq}!{oNC{Y{nCg<>L1!UOX~IS7`(OkDV~o2v1vC;Xm2f
zg9UjN*Db5<9AbIWChPjZtRKZLHl?!5WeXJ@hS6){q<Pl_h7xs0m1>3VnwHS)-vwAV
z9Ji~>B>~pW7}&7@rDT@jv1zcV#GLo!mzFH@gFPmiOn3;bqktmS1s4=17M%&8W!n^%
zGz((#ztQmQHQvI0HsoP;#l94{?UL}J?ta)>Bidcemh?tTHM~{<g{Io9%Q<6xJ$;du
zCB+iy6aKN5P0fI0>A_F9i_gesq&KJ|v1UmcO!0N2qLR~F4fs48zSxJs5&5qInGwf<
zVVbJlbC#?K-U`{8X>h0|@f|t*EfA1MP}CRUq>;xHy4{<57MgZ9NZ`uo7zn=U2O0i;
zQDw7MmV}CXl}tBkLG!fjPd*JwgTGPkDlXdnz>vl7)v>#*n6a6fXw-W*E(w?pyyT-t
zzkcUO9PSGNk>DTW;{ha_xN&m$+PQ?~oxNO0FU4^%F8IX@y7Ld-MVj@3l0IT5$B+e-
z_H8~Pa9OGg#D-Q!=&jJj2zKCmR!bR!l%}f)Q}{VkU`9~ubW&m*?$AR~_C1W%RHVPq
z$oiS<Y<uvw(v!&Q$1fO>r!j}|g&qg7AlevWW_#1_Iq9yn4hSKuY<=Y)tsNT(Cl7d}
zQ>FN-^0}BVGHCh@O#1_|H7`oqzOXs!(&dyaI5GY6XY*IF&her@dOKiN6+BIf$o8ss
z>8a(9!Hd66K0+80_$1ecXOrVhrasqw89R)U`JO!gu7kLV+&tFECXtz+_9^)q#R>7d
z{X~Qd)o1c6isk)MVG0UR`KuLtP^W{~b=TA3jiiC^SaK!?J2|sQ%fsj>rkNg@PX*O0
zZW<)ux4j|lilG^Sr2*2qJVO=LkGfT2VgU`&z9DNtT%3}*Ya%sTOoVD_5GVAKa(Wj1
zmeS%Q%sKJ8ro1VKWKpk(YM(Q1!9sPAW62xT&@~#P0BBAwwi9f03vO+-AK3Wag5ZgV
z@z(wYcvDUt*bFXM))X<N+kw!4Uy=7!VTGf-h9(}~?h3$9k~_t*Ej5A`^Q?h(saGt)
zf{47!ca>RDALTydzQ`sQ!Tx1GYHR!L2@lGN4}8Jf+1C1iubs1tBBp=FSb70ZliJz2
zAy~dy-A3<Z^?h(pl1g-z6>4E0fH<z3tvL@rgvc{l$Az0)Jh-41vN<XW;3~O`WD8`{
zrMdkwNXrNI4Lyu6@Ms^AInl=uBhxo6tuDssrPD%+MNfxRqmLlkms&*<XBAB(d4&X~
zv4CUO{WM~I)W!RrM=tuMzBTTd^NVwYcyuQCP~Nqi$Xw8fvUTb&gj)d+UJeehI{b*g
zo)M5>7=ayJW&{P$k)KobQb;c@Y$tl!o7@~7XUjt#(;>qq0=MQ|Jwe|tP`;$4EH@R3
z&_@mG1D}cCc1O0k9%`Y6%R}@55l4~5g_GghW`qcic2{`&%laf@1gm@ii&$;gMcLZP
zuonRyei00ow}wu+n`e8Bh@DWp^3Zhl@Wg^+J|5f<8SlaJOPdefY{S_S|I%~A?dNbA
z^Aab01|0R+2^#-GV5{Iew*}ix2zERDsGb@!gXo{k^elc;<0s0i-fXQ`y)LTQB2^e#
zoHq@$8x0{RA*RhyIe#9>OF2G?+<AqEiccex+y6YVz4I-lKYr3i(OY)V9wZ75y*nAV
z_iOwYVF`jG{G+J<_!XXh!St2wjwiO9lm919OWSLvf~-Q;HXw-M2=m+_|Lf^i7oCFH
z-Y#B50@Gg}hIF!4ZJ8nMrAmB;2>C+I)3wtgeK382Se8$}k=XeHn;=2~tiA*u4-Ja9
zf9LH9UMxdn%7i^V8&@&>PWMT|jJ`$0bYSrj5D}8AD*nVJO<y?GDvL`1TpgWe55Dy*
zlDPWnU;r|8tCrzLqJNv>q^XIOT=5c>YP!fRr#eh{6Vzl7-*$yK9vRQr+}UBwnIpKw
zrLImX5)Zs0NnhJxl!vLJ0QKmL4C>YgPt>%PtyUBUG<L!o>A8W~Cl#9<1s;o=^g;hV
zsXU)N=cJ>Fk__c~-zI4K+tSpvbzJJP?sLs^rGvBQUDd-KSCUnZv>vYwP9poW+dM^c
za;o!kF>C*Wov+^^fq$AMHO4Ka&V{Yqt_)dfE^mLz@sy)pfKIcPFj4O(#o({#hOdz`
z<;c?shZ<~nd)Q{)3({|QdBGl)XCHPwDLcUE%a;*q>n#mU&ESq>s^Jqdge{%#aG~*1
zp{eTS0S6%?$}e1qMg25;L_d~$o{W*wL`OeEtFCfr=z#t#MUTep@KWTfTHJ?p=IY;%
z5$akbZX7p_qS{^Y3OXW7W`WUgPX)K0k??kx=lG}Ux9+o%ZH)L|`s#l45?)~E)&7yZ
z+_#08et|+C6B}8QA+cdcCA<FDS=SRYZs<rSL@nE<jrVchfrPU}aQ{OuclO?p1+5ad
zF%Wj!wCZjNX<@lI_5k`y`ERXw@BQT6@^Twz-sz^dSn+4TQTyJ;@%Srr<TphkfX8+N
zhGs;yzQVqHC3<uj&wL}i8_hE3srNUSFaL`)g&oEKkprNL3cI{nb$9DGpLu=#`}rig
z2hi~P9W0c5d&T0NO6|~rZU=v4$}8QL!cQ5Z{rvfJ@E6WX$6$N<q?zpSZ_RnzSWoNf
z=xxBa0}CK*m)|KkyrdbNZrfbQbgd7C9=v<jKEFJ}if#z^#&P8qXet`>Sp8-4qH0sQ
zAD<7DwFMK`V&O^%hcolB>+IS3%qWRn`)KnG&opMHcjWBPHwl*v$LoE6DKH)tD=FFS
zVz8PrcQGxZAz(xO;HsB(?s$trm)0%pG`VQ1Q^vw>9CjNfEnv~pQ%zO!>|Ku1&5N|^
z_KQzW@qHh{XWEOT?!QL|=U>E~__<QoFi#>Jw3!b(f-8YNvBvY!J?-jOHAMHV#@KhY
zNxj6iP=ooGI}GlU-4;~vpFj-g6I~uY!&Lw7seu0zxdH35UxvtH`5XMd@v%i;cuR!|
zjUQR<)kzmMNBXA{AJGxxUF2eP#G-GD<z4!ck9jRC0{-D4o53)J>sou(C-Wt8lKqZj
zu?AazRjA;+r9oK3<_uTWNP8P7>3RdE*piYa<irr+Nsl~kj$R>UTi3f~0zm49nGzmo
zt?9+mK*&Og(seA$iR5jZZW2SRSbt6cThvxk8O4*fJOd61ZC^L0EdQ60+uv*eL(ofH
zoa|5Qu8e<Q_V{C}UdBHe8d4*8lqKBn$1Y<zChr+SK!<;F4KlClICjD*n+OeU`7vwx
zU;<_n+iVr&Mo?>Q&T<mPM>zzK6<w<^jtpvx5Z`?}&h2umREcWHE(=)tSnVpjh>t^i
zxwl3)f95qJ7x0#;0Rv?Iy*G|;y|RqtN<KlcYCf%I^3l*yZff-Q6CAq1{l<8LM?q-)
zuuvxjz+YC-M1QXNDgXJ!@=2z`xZkJ(6zfW*u70v2q;Z>b$(fzBG6x=L%35Q~7?N~k
zs=Sp$y0kZPX#rp0rAOr5<HHVjp29tZ+zhT`E=@62E-kCjH$$)RVxIAyvBujAh@0@!
zbT}2>euH%0?JrBQ1opoUbG)CW;3{Pxyj{<=3|8l<s6vXE{k~s>P_{JpD=me`yHms<
z`D7y}6KM?xtQ0REp^(j(OP(c%1XxNz&f05V@x3g$i*&L^s6hhY4(0d@9bS6Z>F&z*
zS=6j0C^pPjrfxOye(bq0qf=310A7ED^cy<Z0;w_BaUxXnZd9yj^;g47TG+2Caog9g
zEe+qCV1)dg1ZsGR==@E3ah8OSZo^tlzp;Q?oMotZw=G@oSh1}(ThrX%^29)QC^M?)
zu|JSWJ$nMZ7yN)t_&%}YjdU#(MmTTc#3TO8z7xlxG&2|jUi5Qx#_+&_-Viy}cdp5E
zoqEcb(^kNNH}|-V1`aeG=ou(XCU!^<s2ui@d)CB8RcI_-#AyPstwOl*&aWb3C;re*
zojVn6N!P_(3h)c)AyZAOH!9?&E&N%qkgpyEjzkN72$v<u)#L5%VzIs@Y$AZ5rZ%S2
zc5&tzX)Gvp9SiH*D2M0yL{vDCNPh49VJ#0WI}BUuei!&!N<`tL<(a<FMS|LqerG|x
z69pjg7(3H|=f)~Mbc5%4kPzV+{>5Wz3HKg506M?>kz_cz%qt#y*a@Kdy}>GBe%EQl
zlH?H4MQ8E;T=&#+Y66;Hlh+T0XPNw5>@@7ivfz^PcIE$StFTrp*_}<6-n33cZ4KLO
zVMF-p(kE?oaHQ>MTP2LHtVF!75q0H9vQpeIb}Tk~Iq4)<8o?@pUEGdy0x*`W;edC=
z3P6P6i*?3b7;`BygmI)0&-X`tcf360`@$b)hwAA01di4eV7^u*g~gciaCM<9F!!j1
zr>Fvt=EkXa);sn`Vd2l?oE-YM-tuc_Qg-o!l%lf7DI6V!TWR(zUlljLnJ`&F-9llo
zs+b5<_w>$S9Yr9Z4%D%>6I@dN)MU4=rUvUu^>S}a=8*Nx@J-P$C9K?TDS@gQ&CxpW
z2WJe|)uH|-@Hrgetmgf&G_9o`+`Mt7SxZTvZ~Tu^`*_^*%U3V@A_#^)-aEbLusmS#
zc9whX(%IRsid(8uU>JXX>Qz-l`Y;9X0b?JT7m<BxZm1nSz~HO$JhqOzah-?|)eLfV
zs`0%?u-|{g7~#}Ay|b|6mC@UAb$$6BnW`UV;XT8waaUpt+ED~Z&hADFqu2TGcji-y
zpKc!**yFi1Ni^+rib^|KoXnRt@iKr@CcW|I>Z0oS7bMdMvs=Fx-Bsd(pdx?<l-Ep$
zS!f7CCr!<8%4xJBh19Rclmq#U^!ENmygDH^GY_~jqdOp;Xl?DTWMl%z{)KX{(8!gT
zsS`5)`dJSX1S<f=jtp8A7p#jS7eX8VhB999T1-EJmZCMdu2lbgRaaLRxzd7RIB3?H
z-~mA+i;EKnf7@3Ot~Pm=>V(!7(23{95SNJPZk&tO?uGEHc4;%pYftCBmgtLFQ()QO
z_he^Y{VQ2KPzsE8&gDeao0G%IL@o}>6HO7#po3S$#I;*G%eA+KH&vG%xa;y&5UqWB
zZ^>?+$3=t~RMHkp>w2M2*Wx9l_&g0NMt;f#>|xW5r>G3Mj^f}b6LyxgFkP9Z|J6jZ
zhMH`cl!`Wq>r=LV>2u!?-F70=YhxIWc464JKKmFs2c@O@@Cb(DK#J-remHqwZxYmx
zlNp+e!tu4;+J!s>2#+(W03{;17Op1O5=rl~SJ!9UB2N6h4~{6HN2xaLwYSx?4v$<<
zY}oxE<7^63S13oGO~ovc?krm+g0@zKqL<ZU?WTDjY(qw~VaLjdBtE%Ug*>;%-hse2
zYK3<)pNSNAx)P+|i0oswJW=13RxpY8p{G{!J3M|cTt8E8-b+j@8Z3SB&Z_{d4KRrC
zooCqof!i~tsmL1Lot_0}^*|=00LM@rB|P(mLC^1XDhTz@k@|F-4DMqL-w0B1hZdC>
z^XhpjwOuJlbW1cMFI+j6PjLd@u-0b4WdNb=$s*R)`5DLygHsIC{s{38&`CPX>ee3&
z1w)>m+kajeCSuH&mwNI`S0zx)YO6Ln6TX{rK-g)$Cu3U@SUZ|SyggaeEgb3B+X{_9
z+$})3Pu_)?Ij>{OLlX!Rh<e1L+pqfX=5$R1LA~jO9hFK;q`pnG-uJ?_muM(L{?0KU
zGcFE+naLi1_ZpQMToxr|YjM&9g?lM5{~Vm-tS+Y%?LvsGWW=B2;VA}xOYGo)1M=^A
zB@jcULPqR+*e0M(mW?3poZoFVlb>os0^2Dml=NP0j;>rr>J*M}rm|1(a|Vr4aX+14
z`MSHV9|j%U+RF~Qt_k6uiM=z^qyU)_V_z#R4x>2Ul?}RrkbnhYqUdJuf5UxKF@B}@
zihMkZ?t!`aBj@u+-XkO+FR7Owc%?(MlrViO`tRA3-Qe@(g}L=7NLMDek5D%krrlLf
z)sN38!YK=9u#qVsXU6T*tQ%XBu_c3F%v10X|82&2uHwE+pCOE^AEJrAs3K+%xP>B_
zPT5n#@=^2onf=g$bw-G09H1i%rjwKenM`<@6kBC^x(UVd=Wn~Z?_*qgo&_r=+E(@G
zJP!dp$q4)7Hl(GCkNS+r^$neERIL<*52L=Gincl5cPt${3R0Lh8f}JSTU~ed%N94X
zpwpv^?j1!EomflprbP38d?xzm-`ncSl<ZFh(#NpjRsj21pZK`4le%P1E%lwb4SElE
zr_K+SV5%tj2m}`=^tEPh8$?ooGJEB<U%P;p4KYJq7}B*{{bW|1UfD(F7c>i%av#_<
zc|Y{{1T@hsON4sN7+MOh8C<Ig&W2w)5Y(`$Yk>PpbwEVs1D0&X?!nE1b1&&DHi-^@
zodIk@tg{UiNTrLy_tS%Di)79<X(1z?mH-Zz)Mx0c4LHlLT;mH1on(!oogbrNuF*ma
z-%wu<N!=Q`Bcvtiju2Sz{Agt)@EBpQ7s~T9_yTKdZol<*rgrBkMh(29Mtdx?1epEo
z6#RU7N`t`%=xlZ`yis&23Me&eu+v_<Y}=0aPivjd#TGY_cJIS-P}Udwb?wP7e3IKV
zo;Ibj4*<jSXpYrZ>PbSOz+*y?i%z#Dq2=7lrs6~1Y`Sg7>-&{rlWl`6R?`mbjDw$?
z`Sj!Adn{CJRI&bogdSIb00&mZq=GYEGOo{@X`iJK=aq}W;5onl8-~)HYGU=(LgQrA
zpOJe?O@ct~KGy5{tdj~Nay_KST8-;q%ne#FCjT|Ey+1=AI{;N2wl%i0H7A0THqZ#Y
zsQ3Sp7>(4hfuZB<YWGNnzhi5;P|WhZLV!Y{iMA8lp-aNwS1zgW4RM1YOOAsA`7^r+
z2Glq9!*z}I+!&7a@3WXWvavsbP#POoWoBALl}akky~%sB^4Be$Kd76Q;Y(z?&#U&_
zPc(HI)E7mx4miLGE;irFn}9CGl8+Y-i{re-PDA7)nF@@^C}4kwW`9Q$O7K?hb^@~m
zLfCP@bQCaABENL>kZ<_^bb#ifFIfR(Np?lXjohhE)MkBN1NuF7a<$iEFf?!5UoM&n
zUK*1j{BY>$<jrMLz723*6?0oS%hgpA2hXKjCY!$ebJt+0Tp@l)WhBKhgForXa>@SJ
zo$RAt#(u;!@C_@0;B|ssO%elAmSrq=n<g&oOEP9Pz(k2#UvM={vYGrxg;831fu}k-
z|0{qJN(f{TG-r`(FUiw%wRen%=a$BBAn_Rn-lhEuCQfu3TZuSu^)y6Hg3>iNq~?C!
zC?+vTIam8Cy}*NFGgRS)zfHy>KlvAGaCh3`{<bo1b7c30ChPV0{F2?F*|Z@`qn|Q#
zM9$uO_TGXaH|^}K?bn}bYL22$PN$-*{K<F4FRWPI8wXccC_=U)z+#%pnub=$Pk!QQ
z;-y*_rS~$ZVB9))k0!GqPezxtXfygj``Qd!DH^@J7larSPf<OLI1b{8s)W{336@05
z$ND&T%%)sYU%R%QR0L2-qST6r1kJU|#qJyNF%HnA3^9zbTc$D=cAOA@YtA36U$;7v
z_1eqEbB2Pm7x0oi<@&Xcp<tR>AFC(6!cfDkd2avn$C>LmsV-JdpxAkd)Vj}WIZi8P
zI9;a1?rbz4r-0&c6~wdE;dD~%1!;MMV3VL<#kyqF9N#SD@C=>n)C%ih?BFeMH*~SN
zyD7+?MQRPI?XaA2aOje5{=rg>2-Zh>gX?CcW`%)+5BRiYZiiHzIMa*m&oVqadC51+
z-?`8`AGVtUQIM7ge3QH{y^cQ2LY(fX9DRRXW7M^*SU>Sw!3WeJ!GyIdA@OXyE%gkj
zd(uGz{K+SInQsKhA%8!@FItbFeS=61j#2A0LD}h&qh|sUhm+0^ZX$0kz^zosHTJbP
zP0&}Qi<`9@6#8&(v;?B(Q!5No-;|u?xNT7Yb94h<I1qy|!H!-~m-9jQ1^e>1we#lC
znycr||5r@-O8z?bnS`zO8yDf_JNN#FK+A6sTHXlC+4Q*i9WC4j70xM-oYvQST&6-h
z@JUhn1Dj=YeuSb_1sx-E`Cd2+h67ngYK})7X9~gG{14BC7DwH<aPhaiLQD_>H)pxS
zJjB1e%}}DV#O?1YzEPjf1gx2W<WK}Y6S0sbcIcWT*Sg`xMwpyw#>Qn^v7B>34G+9M
zzJr4Bt3b87at?U-DG)}n@z=KPzW#ON;g_U0KCegzY`BZYUcEa<LYz(T%fN5B2X2`X
zQvqw`lY4H$%2_kY)^F>?+V3lWh?$+)ymaFbqcZ2@v|>tbMrUosl{ylJ=j1;Qd|Y4e
zi-Ua9@rI#W#;SBekCOvP(NES(O-6$q5Go-b{h;nR>S9{E4$>J+qcPh(VTCtYI|{&Q
zDvB?`e}W~xU5HyJnNO;kG8I9RK;FA!)78?OAA~-=#}@tc(NVv`(z3Sz&^*DjhbSr|
zH^$Zid;COR2#4nVbi<JP?7qM4j@t<SsSG=<N*~~lRKbn3fJV^VD3stzRbCi7v$`KM
zoUisp;A&3J7fcM`NoV)n^`Jb0rFi}-_6P^$NwtBMh#DU*ddUa=&7_ry9;Y0EXV3B@
zi{?~tEqN3XZk8OvqDnOn=;G4KWC<4qsX`_8VLph{en?@L4?M-Cs;OR2#LMXY)~-+U
zuRT!|l{ja$iDL23O?^?F$+GyFC$QDN*Uy6Ie{sl|?BN<Ky_BB*zQ2vZmZBdhhM!a&
z#~uMxF&^cw%b&pyXK?!M-ED2x>c?LUvfW(k%#eA(&8Ipuvkc|+pW}4_HgZZjMm?Kl
z3#5qquLeymvnfe5Oi0gJ`ZL@3>bEt*D<G%r2qmJCkDF4`og1%dD2&BsOo%Pk?BJ=~
zWDC-GZ-vX^P6hq>3FXxpgT`e!MmVFI4#1e`uqgjDNzA%Dzw6LGs^Xi%V=R@+_5pc$
zN$vIA!if8KN*A<4k6KX~7mo>FvdWdJmJ)>@<Bel^YU>xt-MrO*BS+?)&>X~&^(X6q
zwx#;3&ThKC-(8}7XIP=m8;jL7oUHc|PQBgT-d^T0-VESF5mN<)$LHZbGE;%V)5~>Z
z3wn;#xc|;WPU`o%*&ixQ1f^L<1%-Mc6v-TrbI}Rc3lx>$+KuGte$Sci=UJ!F8}XPe
z&zR-gIYt%kQkvSkymeLYh?yiuAb`%i?|#kER8P3y#**VY&n3^aRL(+Qe<sDVvgj;$
zK=ZIMhl;{@p%G`x&P0`%6gUbCEBV~8_@Wn|)-xL%W}P9mXFJ?l(4b2ytr8zE6+qsu
zqjpF@?51jeUz0O`AURW4_D*iwFO8q|sKU6y;;mn!#Mg8lnF_?~V6p2Xo<knmLk=x|
zq7G%lmNTMec03C~J&v1xN4QAEsY+>b`|3i4X%Y`?)2#<rn?61vElzRnyJ+G}KxOGo
zxru3Ci;V+TwrEDkrq;;giDEqwet%U4{|)fliInIX+N$;K@>zdLDL!9i)@E}R2WcAB
z9=DSTuUZc2ffO9F1F&zs$<W&hGR^U`>8XH=vGYCCSpk7B4S$d8(QU3>!M?lEza5Oj
zzIpRK19+5Io1)AJYIf+)wk;|-%S|^#;my@+#zGQ{06<GvA~3R*^?Q%z*D6oGK6R40
zf7RfM?c(RiJ50S}$!?9;B8%9+q#<Yk+$nDOhoR_nn_Xn=E*!J^Q3FyTN$wwWvNA?8
z@Ja6!Kpd-V*AhV-u<EG7L10Ya5mPjAG~4<YYC8u)w1JJ>Z^k@kY>OPu_}gO>Be1_<
z+E~+)`J((urg9?PmHz;<=<mnpAiF9ODDAu%k6Hb!G2a(P7n<XCAwJK?iEZfZt$4AJ
zK=X*M?wTmQ+L<#5!xpozy=d=SttOxY1DrYkeYdpKNTFfTS!!4WFMdP1y^o1-k`wr+
zCU!1@o#%4}q;!$gOyE%4mYZY2c}wo{h&FJa#(&T=5a+RjR`Ux$NE)%B4_>4RN9?HA
zBb%H$fFs&J`=c2VoB5pl+>}E22%YbDw`cbe6XQasJChGAQECr@cE?I8P-WH1YBYN_
zSpBlG8pj}2w1G|J>Dfv>I)oqW(3WUcX~6C$fhTQZ>FgJ7us+&>Fkrtk<sUA4vJ&CJ
z;Y!0nDrL&sP)0%0R^{Ko`-jEw`M)!!H?K_!4WK`~SqbuHe^PVC1W%-lPAg88?#|;k
zdqo#K)%%NWoLchwEbTpLflfAuie_jrzl^%7WXk5hQhC(B4YiXPCRi;;6gXn8j~@)W
z39@q)fVuQ0<5rodrw+h6-0JupuzsOFt9VUnHW~Mmyx~u7W>Yx%4O|^*tasaphSwYL
z_c?@EGoD`FxiE-Sxoa*R&Y9&_*QFdYKd1&GE1pV_ZcQiO8#GG$Ka~iIEo~9dxEY7S
zQ+8Mc6!$e+#XagkLiKhTCOOLA?P;K}+2~Ak9F3db$X8kGd&eg02VuiI<}7nyBF1zd
z@;7Z@*n{3Tn#ck*>>(DtqJ|(;e{rVo6wB=QSrqo>B2+OP3QKkiF#K-ei>(@%rdLcx
z@+Y$Y(qBV<B?FGk&5g1m=->=9$I|(3Z(x-DD+V`U$q+VOT1vsZ{ST3CSUgLb+s#$R
z0je$kOwt9(Q({fy`5?9EW?D`pw@Y%2%h4{Z$20e))Xtn7L{2HJ^vfR*%OoU3mT;T;
zrIOXhk01QY&FZ3NW#fNCiozKBRcF8<Sn}`R-@CiJP7U5S&7r^1j<(zaa5@J@cVK-z
z@czpnagU@E#fc!8PpIN$^^*=BM2^~%o3Mv4JQ(5g6`u2~VpL0A8Rz1OoCS(J=Uv;$
ziCfDQJ8@74N6jOLm^IS+4~Sc_Z>%4NDg)^$8wVfh(eBKQ{-L>8j0tbgO;2<*Eq|;}
zlUA^_W>5P5JjZca<iCNm-3l1cY;Fdv-|SUgP3P_v#Q$Mn)xB9Knfz*m$LC+m&|JLS
zepPN$LVmjtq+5Y0NKX02|DP=cGNTc<II3_nfJuBuhwr`z9ViRhzSFsr9PupjqVlkZ
zT1^vL$f}1)rEBE0V=ovIb^o!Wd?8x$P8j=3^fY&gnn7+bpAm=IB8+h_7I;KuqfP-5
zOaFc6O|^-uHZHhG2T>w9w3V~4Z+Ll;acpuMR<U-JANxgN!3KC&G<7uvnEifqD^Go4
zNea9#{j$(Si`V7VI<OF`^a{U0OusJ}6K2n<6ZS}vAGc$;t`-hLB~VE57P&jK9v`#F
z%jI))cx9gQ0u33TQ}n<FH_x9fwfk<b_Bt@`*H)KsVG4~YouHpeHGra01!tr+(06Py
zCoK;0&yKIu8g=l5#ZC#Ep>Xc#Idq6bb5&-r6Vpu`rQ1TG@x$EEIOVi%I(@4aT`IJ@
zR(?M|z(T#qIdr~Z5xz;-vFb7tExcs0JY7k1Uyf_K{eUMvKl`wvca?Yf&v9RB{eJN^
zsYyB}#G)Lk76T;-8Y&?QiiXnSyFKZS1Gvy6>vBFAsG&lY{PW69&)1vsPwgJC=cuIo
zpr7FhZN!aoR=4N19{v-xDgOo#TrLO7t^KPU=MC1By!^2lm}KaHT8>(L&kPQiDE&F^
zjG}YRtZi>cM&NlZ?lt`9r`U5mDLk5X*$_k4=-(K~nd(HvNyN%^y$po%2YebruYh<2
zWw6p9!3q2T^ZB^+2e#=CNy=yBG^lZ^jjexxlf+iyK2S}J%HrG~p+SCKsTRkJlSH2k
z2ojGSA8+Uf-iQ#Ib98t#rP->M8fhgv427HGf~LCzhTEzbZq89`f`{Zv2lm79^j9lA
z1^%d@T=jXxWYN6UOXzS{R}1b^f4m!kqii#7$1O6*id5K?KY1Jak)lJIxMM7N)41H1
z1)eqXE8LOo#7T^nFTF`MWSfCFP=}QG5vA=9wty$h<{XdIG=5X_U^KE)=d#dF1FEk-
z047z12AV>Ag~)#UT5M)VRh~EQ(S?i(4?amyYmdQ=ti~HMSI8j=G<B@%4J#m0!4SE0
zFx&GEgt#`B0yH`$nJZ%9Yy5LT$kbI3<`X#~GAQq_*!aL>wpt=>k!WKPqvFEcWE}@D
z6W@d^D*SK{xy^IP9zzj%i8m*jYS@Lr6Eu#2!X3uP5W{wW4CBk|L=*8NpTH#md`~{G
zg0D@pg%LfmOXL~pVQ#{6=e9Z;!Rx%(W;5+4W!;x^gN*YYJ}aPBx^(GjoIhnBfTz_<
zQ%+aEIy)<f4!xOYD@(~>%R&U>$tW#1!?^j0uxJ-NeOi3wvd!F~txf_g#*I?N1_!?z
zh~yg%@sq31^Lm5<EQUNS@>FQGsRxVy@#U8^e9g->=#{y)Ul6OVIG~3@qr2i)uSCNi
zd&yphTP-P&PpOZ*$i~Lzk*<(9TQgt)F(UD%NktZ>rqp>Z?f4ebp{~RLu3xo{MtzUn
z9<3&V@3G5rR?f?}XRmB+3Ciu`+u+FM@cJPBWdGKm4NX}WA29T}$|iaEGdgJf;r66g
z{g){Bf3F_u2L^PYW<vG2*^AA<lEFV>Y!}jd1MT(XI6?hY(_$kP5~_LU8XkvTg714q
z6@0KBHUojGN}z0#(74)Sdb0>hMy6ZgYCv+z7S(sTOXj2%J6{%)zV|<PAYQ@x54YfX
z@+c9V?bh72c$8E%6g5hx>-IF1d02imU}EH1;(g7_fZa2@vVS6A2hgB&%5RH5{rk>I
z3?b#Zyf>Iq8+6L6D3b~xSiq?7-r4z(Z96?V{fQmRQwr;YXs~XC-q~1S?x7*68_P{u
zCB^*5QZ7gh&3b%XvBx6U3xN%yCE^F_{~#TYPTKoby4$Xol<-9=<o9(gb|MGzbJoDD
z=E)v5>lF|9BAnoU<sojasl+85oF#k#9ez>L_ER^keQIbyTBGa&#+xJgU3Zm;Z^`d7
zKd+8X-cXEQTLOD3t-1F5PA|@1!bAeXV7^SfL;}zk-lS*WROjO%bQb(M!Sm%IqP<=M
z)=v{K2-~)xB6?=ktPj$<xJiZiC^;*#2VIVz16OiuZPH~I#rv}=aX0{@Uh*P(4jORc
zD?v4rUx1?a6;K5JGGC^}Py1&~))C(aVktr7*>zjeAN$Oc-ETxzMn%gicV`g!cWm82
zDpRQ9vP9V12_#7p-3Qi?G>pxKUm*)qS=Swq2?YjFvr??(BJcH;$c7DxnIt2_i}d!y
zI#zl=8hu1rDOf)irzTVJla6d@B*pu`mca`U0zL1@2Z0}mJZ>irPWP7VMw!6FN9cMX
z+c+#qW>5@`2*W2NyIHC<YdlmoAIZZjgYZ#fPsybg&b2?=02yk$XH&Ztp?aGH?4l0d
z+C<hrfRcQgLNcQicVT#Nj-vj^WS}V859dMG(z3ZBu+~LDSzkL0L%o5s5kgMt-!C`d
z`x^{0-h8C{n}&#qT8<}O%EB|jwW2HxVZ86rJNqkod`|YgW?BIlgtTYOWZ>LzzU#Mb
zrhHq8G%v;E8ODj?abg5NHNu)z5V?Jb?6E?Z7XSMpPk$*y7($W#>5_K7Xs^GNZ?U~Z
zEm(x{;}m(TBxMiJB(9aOPI55Rfj&vOtVvN4HAZ0nz-BrgDk>s|HCCSxURH3gb$!dQ
zF8FK=;9aQ+p=$p`iQQKB4}{akO3M|b&SZ=&RWU4|r(0*E;D|7jm#drQ1()~gj5iOe
z2KGeBnbGMS#fhL0JSczWK*g-1WBaor>~HW!jO4D5zV{HMi)-Etpa8_aubZV1>X8EJ
zR2b;-N;?Mx(^F2dJS7@%BRa<c(5e%e_n7Asp&B+KWxoAdMtd8=e`r9AK>skg#-j--
zJ6DxZ0%!J(_Tlnt$OnM(&m%se_1cm%{+}#N7hPJ7ZuL*KhlgOOw?g+4iEx>Gocj=j
zOJ53(>xXxtPxn5%F(Q8yhJ3jMV%cv5DFa-aif{GBpMOcQTYp8xGg3Xkbv<!Gf%j?u
z`1-SLEyFhqCSL!(2bNtCA~pUvjC``=b|aE=5_66(y*+0pgSc_9cxm*ZR#~N<vM&gB
z5CEgEPI7P=RPn9qwL1K8gI^o0{vj<+ea-X`LOBe;P;7|rN%{FW5}#oGA+f+@NCfHO
zb(-xMgXMzx?8#`ZthF^Gb~_xg(gjD+HA%`8OcJ>D-3Bt#ZQ7m{F<&%$vIk$T`J$Re
z!WUtv&Urw;wXjs>EK_3-r<y!UENbr4c21#c#5dRRi6sR9uOb|2)-^9xEbx)erWUNB
zUeKP^`?ljo4b`5+9e1ZcK2uCp&-5LJ;$H!ps16-oyhudydJ)Pz%*$^hXYuDQMogrg
ze73Yi_Pq#3%aai?x7Vx7#P5E5KT}!?Tpk*T(aVcPII`AW?X^HrylTgRh1GIHGh!AE
z{ys^QXQtnOVP@iIYOb|S_un+@I%b3z{8>GqJCdt6(Z4Y+%Dh*)ZOqsIp-DlR3L&A>
z4sg>bv=IiC6`z8Xq-)8d7McMGY2Dw!a^H^&4d6kHNES3U(DA@JM{*2nzP7P*&h2kB
zXbZxEvqt$EtgZM<2L5(q54L}CB;sY>-Uv{6s_+3Eg*tno(?cKC?77f5RBxrX8Utzm
zGj&x*wK$uSGk-TL05`}|rGvIjz3MoWBE%ec*|+vgJ5Ulh?Q)dyz=#{0GekUvixUV*
zvmV{~C)L>7zt8{1u|$I6G?^|Hz(pxni>oL<s7-=1-S?{=$PB>7TR_ob6!f3;4uFv~
zr-0wy56dlg8cbb1+-3g~N$`!Vn7_Gn^Hl76y<bX8)uFVHPY6?lF04@(h$6EKjaa2`
zBL4saM&LabA3!oTL*+ly`l3r|$qKs)JTBACPxx5>fPR$Vob1>#rmfAo|1CG>u<So1
zn#t&gYU_QV$*B`$fFI+=-~%=riU_C88{X(*bEbb_p%u6{q?$jp&AZ-S0LZ@$<bQzU
zG$GSN{N?cv;idWJgjAOyXUFzzQ!A*Mlu%APaQmhALlps7G&gAZtNTzkEmFz1oP&SN
z%SYD^xx_u}@5mDXB$o2KRRsTvk9aP$H2(1K80N{|0|6BV<7XI%RwG*GZ2NosA3w**
z!PcWv91EB*upkh8>3tTNFPgrFUEI8aL#?0qj}e8?xchtps$yZ-3<FVY5NXetoxq9!
zVM!?qqqmQ}1wR18G3;Hm_ypf13mJl;O9bMd{nz!iwJWfpA_5c+Y@790nC?iY_d>Vj
zFxZtYo68x(a*uoCpk(R{uKYRJ6*}C69&*}vkUg-3FXo}9>fp`>04~Sj_bSeakQy(>
zaHU=+FafX&%A}LcgoS{QIclME6>^KYi1uWfq5HapqZvrUUdr!>WQ%%%89@G8SjeVJ
z35X`DM2=Q{BR&@cbCenxMBK{>QfV^|5KGZ)jXKQ#%;$QlgR^r$aK{Gv4IyNdrG~}?
z<uFeegM(x`;+3|ZLQiNRNsRfNJ9Jhf0gS-+kvDi9;)b5}q`D<Ckry5jp5jPL{Uvsq
zk)o$sqMI6^5C-%b1t^NcGa_L}n@8KIfUu30v2M_uX%!$u+sKfDv!K<B@LO5AgE!$h
zj!W}7>An)d<gy+tCl9G`5-0T)uax_P*-!Gb7ws_y&lH7M0C-?>LI(mQKHEpSn8Ys7
zc0>fMo8;@@Bu_k;5&>t^PA2Jx4zPO~U?)8y(P!5zxCTimsKhhd`nIs<<cM}1><|`-
zokIS1fC=U>N#IGpj{)*{=Jl6AdKya&E*1&teSO;rav*`DwtKGgfLUj`l(x(-h?$1#
zCuj27-LEk+Y#+mT`z7TpR{HfJsz=2Mgf76GONVa9A3R?Xx%oF`7p`vOZ#Lw44XK)}
zH9M>vtlZJT=EOLA+Lj~d)Hf93^8YW-P96=uzbEMNiH#i}pIm!*gaatcYsgi~T7~`(
D^&*Ag

literal 0
HcmV?d00001

diff --git a/apps/desktop/src/components/connection/ConnectionDialog.vue b/apps/desktop/src/components/connection/ConnectionDialog.vue
index 6bb617f370..1ff7ba37a3 100644
--- a/apps/desktop/src/components/connection/ConnectionDialog.vue
+++ b/apps/desktop/src/components/connection/ConnectionDialog.vue
@@ -1162,6 +1162,7 @@ const driverProfiles: Record<
   trino: { type: "trino", port: 8080, user: "", label: "Trino", icon: "trino" },
   prestosql: { type: "prestosql", port: 8080, user: "", label: "PrestoSQL", icon: "presto" },
   hive: { type: "hive", port: 10000, user: "", label: "Apache Hive", icon: "hive" },
+  kyuubi: { type: "kyuubi", port: 10009, user: "", label: "Apache Kyuubi", icon: "kyuubi", urlParams: "auth=NONE" },
   impala: { type: "impala", port: 21050, user: "", label: "Apache Impala", icon: "impala", urlParams: "auth=noSasl" },
   spark: { type: "spark", port: 10015, user: "", label: "Apache Spark", icon: "spark" },
   db2: { type: "db2", port: 50000, user: "db2inst1", label: "IBM DB2", icon: "db2" },
@@ -2416,7 +2417,7 @@ function applyProfile(val: string, preserveConnectionFields = false) {
       form.value.connection_string = undefined;
       form.value.url_params = "";
     }
-    resetHiveKerberosFields(profile.type === "hive" || profile.type === "impala" ? form.value : undefined);
+    resetHiveKerberosFields(profile.type === "hive" || profile.type === "kyuubi" || profile.type === "impala" ? form.value : undefined);
   }
 }
 
@@ -2542,7 +2543,7 @@ watch(
         resetVictoriaMetricsFields();
       }
       resetElasticsearchProxyFields(config.db_type === "elasticsearch" ? config.external_config : undefined);
-      resetHiveKerberosFields(config.db_type === "hive" || config.db_type === "impala" ? config : undefined);
+      resetHiveKerberosFields(config.db_type === "hive" || config.db_type === "kyuubi" || config.db_type === "impala" ? config : undefined);
       resetDamengJvmOptions(config.db_type === "dameng" ? config : undefined);
       h2ConnectionMode.value = h2ConnectionModeForConfig(config);
       customColorInput.value = config.color || "";
@@ -2797,6 +2798,7 @@ const iconTypeMap: Record<string, string> = {
   trino: "trino",
   prestosql: "prestosql",
   hive: "hive",
+  kyuubi: "kyuubi",
   impala: "impala",
   spark: "spark",
   db2: "db2",
@@ -2879,6 +2881,7 @@ const dbOptions: DbOption[] = [
   { value: "trino", label: "Trino" },
   { value: "prestosql", label: "PrestoSQL" },
   { value: "hive", label: "Hive" },
+  { value: "kyuubi", label: "Apache Kyuubi" },
   { value: "impala", label: "Apache Impala" },
   { value: "spark", label: "Apache Spark" },
   { value: "db2", label: "DB2" },
@@ -2925,7 +2928,7 @@ const dbCategoryDefinitions: Array<{
   {
     key: "analytics",
     titleKey: "connection.databaseCategoryAnalytics",
-    optionValues: ["cloudberry", "clickhouse", "doris", "starrocks", "databend", "selectdb", "databricks", "saphana", "teradata", "vertica", "exasol", "redshift", "snowflake", "trino", "prestosql", "hive", "impala", "spark", "bigquery", "kylin", "dremio"],
+    optionValues: ["cloudberry", "clickhouse", "doris", "starrocks", "databend", "selectdb", "databricks", "saphana", "teradata", "vertica", "exasol", "redshift", "snowflake", "trino", "prestosql", "hive", "kyuubi", "impala", "spark", "bigquery", "kylin", "dremio"],
   },
   {
     key: "domestic",
@@ -3767,7 +3770,7 @@ function connectionConfigForSubmit(id: string, generatedName = ""): ConnectionCo
     config.ssl = !!config.ssl || damengSsl.enabled;
     config.url_params = applyDamengSslUrlParams(config.url_params, config.ssl, damengSsl.sslFilesPath, damengSsl.sslKeystorePassword, damengSsl.sslProtocol);
   }
-  if (config.db_type === "hive" || config.db_type === "impala") {
+  if (config.db_type === "hive" || config.db_type === "kyuubi" || config.db_type === "impala") {
     if (hiveAuthMode.value === "kerberos" && !hivePrincipal.value.trim()) {
       throw new Error(t("connection.hiveKerberosPrincipalRequired"));
     }
@@ -7039,7 +7042,7 @@ function openExternalUrl(url: string) {
                     <p class="col-span-3 text-xs text-muted-foreground">{{ t("connection.oracleTnsPathHint") }}</p>
                   </div>
 
-                  <template v-if="form.db_type === 'hive' || form.db_type === 'impala'">
+                  <template v-if="form.db_type === 'hive' || form.db_type === 'kyuubi' || form.db_type === 'impala'">
                     <div class="grid grid-cols-4 items-center gap-4">
                       <Label :class="connectionLabelClass">{{ t("connection.hiveAuthMode") }}</Label>
                       <div class="col-span-3 grid h-8 grid-cols-2 overflow-hidden rounded-md border border-input bg-muted/30 p-0.5">
diff --git a/apps/desktop/src/components/icons/DatabaseIcon.spec.ts b/apps/desktop/src/components/icons/DatabaseIcon.spec.ts
index acdc7eef84..512917a863 100644
--- a/apps/desktop/src/components/icons/DatabaseIcon.spec.ts
+++ b/apps/desktop/src/components/icons/DatabaseIcon.spec.ts
@@ -44,6 +44,17 @@ describe("DatabaseIcon", () => {
     app.unmount();
   });
 
+  it("uses the Apache Kyuubi asset instead of the Hive asset", async () => {
+    const container = document.createElement("div");
+    document.body.appendChild(container);
+    const app = createApp(DatabaseIcon, { dbType: "kyuubi" });
+    app.mount(container);
+    await nextTick();
+
+    expect(container.querySelector("img")?.getAttribute("src")).toBe("/icons/database/kyuubi.png");
+    app.unmount();
+  });
+
   it("uses the Meilisearch asset", async () => {
     const container = document.createElement("div");
     document.body.appendChild(container);
diff --git a/apps/desktop/src/components/icons/DatabaseIcon.vue b/apps/desktop/src/components/icons/DatabaseIcon.vue
index 4da59dd00a..62d0c6491c 100644
--- a/apps/desktop/src/components/icons/DatabaseIcon.vue
+++ b/apps/desktop/src/components/icons/DatabaseIcon.vue
@@ -56,6 +56,7 @@ const assetIcons: Record<string, string> = {
   presto: "presto",
   prestosql: "presto",
   hive: "hive",
+  kyuubi: "kyuubi.png",
   impala: "impala",
   hbase: "hbase",
   phoenix: "phoenix",
diff --git a/apps/desktop/src/lib/__tests__/connection/connectionAttemptTimeout.spec.ts b/apps/desktop/src/lib/__tests__/connection/connectionAttemptTimeout.spec.ts
index a63af01d92..a3899047b7 100644
--- a/apps/desktop/src/lib/__tests__/connection/connectionAttemptTimeout.spec.ts
+++ b/apps/desktop/src/lib/__tests__/connection/connectionAttemptTimeout.spec.ts
@@ -22,6 +22,10 @@ describe("connectionAttemptTimeout", () => {
     expect(connectionAttemptTimeoutMs({ db_type: "impala", connect_timeout_secs: 5, transport_layers: [] })).toBe(AGENT_DRIVER_MIN_CONNECT_TIMEOUT_SECS * 1000 + CONNECTION_ATTEMPT_TIMEOUT_BUFFER_MS);
   });
 
+  it("uses the startup floor for Kyuubi agent connections", () => {
+    expect(connectionAttemptTimeoutMs({ db_type: "kyuubi", connect_timeout_secs: 5, transport_layers: [] })).toBe(AGENT_DRIVER_MIN_CONNECT_TIMEOUT_SECS * 1000 + CONNECTION_ATTEMPT_TIMEOUT_BUFFER_MS);
+  });
+
   it("uses the startup floor for generic JDBC plugin connections", () => {
     expect(connectionAttemptTimeoutMs({ db_type: "jdbc", connect_timeout_secs: 5, transport_layers: [] })).toBe(AGENT_DRIVER_MIN_CONNECT_TIMEOUT_SECS * 1000 + CONNECTION_ATTEMPT_TIMEOUT_BUFFER_MS);
   });
diff --git a/apps/desktop/src/lib/__tests__/connection/connectionPassword.spec.ts b/apps/desktop/src/lib/__tests__/connection/connectionPassword.spec.ts
index 4cb6466787..42df5c7f56 100644
--- a/apps/desktop/src/lib/__tests__/connection/connectionPassword.spec.ts
+++ b/apps/desktop/src/lib/__tests__/connection/connectionPassword.spec.ts
@@ -29,6 +29,17 @@ describe("connection password prompting", () => {
     expect(connectionNeedsPasswordPrompt(connection({ url_params: "auth=noSasl;principal=impala/_HOST@EXAMPLE.COM" }))).toBe(true);
   });
 
+  it("allows Kyuubi NONE and NOSASL connections to persist an empty password", () => {
+    expect(connectionNeedsPasswordPrompt(connection({ db_type: "kyuubi", port: 10009, url_params: "auth=NONE" }))).toBe(false);
+    expect(connectionNeedsPasswordPrompt(connection({ db_type: "kyuubi", port: 10009, url_params: "auth=NOSASL" }))).toBe(false);
+    expect(connectionNeedsPasswordPrompt(connection({ db_type: "kyuubi", port: 10009, url_params: "" }))).toBe(false);
+  });
+
+  it("prompts for Kyuubi authentication modes that require credentials", () => {
+    expect(connectionNeedsPasswordPrompt(connection({ db_type: "kyuubi", port: 10009, url_params: "auth=LDAP" }))).toBe(true);
+    expect(connectionNeedsPasswordPrompt(connection({ db_type: "kyuubi", port: 10009, url_params: "principal=hive/_HOST@EXAMPLE.COM" }))).toBe(true);
+  });
+
   it("does not change password prompting for other database types", () => {
     expect(connectionNeedsPasswordPrompt(connection({ db_type: "mysql", port: 3306, url_params: "auth=noSasl" }))).toBe(true);
     expect(connectionNeedsPasswordPrompt(connection({ db_type: "postgres", port: 5432, save_password: true }))).toBe(false);
diff --git a/apps/desktop/src/lib/__tests__/table/tableSelectSql.spec.ts b/apps/desktop/src/lib/__tests__/table/tableSelectSql.spec.ts
index b56d08881a..7a59d1cdcc 100644
--- a/apps/desktop/src/lib/__tests__/table/tableSelectSql.spec.ts
+++ b/apps/desktop/src/lib/__tests__/table/tableSelectSql.spec.ts
@@ -50,6 +50,10 @@ describe("quoteTableIdentifier", () => {
     expect(quoteTableIdentifier("mysql", "orders")).toBe("`orders`");
   });
 
+  it("backtick-quotes Kyuubi identifiers", () => {
+    expect(quoteTableIdentifier("kyuubi", "order`items")).toBe("`order``items`");
+  });
+
   it("uses BigQuery quoted identifiers and escape sequences", () => {
     expect(quoteTableIdentifier("bigquery", "order")).toBe("`order`");
     expect(quoteTableIdentifier("bigquery", "a`b")).toBe("`a\\`b`");
diff --git a/apps/desktop/src/lib/connection/__tests__/agentDriverInstallHint.spec.ts b/apps/desktop/src/lib/connection/__tests__/agentDriverInstallHint.spec.ts
index 3db264339f..29d19b68ed 100644
--- a/apps/desktop/src/lib/connection/__tests__/agentDriverInstallHint.spec.ts
+++ b/apps/desktop/src/lib/connection/__tests__/agentDriverInstallHint.spec.ts
@@ -9,10 +9,12 @@ describe("DuckDB driver installation", () => {
   });
 });
 
-describe("Impala driver installation", () => {
+describe("HiveServer2-compatible driver installation", () => {
   it("reuses the downloadable Hive driver", () => {
     expect(agentDriverInstallKey("impala")).toBe("hive");
     expect(showAgentDriverInstallHint("impala", [{ db_type: "hive", installed: true }])).toBe(false);
+    expect(agentDriverInstallKey("kyuubi")).toBe("hive");
+    expect(showAgentDriverInstallHint("kyuubi", [{ db_type: "hive", installed: true }])).toBe(false);
   });
 });
 
diff --git a/apps/desktop/src/lib/connection/agentDriverInstallHint.ts b/apps/desktop/src/lib/connection/agentDriverInstallHint.ts
index 7cd1f67506..3b4e95cdc1 100644
--- a/apps/desktop/src/lib/connection/agentDriverInstallHint.ts
+++ b/apps/desktop/src/lib/connection/agentDriverInstallHint.ts
@@ -24,7 +24,7 @@ export function hasInstalledAgentVersion(drivers: readonly AgentDriverInstallSta
 }
 
 export function agentDriverInstallKey(dbType: DatabaseType | undefined, driverProfile?: string): string | undefined {
-  if (dbType === "impala") return "hive";
+  if (dbType === "kyuubi" || dbType === "impala") return "hive";
   if (dbType === "oracle") return "oracle";
   if (dbType === "mongodb") return "mongodb";
   if (dbType === "dameng") return "dameng";
diff --git a/apps/desktop/src/lib/connection/connectionAttemptTimeout.ts b/apps/desktop/src/lib/connection/connectionAttemptTimeout.ts
index d27d383be4..1696b5fd29 100644
--- a/apps/desktop/src/lib/connection/connectionAttemptTimeout.ts
+++ b/apps/desktop/src/lib/connection/connectionAttemptTimeout.ts
@@ -30,6 +30,7 @@ const DRIVER_STARTUP_FLOOR_TYPES = new Set<DatabaseType>([
   "prestosql",
   "jdbc",
   "hive",
+  "kyuubi",
   "impala",
   "spark",
   "db2",
diff --git a/apps/desktop/src/lib/connection/connectionPassword.ts b/apps/desktop/src/lib/connection/connectionPassword.ts
index 4b51aa4b78..cccd086dd5 100644
--- a/apps/desktop/src/lib/connection/connectionPassword.ts
+++ b/apps/desktop/src/lib/connection/connectionPassword.ts
@@ -17,12 +17,14 @@ function hiveServerUrlParams(urlParams?: string): Map<string, string> {
 
 export function connectionUsesPasswordlessAuthentication(config: PasswordAuthenticationConfig): boolean {
   const profile = config.driver_profile || config.db_type;
-  if (config.db_type !== "impala" && profile !== "impala") return false;
+  const isImpala = config.db_type === "impala" || profile === "impala";
+  const isKyuubi = config.db_type === "kyuubi" || profile === "kyuubi";
+  if (!isImpala && !isKyuubi) return false;
 
   const params = hiveServerUrlParams(config.url_params);
   if (params.get("principal")) return false;
-  const auth = (params.get("auth") || "nosasl").toLowerCase();
-  return auth === "nosasl";
+  const auth = (params.get("auth") || (isKyuubi ? "none" : "nosasl")).toLowerCase();
+  return isKyuubi ? auth === "none" || auth === "nosasl" : auth === "nosasl";
 }
 
 export function connectionNeedsPasswordPrompt(config: ConnectionConfig): boolean {
diff --git a/apps/desktop/src/lib/database/__tests__/transferObjectKinds.spec.ts b/apps/desktop/src/lib/database/__tests__/transferObjectKinds.spec.ts
index 6e5dbda93f..3b1b5404d4 100644
--- a/apps/desktop/src/lib/database/__tests__/transferObjectKinds.spec.ts
+++ b/apps/desktop/src/lib/database/__tests__/transferObjectKinds.spec.ts
@@ -4,7 +4,7 @@ import { manifestDatabaseTypes } from "@/lib/database/databaseDriverManifest";
 import { supportsTransfer } from "@/lib/database/databaseFeatureSupport";
 import type { DatabaseType } from "@/types/database";
 
-const TABLE_ONLY_TRANSFER_DATABASES: DatabaseType[] = ["sqlite", "rqlite", "cloudflare-d1", "duckdb", "clickhouse", "mongodb", "questdb", "hive", "impala", "spark"];
+const TABLE_ONLY_TRANSFER_DATABASES: DatabaseType[] = ["sqlite", "rqlite", "cloudflare-d1", "duckdb", "clickhouse", "mongodb", "questdb", "hive", "kyuubi", "impala", "spark"];
 
 describe("transferObjectKinds", () => {
   it("groups databases into transfer families", () => {
diff --git a/apps/desktop/src/lib/database/databaseCapabilitySets.ts b/apps/desktop/src/lib/database/databaseCapabilitySets.ts
index 865f15bb32..a0da6d6a39 100644
--- a/apps/desktop/src/lib/database/databaseCapabilitySets.ts
+++ b/apps/desktop/src/lib/database/databaseCapabilitySets.ts
@@ -27,6 +27,7 @@ export const SCHEMA_AWARE_TYPES = new Set<DatabaseType>([
   "trino",
   "prestosql",
   "hive",
+  "kyuubi",
   "impala",
   "spark",
   "databend",
diff --git a/apps/desktop/src/lib/database/databaseNamespaceCreation.ts b/apps/desktop/src/lib/database/databaseNamespaceCreation.ts
index 3c6543522a..107d666857 100644
--- a/apps/desktop/src/lib/database/databaseNamespaceCreation.ts
+++ b/apps/desktop/src/lib/database/databaseNamespaceCreation.ts
@@ -66,6 +66,7 @@ export const DATABASE_NAMESPACE_CREATION_MATRIX = {
   trino: { database: "schema" },
   prestosql: { database: "schema" },
   hive: { deferred: "Hive database creation needs agent metadata validation first" },
+  kyuubi: { deferred: "Kyuubi database creation needs dedicated metadata validation first" },
   impala: { deferred: "Impala database creation needs dedicated metadata validation first" },
   spark: { deferred: "Spark database creation needs agent metadata validation first" },
   db2: { database: "schema" },
diff --git a/apps/desktop/src/lib/database/databaseObjectCapabilities.ts b/apps/desktop/src/lib/database/databaseObjectCapabilities.ts
index f6ddc4b149..935769e93b 100644
--- a/apps/desktop/src/lib/database/databaseObjectCapabilities.ts
+++ b/apps/desktop/src/lib/database/databaseObjectCapabilities.ts
@@ -69,6 +69,7 @@ const DATABASE_TYPE_OBJECTS = new Map<DatabaseType, SidebarObjectKind[]>([
   ["doris", TABLE_VIEW_OBJECTS],
   ["starrocks", TABLE_VIEW_MV_OBJECTS],
   ["hive", TABLE_VIEW_OBJECTS],
+  ["kyuubi", TABLE_VIEW_OBJECTS],
   ["impala", TABLE_VIEW_OBJECTS],
   ["spark", TABLE_VIEW_OBJECTS],
   ["trino", TABLE_VIEW_OBJECTS],
diff --git a/apps/desktop/src/lib/database/databasePropertyEditing.ts b/apps/desktop/src/lib/database/databasePropertyEditing.ts
index 8b212efe2b..9d737b12e8 100644
--- a/apps/desktop/src/lib/database/databasePropertyEditing.ts
+++ b/apps/desktop/src/lib/database/databasePropertyEditing.ts
@@ -66,6 +66,7 @@ export const DATABASE_PROPERTY_EDITING_MATRIX = {
   trino: { deferred: "catalog properties are connector-managed" },
   prestosql: { deferred: "catalog properties are connector-managed" },
   hive: { deferred: "database properties need agent metadata validation first" },
+  kyuubi: { deferred: "database properties need Kyuubi-specific validation first" },
   impala: { deferred: "database properties need Impala-specific validation first" },
   spark: { deferred: "database properties need agent metadata validation first" },
   db2: { deferred: "schema properties need product-specific handling" },
diff --git a/apps/desktop/src/lib/database/databaseTableDataCapabilities.ts b/apps/desktop/src/lib/database/databaseTableDataCapabilities.ts
index 233fe9062d..e8db6baeb2 100644
--- a/apps/desktop/src/lib/database/databaseTableDataCapabilities.ts
+++ b/apps/desktop/src/lib/database/databaseTableDataCapabilities.ts
@@ -90,6 +90,17 @@ const NAVICAT_STYLE_TABLE_DATA_TYPES = new Set<DatabaseType>([
 ]);
 
 const DATABASE_CAPABILITY_OVERRIDES: Partial<Record<DatabaseType, Partial<DatabaseCapability>>> = {
+  kyuubi: {
+    tableData: {
+      insert: false,
+      updateRequiresPrimaryKey: false,
+      deleteRequiresPrimaryKey: false,
+      requiresTransactionalTableForExistingRows: false,
+      existingRowsReadonly: true,
+      transaction: false,
+      readonly: true,
+    },
+  },
   impala: {
     tableData: {
       insert: false,
diff --git a/apps/desktop/src/lib/database/jdbcDialect.ts b/apps/desktop/src/lib/database/jdbcDialect.ts
index 4d1c4ea29b..f67e283bfb 100644
--- a/apps/desktop/src/lib/database/jdbcDialect.ts
+++ b/apps/desktop/src/lib/database/jdbcDialect.ts
@@ -13,7 +13,7 @@ const GAUSSDB_TARGET_SERVER_TYPE_KEY = "gaussdbTargetServerType";
 export const GAUSSDB_M_JDBC_DRIVER_PROFILE = "gaussdb-m";
 export const GAUSSDB_M_JDBC_DRIVER_CLASS = "com.huawei.gaussdb.jdbc.Driver";
 
-const DATABASE_AS_EXECUTION_SCHEMA_TYPES = new Set<DatabaseType>(["hive", "impala", "spark"]);
+const DATABASE_AS_EXECUTION_SCHEMA_TYPES = new Set<DatabaseType>(["hive", "kyuubi", "impala", "spark"]);
 const CONNECTION_ROOT_SCHEMA_TYPES = new Set<DatabaseType>(["oracle", "dameng", "oceanbase-oracle"]);
 
 const JDBC_DIALECT_MATCHERS: Array<{ type: DatabaseType; patterns: RegExp[] }> = [
diff --git a/apps/desktop/src/lib/table/tableSelectSql.ts b/apps/desktop/src/lib/table/tableSelectSql.ts
index c4fe8c525d..988f43ffe3 100644
--- a/apps/desktop/src/lib/table/tableSelectSql.ts
+++ b/apps/desktop/src/lib/table/tableSelectSql.ts
@@ -33,7 +33,19 @@ export function quoteTableIdentifier(databaseType: DatabaseType | undefined, nam
   // (DatabaseMetaData.getIdentifierQuoteString()) — pass through unquoted.
   if (databaseType === "jdbc") return name;
   if (databaseType === "bigquery") return `\`${name.replace(/`/g, "\\`")}\``;
-  if (databaseType === "mysql" || databaseType === "clickhouse" || databaseType === "hive" || databaseType === "impala" || databaseType === "spark" || databaseType === "databend" || databaseType === "tdengine" || databaseType === "access" || databaseType === "doris" || databaseType === "starrocks")
+  if (
+    databaseType === "mysql" ||
+    databaseType === "clickhouse" ||
+    databaseType === "hive" ||
+    databaseType === "kyuubi" ||
+    databaseType === "impala" ||
+    databaseType === "spark" ||
+    databaseType === "databend" ||
+    databaseType === "tdengine" ||
+    databaseType === "access" ||
+    databaseType === "doris" ||
+    databaseType === "starrocks"
+  )
     return `\`${name.replace(/`/g, "``")}\``;
   if (databaseType === "informix" && /^[A-Za-z_][A-Za-z0-9_$]*$/.test(name)) return name;
   if (databaseType === "neo4j") return quoteCypherIdentifier(name);
diff --git a/apps/desktop/src/stores/connectionStore.ts b/apps/desktop/src/stores/connectionStore.ts
index 042436edf0..da1e3a46e6 100644
--- a/apps/desktop/src/stores/connectionStore.ts
+++ b/apps/desktop/src/stores/connectionStore.ts
@@ -1095,6 +1095,7 @@ export const useConnectionStore = defineStore("connection", () => {
       trino: "Trino",
       prestosql: "PrestoSQL",
       hive: "Hive",
+      kyuubi: "Apache Kyuubi",
       impala: "Apache Impala",
       spark: "Apache Spark",
       db2: "DB2",
diff --git a/apps/desktop/src/types/database.ts b/apps/desktop/src/types/database.ts
index e81560a87b..47457cfc76 100644
--- a/apps/desktop/src/types/database.ts
+++ b/apps/desktop/src/types/database.ts
@@ -53,6 +53,7 @@ export type DatabaseType =
   | "trino"
   | "prestosql"
   | "hive"
+  | "kyuubi"
   | "impala"
   | "spark"
   | "db2"
diff --git a/crates/dbx-core/assets/database-drivers.manifest.json b/crates/dbx-core/assets/database-drivers.manifest.json
index 87b707b93d..48cd627ef8 100644
--- a/crates/dbx-core/assets/database-drivers.manifest.json
+++ b/crates/dbx-core/assets/database-drivers.manifest.json
@@ -1460,6 +1460,36 @@
         "driverManagement": true
       }
     },
+    {
+      "dbType": "kyuubi",
+      "label": "Apache Kyuubi",
+      "runtimeMode": "agent",
+      "mcpMode": "bridge",
+      "agentKey": "hive",
+      "singleConnectionPool": false,
+      "metadataConnectionScoped": false,
+      "skipTcpProbe": true,
+      "defaultPort": 10009,
+      "supportLevel": "operate",
+      "capabilities": {
+        "queryExecution": true,
+        "metadataBrowse": true,
+        "objectBrowser": true,
+        "objectSource": true,
+        "schemaSearch": true,
+        "diagram": false,
+        "tableDataEdit": false,
+        "tableStructureEdit": false,
+        "tableImport": false,
+        "dataTransfer": true,
+        "sqlFileExecution": true,
+        "databaseCreate": false,
+        "fieldLineage": false,
+        "sqlExplain": true,
+        "userAdmin": false,
+        "driverManagement": true
+      }
+    },
     {
       "dbType": "impala",
       "label": "Apache Impala",
diff --git a/crates/dbx-core/src/agent_catalog.rs b/crates/dbx-core/src/agent_catalog.rs
index 6ecef5f7d4..001da03ec3 100644
--- a/crates/dbx-core/src/agent_catalog.rs
+++ b/crates/dbx-core/src/agent_catalog.rs
@@ -196,6 +196,13 @@ const AGENT_CATALOG: &[AgentCatalogEntry] = &[
         store_visible: true,
         profiles: &[],
     },
+    AgentCatalogEntry {
+        db_type: DatabaseType::Kyuubi,
+        key: "hive",
+        label: "Apache Kyuubi",
+        store_visible: false,
+        profiles: &[],
+    },
     AgentCatalogEntry {
         db_type: DatabaseType::Impala,
         key: "hive",
@@ -410,4 +417,10 @@ mod tests {
         assert_eq!(agent_key(&DatabaseType::Impala, None), Some("hive"));
         assert_eq!(driver_store_entries().filter(|(key, _)| *key == "hive").count(), 1);
     }
+
+    #[test]
+    fn kyuubi_reuses_hive_agent_without_duplicate_store_entry() {
+        assert_eq!(agent_key(&DatabaseType::Kyuubi, None), Some("hive"));
+        assert_eq!(driver_store_entries().filter(|(key, _)| *key == "hive").count(), 1);
+    }
 }
diff --git a/crates/dbx-core/src/connection.rs b/crates/dbx-core/src/connection.rs
index 35745c5a59..abdd6ad7cd 100644
--- a/crates/dbx-core/src/connection.rs
+++ b/crates/dbx-core/src/connection.rs
@@ -172,6 +172,7 @@ macro_rules! agent_connection_pool_database_type {
             | DatabaseType::Snowflake
             | DatabaseType::Trino
             | DatabaseType::Hive
+            | DatabaseType::Kyuubi
             | DatabaseType::Impala
             | DatabaseType::Spark
             | DatabaseType::Db2
diff --git a/crates/dbx-core/src/db_admin_sql.rs b/crates/dbx-core/src/db_admin_sql.rs
index 72d34d0284..053fbaeb85 100644
--- a/crates/dbx-core/src/db_admin_sql.rs
+++ b/crates/dbx-core/src/db_admin_sql.rs
@@ -489,7 +489,13 @@ pub fn build_empty_table_sql(options: TableAdminSqlOptions) -> String {
     match options.database_type {
         Some(DatabaseType::ClickHouse) => format!("ALTER TABLE {table} DELETE WHERE 1 = 1;"),
         Some(DatabaseType::Bigquery) => format!("DELETE FROM {table} WHERE TRUE;"),
-        Some(DatabaseType::Cassandra | DatabaseType::Hive | DatabaseType::Kylin | DatabaseType::Questdb) => {
+        Some(
+            DatabaseType::Cassandra
+            | DatabaseType::Hive
+            | DatabaseType::Kyuubi
+            | DatabaseType::Kylin
+            | DatabaseType::Questdb,
+        ) => {
             format!("TRUNCATE TABLE {table};")
         }
         Some(DatabaseType::Iotdb) => format!("DELETE FROM {};", iotdb_timeseries_pattern(&table)),
@@ -645,19 +651,20 @@ pub fn build_duplicate_table_structure_sql(options: DuplicateTableStructureSqlOp
     let source = qualified_name(options.database_type, options.schema.as_deref(), &options.source_name);
     let target =
         qualified_duplicate_target_name(options.database_type, options.schema.as_deref(), &options.target_name);
-    let structure_sql = if matches!(options.database_type, Some(DatabaseType::Mysql | DatabaseType::Impala)) {
-        format!("CREATE TABLE {target} LIKE {source};")
-    } else if options.database_type == Some(DatabaseType::Questdb) {
-        format!("CREATE TABLE {target} (LIKE {source});")
-    } else if options.database_type.is_some_and(is_postgres_like_structure_copy) {
-        format!("CREATE TABLE {target} (LIKE {source} INCLUDING ALL);")
-    } else if options.database_type == Some(DatabaseType::SqlServer) {
-        format!("SELECT TOP 0 * INTO {target} FROM {source};")
-    } else if options.database_type.is_some_and(uses_false_predicate_duplicate_structure) {
-        format!("CREATE TABLE {target} AS SELECT * FROM {source} WHERE 1=0")
-    } else {
-        format!("CREATE TABLE {target} AS SELECT * FROM {source} WHERE 0;")
-    };
+    let structure_sql =
+        if matches!(options.database_type, Some(DatabaseType::Mysql | DatabaseType::Kyuubi | DatabaseType::Impala)) {
+            format!("CREATE TABLE {target} LIKE {source};")
+        } else if options.database_type == Some(DatabaseType::Questdb) {
+            format!("CREATE TABLE {target} (LIKE {source});")
+        } else if options.database_type.is_some_and(is_postgres_like_structure_copy) {
+            format!("CREATE TABLE {target} (LIKE {source} INCLUDING ALL);")
+        } else if options.database_type == Some(DatabaseType::SqlServer) {
+            format!("SELECT TOP 0 * INTO {target} FROM {source};")
+        } else if options.database_type.is_some_and(uses_false_predicate_duplicate_structure) {
+            format!("CREATE TABLE {target} AS SELECT * FROM {source} WHERE 1=0")
+        } else {
+            format!("CREATE TABLE {target} AS SELECT * FROM {source} WHERE 0;")
+        };
 
     let mut comment_sql = Vec::new();
     if let Some(database_type) =
@@ -1695,6 +1702,17 @@ mod tests {
             }),
             "CREATE TABLE `dbx_demo`.`connection_test_copy` LIKE `dbx_demo`.`connection_test`;"
         );
+        assert_eq!(
+            build_duplicate_table_structure_sql(DuplicateTableStructureSqlOptions {
+                database_type: Some(DatabaseType::Kyuubi),
+                schema: Some("dbx_demo".to_string()),
+                source_name: "orders".to_string(),
+                target_name: "orders_copy".to_string(),
+                table_comment: None,
+                column_comments: vec![],
+            }),
+            "CREATE TABLE `dbx_demo`.`orders_copy` LIKE `dbx_demo`.`orders`;"
+        );
         assert_eq!(
             build_duplicate_table_structure_sql(DuplicateTableStructureSqlOptions {
                 database_type: Some(DatabaseType::Postgres),
diff --git a/crates/dbx-core/src/models/connection.rs b/crates/dbx-core/src/models/connection.rs
index 8c2514e857..bb596aa009 100644
--- a/crates/dbx-core/src/models/connection.rs
+++ b/crates/dbx-core/src/models/connection.rs
@@ -564,6 +564,7 @@ pub enum DatabaseType {
     #[serde(rename = "prestosql")]
     PrestoSql,
     Hive,
+    Kyuubi,
     Impala,
     Spark,
     #[serde(rename = "db2")]
@@ -1142,6 +1143,7 @@ impl ConnectionConfig {
             DatabaseType::Trino => format!("trino://{host}:{port}{db_part}"),
             DatabaseType::PrestoSql => format!("prestosql://{host}:{port}{db_part}"),
             DatabaseType::Hive => format!("hive://{host}:{port}{db_part}"),
+            DatabaseType::Kyuubi => format!("kyuubi://{host}:{port}{db_part}"),
             DatabaseType::Impala => format!("impala://{host}:{port}{db_part}"),
             DatabaseType::Spark => format!("spark://{host}:{port}{db_part}"),
             DatabaseType::Db2 => format!("db2://{host}:{port}{db_part}"),
@@ -1353,6 +1355,15 @@ impl ConnectionConfig {
             DatabaseType::Hive => {
                 format!("hive://{}:{}@{host}:{port}{db_part}", username, password)
             }
+            DatabaseType::Kyuubi => {
+                if self.username.is_empty() && self.password.is_empty() {
+                    format!("kyuubi://{host}:{port}{db_part}")
+                } else if self.password.is_empty() {
+                    format!("kyuubi://{}@{host}:{port}{db_part}", username)
+                } else {
+                    format!("kyuubi://{}:{}@{host}:{port}{db_part}", username, password)
+                }
+            }
             DatabaseType::Impala => {
                 if self.username.is_empty() && self.password.is_empty() {
                     format!("impala://{host}:{port}{db_part}")
@@ -2627,6 +2638,28 @@ mod tests {
         );
     }
 
+    #[test]
+    fn kyuubi_database_type_and_connection_urls_are_stable() {
+        assert_eq!(serde_json::to_string(&DatabaseType::Kyuubi).unwrap(), "\"kyuubi\"");
+        assert_eq!(serde_json::from_str::<DatabaseType>("\"kyuubi\"").unwrap(), DatabaseType::Kyuubi);
+
+        let mut config = mysql_config("dbx", "", Some("analytics"));
+        config.db_type = DatabaseType::Kyuubi;
+        config.host = "kyuubi.local".to_string();
+        config.port = 10009;
+        assert_eq!(config.connection_url(), "kyuubi://dbx@kyuubi.local:10009/analytics");
+
+        config.username.clear();
+        assert_eq!(config.connection_url(), "kyuubi://kyuubi.local:10009/analytics");
+
+        config.username = "dbx".to_string();
+        config.password = "secret".to_string();
+        assert_eq!(
+            config.connection_url_with_host(&config.host, config.port),
+            "kyuubi://dbx:secret@kyuubi.local:10009/analytics"
+        );
+    }
+
     #[test]
     fn cloudflare_d1_database_type_and_api_url_are_stable() {
         assert_eq!(serde_json::to_string(&DatabaseType::CloudflareD1).unwrap(), "\"cloudflare-d1\"");
diff --git a/crates/dbx-core/src/sql_dialect/capabilities.rs b/crates/dbx-core/src/sql_dialect/capabilities.rs
index 022b08b6ea..dc4cebebc6 100644
--- a/crates/dbx-core/src/sql_dialect/capabilities.rs
+++ b/crates/dbx-core/src/sql_dialect/capabilities.rs
@@ -53,6 +53,7 @@ pub fn is_schema_aware(database_type: DatabaseType) -> bool {
             | DatabaseType::Trino
             | DatabaseType::PrestoSql
             | DatabaseType::Hive
+            | DatabaseType::Kyuubi
             | DatabaseType::Impala
             | DatabaseType::Spark
             | DatabaseType::Db2
diff --git a/crates/dbx-core/src/sql_dialect/ddl_profile.rs b/crates/dbx-core/src/sql_dialect/ddl_profile.rs
index 87bf208955..7fcffd046b 100644
--- a/crates/dbx-core/src/sql_dialect/ddl_profile.rs
+++ b/crates/dbx-core/src/sql_dialect/ddl_profile.rs
@@ -669,8 +669,10 @@ pub fn profile_for(db_type: DatabaseType) -> DdlDialectProfile {
 
         ClickHouse => clickhouse_profile(),
 
-        DuckDb | Questdb | SapHana | Teradata | Snowflake | Trino | PrestoSql | Hive | Impala | Spark | Db2
-        | Informix | Bigquery | Kylin | Oscar | Tdengine | Iotdb | Databricks | Jdbc => conservative_ansi(db_type),
+        DuckDb | Questdb | SapHana | Teradata | Snowflake | Trino | PrestoSql | Hive | Kyuubi | Impala | Spark
+        | Db2 | Informix | Bigquery | Kylin | Oscar | Tdengine | Iotdb | Databricks | Jdbc => {
+            conservative_ansi(db_type)
+        }
 
         // Non-tabular / not applicable for relational CREATE TABLE
         Redis | MongoDb | Elasticsearch | Easysearch | Meilisearch | Qdrant | Milvus | Weaviate | ChromaDb | Neo4j
diff --git a/crates/dbx-core/src/sql_dialect/identifiers.rs b/crates/dbx-core/src/sql_dialect/identifiers.rs
index b95ee9e4ae..6ed24beb31 100644
--- a/crates/dbx-core/src/sql_dialect/identifiers.rs
+++ b/crates/dbx-core/src/sql_dialect/identifiers.rs
@@ -129,6 +129,7 @@ pub fn quote_table_identifier(database_type: Option<DatabaseType>, name: &str) -
             | DatabaseType::StarRocks
             | DatabaseType::ManticoreSearch
             | DatabaseType::Hive
+            | DatabaseType::Kyuubi
             | DatabaseType::Impala
             | DatabaseType::Spark
             | DatabaseType::Databend
@@ -379,6 +380,7 @@ pub(crate) fn quote_transfer_identifier(name: &str, database_type: &DatabaseType
         | DatabaseType::Doris
         | DatabaseType::StarRocks
         | DatabaseType::Hive
+        | DatabaseType::Kyuubi
         | DatabaseType::Impala
         | DatabaseType::Spark
         | DatabaseType::Questdb => format!("`{}`", name.replace('`', "``")),
diff --git a/crates/dbx-core/src/sql_dialect/table_select.rs b/crates/dbx-core/src/sql_dialect/table_select.rs
index cde2ed9e1f..5070f5141f 100644
--- a/crates/dbx-core/src/sql_dialect/table_select.rs
+++ b/crates/dbx-core/src/sql_dialect/table_select.rs
@@ -529,7 +529,7 @@ pub(super) fn build_select_columns(
             .collect::<Vec<_>>()
             .join(", ");
     }
-    if !matches!(database_type, Some(DatabaseType::Hive | DatabaseType::Impala)) {
+    if !matches!(database_type, Some(DatabaseType::Hive | DatabaseType::Kyuubi | DatabaseType::Impala)) {
         return "*".to_string();
     }
     columns
diff --git a/crates/dbx-core/src/table_import.rs b/crates/dbx-core/src/table_import.rs
index 367fe79c7a..13ff2aaf77 100644
--- a/crates/dbx-core/src/table_import.rs
+++ b/crates/dbx-core/src/table_import.rs
@@ -3550,7 +3550,11 @@ fn text_data_type(db_type: &DatabaseType) -> &'static str {
         DatabaseType::SqlServer => "NVARCHAR(MAX)",
         DatabaseType::Oracle | DatabaseType::OceanbaseOracle | DatabaseType::Dameng => "CLOB",
         DatabaseType::ClickHouse => "String",
-        DatabaseType::Hive | DatabaseType::Trino | DatabaseType::PrestoSql | DatabaseType::Databricks => "STRING",
+        DatabaseType::Hive
+        | DatabaseType::Kyuubi
+        | DatabaseType::Trino
+        | DatabaseType::PrestoSql
+        | DatabaseType::Databricks => "STRING",
         _ => "TEXT",
     }
 }
diff --git a/crates/dbx-core/src/transfer.rs b/crates/dbx-core/src/transfer.rs
index 0d0a61b812..4b2193553f 100644
--- a/crates/dbx-core/src/transfer.rs
+++ b/crates/dbx-core/src/transfer.rs
@@ -2655,7 +2655,7 @@ pub fn map_column_type(source_type: &str, _source_db: &DatabaseType, target_db:
     // Extract basic type, `bigint unsigned` -> `bigint`
     base = base.split(' ').next().unwrap_or(base).trim();
 
-    if matches!(target_db, DatabaseType::Hive | DatabaseType::Impala) {
+    if matches!(target_db, DatabaseType::Hive | DatabaseType::Kyuubi | DatabaseType::Impala) {
         return match base {
             "tinyint" => "TINYINT".into(),
             "smallint" | "int2" => "SMALLINT".into(),
@@ -2859,7 +2859,8 @@ pub fn generate_create_table_ddl(
                 line.push(' ');
                 line.push_str(&default_clause);
             }
-            if !c.is_nullable && !matches!(target_db, DatabaseType::Hive | DatabaseType::Impala) {
+            if !c.is_nullable && !matches!(target_db, DatabaseType::Hive | DatabaseType::Kyuubi | DatabaseType::Impala)
+            {
                 line.push_str(" NOT NULL");
             }
             if is_mysql_family {
@@ -2882,7 +2883,7 @@ pub fn generate_create_table_ddl(
     }
 
     let mut pks = Vec::with_capacity(columns.iter().filter(|c| c.is_primary_key).count());
-    if !matches!(target_db, DatabaseType::Hive | DatabaseType::Impala) {
+    if !matches!(target_db, DatabaseType::Hive | DatabaseType::Kyuubi | DatabaseType::Impala) {
         for c in columns {
             if c.is_primary_key {
                 let qname = quote_identifier(&c.name, target_db);
@@ -3320,7 +3321,7 @@ fn generate_upsert_typed_for_transfer(
 fn max_transfer_write_rows(db_type: &DatabaseType, mode: &TransferMode) -> usize {
     match (db_type, mode) {
         (DatabaseType::SqlServer, TransferMode::Append | TransferMode::Overwrite) => MAX_SQLSERVER_INSERT_ROWS,
-        (DatabaseType::Hive | DatabaseType::Impala, _) => 500,
+        (DatabaseType::Hive | DatabaseType::Kyuubi | DatabaseType::Impala, _) => 500,
         (DatabaseType::Oracle, TransferMode::Append | TransferMode::Overwrite) => MAX_ORACLE_INSERT_ALL_ROWS,
         (DatabaseType::Oracle, TransferMode::Upsert) => MAX_ORACLE_MERGE_ROWS,
         _ => usize::MAX,
@@ -6331,7 +6332,7 @@ where
 }
 
 #[derive(Default)]
-struct ImpalaTransferCursor {
+struct HiveServerTransferCursor {
     started: bool,
     session_id: Option<String>,
 }
@@ -6348,13 +6349,13 @@ fn transfer_cursor_sql(
     format!("SELECT {col_list} FROM {full_table}")
 }
 
-async fn fetch_impala_transfer_batch(
+async fn fetch_hive_server_transfer_batch(
     state: &AppState,
     pool_key: &str,
     request: &TransferRequest,
     sql: &str,
     batch_size: usize,
-    cursor: &mut ImpalaTransferCursor,
+    cursor: &mut HiveServerTransferCursor,
 ) -> Result<db::QueryResult, String> {
     let query_timeout_secs = if cursor.started {
         0
@@ -6400,7 +6401,7 @@ async fn fetch_impala_transfer_batch(
     Ok(result)
 }
 
-async fn close_impala_transfer_cursor(state: &AppState, pool_key: &str, cursor: &mut ImpalaTransferCursor) {
+async fn close_hive_server_transfer_cursor(state: &AppState, pool_key: &str, cursor: &mut HiveServerTransferCursor) {
     let Some(session_id) = cursor.session_id.take() else {
         return;
     };
@@ -6776,7 +6777,10 @@ where
     }
 
     let target_columns = if (request.mode == TransferMode::Upsert
-        && !matches!(target_db_type, DatabaseType::ClickHouse | DatabaseType::Hive | DatabaseType::Impala))
+        && !matches!(
+            target_db_type,
+            DatabaseType::ClickHouse | DatabaseType::Hive | DatabaseType::Kyuubi | DatabaseType::Impala
+        ))
         || matches!(target_db_type, DatabaseType::Postgres | DatabaseType::Dameng)
     {
         get_columns_for_transfer(
@@ -6796,7 +6800,10 @@ where
 
     // Determine effective mode and PK columns for upsert
     let (effective_mode, pk_columns) = if request.mode == TransferMode::Upsert {
-        if matches!(target_db_type, DatabaseType::ClickHouse | DatabaseType::Hive | DatabaseType::Impala) {
+        if matches!(
+            target_db_type,
+            DatabaseType::ClickHouse | DatabaseType::Hive | DatabaseType::Kyuubi | DatabaseType::Impala
+        ) {
             log::warn!("[transfer] upsert not supported for {:?}, falling back to append", target_db_type);
             (TransferMode::Append, vec![])
         } else {
@@ -6823,10 +6830,10 @@ where
     let batch_size = if request.batch_size == 0 { 1000 } else { request.batch_size };
     let mut offset: u64 = 0;
     let mut total_transferred: u64 = 0;
-    // A single Agent cursor keeps Impala rows in one query execution. Re-running
-    // LIMIT/OFFSET pages cannot be made stable for tables without a unique key.
-    let use_impala_cursor = matches!(source_db_type, DatabaseType::Impala);
-    let impala_transfer_sql = use_impala_cursor.then(|| {
+    // A single Agent cursor keeps Kyuubi/Impala rows in one query execution.
+    // Re-running LIMIT/OFFSET pages is unstable for tables without a unique key.
+    let use_hive_server_cursor = matches!(source_db_type, DatabaseType::Kyuubi | DatabaseType::Impala);
+    let hive_server_transfer_sql = use_hive_server_cursor.then(|| {
         transfer_cursor_sql(
             &col_names,
             table,
@@ -6835,7 +6842,7 @@ where
             request.source_catalog.as_deref(),
         )
     });
-    let mut impala_cursor = ImpalaTransferCursor::default();
+    let mut hive_server_cursor = HiveServerTransferCursor::default();
 
     let transfer_result: Result<(), String> = async {
         loop {
@@ -6843,10 +6850,17 @@ where
                 return Err("Cancelled".to_string());
             }
 
-            let (result, mysql_spatial_markers) = if let Some(sql) = impala_transfer_sql.as_deref() {
+            let (result, mysql_spatial_markers) = if let Some(sql) = hive_server_transfer_sql.as_deref() {
                 (
-                    fetch_impala_transfer_batch(state, source_pool_key, request, sql, batch_size, &mut impala_cursor)
-                        .await?,
+                    fetch_hive_server_transfer_batch(
+                        state,
+                        source_pool_key,
+                        request,
+                        sql,
+                        batch_size,
+                        &mut hive_server_cursor,
+                    )
+                    .await?,
                     false,
                 )
             } else {
@@ -6928,14 +6942,14 @@ where
                 terminal: false,
             });
 
-            if (use_impala_cursor && !has_more) || (!use_impala_cursor && row_count < batch_size) {
+            if (use_hive_server_cursor && !has_more) || (!use_hive_server_cursor && row_count < batch_size) {
                 break;
             }
         }
         Ok(())
     }
     .await;
-    close_impala_transfer_cursor(state, source_pool_key, &mut impala_cursor).await;
+    close_hive_server_transfer_cursor(state, source_pool_key, &mut hive_server_cursor).await;
     transfer_result?;
 
     if pg_compat_transfer {
@@ -9335,6 +9349,34 @@ mod tests {
         );
     }
 
+    #[test]
+    fn kyuubi_transfer_uses_spark_sql_compatible_ddl_and_batches() {
+        let cols = vec![
+            db::ColumnInfo { is_primary_key: true, is_nullable: false, ..test_column("id", "bigint") },
+            db::ColumnInfo { is_nullable: false, ..test_column("payload", "jsonb") },
+        ];
+
+        let ddl = generate_create_table_ddl(
+            &cols,
+            "events",
+            "public",
+            "warehouse",
+            &DatabaseType::Kyuubi,
+            &DatabaseType::Postgres,
+            None,
+            None,
+        );
+
+        assert!(ddl.contains("CREATE TABLE IF NOT EXISTS `warehouse`.`events`"));
+        assert!(ddl.contains("`id` BIGINT"));
+        assert!(ddl.contains("`payload` STRING"));
+        assert!(!ddl.contains("PRIMARY KEY"));
+        assert!(!ddl.contains("NOT NULL"));
+        assert_eq!(quote_identifier("user`events", &DatabaseType::Kyuubi), "`user``events`");
+        assert_eq!(max_transfer_write_rows(&DatabaseType::Kyuubi, &TransferMode::Append), 500);
+        assert_eq!(max_transfer_write_rows(&DatabaseType::Kyuubi, &TransferMode::Upsert), 500);
+    }
+
     #[test]
     fn impala_transfer_uses_impala_compatible_ddl_and_batches() {
         let cols = vec![
diff --git a/crates/dbx-core/tests/database_capabilities.rs b/crates/dbx-core/tests/database_capabilities.rs
index ed9351560d..a175e1df23 100644
--- a/crates/dbx-core/tests/database_capabilities.rs
+++ b/crates/dbx-core/tests/database_capabilities.rs
@@ -97,6 +97,7 @@ fn driver_manifest() -> DriverManifest {
 fn maps_agent_database_types_to_driver_keys() {
     assert_eq!(agent_key(&DatabaseType::Trino, None), Some("trino"));
     assert_eq!(agent_key(&DatabaseType::Hive, None), Some("hive"));
+    assert_eq!(agent_key(&DatabaseType::Kyuubi, None), Some("hive"));
     assert_eq!(agent_key(&DatabaseType::Impala, None), Some("hive"));
     assert_eq!(agent_key(&DatabaseType::Tdengine, None), Some("tdengine"));
     assert_eq!(agent_key(&DatabaseType::Iotdb, None), Some("iotdb"));
@@ -140,6 +141,7 @@ fn classifies_agent_database_types() {
     assert!(is_agent_type(&DatabaseType::Oracle));
     assert!(is_agent_type(&DatabaseType::Trino));
     assert!(is_agent_type(&DatabaseType::Hive));
+    assert!(is_agent_type(&DatabaseType::Kyuubi));
     assert!(is_agent_type(&DatabaseType::Impala));
     assert!(is_agent_type(&DatabaseType::Tdengine));
     assert!(is_agent_type(&DatabaseType::Iotdb));
@@ -373,6 +375,25 @@ fn driver_manifest_declares_expected_product_capabilities() {
     assert!(!impala.capabilities.table_import);
     assert!(!impala.capabilities.diagram);
     assert!(!impala.capabilities.user_admin);
+
+    let kyuubi = find_driver(DatabaseType::Kyuubi);
+    assert_eq!(kyuubi.label, "Apache Kyuubi");
+    assert_eq!(kyuubi.runtime_mode, "agent");
+    assert_eq!(kyuubi.agent_key.as_deref(), Some("hive"));
+    assert_eq!(kyuubi.support_level, "operate");
+    assert!(kyuubi.capabilities.query_execution);
+    assert!(kyuubi.capabilities.metadata_browse);
+    assert!(kyuubi.capabilities.object_browser);
+    assert!(kyuubi.capabilities.object_source);
+    assert!(kyuubi.capabilities.schema_search);
+    assert!(kyuubi.capabilities.sql_explain);
+    assert!(kyuubi.capabilities.data_transfer);
+    assert!(kyuubi.capabilities.sql_file_execution);
+    assert!(!kyuubi.capabilities.table_data_edit);
+    assert!(!kyuubi.capabilities.table_structure_edit);
+    assert!(!kyuubi.capabilities.table_import);
+    assert!(!kyuubi.capabilities.diagram);
+    assert!(!kyuubi.capabilities.user_admin);
 }
 
 #[test]