From 52b268c05c80b71c6c37fd794cc50b63d5f68f7d Mon Sep 17 00:00:00 2001 From: Ariel Mashraki Date: Wed, 28 Aug 2019 11:21:45 -0700 Subject: [PATCH] ent/doc: crud api Reviewed By: alexsn Differential Revision: D17094376 fbshipit-source-id: 9b1da24b99bb3ff15382b3a17516904decbca322 --- dialect/gremlin/driver.go | 2 +- doc/md/code-gen.md | 10 +++ doc/md/crud.md | 103 ++++++++++++++++++++++- doc/md/predicates.md | 2 +- doc/website/sidebars.json | 2 +- doc/website/siteConfig.js | 1 - entc/gen/bindata.go | 4 +- entc/gen/storage.go | 2 +- entc/integration/ent/card_create.go | 2 +- entc/integration/ent/card_delete.go | 2 +- entc/integration/ent/card_query.go | 14 +-- entc/integration/ent/card_update.go | 4 +- entc/integration/ent/client.go | 48 +++++------ entc/integration/ent/comment_create.go | 2 +- entc/integration/ent/comment_delete.go | 2 +- entc/integration/ent/comment_query.go | 12 +-- entc/integration/ent/comment_update.go | 4 +- entc/integration/ent/fieldtype_create.go | 2 +- entc/integration/ent/fieldtype_delete.go | 2 +- entc/integration/ent/fieldtype_query.go | 12 +-- entc/integration/ent/fieldtype_update.go | 4 +- entc/integration/ent/file_create.go | 2 +- entc/integration/ent/file_delete.go | 2 +- entc/integration/ent/file_query.go | 16 ++-- entc/integration/ent/file_update.go | 4 +- entc/integration/ent/filetype_create.go | 2 +- entc/integration/ent/filetype_delete.go | 2 +- entc/integration/ent/filetype_query.go | 14 +-- entc/integration/ent/filetype_update.go | 4 +- entc/integration/ent/group_create.go | 2 +- entc/integration/ent/group_delete.go | 2 +- entc/integration/ent/group_query.go | 20 ++--- entc/integration/ent/group_update.go | 4 +- entc/integration/ent/groupinfo_create.go | 2 +- entc/integration/ent/groupinfo_delete.go | 2 +- entc/integration/ent/groupinfo_query.go | 14 +-- entc/integration/ent/groupinfo_update.go | 4 +- entc/integration/ent/node_create.go | 2 +- entc/integration/ent/node_delete.go | 2 +- entc/integration/ent/node_query.go | 16 ++-- entc/integration/ent/node_update.go | 4 +- entc/integration/ent/pet_create.go | 2 +- entc/integration/ent/pet_delete.go | 2 +- entc/integration/ent/pet_query.go | 16 ++-- entc/integration/ent/pet_update.go | 4 +- entc/integration/ent/user_create.go | 2 +- entc/integration/ent/user_delete.go | 2 +- entc/integration/ent/user_query.go | 34 ++++---- entc/integration/ent/user_update.go | 4 +- 49 files changed, 266 insertions(+), 156 deletions(-) diff --git a/dialect/gremlin/driver.go b/dialect/gremlin/driver.go index 904ec54ed..54fa1e8cf 100644 --- a/dialect/gremlin/driver.go +++ b/dialect/gremlin/driver.go @@ -24,7 +24,7 @@ func NewDriver(c *Client) *Driver { } // Dialect implements the dialect.Dialect method. -func (Driver) Dialect() string { return dialect.Neptune } +func (Driver) Dialect() string { return dialect.Gremlin } // Exec implements the dialect.Exec method. func (c *Driver) Exec(ctx context.Context, query string, args, v interface{}) error { diff --git a/doc/md/code-gen.md b/doc/md/code-gen.md index 9cfe96a60..d9c427ec7 100755 --- a/doc/md/code-gen.md +++ b/doc/md/code-gen.md @@ -39,6 +39,16 @@ You should note, that `goimports` is required for the codegen, and it can be ins go get -u golang.org/x/tools/cmd/goimports ``` +The `generate` command generates the following assets for the schemas: + +- `Client` and `Tx` objects used for interacting with the graph. +- CRUD builders for each schema type. See [CRUD](crud.md) for more info. +- Entity object (Go struct) for each of the schema type. +- Package contains constants and predicates used for interacting with the builders. +- A `migrate` package, for SQL dialects. See [Migration](migrate.md) for more info. + +## Code Generation Options + For more info about codegen options, run `entc generate -h`: ```console diff --git a/doc/md/crud.md b/doc/md/crud.md index b00775d9b..0fa1c762c 100755 --- a/doc/md/crud.md +++ b/doc/md/crud.md @@ -2,4 +2,105 @@ id: crud title: CRUD API --- -Lorem ipsum. + +As mentioned in the [introduction](code-gen.md) section, running `entc` on the schemas, +will generate the following assets: + +- `Client` and `Tx` objects used for interacting with the graph. +- CRUD builders for each schema type. See [CRUD](crud.md) for more info. +- Entity object (Go struct) for each of the schema type. +- Package contains constants and predicates used for interacting with the builders. +- A `migrate` package, for SQL dialects. See [Migration](migrate.md) for more info. + +## Create A New Client + +**MySQL** + +```go +package main + +import ( + "log" + + "/ent" + + _ "github.com/go-sql-driver/mysql" + "github.com/facebookincubator/ent/dialect/sql" +) + +func main() { + drv, err := sql.Open("mysql", ":@tcp(:)/?parseTime=True") + if err != nil { + log.Fatal(err) + } + defer drv.Close() + client := ent.NewClient(ent.Driver(drv)) +} +``` + +**SQLite** + +```go +package main + +import ( + "log" + + "/ent" + + _ "github.com/mattn/go-sqlite3" + "github.com/facebookincubator/ent/dialect/sql" +) + +func main() { + drv, err := sql.Open("sqlite3", "file:ent?mode=memory&cache=shared&_fk=1") + if err != nil { + log.Fatal(err) + } + defer drv.Close() + client := ent.NewClient(ent.Driver(drv)) +} +``` + + +**Gremlin (AWS Neptune)** + +```go +package main + +import ( + "log" + "net/url" + + "/ent" + + "github.com/facebookincubator/ent/dialect/gremlin" +) + +func main() { + c, err := gremlin.NewClient(gremlin.Config{ + Endpoint: gremlin.Endpoint{ + URL: &url.URL{ + Scheme: "http", + Host: "localhost:8182", + }, + }, + }) + if err != nil { + log.Fatal(err) + } + client := ent.NewClient(ent.Driver(gremlin.NewDriver(c))) +} +``` + +## Create An Entity + +## Update An Entity + +## Update Many Entities + +## Query An Entity + +## Delete An Entity + +## Delete Entities \ No newline at end of file diff --git a/doc/md/predicates.md b/doc/md/predicates.md index 9907990a9..9d60e9fc6 100755 --- a/doc/md/predicates.md +++ b/doc/md/predicates.md @@ -1,5 +1,5 @@ --- -id: predicate +id: predicates title: Predicates --- Lorem ipsum. diff --git a/doc/website/sidebars.json b/doc/website/sidebars.json index d2be625b3..3fcfed771 100755 --- a/doc/website/sidebars.json +++ b/doc/website/sidebars.json @@ -12,9 +12,9 @@ "Code Generation": [ "code-gen", "crud", - "predicates", "traversals", "aggregate", + "predicates", "transactions" ], "Migration": [ diff --git a/doc/website/siteConfig.js b/doc/website/siteConfig.js index 4ff716640..8d241944a 100644 --- a/doc/website/siteConfig.js +++ b/doc/website/siteConfig.js @@ -86,7 +86,6 @@ const siteConfig = { '/js/code-block-buttons.js', '/js/custom.js', ], - stylesheets: ['/css/code-block-buttons.css'], // On page navigation for the current documentation page. onPageNav: 'separate', diff --git a/entc/gen/bindata.go b/entc/gen/bindata.go index 33396d5f8..d2864f1de 100644 --- a/entc/gen/bindata.go +++ b/entc/gen/bindata.go @@ -239,7 +239,7 @@ func templateClientTmpl() (*asset, error) { return nil, err } - info := bindataFileInfo{name: "template/client.tmpl", size: 4844, mode: os.FileMode(420), modTime: time.Unix(1566998190, 0)} + info := bindataFileInfo{name: "template/client.tmpl", size: 4844, mode: os.FileMode(420), modTime: time.Unix(1567007034, 0)} a := &asset{bytes: bytes, info: info} return a, nil } @@ -259,7 +259,7 @@ func templateConfigTmpl() (*asset, error) { return nil, err } - info := bindataFileInfo{name: "template/config.tmpl", size: 1058, mode: os.FileMode(420), modTime: time.Unix(1566996430, 0)} + info := bindataFileInfo{name: "template/config.tmpl", size: 1058, mode: os.FileMode(420), modTime: time.Unix(1567007034, 0)} a := &asset{bytes: bytes, info: info} return a, nil } diff --git a/entc/gen/storage.go b/entc/gen/storage.go index f89c16230..6a59ba85e 100644 --- a/entc/gen/storage.go +++ b/entc/gen/storage.go @@ -64,7 +64,7 @@ var drivers = []*Storage{ Name: "gremlin", IdentName: "Gremlin", Builder: reflect.TypeOf(&dsl.Traversal{}), - Dialects: []string{"dialect.Neptune"}, + Dialects: []string{"dialect.Gremlin"}, Imports: []string{ "github.com/facebookincubator/ent/dialect/gremlin", "github.com/facebookincubator/ent/dialect/gremlin/graph/dsl", diff --git a/entc/integration/ent/card_create.go b/entc/integration/ent/card_create.go index 671cdd2cd..4a70a741e 100644 --- a/entc/integration/ent/card_create.go +++ b/entc/integration/ent/card_create.go @@ -108,7 +108,7 @@ func (cc *CardCreate) Save(ctx context.Context) (*Card, error) { switch cc.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cc.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cc.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/card_delete.go b/entc/integration/ent/card_delete.go index 21d1aea4c..1ca747755 100644 --- a/entc/integration/ent/card_delete.go +++ b/entc/integration/ent/card_delete.go @@ -33,7 +33,7 @@ func (cd *CardDelete) Exec(ctx context.Context) error { switch cd.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cd.sqlExec(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cd.gremlinExec(ctx) default: return errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/card_query.go b/entc/integration/ent/card_query.go index 8fd7e7dee..2ad744c45 100644 --- a/entc/integration/ent/card_query.go +++ b/entc/integration/ent/card_query.go @@ -69,7 +69,7 @@ func (cq *CardQuery) QueryOwner() *UserQuery { From(t1). Join(t2). On(t1.C(user.FieldID), t2.C(card.OwnerColumn)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := cq.gremlinQuery() query.gremlin = gremlin.InE(user.CardLabel).OutV() } @@ -189,7 +189,7 @@ func (cq *CardQuery) All(ctx context.Context) ([]*Card, error) { switch cq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cq.sqlAll(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cq.gremlinAll(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -210,7 +210,7 @@ func (cq *CardQuery) IDs(ctx context.Context) ([]string, error) { switch cq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cq.sqlIDs(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cq.gremlinIDs(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -231,7 +231,7 @@ func (cq *CardQuery) Count(ctx context.Context) (int, error) { switch cq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cq.sqlCount(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cq.gremlinCount(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -252,7 +252,7 @@ func (cq *CardQuery) Exist(ctx context.Context) (bool, error) { switch cq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cq.sqlExist(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cq.gremlinExist(ctx) default: return false, errors.New("ent: unsupported dialect") @@ -305,7 +305,7 @@ func (cq *CardQuery) GroupBy(field string, fields ...string) *CardGroupBy { switch cq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: group.sql = cq.sqlQuery() - case dialect.Neptune: + case dialect.Gremlin: group.gremlin = cq.gremlinQuery() } return group @@ -495,7 +495,7 @@ func (cgb *CardGroupBy) Scan(ctx context.Context, v interface{}) error { switch cgb.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cgb.sqlScan(ctx, v) - case dialect.Neptune: + case dialect.Gremlin: return cgb.gremlinScan(ctx, v) default: return errors.New("cgb: unsupported dialect") diff --git a/entc/integration/ent/card_update.go b/entc/integration/ent/card_update.go index 66e1fea9e..9b41cdf02 100644 --- a/entc/integration/ent/card_update.go +++ b/entc/integration/ent/card_update.go @@ -90,7 +90,7 @@ func (cu *CardUpdate) Save(ctx context.Context) (int, error) { switch cu.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cu.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cu.gremlinSave(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -324,7 +324,7 @@ func (cuo *CardUpdateOne) Save(ctx context.Context) (*Card, error) { switch cuo.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cuo.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cuo.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/client.go b/entc/integration/ent/client.go index 556b2f1a7..6a1fc72b4 100644 --- a/entc/integration/ent/client.go +++ b/entc/integration/ent/client.go @@ -187,7 +187,7 @@ func (c *CardClient) QueryOwner(ca *Card) *UserQuery { Where(sql.EQ(card.FieldID, id)) query.sql = sql.Select().From(t1).Join(t2).On(t1.C(user.FieldID), t2.C(card.OwnerColumn)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(ca.ID).InE(user.CardLabel).OutV() } @@ -356,7 +356,7 @@ func (c *FileClient) QueryOwner(f *File) *UserQuery { Where(sql.EQ(file.FieldID, id)) query.sql = sql.Select().From(t1).Join(t2).On(t1.C(user.FieldID), t2.C(file.OwnerColumn)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(f.ID).InE(user.FilesLabel).OutV() } @@ -375,7 +375,7 @@ func (c *FileClient) QueryType(f *File) *FileTypeQuery { Where(sql.EQ(file.FieldID, id)) query.sql = sql.Select().From(t1).Join(t2).On(t1.C(filetype.FieldID), t2.C(file.TypeColumn)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(f.ID).InE(filetype.FilesLabel).OutV() } @@ -441,7 +441,7 @@ func (c *FileTypeClient) QueryFiles(ft *FileType) *FileQuery { query.sql = sql.Select().From(sql.Table(file.Table)). Where(sql.EQ(filetype.FilesColumn, id)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(ft.ID).OutE(filetype.FilesLabel).InV() } @@ -507,7 +507,7 @@ func (c *GroupClient) QueryFiles(gr *Group) *FileQuery { query.sql = sql.Select().From(sql.Table(file.Table)). Where(sql.EQ(group.FilesColumn, id)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(gr.ID).OutE(group.FilesLabel).InV() } @@ -523,7 +523,7 @@ func (c *GroupClient) QueryBlocked(gr *Group) *UserQuery { query.sql = sql.Select().From(sql.Table(user.Table)). Where(sql.EQ(group.BlockedColumn, id)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(gr.ID).OutE(group.BlockedLabel).InV() } @@ -549,7 +549,7 @@ func (c *GroupClient) QueryUsers(gr *Group) *UserQuery { Join(t4). On(t1.C(user.FieldID), t4.C(group.UsersPrimaryKey[0])) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(gr.ID).InE(user.GroupsLabel).OutV() } @@ -568,7 +568,7 @@ func (c *GroupClient) QueryInfo(gr *Group) *GroupInfoQuery { Where(sql.EQ(group.FieldID, id)) query.sql = sql.Select().From(t1).Join(t2).On(t1.C(groupinfo.FieldID), t2.C(group.InfoColumn)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(gr.ID).OutE(group.InfoLabel).InV() } @@ -634,7 +634,7 @@ func (c *GroupInfoClient) QueryGroups(gi *GroupInfo) *GroupQuery { query.sql = sql.Select().From(sql.Table(group.Table)). Where(sql.EQ(groupinfo.GroupsColumn, id)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(gi.ID).InE(group.InfoLabel).OutV() } @@ -703,7 +703,7 @@ func (c *NodeClient) QueryPrev(n *Node) *NodeQuery { Where(sql.EQ(node.FieldID, id)) query.sql = sql.Select().From(t1).Join(t2).On(t1.C(node.FieldID), t2.C(node.PrevColumn)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(n.ID).InE(node.NextLabel).OutV() } @@ -719,7 +719,7 @@ func (c *NodeClient) QueryNext(n *Node) *NodeQuery { query.sql = sql.Select().From(sql.Table(node.Table)). Where(sql.EQ(node.NextColumn, id)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(n.ID).OutE(node.NextLabel).InV() } @@ -788,7 +788,7 @@ func (c *PetClient) QueryTeam(pe *Pet) *UserQuery { Where(sql.EQ(pet.FieldID, id)) query.sql = sql.Select().From(t1).Join(t2).On(t1.C(user.FieldID), t2.C(pet.TeamColumn)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(pe.ID).InE(user.TeamLabel).OutV() } @@ -807,7 +807,7 @@ func (c *PetClient) QueryOwner(pe *Pet) *UserQuery { Where(sql.EQ(pet.FieldID, id)) query.sql = sql.Select().From(t1).Join(t2).On(t1.C(user.FieldID), t2.C(pet.OwnerColumn)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(pe.ID).InE(user.PetsLabel).OutV() } @@ -873,7 +873,7 @@ func (c *UserClient) QueryCard(u *User) *CardQuery { query.sql = sql.Select().From(sql.Table(card.Table)). Where(sql.EQ(user.CardColumn, id)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(u.ID).OutE(user.CardLabel).InV() } @@ -889,7 +889,7 @@ func (c *UserClient) QueryPets(u *User) *PetQuery { query.sql = sql.Select().From(sql.Table(pet.Table)). Where(sql.EQ(user.PetsColumn, id)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(u.ID).OutE(user.PetsLabel).InV() } @@ -905,7 +905,7 @@ func (c *UserClient) QueryFiles(u *User) *FileQuery { query.sql = sql.Select().From(sql.Table(file.Table)). Where(sql.EQ(user.FilesColumn, id)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(u.ID).OutE(user.FilesLabel).InV() } @@ -931,7 +931,7 @@ func (c *UserClient) QueryGroups(u *User) *GroupQuery { Join(t4). On(t1.C(group.FieldID), t4.C(user.GroupsPrimaryKey[1])) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(u.ID).OutE(user.GroupsLabel).InV() } @@ -957,7 +957,7 @@ func (c *UserClient) QueryFriends(u *User) *UserQuery { Join(t4). On(t1.C(user.FieldID), t4.C(user.FriendsPrimaryKey[1])) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(u.ID).Both(user.FriendsLabel) } @@ -983,7 +983,7 @@ func (c *UserClient) QueryFollowers(u *User) *UserQuery { Join(t4). On(t1.C(user.FieldID), t4.C(user.FollowersPrimaryKey[0])) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(u.ID).InE(user.FollowingLabel).OutV() } @@ -1009,7 +1009,7 @@ func (c *UserClient) QueryFollowing(u *User) *UserQuery { Join(t4). On(t1.C(user.FieldID), t4.C(user.FollowingPrimaryKey[1])) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(u.ID).OutE(user.FollowingLabel).InV() } @@ -1025,7 +1025,7 @@ func (c *UserClient) QueryTeam(u *User) *PetQuery { query.sql = sql.Select().From(sql.Table(pet.Table)). Where(sql.EQ(user.TeamColumn, id)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(u.ID).OutE(user.TeamLabel).InV() } @@ -1041,7 +1041,7 @@ func (c *UserClient) QuerySpouse(u *User) *UserQuery { query.sql = sql.Select().From(sql.Table(user.Table)). Where(sql.EQ(user.SpouseColumn, id)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(u.ID).Both(user.SpouseLabel) } @@ -1057,7 +1057,7 @@ func (c *UserClient) QueryChildren(u *User) *UserQuery { query.sql = sql.Select().From(sql.Table(user.Table)). Where(sql.EQ(user.ChildrenColumn, id)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(u.ID).InE(user.ParentLabel).OutV() } @@ -1076,7 +1076,7 @@ func (c *UserClient) QueryParent(u *User) *UserQuery { Where(sql.EQ(user.FieldID, id)) query.sql = sql.Select().From(t1).Join(t2).On(t1.C(user.FieldID), t2.C(user.ParentColumn)) - case dialect.Neptune: + case dialect.Gremlin: query.gremlin = g.V(u.ID).OutE(user.ParentLabel).InV() } diff --git a/entc/integration/ent/comment_create.go b/entc/integration/ent/comment_create.go index 3024f7e5b..cf7f457bc 100644 --- a/entc/integration/ent/comment_create.go +++ b/entc/integration/ent/comment_create.go @@ -48,7 +48,7 @@ func (cc *CommentCreate) Save(ctx context.Context) (*Comment, error) { switch cc.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cc.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cc.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/comment_delete.go b/entc/integration/ent/comment_delete.go index 50d1338fe..67ae865ed 100644 --- a/entc/integration/ent/comment_delete.go +++ b/entc/integration/ent/comment_delete.go @@ -33,7 +33,7 @@ func (cd *CommentDelete) Exec(ctx context.Context) error { switch cd.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cd.sqlExec(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cd.gremlinExec(ctx) default: return errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/comment_query.go b/entc/integration/ent/comment_query.go index ee4efdc57..80017a5ed 100644 --- a/entc/integration/ent/comment_query.go +++ b/entc/integration/ent/comment_query.go @@ -169,7 +169,7 @@ func (cq *CommentQuery) All(ctx context.Context) ([]*Comment, error) { switch cq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cq.sqlAll(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cq.gremlinAll(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -190,7 +190,7 @@ func (cq *CommentQuery) IDs(ctx context.Context) ([]string, error) { switch cq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cq.sqlIDs(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cq.gremlinIDs(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -211,7 +211,7 @@ func (cq *CommentQuery) Count(ctx context.Context) (int, error) { switch cq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cq.sqlCount(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cq.gremlinCount(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -232,7 +232,7 @@ func (cq *CommentQuery) Exist(ctx context.Context) (bool, error) { switch cq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cq.sqlExist(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cq.gremlinExist(ctx) default: return false, errors.New("ent: unsupported dialect") @@ -285,7 +285,7 @@ func (cq *CommentQuery) GroupBy(field string, fields ...string) *CommentGroupBy switch cq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: group.sql = cq.sqlQuery() - case dialect.Neptune: + case dialect.Gremlin: group.gremlin = cq.gremlinQuery() } return group @@ -475,7 +475,7 @@ func (cgb *CommentGroupBy) Scan(ctx context.Context, v interface{}) error { switch cgb.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cgb.sqlScan(ctx, v) - case dialect.Neptune: + case dialect.Gremlin: return cgb.gremlinScan(ctx, v) default: return errors.New("cgb: unsupported dialect") diff --git a/entc/integration/ent/comment_update.go b/entc/integration/ent/comment_update.go index 8f2aa1a51..28256a271 100644 --- a/entc/integration/ent/comment_update.go +++ b/entc/integration/ent/comment_update.go @@ -50,7 +50,7 @@ func (cu *CommentUpdate) Save(ctx context.Context) (int, error) { switch cu.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cu.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cu.gremlinSave(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -213,7 +213,7 @@ func (cuo *CommentUpdateOne) Save(ctx context.Context) (*Comment, error) { switch cuo.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return cuo.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return cuo.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/fieldtype_create.go b/entc/integration/ent/fieldtype_create.go index 3d8b7796a..9d0858d7c 100644 --- a/entc/integration/ent/fieldtype_create.go +++ b/entc/integration/ent/fieldtype_create.go @@ -247,7 +247,7 @@ func (ftc *FieldTypeCreate) Save(ctx context.Context) (*FieldType, error) { switch ftc.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftc.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftc.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/fieldtype_delete.go b/entc/integration/ent/fieldtype_delete.go index 12a6ba1c5..945b8c1dc 100644 --- a/entc/integration/ent/fieldtype_delete.go +++ b/entc/integration/ent/fieldtype_delete.go @@ -33,7 +33,7 @@ func (ftd *FieldTypeDelete) Exec(ctx context.Context) error { switch ftd.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftd.sqlExec(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftd.gremlinExec(ctx) default: return errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/fieldtype_query.go b/entc/integration/ent/fieldtype_query.go index b835c3ee1..36eab345d 100644 --- a/entc/integration/ent/fieldtype_query.go +++ b/entc/integration/ent/fieldtype_query.go @@ -169,7 +169,7 @@ func (ftq *FieldTypeQuery) All(ctx context.Context) ([]*FieldType, error) { switch ftq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftq.sqlAll(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftq.gremlinAll(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -190,7 +190,7 @@ func (ftq *FieldTypeQuery) IDs(ctx context.Context) ([]string, error) { switch ftq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftq.sqlIDs(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftq.gremlinIDs(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -211,7 +211,7 @@ func (ftq *FieldTypeQuery) Count(ctx context.Context) (int, error) { switch ftq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftq.sqlCount(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftq.gremlinCount(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -232,7 +232,7 @@ func (ftq *FieldTypeQuery) Exist(ctx context.Context) (bool, error) { switch ftq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftq.sqlExist(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftq.gremlinExist(ctx) default: return false, errors.New("ent: unsupported dialect") @@ -285,7 +285,7 @@ func (ftq *FieldTypeQuery) GroupBy(field string, fields ...string) *FieldTypeGro switch ftq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: group.sql = ftq.sqlQuery() - case dialect.Neptune: + case dialect.Gremlin: group.gremlin = ftq.gremlinQuery() } return group @@ -475,7 +475,7 @@ func (ftgb *FieldTypeGroupBy) Scan(ctx context.Context, v interface{}) error { switch ftgb.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftgb.sqlScan(ctx, v) - case dialect.Neptune: + case dialect.Gremlin: return ftgb.gremlinScan(ctx, v) default: return errors.New("ftgb: unsupported dialect") diff --git a/entc/integration/ent/fieldtype_update.go b/entc/integration/ent/fieldtype_update.go index 9a3fbf640..91efbbb67 100644 --- a/entc/integration/ent/fieldtype_update.go +++ b/entc/integration/ent/fieldtype_update.go @@ -239,7 +239,7 @@ func (ftu *FieldTypeUpdate) Save(ctx context.Context) (int, error) { switch ftu.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftu.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftu.gremlinSave(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -665,7 +665,7 @@ func (ftuo *FieldTypeUpdateOne) Save(ctx context.Context) (*FieldType, error) { switch ftuo.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftuo.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftuo.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/file_create.go b/entc/integration/ent/file_create.go index 4a17077d9..895a187a9 100644 --- a/entc/integration/ent/file_create.go +++ b/entc/integration/ent/file_create.go @@ -160,7 +160,7 @@ func (fc *FileCreate) Save(ctx context.Context) (*File, error) { switch fc.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return fc.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return fc.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/file_delete.go b/entc/integration/ent/file_delete.go index 5b678e7e6..c93caf686 100644 --- a/entc/integration/ent/file_delete.go +++ b/entc/integration/ent/file_delete.go @@ -33,7 +33,7 @@ func (fd *FileDelete) Exec(ctx context.Context) error { switch fd.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return fd.sqlExec(ctx) - case dialect.Neptune: + case dialect.Gremlin: return fd.gremlinExec(ctx) default: return errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/file_query.go b/entc/integration/ent/file_query.go index b7d56417d..2ad9c61c0 100644 --- a/entc/integration/ent/file_query.go +++ b/entc/integration/ent/file_query.go @@ -70,7 +70,7 @@ func (fq *FileQuery) QueryOwner() *UserQuery { From(t1). Join(t2). On(t1.C(user.FieldID), t2.C(file.OwnerColumn)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := fq.gremlinQuery() query.gremlin = gremlin.InE(user.FilesLabel).OutV() } @@ -89,7 +89,7 @@ func (fq *FileQuery) QueryType() *FileTypeQuery { From(t1). Join(t2). On(t1.C(filetype.FieldID), t2.C(file.TypeColumn)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := fq.gremlinQuery() query.gremlin = gremlin.InE(filetype.FilesLabel).OutV() } @@ -209,7 +209,7 @@ func (fq *FileQuery) All(ctx context.Context) ([]*File, error) { switch fq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return fq.sqlAll(ctx) - case dialect.Neptune: + case dialect.Gremlin: return fq.gremlinAll(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -230,7 +230,7 @@ func (fq *FileQuery) IDs(ctx context.Context) ([]string, error) { switch fq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return fq.sqlIDs(ctx) - case dialect.Neptune: + case dialect.Gremlin: return fq.gremlinIDs(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -251,7 +251,7 @@ func (fq *FileQuery) Count(ctx context.Context) (int, error) { switch fq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return fq.sqlCount(ctx) - case dialect.Neptune: + case dialect.Gremlin: return fq.gremlinCount(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -272,7 +272,7 @@ func (fq *FileQuery) Exist(ctx context.Context) (bool, error) { switch fq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return fq.sqlExist(ctx) - case dialect.Neptune: + case dialect.Gremlin: return fq.gremlinExist(ctx) default: return false, errors.New("ent: unsupported dialect") @@ -325,7 +325,7 @@ func (fq *FileQuery) GroupBy(field string, fields ...string) *FileGroupBy { switch fq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: group.sql = fq.sqlQuery() - case dialect.Neptune: + case dialect.Gremlin: group.gremlin = fq.gremlinQuery() } return group @@ -515,7 +515,7 @@ func (fgb *FileGroupBy) Scan(ctx context.Context, v interface{}) error { switch fgb.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return fgb.sqlScan(ctx, v) - case dialect.Neptune: + case dialect.Gremlin: return fgb.gremlinScan(ctx, v) default: return errors.New("fgb: unsupported dialect") diff --git a/entc/integration/ent/file_update.go b/entc/integration/ent/file_update.go index 4fcb4a9b5..d4ae043b5 100644 --- a/entc/integration/ent/file_update.go +++ b/entc/integration/ent/file_update.go @@ -177,7 +177,7 @@ func (fu *FileUpdate) Save(ctx context.Context) (int, error) { switch fu.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return fu.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return fu.gremlinSave(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -545,7 +545,7 @@ func (fuo *FileUpdateOne) Save(ctx context.Context) (*File, error) { switch fuo.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return fuo.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return fuo.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/filetype_create.go b/entc/integration/ent/filetype_create.go index 3dd4f1716..4914ae10d 100644 --- a/entc/integration/ent/filetype_create.go +++ b/entc/integration/ent/filetype_create.go @@ -61,7 +61,7 @@ func (ftc *FileTypeCreate) Save(ctx context.Context) (*FileType, error) { switch ftc.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftc.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftc.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/filetype_delete.go b/entc/integration/ent/filetype_delete.go index 996c30628..84904c14b 100644 --- a/entc/integration/ent/filetype_delete.go +++ b/entc/integration/ent/filetype_delete.go @@ -33,7 +33,7 @@ func (ftd *FileTypeDelete) Exec(ctx context.Context) error { switch ftd.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftd.sqlExec(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftd.gremlinExec(ctx) default: return errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/filetype_query.go b/entc/integration/ent/filetype_query.go index 72a3b4bde..194d858a6 100644 --- a/entc/integration/ent/filetype_query.go +++ b/entc/integration/ent/filetype_query.go @@ -69,7 +69,7 @@ func (ftq *FileTypeQuery) QueryFiles() *FileQuery { From(t1). Join(t2). On(t1.C(filetype.FilesColumn), t2.C(filetype.FieldID)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := ftq.gremlinQuery() query.gremlin = gremlin.OutE(filetype.FilesLabel).InV() } @@ -189,7 +189,7 @@ func (ftq *FileTypeQuery) All(ctx context.Context) ([]*FileType, error) { switch ftq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftq.sqlAll(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftq.gremlinAll(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -210,7 +210,7 @@ func (ftq *FileTypeQuery) IDs(ctx context.Context) ([]string, error) { switch ftq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftq.sqlIDs(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftq.gremlinIDs(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -231,7 +231,7 @@ func (ftq *FileTypeQuery) Count(ctx context.Context) (int, error) { switch ftq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftq.sqlCount(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftq.gremlinCount(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -252,7 +252,7 @@ func (ftq *FileTypeQuery) Exist(ctx context.Context) (bool, error) { switch ftq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftq.sqlExist(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftq.gremlinExist(ctx) default: return false, errors.New("ent: unsupported dialect") @@ -305,7 +305,7 @@ func (ftq *FileTypeQuery) GroupBy(field string, fields ...string) *FileTypeGroup switch ftq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: group.sql = ftq.sqlQuery() - case dialect.Neptune: + case dialect.Gremlin: group.gremlin = ftq.gremlinQuery() } return group @@ -495,7 +495,7 @@ func (ftgb *FileTypeGroupBy) Scan(ctx context.Context, v interface{}) error { switch ftgb.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftgb.sqlScan(ctx, v) - case dialect.Neptune: + case dialect.Gremlin: return ftgb.gremlinScan(ctx, v) default: return errors.New("ftgb: unsupported dialect") diff --git a/entc/integration/ent/filetype_update.go b/entc/integration/ent/filetype_update.go index 67b70abbd..aa2310bee 100644 --- a/entc/integration/ent/filetype_update.go +++ b/entc/integration/ent/filetype_update.go @@ -87,7 +87,7 @@ func (ftu *FileTypeUpdate) Save(ctx context.Context) (int, error) { switch ftu.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftu.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftu.gremlinSave(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -331,7 +331,7 @@ func (ftuo *FileTypeUpdateOne) Save(ctx context.Context) (*FileType, error) { switch ftuo.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ftuo.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ftuo.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/group_create.go b/entc/integration/ent/group_create.go index d11c4ebaa..4f9115952 100644 --- a/entc/integration/ent/group_create.go +++ b/entc/integration/ent/group_create.go @@ -200,7 +200,7 @@ func (gc *GroupCreate) Save(ctx context.Context) (*Group, error) { switch gc.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return gc.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return gc.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/group_delete.go b/entc/integration/ent/group_delete.go index c958cb93c..74bac41e9 100644 --- a/entc/integration/ent/group_delete.go +++ b/entc/integration/ent/group_delete.go @@ -33,7 +33,7 @@ func (gd *GroupDelete) Exec(ctx context.Context) error { switch gd.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return gd.sqlExec(ctx) - case dialect.Neptune: + case dialect.Gremlin: return gd.gremlinExec(ctx) default: return errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/group_query.go b/entc/integration/ent/group_query.go index 853f6892b..aa1da031c 100644 --- a/entc/integration/ent/group_query.go +++ b/entc/integration/ent/group_query.go @@ -71,7 +71,7 @@ func (gq *GroupQuery) QueryFiles() *FileQuery { From(t1). Join(t2). On(t1.C(group.FilesColumn), t2.C(group.FieldID)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := gq.gremlinQuery() query.gremlin = gremlin.OutE(group.FilesLabel).InV() } @@ -90,7 +90,7 @@ func (gq *GroupQuery) QueryBlocked() *UserQuery { From(t1). Join(t2). On(t1.C(group.BlockedColumn), t2.C(group.FieldID)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := gq.gremlinQuery() query.gremlin = gremlin.OutE(group.BlockedLabel).InV() } @@ -114,7 +114,7 @@ func (gq *GroupQuery) QueryUsers() *UserQuery { From(t1). Join(t4). On(t1.C(user.FieldID), t4.C(group.UsersPrimaryKey[0])) - case dialect.Neptune: + case dialect.Gremlin: gremlin := gq.gremlinQuery() query.gremlin = gremlin.InE(user.GroupsLabel).OutV() } @@ -133,7 +133,7 @@ func (gq *GroupQuery) QueryInfo() *GroupInfoQuery { From(t1). Join(t2). On(t1.C(groupinfo.FieldID), t2.C(group.InfoColumn)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := gq.gremlinQuery() query.gremlin = gremlin.OutE(group.InfoLabel).InV() } @@ -253,7 +253,7 @@ func (gq *GroupQuery) All(ctx context.Context) ([]*Group, error) { switch gq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return gq.sqlAll(ctx) - case dialect.Neptune: + case dialect.Gremlin: return gq.gremlinAll(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -274,7 +274,7 @@ func (gq *GroupQuery) IDs(ctx context.Context) ([]string, error) { switch gq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return gq.sqlIDs(ctx) - case dialect.Neptune: + case dialect.Gremlin: return gq.gremlinIDs(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -295,7 +295,7 @@ func (gq *GroupQuery) Count(ctx context.Context) (int, error) { switch gq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return gq.sqlCount(ctx) - case dialect.Neptune: + case dialect.Gremlin: return gq.gremlinCount(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -316,7 +316,7 @@ func (gq *GroupQuery) Exist(ctx context.Context) (bool, error) { switch gq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return gq.sqlExist(ctx) - case dialect.Neptune: + case dialect.Gremlin: return gq.gremlinExist(ctx) default: return false, errors.New("ent: unsupported dialect") @@ -369,7 +369,7 @@ func (gq *GroupQuery) GroupBy(field string, fields ...string) *GroupGroupBy { switch gq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: group.sql = gq.sqlQuery() - case dialect.Neptune: + case dialect.Gremlin: group.gremlin = gq.gremlinQuery() } return group @@ -559,7 +559,7 @@ func (ggb *GroupGroupBy) Scan(ctx context.Context, v interface{}) error { switch ggb.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ggb.sqlScan(ctx, v) - case dialect.Neptune: + case dialect.Gremlin: return ggb.gremlinScan(ctx, v) default: return errors.New("ggb: unsupported dialect") diff --git a/entc/integration/ent/group_update.go b/entc/integration/ent/group_update.go index 3d3c2139c..b937066f7 100644 --- a/entc/integration/ent/group_update.go +++ b/entc/integration/ent/group_update.go @@ -269,7 +269,7 @@ func (gu *GroupUpdate) Save(ctx context.Context) (int, error) { switch gu.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return gu.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return gu.gremlinSave(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -852,7 +852,7 @@ func (guo *GroupUpdateOne) Save(ctx context.Context) (*Group, error) { switch guo.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return guo.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return guo.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/groupinfo_create.go b/entc/integration/ent/groupinfo_create.go index 55332a58a..690a268c1 100644 --- a/entc/integration/ent/groupinfo_create.go +++ b/entc/integration/ent/groupinfo_create.go @@ -80,7 +80,7 @@ func (gic *GroupInfoCreate) Save(ctx context.Context) (*GroupInfo, error) { switch gic.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return gic.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return gic.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/groupinfo_delete.go b/entc/integration/ent/groupinfo_delete.go index a5853ef06..2912d3efd 100644 --- a/entc/integration/ent/groupinfo_delete.go +++ b/entc/integration/ent/groupinfo_delete.go @@ -33,7 +33,7 @@ func (gid *GroupInfoDelete) Exec(ctx context.Context) error { switch gid.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return gid.sqlExec(ctx) - case dialect.Neptune: + case dialect.Gremlin: return gid.gremlinExec(ctx) default: return errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/groupinfo_query.go b/entc/integration/ent/groupinfo_query.go index 4049485b4..25d10662f 100644 --- a/entc/integration/ent/groupinfo_query.go +++ b/entc/integration/ent/groupinfo_query.go @@ -69,7 +69,7 @@ func (giq *GroupInfoQuery) QueryGroups() *GroupQuery { From(t1). Join(t2). On(t1.C(groupinfo.GroupsColumn), t2.C(groupinfo.FieldID)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := giq.gremlinQuery() query.gremlin = gremlin.InE(group.InfoLabel).OutV() } @@ -189,7 +189,7 @@ func (giq *GroupInfoQuery) All(ctx context.Context) ([]*GroupInfo, error) { switch giq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return giq.sqlAll(ctx) - case dialect.Neptune: + case dialect.Gremlin: return giq.gremlinAll(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -210,7 +210,7 @@ func (giq *GroupInfoQuery) IDs(ctx context.Context) ([]string, error) { switch giq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return giq.sqlIDs(ctx) - case dialect.Neptune: + case dialect.Gremlin: return giq.gremlinIDs(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -231,7 +231,7 @@ func (giq *GroupInfoQuery) Count(ctx context.Context) (int, error) { switch giq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return giq.sqlCount(ctx) - case dialect.Neptune: + case dialect.Gremlin: return giq.gremlinCount(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -252,7 +252,7 @@ func (giq *GroupInfoQuery) Exist(ctx context.Context) (bool, error) { switch giq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return giq.sqlExist(ctx) - case dialect.Neptune: + case dialect.Gremlin: return giq.gremlinExist(ctx) default: return false, errors.New("ent: unsupported dialect") @@ -305,7 +305,7 @@ func (giq *GroupInfoQuery) GroupBy(field string, fields ...string) *GroupInfoGro switch giq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: group.sql = giq.sqlQuery() - case dialect.Neptune: + case dialect.Gremlin: group.gremlin = giq.gremlinQuery() } return group @@ -495,7 +495,7 @@ func (gigb *GroupInfoGroupBy) Scan(ctx context.Context, v interface{}) error { switch gigb.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return gigb.sqlScan(ctx, v) - case dialect.Neptune: + case dialect.Gremlin: return gigb.gremlinScan(ctx, v) default: return errors.New("gigb: unsupported dialect") diff --git a/entc/integration/ent/groupinfo_update.go b/entc/integration/ent/groupinfo_update.go index 9c707fc05..f7fd464ee 100644 --- a/entc/integration/ent/groupinfo_update.go +++ b/entc/integration/ent/groupinfo_update.go @@ -102,7 +102,7 @@ func (giu *GroupInfoUpdate) Save(ctx context.Context) (int, error) { switch giu.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return giu.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return giu.gremlinSave(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -364,7 +364,7 @@ func (giuo *GroupInfoUpdateOne) Save(ctx context.Context) (*GroupInfo, error) { switch giuo.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return giuo.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return giuo.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/node_create.go b/entc/integration/ent/node_create.go index 305e76aac..5989ff47f 100644 --- a/entc/integration/ent/node_create.go +++ b/entc/integration/ent/node_create.go @@ -96,7 +96,7 @@ func (nc *NodeCreate) Save(ctx context.Context) (*Node, error) { switch nc.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return nc.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return nc.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/node_delete.go b/entc/integration/ent/node_delete.go index 2f168d016..ca5f6f21c 100644 --- a/entc/integration/ent/node_delete.go +++ b/entc/integration/ent/node_delete.go @@ -33,7 +33,7 @@ func (nd *NodeDelete) Exec(ctx context.Context) error { switch nd.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return nd.sqlExec(ctx) - case dialect.Neptune: + case dialect.Gremlin: return nd.gremlinExec(ctx) default: return errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/node_query.go b/entc/integration/ent/node_query.go index a0bfc7871..1725f89a3 100644 --- a/entc/integration/ent/node_query.go +++ b/entc/integration/ent/node_query.go @@ -68,7 +68,7 @@ func (nq *NodeQuery) QueryPrev() *NodeQuery { From(t1). Join(t2). On(t1.C(node.FieldID), t2.C(node.PrevColumn)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := nq.gremlinQuery() query.gremlin = gremlin.InE(node.NextLabel).OutV() } @@ -87,7 +87,7 @@ func (nq *NodeQuery) QueryNext() *NodeQuery { From(t1). Join(t2). On(t1.C(node.NextColumn), t2.C(node.FieldID)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := nq.gremlinQuery() query.gremlin = gremlin.OutE(node.NextLabel).InV() } @@ -207,7 +207,7 @@ func (nq *NodeQuery) All(ctx context.Context) ([]*Node, error) { switch nq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return nq.sqlAll(ctx) - case dialect.Neptune: + case dialect.Gremlin: return nq.gremlinAll(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -228,7 +228,7 @@ func (nq *NodeQuery) IDs(ctx context.Context) ([]string, error) { switch nq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return nq.sqlIDs(ctx) - case dialect.Neptune: + case dialect.Gremlin: return nq.gremlinIDs(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -249,7 +249,7 @@ func (nq *NodeQuery) Count(ctx context.Context) (int, error) { switch nq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return nq.sqlCount(ctx) - case dialect.Neptune: + case dialect.Gremlin: return nq.gremlinCount(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -270,7 +270,7 @@ func (nq *NodeQuery) Exist(ctx context.Context) (bool, error) { switch nq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return nq.sqlExist(ctx) - case dialect.Neptune: + case dialect.Gremlin: return nq.gremlinExist(ctx) default: return false, errors.New("ent: unsupported dialect") @@ -323,7 +323,7 @@ func (nq *NodeQuery) GroupBy(field string, fields ...string) *NodeGroupBy { switch nq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: group.sql = nq.sqlQuery() - case dialect.Neptune: + case dialect.Gremlin: group.gremlin = nq.gremlinQuery() } return group @@ -513,7 +513,7 @@ func (ngb *NodeGroupBy) Scan(ctx context.Context, v interface{}) error { switch ngb.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ngb.sqlScan(ctx, v) - case dialect.Neptune: + case dialect.Gremlin: return ngb.gremlinScan(ctx, v) default: return errors.New("ngb: unsupported dialect") diff --git a/entc/integration/ent/node_update.go b/entc/integration/ent/node_update.go index 535fd1715..acc4fd731 100644 --- a/entc/integration/ent/node_update.go +++ b/entc/integration/ent/node_update.go @@ -118,7 +118,7 @@ func (nu *NodeUpdate) Save(ctx context.Context) (int, error) { switch nu.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return nu.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return nu.gremlinSave(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -417,7 +417,7 @@ func (nuo *NodeUpdateOne) Save(ctx context.Context) (*Node, error) { switch nuo.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return nuo.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return nuo.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/pet_create.go b/entc/integration/ent/pet_create.go index e7d806557..38cb0802c 100644 --- a/entc/integration/ent/pet_create.go +++ b/entc/integration/ent/pet_create.go @@ -92,7 +92,7 @@ func (pc *PetCreate) Save(ctx context.Context) (*Pet, error) { switch pc.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return pc.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return pc.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/pet_delete.go b/entc/integration/ent/pet_delete.go index 9e77e306f..313a6338f 100644 --- a/entc/integration/ent/pet_delete.go +++ b/entc/integration/ent/pet_delete.go @@ -33,7 +33,7 @@ func (pd *PetDelete) Exec(ctx context.Context) error { switch pd.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return pd.sqlExec(ctx) - case dialect.Neptune: + case dialect.Gremlin: return pd.gremlinExec(ctx) default: return errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/pet_query.go b/entc/integration/ent/pet_query.go index 9ccb48b05..02a48e767 100644 --- a/entc/integration/ent/pet_query.go +++ b/entc/integration/ent/pet_query.go @@ -69,7 +69,7 @@ func (pq *PetQuery) QueryTeam() *UserQuery { From(t1). Join(t2). On(t1.C(user.FieldID), t2.C(pet.TeamColumn)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := pq.gremlinQuery() query.gremlin = gremlin.InE(user.TeamLabel).OutV() } @@ -88,7 +88,7 @@ func (pq *PetQuery) QueryOwner() *UserQuery { From(t1). Join(t2). On(t1.C(user.FieldID), t2.C(pet.OwnerColumn)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := pq.gremlinQuery() query.gremlin = gremlin.InE(user.PetsLabel).OutV() } @@ -208,7 +208,7 @@ func (pq *PetQuery) All(ctx context.Context) ([]*Pet, error) { switch pq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return pq.sqlAll(ctx) - case dialect.Neptune: + case dialect.Gremlin: return pq.gremlinAll(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -229,7 +229,7 @@ func (pq *PetQuery) IDs(ctx context.Context) ([]string, error) { switch pq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return pq.sqlIDs(ctx) - case dialect.Neptune: + case dialect.Gremlin: return pq.gremlinIDs(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -250,7 +250,7 @@ func (pq *PetQuery) Count(ctx context.Context) (int, error) { switch pq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return pq.sqlCount(ctx) - case dialect.Neptune: + case dialect.Gremlin: return pq.gremlinCount(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -271,7 +271,7 @@ func (pq *PetQuery) Exist(ctx context.Context) (bool, error) { switch pq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return pq.sqlExist(ctx) - case dialect.Neptune: + case dialect.Gremlin: return pq.gremlinExist(ctx) default: return false, errors.New("ent: unsupported dialect") @@ -324,7 +324,7 @@ func (pq *PetQuery) GroupBy(field string, fields ...string) *PetGroupBy { switch pq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: group.sql = pq.sqlQuery() - case dialect.Neptune: + case dialect.Gremlin: group.gremlin = pq.gremlinQuery() } return group @@ -514,7 +514,7 @@ func (pgb *PetGroupBy) Scan(ctx context.Context, v interface{}) error { switch pgb.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return pgb.sqlScan(ctx, v) - case dialect.Neptune: + case dialect.Gremlin: return pgb.gremlinScan(ctx, v) default: return errors.New("pgb: unsupported dialect") diff --git a/entc/integration/ent/pet_update.go b/entc/integration/ent/pet_update.go index de8c2de69..0a3f6f109 100644 --- a/entc/integration/ent/pet_update.go +++ b/entc/integration/ent/pet_update.go @@ -111,7 +111,7 @@ func (pu *PetUpdate) Save(ctx context.Context) (int, error) { switch pu.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return pu.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return pu.gremlinSave(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -392,7 +392,7 @@ func (puo *PetUpdateOne) Save(ctx context.Context) (*Pet, error) { switch puo.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return puo.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return puo.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/user_create.go b/entc/integration/ent/user_create.go index 97efb66ce..9c3b409c5 100644 --- a/entc/integration/ent/user_create.go +++ b/entc/integration/ent/user_create.go @@ -352,7 +352,7 @@ func (uc *UserCreate) Save(ctx context.Context) (*User, error) { switch uc.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return uc.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return uc.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/user_delete.go b/entc/integration/ent/user_delete.go index 7136a1d84..38c9dce41 100644 --- a/entc/integration/ent/user_delete.go +++ b/entc/integration/ent/user_delete.go @@ -33,7 +33,7 @@ func (ud *UserDelete) Exec(ctx context.Context) error { switch ud.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ud.sqlExec(ctx) - case dialect.Neptune: + case dialect.Gremlin: return ud.gremlinExec(ctx) default: return errors.New("ent: unsupported dialect") diff --git a/entc/integration/ent/user_query.go b/entc/integration/ent/user_query.go index 2b68685d2..6745a5d0f 100644 --- a/entc/integration/ent/user_query.go +++ b/entc/integration/ent/user_query.go @@ -72,7 +72,7 @@ func (uq *UserQuery) QueryCard() *CardQuery { From(t1). Join(t2). On(t1.C(user.CardColumn), t2.C(user.FieldID)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := uq.gremlinQuery() query.gremlin = gremlin.OutE(user.CardLabel).InV() } @@ -91,7 +91,7 @@ func (uq *UserQuery) QueryPets() *PetQuery { From(t1). Join(t2). On(t1.C(user.PetsColumn), t2.C(user.FieldID)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := uq.gremlinQuery() query.gremlin = gremlin.OutE(user.PetsLabel).InV() } @@ -110,7 +110,7 @@ func (uq *UserQuery) QueryFiles() *FileQuery { From(t1). Join(t2). On(t1.C(user.FilesColumn), t2.C(user.FieldID)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := uq.gremlinQuery() query.gremlin = gremlin.OutE(user.FilesLabel).InV() } @@ -134,7 +134,7 @@ func (uq *UserQuery) QueryGroups() *GroupQuery { From(t1). Join(t4). On(t1.C(group.FieldID), t4.C(user.GroupsPrimaryKey[1])) - case dialect.Neptune: + case dialect.Gremlin: gremlin := uq.gremlinQuery() query.gremlin = gremlin.OutE(user.GroupsLabel).InV() } @@ -158,7 +158,7 @@ func (uq *UserQuery) QueryFriends() *UserQuery { From(t1). Join(t4). On(t1.C(user.FieldID), t4.C(user.FriendsPrimaryKey[1])) - case dialect.Neptune: + case dialect.Gremlin: gremlin := uq.gremlinQuery() query.gremlin = gremlin.Both(user.FriendsLabel) } @@ -182,7 +182,7 @@ func (uq *UserQuery) QueryFollowers() *UserQuery { From(t1). Join(t4). On(t1.C(user.FieldID), t4.C(user.FollowersPrimaryKey[0])) - case dialect.Neptune: + case dialect.Gremlin: gremlin := uq.gremlinQuery() query.gremlin = gremlin.InE(user.FollowingLabel).OutV() } @@ -206,7 +206,7 @@ func (uq *UserQuery) QueryFollowing() *UserQuery { From(t1). Join(t4). On(t1.C(user.FieldID), t4.C(user.FollowingPrimaryKey[1])) - case dialect.Neptune: + case dialect.Gremlin: gremlin := uq.gremlinQuery() query.gremlin = gremlin.OutE(user.FollowingLabel).InV() } @@ -225,7 +225,7 @@ func (uq *UserQuery) QueryTeam() *PetQuery { From(t1). Join(t2). On(t1.C(user.TeamColumn), t2.C(user.FieldID)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := uq.gremlinQuery() query.gremlin = gremlin.OutE(user.TeamLabel).InV() } @@ -244,7 +244,7 @@ func (uq *UserQuery) QuerySpouse() *UserQuery { From(t1). Join(t2). On(t1.C(user.SpouseColumn), t2.C(user.FieldID)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := uq.gremlinQuery() query.gremlin = gremlin.Both(user.SpouseLabel) } @@ -263,7 +263,7 @@ func (uq *UserQuery) QueryChildren() *UserQuery { From(t1). Join(t2). On(t1.C(user.ChildrenColumn), t2.C(user.FieldID)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := uq.gremlinQuery() query.gremlin = gremlin.InE(user.ParentLabel).OutV() } @@ -282,7 +282,7 @@ func (uq *UserQuery) QueryParent() *UserQuery { From(t1). Join(t2). On(t1.C(user.FieldID), t2.C(user.ParentColumn)) - case dialect.Neptune: + case dialect.Gremlin: gremlin := uq.gremlinQuery() query.gremlin = gremlin.OutE(user.ParentLabel).InV() } @@ -402,7 +402,7 @@ func (uq *UserQuery) All(ctx context.Context) ([]*User, error) { switch uq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return uq.sqlAll(ctx) - case dialect.Neptune: + case dialect.Gremlin: return uq.gremlinAll(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -423,7 +423,7 @@ func (uq *UserQuery) IDs(ctx context.Context) ([]string, error) { switch uq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return uq.sqlIDs(ctx) - case dialect.Neptune: + case dialect.Gremlin: return uq.gremlinIDs(ctx) default: return nil, errors.New("ent: unsupported dialect") @@ -444,7 +444,7 @@ func (uq *UserQuery) Count(ctx context.Context) (int, error) { switch uq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return uq.sqlCount(ctx) - case dialect.Neptune: + case dialect.Gremlin: return uq.gremlinCount(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -465,7 +465,7 @@ func (uq *UserQuery) Exist(ctx context.Context) (bool, error) { switch uq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return uq.sqlExist(ctx) - case dialect.Neptune: + case dialect.Gremlin: return uq.gremlinExist(ctx) default: return false, errors.New("ent: unsupported dialect") @@ -518,7 +518,7 @@ func (uq *UserQuery) GroupBy(field string, fields ...string) *UserGroupBy { switch uq.driver.Dialect() { case dialect.MySQL, dialect.SQLite: group.sql = uq.sqlQuery() - case dialect.Neptune: + case dialect.Gremlin: group.gremlin = uq.gremlinQuery() } return group @@ -708,7 +708,7 @@ func (ugb *UserGroupBy) Scan(ctx context.Context, v interface{}) error { switch ugb.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return ugb.sqlScan(ctx, v) - case dialect.Neptune: + case dialect.Gremlin: return ugb.gremlinScan(ctx, v) default: return errors.New("ugb: unsupported dialect") diff --git a/entc/integration/ent/user_update.go b/entc/integration/ent/user_update.go index 8c916e437..c4dd1feba 100644 --- a/entc/integration/ent/user_update.go +++ b/entc/integration/ent/user_update.go @@ -525,7 +525,7 @@ func (uu *UserUpdate) Save(ctx context.Context) (int, error) { switch uu.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return uu.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return uu.gremlinSave(ctx) default: return 0, errors.New("ent: unsupported dialect") @@ -1724,7 +1724,7 @@ func (uuo *UserUpdateOne) Save(ctx context.Context) (*User, error) { switch uuo.driver.Dialect() { case dialect.MySQL, dialect.SQLite: return uuo.sqlSave(ctx) - case dialect.Neptune: + case dialect.Gremlin: return uuo.gremlinSave(ctx) default: return nil, errors.New("ent: unsupported dialect")