回答

收藏

高效地将一对多对多数据库映射到Golang中的struct

技术问答 技术问答 766 人阅读 | 0 人回复 | 2023-09-14

问题在Golang一对多或多对多的中处理SQL在关系中,将线映射到最佳结构(高效,推荐类似Go什么是方式?
. {' Q! E  V  D以下示例为例。我试图详细介绍每种方法的优缺点,但我想知道社区的建议是什么。
% n% ^/ m+ `6 z0 x$ r5 i要求适用于PostgreSQL(可以通用,但不包括MySQL / Oracle特定功能)
" J+ _# _% v+ ?8 e& ]效率-每种组合都不会被强迫
  L( l1 b) ~- k) C: Q- t没有ORM-仅在理想情况下使用database/sql和jmoiron/sqlx
例子为了明确起见,我删除了错误的处理
8 `9 d. K0 P% Y! _: ?: e) A) G楷模; O* g8 L8 H7 J) r
type Tag struct {  ID int  Name string}type Item struct {  ID int  Tags []Tag}数据库# z3 G7 y* x2 y; A! U+ Y
CREATE TABLE item (  id                      INT GENERATED BY DEFAULT AS IDENTITY PRIMARY KEY);CREATE TABLE tag (  id                      INT GENERATED BY DEFAULT AS IDENTITY PRIMARY KEY, name                    VARCHAR(160), item_id                 INT REFERENCES item(id));方法1-选择所有项目,然后为每个项目选择标签* }6 Y& D5 L9 N$ l- }( ^
var items []Itemsqlxdb.Select(&items,&quot;SELECT * FROM item&quot;)for i,item := range items {  var tags []Tag  sqlxdb.Select(&tags,&quot;SELECT * FROM tag WHERE item_id = $1&quot;,item.ID)  items<i>.Tags = tags}优点
, S3 J/ P6 ~& G简单的
6 l) b9 M: g, q容易明白
缺点2 ^' E: e: X; X- p: a2 Q" I$ f
数据库查询数量与项目数量成正比方法2-构造SQL连接并手动遍历行
; E4 H7 P5 i/ @var itemTags = make(map[int][]Tag)var items = []Item{}rows,_ := sqlxdb.Queryx(&quot;SELECT i.id,t.id,t.name FROM item AS i JOIN tag AS t ON t.item_id = i.id&quot;)for rows.Next() {  var  itemID  int    tagID   int    tagName string  )  rows.Scan(&itemID,&tagID,&tagName)  if tags,ok := itemTags[itemID]; ok    itemTags[itemID] = append(tags,Tag{ID: tagID,Name: tagName,})  } else    itemTags[itemID] = []Tag{Tag{ID: tagID,Name: tagName,}}  }}for itemID,tags := range itemTags {  items = append(Item{    ID: itemID,   Tags: tags, })}优点/ J- s. F: _7 f$ N" o. o
单个数据库调用和游标可以在不占用太多内存的情况下循环缺点
3 q3 Y+ x: z0 Z" r* m9 U- b/ h. F复杂且难以开发多个连接和结构的许多属性  r! Y3 F$ j; i' C
性能不好;更多的内存使用和处理时间,而不是更多的网络调用
失败的方法3-SQLX结构扫描& D* u+ c  G5 f6 ~: Y/ f8 G
虽然失败了,但我还是想包括这个方法,因为我发现它是我目前效率和发展简单性相结合的目标。我的希望是通过db标签设置在每个结构字段上sqlx可以扫描一些高级结构
1 D  M8 S- k9 q$ y7 `+ {8 }9 lvar items []Itemsqlxdb.Select(&items,&quot;SELECT i.id AS item_id,t.id AS tag_id,t.name AS tag_name FROM item AS i JOIN tag AS t ON t.item_id = i.id&quot;)不幸的是,这个错误使得missing destination name tag_id in*[]Item我相信消息StructScan还不够先进,不能递归历行(无可奉告-这是一个复杂的场景)
$ E$ o, Y1 D4 x: e可能的方法4-PostgreSQL数组聚合器和GROUP BY# D$ J; q% n! ^) O3 U5 w6 `- e
尽管我相信这将 不会    工作,我已经包含了这个未经测试的选项,看看它是否可以改进 可    工作。
2 m9 z, v; j2 V9 a' Svar items = []Item{}sqlxdb.Select(&items,&quot;SELECT i.id as item_id,array_agg(t.*) as tags FROM item AS i JOIN tag AS t ON t.item_id = i.id GROUP BY i.id&quot;)有时间的时候,我会试着在这里做一些实验。. Y  h4 H4 A, |
                                                                + x# A# r$ B1 l7 f  m7 O- s
    解决方案:                                                                : @- J( d: D( Q/ A: a4 ?
                                                                postgres中的sql:. y# j5 Z7 ]2 ~$ w7 d; o
create schema temp;set search_path = temp;create table item(  id INT generated by default as identity primary key);create table tag(  id      INT generated by default as identity primary key, name    VARCHAR(160), item_id INT references item (id));create view item_tags asselect id, (         select            array_to_json(array_agg(row_to_json(taglist.*))) as array_to_json          from (               select tag.name,tag.id                 from tag                         where item_id = item.id               ) taglist ) as tagsfrom item ;-- golang query this maybe select  row_to_json(row)from (    select * from item_tags) row;然后golang查询这个SQL:. r+ `) {/ _8 W, R
select  row_to_json(row)from  select * from item_tags) row;并解组结构:
6 Z$ u4 o1 ~8 D4 m+ \优点:
4 O. W# Z0 i$ g1 W" Q9 U[ol]postgres管理数据关系sql函数添加/更新数据。
) p7 c+ R0 c' v, x# n" jgolang管理业务模型和逻辑。
0 f# |5 _- t$ E[/ol]这是一个简单的方法。
6 H3 q) ?0 ?+ f* ^1 G0 Y* U1 U
分享到:
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则