戰(zhàn)指南：Aggregate、GroupBy 與自定義 SQL 修飾符)
Ent 聚合查詢實(shí)戰(zhàn)指南Aggregate、GroupBy 與自定義 SQL 修飾符【免費(fèi)下載鏈接】entAn entity framework for Go項(xiàng)目地址: https://gitcode.com/gh_mirrors/en/ent本指南基于 ent 框架的官方文檔 aggregate.md系統(tǒng)講解在 ent 查詢構(gòu)建器中使用Aggregate聚合函數(shù)、GroupBy分組、跨邊分組Group By Edge以及Modify自定義 SQL 修飾符Having Group By的完整實(shí)戰(zhàn)方法。讀完本文你將掌握如何用類型安全的 Go 代碼替代手寫 SQL 完成 SUM、MIN、MAX、COUNT、AVG 等統(tǒng)計(jì)查詢并能深入自定義 SQL 層實(shí)現(xiàn)存儲(chǔ)特定的分組聚合邏輯。概述從查詢構(gòu)建器到 SQL 聚合ent 的查詢 API 在client.T.Query()返回的類型安全查詢構(gòu)建器之上提供了三個(gè)與聚合相關(guān)的擴(kuò)展點(diǎn)Aggregate(fns ...AggregateFunc)向查詢追加一個(gè)或多個(gè)聚合函數(shù)列例如ent.Sum、ent.Min、ent.Max、ent.Count、ent.AvgGroupBy(field string, fields ...string)按一個(gè)或多個(gè)字段對(duì)結(jié)果分組返回GroupBy構(gòu)建器可與Aggregate組合使用Modify(modifiers ...func(s *sql.Selector))在 SQL 層對(duì)查詢進(jìn)行任意修改例如追加GROUP BY ... HAVING ...子句或通過(guò)sql.Selector手動(dòng)Join其他表。這些方法由 ent 代碼生成器entc寫入每個(gè)實(shí)體的查詢構(gòu)建器中模板定義位于 entc/gen/template/builder/query.tmpl。聚合函數(shù)的實(shí)際 SQL 拼接則交由 dialect/sql/builder.go 中的構(gòu)建器完成。Aggregate單字段與多字段聚合Aggregate選項(xiàng)允許在一條查詢中添加一個(gè)或多個(gè)聚合函數(shù)。其簽名由 entc/gen/template/base.tmpl 生成為func Aggregate(fns ...AggregateFunc) *TSelect單個(gè)聚合字段對(duì)Payment實(shí)體的amount字段求和并直接以int形式取出結(jié)果package main import ( context project/ent project/ent/payment project/ent/pet ) func Do(ctx context.Context, client *ent.Client) { // Aggregate one field. sum, err : client.Payment.Query(). Aggregate( ent.Sum(payment.Amount), ). Int(ctx) }Int(ctx)是聚合查詢的便捷終結(jié)方法當(dāng)只聚合一個(gè)字段時(shí)它把第一行第一列的結(jié)果掃描為int并返回。多個(gè)聚合字段同時(shí)聚合多個(gè)字段時(shí)需要把結(jié)果掃描到結(jié)構(gòu)體切片中。Sum、Min、Max、Count可任意組合輸出列的默認(rèn)命名與聚合函數(shù)同名package main import ( context project/ent project/ent/pet ) func Do(ctx context.Context, client *ent.Client) { // Aggregate multiple fields. var v []struct { Sum, Min, Max, Count int } err : client.Pet.Query(). Aggregate( ent.Sum(pet.FieldAge), ent.Min(pet.FieldAge), ent.Max(pet.FieldAge), ent.Count(), ). Scan(ctx, v) }這里的Scan(ctx, v)會(huì)把結(jié)果集的每一行映射到結(jié)構(gòu)體字段上字段名與聚合函數(shù)名一一對(duì)應(yīng)Sum、Min、Max、Count。聚合函數(shù)的生成與實(shí)現(xiàn)ent.Sum等函數(shù)由代碼生成器按aggregate配置逐一生成定義在 entc/gen/template/base.tmpl// Sum applies the sum aggregation function on the given field of each group. func Sum(field string) AggregateFunc { return func(s *sql.Selector) string { if err : checkColumn(s.TableName(), field); err ! nil { s.AddError(ValidationError{Name: field, err: fmt.Errorf(package: %w, err)}) return } return sql.Sum(s.C(field)) } }關(guān)鍵點(diǎn)在于 entc/gen/template/dialect/sql/by.tmpl 中的實(shí)現(xiàn)細(xì)節(jié)AggregateFunc的真實(shí)類型是func(*sql.Selector) string即“接收 SQL 選擇器、返回一段 SQL 表達(dá)式字符串”的函數(shù)Count()不帶字段參數(shù)內(nèi)部生成COUNT(*)Mean均值在 SQL 層被映射為AVG每個(gè)帶字段的聚合函數(shù)都會(huì)先調(diào)用checkColumn校驗(yàn)字段是否真實(shí)存在于對(duì)應(yīng)表中見(jiàn) entc/gen/template/dialect/sql/by.tmpl。而sql.Sum、sql.Count、sql.Min、sql.Max、sql.Avg的底層實(shí)現(xiàn)位于 dialect/sql/builder.go它們統(tǒng)一通過(guò)Func構(gòu)建器把標(biāo)識(shí)符包裝為SUM(x)、COUNT(x)、MIN(x)、MAX(x)、AVG(x)形式的 SQL 片段例如// Sum wraps the ident with the SUM aggregation function. func Sum(ident string) string { f : Func{} f.Sum(ident) return f.String() }byName負(fù)責(zé)拼接函數(shù)名與括號(hào)包裹的列名dialect/sql/builder.go。Group By按字段分組統(tǒng)計(jì)GroupBy讓查詢按一個(gè)或多個(gè)字段分組再配合Aggregate計(jì)算每組的統(tǒng)計(jì)值。按多個(gè)字段分組并聚合按所有用戶的name和age分組并統(tǒng)計(jì)每組的年齡總和與用戶數(shù)package main import ( context project/ent project/ent/user ) func Do(ctx context.Context, client *ent.Client) { var v []struct { Name string json:name Age int json:age Sum int json:sum Count int json:count } err : client.User.Query(). GroupBy(user.FieldName, user.FieldAge). Aggregate(ent.Count(), ent.Sum(user.FieldAge)). Scan(ctx, v) }這里GroupBy(user.FieldName, user.FieldAge)生成GROUP BY name, ageAggregate(ent.Count(), ent.Sum(user.FieldAge))追加COUNT(*)與SUM(age)兩列。結(jié)果通過(guò)結(jié)構(gòu)體的json標(biāo)簽按列名掃描。按單個(gè)字段分組并取列值如果只想拿到分組后的某一列去重后的值列表可以省略Aggregate直接使用Strings(ctx)等便捷方法package main import ( context project/ent project/ent/user ) func Do(ctx context.Context, client *ent.Client) { names, err : client.User. Query(). GroupBy(user.FieldName). Strings(ctx) }Strings(ctx)會(huì)把GROUP BY name結(jié)果的第一列掃描為[]string。同理還有Ints(ctx)、Int64s(ctx)、IDs(ctx)等系列方法適用于“取一列”的常見(jiàn)場(chǎng)景。GroupBy 的底層執(zhí)行流程GroupBy生成器最終通過(guò)sqlScan執(zhí)行其實(shí)現(xiàn)見(jiàn) entc/gen/template/dialect/sql/group.tmpl流程如下基于根查詢創(chuàng)建sql.Selector依次執(zhí)行每個(gè)AggregateFunc收集聚合表達(dá)式字符串若未顯式選擇列則默認(rèn)選擇“分組字段列 聚合函數(shù)列”調(diào)用selector.GroupBy(...)生成GROUP BY子句通過(guò) driver 執(zhí)行查詢并用sql.ScanSlice掃描結(jié)果。因此GroupBy(f1, f2).Aggregate(...)最終等價(jià)于SELECT f1, f2, COUNT(*), SUM(f2) FROM table GROUP BY f1, f2Group By Edge跨邊的自定義聚合當(dāng)聚合目標(biāo)不在當(dāng)前實(shí)體而在其關(guān)聯(lián)實(shí)體邊上時(shí)需要寫存儲(chǔ)特定的自定義聚合函數(shù)。下面的例子按用戶的id與name分組并計(jì)算每個(gè)用戶所有寵物的平均年齡package main import ( context log project/ent project/ent/pet project/ent/user entgo.io/ent/dialect/sql ) func Do(ctx context.Context, client *ent.Client) { var users []struct { ID int Name string Average float64 } err : client.User.Query(). GroupBy(user.FieldID, user.FieldName). Aggregate(func(s *sql.Selector) string { t : sql.Table(pet.Table) s.Join(t).On(s.C(user.FieldID), t.C(pet.OwnerColumn)) return sql.As(sql.Avg(t.C(pet.FieldAge)), average) }). Scan(ctx, users) }這段代碼的關(guān)鍵動(dòng)作sql.Table(pet.Table)取得 pets 表的引用dialect/sql/builder.gos.Join(t).On(...)把 pets 表 JOIN 到當(dāng)前查詢連接條件為user.id pet.owner_idsql.Avg(t.C(pet.FieldAge))計(jì)算寵物年齡均值sql.As(expr, average)為該表達(dá)式起別名dialect/sql/builder.go別名average與結(jié)果結(jié)構(gòu)體的Average字段對(duì)應(yīng)由于AggregateFunc可以訪問(wèn)并修改*sql.Selector因此可以在聚合的同時(shí)擴(kuò)展查詢本身此處即 JOIN這正是“自定義聚合函數(shù)適合寫存儲(chǔ)特定邏輯”的原因。生成的 SQL 大致為SELECT users.id, users.name, AVG(pets.age) AS average FROM users JOIN pets ON users.id pets.owner_id GROUP BY users.id, users.name提示As本身也是一個(gè)公開(kāi)的“偽聚合函數(shù)”見(jiàn) entc/gen/template/base.tmpl可用ent.As(ent.Sum(f1), sum_field1)這類形式對(duì)內(nèi)置聚合結(jié)果重命名。Having Group By自定義 SQL 修飾符如果你需要控制查詢的所有部分例如添加HAVING過(guò)濾可以借助Modify直接操作sql.Selector。下面的例子查詢每個(gè)角色role中年齡最大的用戶package main import ( context log entgo.io/ent/dialect/sql project/ent project/ent/user ) func Do(ctx context.Context, client *ent.Client) { var users []struct { Id int Age int Role string } err : client.User.Query(). Modify(func(s *sql.Selector) { s.GroupBy(user.Role) s.Having( sql.EQ( user.FieldAge, sql.Raw(sql.Max(user.FieldAge)), ), ) }). ScanX(ctx, users) }Modify方法由 SQL dialect 模板生成entc/gen/template/dialect/sql/feature/modifier.tmpl其語(yǔ)義是“為查詢附加自定義邏輯”接收f(shuō)unc(s *sql.Selector)類型的修飾符列表。這里做了三件事s.GroupBy(user.Role)按角色分組s.Having(...)追加HAVING子句sql.EQ(user.FieldAge, sql.Raw(sql.Max(user.FieldAge)))限定“本行年齡等于該組最大年齡”。注意sql.Raw至關(guān)重要。它告訴謂詞構(gòu)建器sql.Max(user.FieldAge)是一段原始 SQL 表達(dá)式而非綁定參數(shù)值。sql.Raw的實(shí)現(xiàn)位于 dialect/sql/builder.go其Query()直接返回原始字符串且不帶任何參數(shù)若不加sql.RawMAX(user.age)會(huì)被當(dāng)作參數(shù)值處理HAVING條件就會(huì)失真。另外ScanX(ctx, v)與Scan行為一致但出錯(cuò)時(shí)直接 panic見(jiàn) entc/gen/template/base.tmpl適合在錯(cuò)誤無(wú)需優(yōu)雅處理的場(chǎng)景下簡(jiǎn)化代碼。上面的代碼本質(zhì)上生成的 SQL 查詢?yōu)镾ELECT * FROM user GROUP BY user.role HAVING user.age MAX(user.age)小結(jié)與進(jìn)階指引ent 的聚合能力形成了一個(gè)從“類型安全 API”到“裸 SQL”的完整梯度需求推薦 API示例單字段統(tǒng)計(jì)Aggregate 便捷終結(jié)方法Aggregate(ent.Sum(f)).Int(ctx)多字段統(tǒng)計(jì)AggregateScanAggregate(ent.Sum(f), ent.Min(f), ...)分組統(tǒng)計(jì)GroupByAggregateGroupBy(f1, f2).Aggregate(ent.Count(), ...)取分組列值GroupByStrings/Ints/...GroupBy(f).Strings(ctx)跨邊聚合自定義AggregateFuncsql.SelectorJOIN 關(guān)聯(lián)表后sql.Avgsql.As完全自定義Modifysql.SelectorGroupByHavingsql.Raw繼續(xù)深入可以參考倉(cāng)庫(kù)中的相關(guān)資源聚合函數(shù)與AggregateFunc的生成模板e(cuò)ntc/gen/template/base.tmpl、entc/gen/template/dialect/sql/by.tmplGroupBy/Aggregate/Scan構(gòu)建器定義entc/gen/template/builder/query.tmplGroupBy 執(zhí)行與列組裝邏輯entc/gen/template/dialect/sql/group.tmplSQL 層聚合函數(shù)與As、Raw、EQ實(shí)現(xiàn)dialect/sql/builder.go、dialect/sql/builder.goModify方法模板e(cuò)ntc/gen/template/dialect/sql/feature/modifier.tmpl。需要說(shuō)明的是上述示例中的project/ent等導(dǎo)入路徑需替換為你的項(xiàng)目實(shí)際生成的 ent 包路徑聚合與分組 API 面向 SQL 方言MySQL、PostgreSQL、SQLite 等生成Gremlin 方言下的實(shí)現(xiàn)與簽名略有不同見(jiàn) entc/gen/template/dialect/gremlin/by.tmpl使用前請(qǐng)確認(rèn)你的存儲(chǔ)類型。【免費(fèi)下載鏈接】entAn entity framework for Go項(xiàng)目地址: https://gitcode.com/gh_mirrors/en/ent創(chuàng)作聲明：本文部分內(nèi)容由AI輔助生成（AIGC），僅供參考 Ent 聚合查詢實(shí)戰(zhàn)指南：Aggregate、GroupBy 與自定義 SQL 修飾符
Ent 聚合查詢實(shí)戰(zhàn)指南Aggregate、GroupBy 與自定義 SQL 修飾符【免費(fèi)下載鏈接】entAn entity framework for Go項(xiàng)目地址: https://gitcode.com/gh_mirrors/en/ent本指南基于 ent 框架的官方文檔 aggregate.md系統(tǒng)講解在 ent 查詢構(gòu)建器中使用Aggregate聚合函數(shù)、GroupBy分組、跨邊分組Group By Edge以及Modify自定義 SQL 修飾符Having Group By的完整實(shí)戰(zhàn)方法。讀完本文你將掌握如何用類型安全的 Go 代碼替代手寫 SQL 完成 SUM、MIN、MAX、COUNT、AVG 等統(tǒng)計(jì)查詢并能深入自定義 SQL 層實(shí)現(xiàn)存儲(chǔ)特定的分組聚合邏輯。概述從查詢構(gòu)建器到 SQL 聚合ent 的查詢 API 在client.T.Query()返回的類型安全查詢構(gòu)建器之上提供了三個(gè)與聚合相關(guān)的擴(kuò)展點(diǎn)Aggregate(fns ...AggregateFunc)向查詢追加一個(gè)或多個(gè)聚合函數(shù)列例如ent.Sum、ent.Min、ent.Max、ent.Count、ent.AvgGroupBy(field string, fields ...string)按一個(gè)或多個(gè)字段對(duì)結(jié)果分組返回GroupBy構(gòu)建器可與Aggregate組合使用Modify(modifiers ...func(s *sql.Selector))在 SQL 層對(duì)查詢進(jìn)行任意修改例如追加GROUP BY ... HAVING ...子句或通過(guò)sql.Selector手動(dòng)Join其他表。這些方法由 ent 代碼生成器entc寫入每個(gè)實(shí)體的查詢構(gòu)建器中模板定義位于 entc/gen/template/builder/query.tmpl。聚合函數(shù)的實(shí)際 SQL 拼接則交由 dialect/sql/builder.go 中的構(gòu)建器完成。Aggregate單字段與多字段聚合Aggregate選項(xiàng)允許在一條查詢中添加一個(gè)或多個(gè)聚合函數(shù)。其簽名由 entc/gen/template/base.tmpl 生成為func Aggregate(fns ...AggregateFunc) *TSelect單個(gè)聚合字段對(duì)Payment實(shí)體的amount字段求和并直接以int形式取出結(jié)果package main import ( context project/ent project/ent/payment project/ent/pet ) func Do(ctx context.Context, client *ent.Client) { // Aggregate one field. sum, err : client.Payment.Query(). Aggregate( ent.Sum(payment.Amount), ). Int(ctx) }Int(ctx)是聚合查詢的便捷終結(jié)方法當(dāng)只聚合一個(gè)字段時(shí)它把第一行第一列的結(jié)果掃描為int并返回。多個(gè)聚合字段同時(shí)聚合多個(gè)字段時(shí)需要把結(jié)果掃描到結(jié)構(gòu)體切片中。Sum、Min、Max、Count可任意組合輸出列的默認(rèn)命名與聚合函數(shù)同名package main import ( context project/ent project/ent/pet ) func Do(ctx context.Context, client *ent.Client) { // Aggregate multiple fields. var v []struct { Sum, Min, Max, Count int } err : client.Pet.Query(). Aggregate( ent.Sum(pet.FieldAge), ent.Min(pet.FieldAge), ent.Max(pet.FieldAge), ent.Count(), ). Scan(ctx, v) }這里的Scan(ctx, v)會(huì)把結(jié)果集的每一行映射到結(jié)構(gòu)體字段上字段名與聚合函數(shù)名一一對(duì)應(yīng)Sum、Min、Max、Count。聚合函數(shù)的生成與實(shí)現(xiàn)ent.Sum等函數(shù)由代碼生成器按aggregate配置逐一生成定義在 entc/gen/template/base.tmpl// Sum applies the sum aggregation function on the given field of each group. func Sum(field string) AggregateFunc { return func(s *sql.Selector) string { if err : checkColumn(s.TableName(), field); err ! nil { s.AddError(ValidationError{Name: field, err: fmt.Errorf(package: %w, err)}) return } return sql.Sum(s.C(field)) } }關(guān)鍵點(diǎn)在于 entc/gen/template/dialect/sql/by.tmpl 中的實(shí)現(xiàn)細(xì)節(jié)AggregateFunc的真實(shí)類型是func(*sql.Selector) string即“接收 SQL 選擇器、返回一段 SQL 表達(dá)式字符串”的函數(shù)Count()不帶字段參數(shù)內(nèi)部生成COUNT(*)Mean均值在 SQL 層被映射為AVG每個(gè)帶字段的聚合函數(shù)都會(huì)先調(diào)用checkColumn校驗(yàn)字段是否真實(shí)存在于對(duì)應(yīng)表中見(jiàn) entc/gen/template/dialect/sql/by.tmpl。而sql.Sum、sql.Count、sql.Min、sql.Max、sql.Avg的底層實(shí)現(xiàn)位于 dialect/sql/builder.go它們統(tǒng)一通過(guò)Func構(gòu)建器把標(biāo)識(shí)符包裝為SUM(x)、COUNT(x)、MIN(x)、MAX(x)、AVG(x)形式的 SQL 片段例如// Sum wraps the ident with the SUM aggregation function. func Sum(ident string) string { f : Func{} f.Sum(ident) return f.String() }byName負(fù)責(zé)拼接函數(shù)名與括號(hào)包裹的列名dialect/sql/builder.go。Group By按字段分組統(tǒng)計(jì)GroupBy讓查詢按一個(gè)或多個(gè)字段分組再配合Aggregate計(jì)算每組的統(tǒng)計(jì)值。按多個(gè)字段分組并聚合按所有用戶的name和age分組并統(tǒng)計(jì)每組的年齡總和與用戶數(shù)package main import ( context project/ent project/ent/user ) func Do(ctx context.Context, client *ent.Client) { var v []struct { Name string json:name Age int json:age Sum int json:sum Count int json:count } err : client.User.Query(). GroupBy(user.FieldName, user.FieldAge). Aggregate(ent.Count(), ent.Sum(user.FieldAge)). Scan(ctx, v) }這里GroupBy(user.FieldName, user.FieldAge)生成GROUP BY name, ageAggregate(ent.Count(), ent.Sum(user.FieldAge))追加COUNT(*)與SUM(age)兩列。結(jié)果通過(guò)結(jié)構(gòu)體的json標(biāo)簽按列名掃描。按單個(gè)字段分組并取列值如果只想拿到分組后的某一列去重后的值列表可以省略Aggregate直接使用Strings(ctx)等便捷方法package main import ( context project/ent project/ent/user ) func Do(ctx context.Context, client *ent.Client) { names, err : client.User. Query(). GroupBy(user.FieldName). Strings(ctx) }Strings(ctx)會(huì)把GROUP BY name結(jié)果的第一列掃描為[]string。同理還有Ints(ctx)、Int64s(ctx)、IDs(ctx)等系列方法適用于“取一列”的常見(jiàn)場(chǎng)景。GroupBy 的底層執(zhí)行流程GroupBy生成器最終通過(guò)sqlScan執(zhí)行其實(shí)現(xiàn)見(jiàn) entc/gen/template/dialect/sql/group.tmpl流程如下基于根查詢創(chuàng)建sql.Selector依次執(zhí)行每個(gè)AggregateFunc收集聚合表達(dá)式字符串若未顯式選擇列則默認(rèn)選擇“分組字段列 聚合函數(shù)列”調(diào)用selector.GroupBy(...)生成GROUP BY子句通過(guò) driver 執(zhí)行查詢并用sql.ScanSlice掃描結(jié)果。因此GroupBy(f1, f2).Aggregate(...)最終等價(jià)于SELECT f1, f2, COUNT(*), SUM(f2) FROM table GROUP BY f1, f2Group By Edge跨邊的自定義聚合當(dāng)聚合目標(biāo)不在當(dāng)前實(shí)體而在其關(guān)聯(lián)實(shí)體邊上時(shí)需要寫存儲(chǔ)特定的自定義聚合函數(shù)。下面的例子按用戶的id與name分組并計(jì)算每個(gè)用戶所有寵物的平均年齡package main import ( context log project/ent project/ent/pet project/ent/user entgo.io/ent/dialect/sql ) func Do(ctx context.Context, client *ent.Client) { var users []struct { ID int Name string Average float64 } err : client.User.Query(). GroupBy(user.FieldID, user.FieldName). Aggregate(func(s *sql.Selector) string { t : sql.Table(pet.Table) s.Join(t).On(s.C(user.FieldID), t.C(pet.OwnerColumn)) return sql.As(sql.Avg(t.C(pet.FieldAge)), average) }). Scan(ctx, users) }這段代碼的關(guān)鍵動(dòng)作sql.Table(pet.Table)取得 pets 表的引用dialect/sql/builder.gos.Join(t).On(...)把 pets 表 JOIN 到當(dāng)前查詢連接條件為user.id pet.owner_idsql.Avg(t.C(pet.FieldAge))計(jì)算寵物年齡均值sql.As(expr, average)為該表達(dá)式起別名dialect/sql/builder.go別名average與結(jié)果結(jié)構(gòu)體的Average字段對(duì)應(yīng)由于AggregateFunc可以訪問(wèn)并修改*sql.Selector因此可以在聚合的同時(shí)擴(kuò)展查詢本身此處即 JOIN這正是“自定義聚合函數(shù)適合寫存儲(chǔ)特定邏輯”的原因。生成的 SQL 大致為SELECT users.id, users.name, AVG(pets.age) AS average FROM users JOIN pets ON users.id pets.owner_id GROUP BY users.id, users.name提示As本身也是一個(gè)公開(kāi)的“偽聚合函數(shù)”見(jiàn) entc/gen/template/base.tmpl可用ent.As(ent.Sum(f1), sum_field1)這類形式對(duì)內(nèi)置聚合結(jié)果重命名。Having Group By自定義 SQL 修飾符如果你需要控制查詢的所有部分例如添加HAVING過(guò)濾可以借助Modify直接操作sql.Selector。下面的例子查詢每個(gè)角色role中年齡最大的用戶package main import ( context log entgo.io/ent/dialect/sql project/ent project/ent/user ) func Do(ctx context.Context, client *ent.Client) { var users []struct { Id int Age int Role string } err : client.User.Query(). Modify(func(s *sql.Selector) { s.GroupBy(user.Role) s.Having( sql.EQ( user.FieldAge, sql.Raw(sql.Max(user.FieldAge)), ), ) }). ScanX(ctx, users) }Modify方法由 SQL dialect 模板生成entc/gen/template/dialect/sql/feature/modifier.tmpl其語(yǔ)義是“為查詢附加自定義邏輯”接收f(shuō)unc(s *sql.Selector)類型的修飾符列表。這里做了三件事s.GroupBy(user.Role)按角色分組s.Having(...)追加HAVING子句sql.EQ(user.FieldAge, sql.Raw(sql.Max(user.FieldAge)))限定“本行年齡等于該組最大年齡”。注意sql.Raw至關(guān)重要。它告訴謂詞構(gòu)建器sql.Max(user.FieldAge)是一段原始 SQL 表達(dá)式而非綁定參數(shù)值。sql.Raw的實(shí)現(xiàn)位于 dialect/sql/builder.go其Query()直接返回原始字符串且不帶任何參數(shù)若不加sql.RawMAX(user.age)會(huì)被當(dāng)作參數(shù)值處理HAVING條件就會(huì)失真。另外ScanX(ctx, v)與Scan行為一致但出錯(cuò)時(shí)直接 panic見(jiàn) entc/gen/template/base.tmpl適合在錯(cuò)誤無(wú)需優(yōu)雅處理的場(chǎng)景下簡(jiǎn)化代碼。上面的代碼本質(zhì)上生成的 SQL 查詢?yōu)镾ELECT * FROM user GROUP BY user.role HAVING user.age MAX(user.age)小結(jié)與進(jìn)階指引ent 的聚合能力形成了一個(gè)從“類型安全 API”到“裸 SQL”的完整梯度需求推薦 API示例單字段統(tǒng)計(jì)Aggregate 便捷終結(jié)方法Aggregate(ent.Sum(f)).Int(ctx)多字段統(tǒng)計(jì)AggregateScanAggregate(ent.Sum(f), ent.Min(f), ...)分組統(tǒng)計(jì)GroupByAggregateGroupBy(f1, f2).Aggregate(ent.Count(), ...)取分組列值GroupByStrings/Ints/...GroupBy(f).Strings(ctx)跨邊聚合自定義AggregateFuncsql.SelectorJOIN 關(guān)聯(lián)表后sql.Avgsql.As完全自定義Modifysql.SelectorGroupByHavingsql.Raw繼續(xù)深入可以參考倉(cāng)庫(kù)中的相關(guān)資源聚合函數(shù)與AggregateFunc的生成模板e(cuò)ntc/gen/template/base.tmpl、entc/gen/template/dialect/sql/by.tmplGroupBy/Aggregate/Scan構(gòu)建器定義entc/gen/template/builder/query.tmplGroupBy 執(zhí)行與列組裝邏輯entc/gen/template/dialect/sql/group.tmplSQL 層聚合函數(shù)與As、Raw、EQ實(shí)現(xiàn)dialect/sql/builder.go、dialect/sql/builder.goModify方法模板e(cuò)ntc/gen/template/dialect/sql/feature/modifier.tmpl。需要說(shuō)明的是上述示例中的project/ent等導(dǎo)入路徑需替換為你的項(xiàng)目實(shí)際生成的 ent 包路徑聚合與分組 API 面向 SQL 方言MySQL、PostgreSQL、SQLite 等生成Gremlin 方言下的實(shí)現(xiàn)與簽名略有不同見(jiàn) entc/gen/template/dialect/gremlin/by.tmpl使用前請(qǐng)確認(rèn)你的存儲(chǔ)類型。【免費(fèi)下載鏈接】entAn entity framework for Go項(xiàng)目地址: https://gitcode.com/gh_mirrors/en/ent創(chuàng)作聲明：本文部分內(nèi)容由AI輔助生成（AIGC），僅供參考