entc/gen: move sql-delete to sqlgraph

This commit is contained in:
Ariel Mashraki
2019-12-18 15:14:53 +02:00
parent dc1a4cb89d
commit 04e9391c25
46 changed files with 765 additions and 677 deletions

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/edgeindex/ent/city"
"github.com/facebookincubator/ent/examples/edgeindex/ent/predicate"
"github.com/facebookincubator/ent/schema/field"
)
// CityDelete is the builder for deleting a City entity.
@@ -41,23 +43,23 @@ func (cd *CityDelete) ExecX(ctx context.Context) int {
}
func (cd *CityDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(cd.driver.Dialect())
)
selector := builder.Select().From(sql.Table(city.Table))
for _, p := range cd.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: city.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: city.FieldID,
},
},
}
query, args := builder.Delete(city.Table).FromSelect(selector).Query()
if err := cd.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := cd.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, cd.driver, spec)
}
// CityDeleteOne is the builder for deleting a single City entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/edgeindex/ent/predicate"
"github.com/facebookincubator/ent/examples/edgeindex/ent/street"
"github.com/facebookincubator/ent/schema/field"
)
// StreetDelete is the builder for deleting a Street entity.
@@ -41,23 +43,23 @@ func (sd *StreetDelete) ExecX(ctx context.Context) int {
}
func (sd *StreetDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(sd.driver.Dialect())
)
selector := builder.Select().From(sql.Table(street.Table))
for _, p := range sd.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: street.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: street.FieldID,
},
},
}
query, args := builder.Delete(street.Table).FromSelect(selector).Query()
if err := sd.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := sd.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, sd.driver, spec)
}
// StreetDeleteOne is the builder for deleting a single Street entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/entcpkg/ent/predicate"
"github.com/facebookincubator/ent/examples/entcpkg/ent/user"
"github.com/facebookincubator/ent/schema/field"
)
// UserDelete is the builder for deleting a User entity.
@@ -41,23 +43,23 @@ func (ud *UserDelete) ExecX(ctx context.Context) int {
}
func (ud *UserDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(ud.driver.Dialect())
)
selector := builder.Select().From(sql.Table(user.Table))
for _, p := range ud.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: user.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: user.FieldID,
},
},
}
query, args := builder.Delete(user.Table).FromSelect(selector).Query()
if err := ud.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := ud.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, ud.driver, spec)
}
// UserDeleteOne is the builder for deleting a single User entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/m2m2types/ent/group"
"github.com/facebookincubator/ent/examples/m2m2types/ent/predicate"
"github.com/facebookincubator/ent/schema/field"
)
// GroupDelete is the builder for deleting a Group entity.
@@ -41,23 +43,23 @@ func (gd *GroupDelete) ExecX(ctx context.Context) int {
}
func (gd *GroupDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(gd.driver.Dialect())
)
selector := builder.Select().From(sql.Table(group.Table))
for _, p := range gd.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: group.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: group.FieldID,
},
},
}
query, args := builder.Delete(group.Table).FromSelect(selector).Query()
if err := gd.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := gd.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, gd.driver, spec)
}
// GroupDeleteOne is the builder for deleting a single Group entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/m2m2types/ent/predicate"
"github.com/facebookincubator/ent/examples/m2m2types/ent/user"
"github.com/facebookincubator/ent/schema/field"
)
// UserDelete is the builder for deleting a User entity.
@@ -41,23 +43,23 @@ func (ud *UserDelete) ExecX(ctx context.Context) int {
}
func (ud *UserDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(ud.driver.Dialect())
)
selector := builder.Select().From(sql.Table(user.Table))
for _, p := range ud.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: user.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: user.FieldID,
},
},
}
query, args := builder.Delete(user.Table).FromSelect(selector).Query()
if err := ud.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := ud.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, ud.driver, spec)
}
// UserDeleteOne is the builder for deleting a single User entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/m2mbidi/ent/predicate"
"github.com/facebookincubator/ent/examples/m2mbidi/ent/user"
"github.com/facebookincubator/ent/schema/field"
)
// UserDelete is the builder for deleting a User entity.
@@ -41,23 +43,23 @@ func (ud *UserDelete) ExecX(ctx context.Context) int {
}
func (ud *UserDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(ud.driver.Dialect())
)
selector := builder.Select().From(sql.Table(user.Table))
for _, p := range ud.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: user.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: user.FieldID,
},
},
}
query, args := builder.Delete(user.Table).FromSelect(selector).Query()
if err := ud.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := ud.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, ud.driver, spec)
}
// UserDeleteOne is the builder for deleting a single User entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/m2mrecur/ent/predicate"
"github.com/facebookincubator/ent/examples/m2mrecur/ent/user"
"github.com/facebookincubator/ent/schema/field"
)
// UserDelete is the builder for deleting a User entity.
@@ -41,23 +43,23 @@ func (ud *UserDelete) ExecX(ctx context.Context) int {
}
func (ud *UserDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(ud.driver.Dialect())
)
selector := builder.Select().From(sql.Table(user.Table))
for _, p := range ud.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: user.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: user.FieldID,
},
},
}
query, args := builder.Delete(user.Table).FromSelect(selector).Query()
if err := ud.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := ud.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, ud.driver, spec)
}
// UserDeleteOne is the builder for deleting a single User entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/o2m2types/ent/pet"
"github.com/facebookincubator/ent/examples/o2m2types/ent/predicate"
"github.com/facebookincubator/ent/schema/field"
)
// PetDelete is the builder for deleting a Pet entity.
@@ -41,23 +43,23 @@ func (pd *PetDelete) ExecX(ctx context.Context) int {
}
func (pd *PetDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(pd.driver.Dialect())
)
selector := builder.Select().From(sql.Table(pet.Table))
for _, p := range pd.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: pet.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: pet.FieldID,
},
},
}
query, args := builder.Delete(pet.Table).FromSelect(selector).Query()
if err := pd.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := pd.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, pd.driver, spec)
}
// PetDeleteOne is the builder for deleting a single Pet entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/o2m2types/ent/predicate"
"github.com/facebookincubator/ent/examples/o2m2types/ent/user"
"github.com/facebookincubator/ent/schema/field"
)
// UserDelete is the builder for deleting a User entity.
@@ -41,23 +43,23 @@ func (ud *UserDelete) ExecX(ctx context.Context) int {
}
func (ud *UserDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(ud.driver.Dialect())
)
selector := builder.Select().From(sql.Table(user.Table))
for _, p := range ud.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: user.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: user.FieldID,
},
},
}
query, args := builder.Delete(user.Table).FromSelect(selector).Query()
if err := ud.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := ud.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, ud.driver, spec)
}
// UserDeleteOne is the builder for deleting a single User entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/o2mrecur/ent/node"
"github.com/facebookincubator/ent/examples/o2mrecur/ent/predicate"
"github.com/facebookincubator/ent/schema/field"
)
// NodeDelete is the builder for deleting a Node entity.
@@ -41,23 +43,23 @@ func (nd *NodeDelete) ExecX(ctx context.Context) int {
}
func (nd *NodeDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(nd.driver.Dialect())
)
selector := builder.Select().From(sql.Table(node.Table))
for _, p := range nd.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: node.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: node.FieldID,
},
},
}
query, args := builder.Delete(node.Table).FromSelect(selector).Query()
if err := nd.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := nd.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, nd.driver, spec)
}
// NodeDeleteOne is the builder for deleting a single Node entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/o2o2types/ent/card"
"github.com/facebookincubator/ent/examples/o2o2types/ent/predicate"
"github.com/facebookincubator/ent/schema/field"
)
// CardDelete is the builder for deleting a Card entity.
@@ -41,23 +43,23 @@ func (cd *CardDelete) ExecX(ctx context.Context) int {
}
func (cd *CardDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(cd.driver.Dialect())
)
selector := builder.Select().From(sql.Table(card.Table))
for _, p := range cd.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: card.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: card.FieldID,
},
},
}
query, args := builder.Delete(card.Table).FromSelect(selector).Query()
if err := cd.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := cd.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, cd.driver, spec)
}
// CardDeleteOne is the builder for deleting a single Card entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/o2o2types/ent/predicate"
"github.com/facebookincubator/ent/examples/o2o2types/ent/user"
"github.com/facebookincubator/ent/schema/field"
)
// UserDelete is the builder for deleting a User entity.
@@ -41,23 +43,23 @@ func (ud *UserDelete) ExecX(ctx context.Context) int {
}
func (ud *UserDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(ud.driver.Dialect())
)
selector := builder.Select().From(sql.Table(user.Table))
for _, p := range ud.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: user.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: user.FieldID,
},
},
}
query, args := builder.Delete(user.Table).FromSelect(selector).Query()
if err := ud.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := ud.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, ud.driver, spec)
}
// UserDeleteOne is the builder for deleting a single User entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/o2obidi/ent/predicate"
"github.com/facebookincubator/ent/examples/o2obidi/ent/user"
"github.com/facebookincubator/ent/schema/field"
)
// UserDelete is the builder for deleting a User entity.
@@ -41,23 +43,23 @@ func (ud *UserDelete) ExecX(ctx context.Context) int {
}
func (ud *UserDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(ud.driver.Dialect())
)
selector := builder.Select().From(sql.Table(user.Table))
for _, p := range ud.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: user.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: user.FieldID,
},
},
}
query, args := builder.Delete(user.Table).FromSelect(selector).Query()
if err := ud.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := ud.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, ud.driver, spec)
}
// UserDeleteOne is the builder for deleting a single User entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/o2orecur/ent/node"
"github.com/facebookincubator/ent/examples/o2orecur/ent/predicate"
"github.com/facebookincubator/ent/schema/field"
)
// NodeDelete is the builder for deleting a Node entity.
@@ -41,23 +43,23 @@ func (nd *NodeDelete) ExecX(ctx context.Context) int {
}
func (nd *NodeDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(nd.driver.Dialect())
)
selector := builder.Select().From(sql.Table(node.Table))
for _, p := range nd.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: node.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: node.FieldID,
},
},
}
query, args := builder.Delete(node.Table).FromSelect(selector).Query()
if err := nd.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := nd.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, nd.driver, spec)
}
// NodeDeleteOne is the builder for deleting a single Node entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/start/ent/car"
"github.com/facebookincubator/ent/examples/start/ent/predicate"
"github.com/facebookincubator/ent/schema/field"
)
// CarDelete is the builder for deleting a Car entity.
@@ -41,23 +43,23 @@ func (cd *CarDelete) ExecX(ctx context.Context) int {
}
func (cd *CarDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(cd.driver.Dialect())
)
selector := builder.Select().From(sql.Table(car.Table))
for _, p := range cd.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: car.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: car.FieldID,
},
},
}
query, args := builder.Delete(car.Table).FromSelect(selector).Query()
if err := cd.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := cd.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, cd.driver, spec)
}
// CarDeleteOne is the builder for deleting a single Car entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/start/ent/group"
"github.com/facebookincubator/ent/examples/start/ent/predicate"
"github.com/facebookincubator/ent/schema/field"
)
// GroupDelete is the builder for deleting a Group entity.
@@ -41,23 +43,23 @@ func (gd *GroupDelete) ExecX(ctx context.Context) int {
}
func (gd *GroupDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(gd.driver.Dialect())
)
selector := builder.Select().From(sql.Table(group.Table))
for _, p := range gd.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: group.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: group.FieldID,
},
},
}
query, args := builder.Delete(group.Table).FromSelect(selector).Query()
if err := gd.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := gd.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, gd.driver, spec)
}
// GroupDeleteOne is the builder for deleting a single Group entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/start/ent/predicate"
"github.com/facebookincubator/ent/examples/start/ent/user"
"github.com/facebookincubator/ent/schema/field"
)
// UserDelete is the builder for deleting a User entity.
@@ -41,23 +43,23 @@ func (ud *UserDelete) ExecX(ctx context.Context) int {
}
func (ud *UserDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(ud.driver.Dialect())
)
selector := builder.Select().From(sql.Table(user.Table))
for _, p := range ud.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: user.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: user.FieldID,
},
},
}
query, args := builder.Delete(user.Table).FromSelect(selector).Query()
if err := ud.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := ud.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, ud.driver, spec)
}
// UserDeleteOne is the builder for deleting a single User entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/traversal/ent/group"
"github.com/facebookincubator/ent/examples/traversal/ent/predicate"
"github.com/facebookincubator/ent/schema/field"
)
// GroupDelete is the builder for deleting a Group entity.
@@ -41,23 +43,23 @@ func (gd *GroupDelete) ExecX(ctx context.Context) int {
}
func (gd *GroupDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(gd.driver.Dialect())
)
selector := builder.Select().From(sql.Table(group.Table))
for _, p := range gd.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: group.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: group.FieldID,
},
},
}
query, args := builder.Delete(group.Table).FromSelect(selector).Query()
if err := gd.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := gd.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, gd.driver, spec)
}
// GroupDeleteOne is the builder for deleting a single Group entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/traversal/ent/pet"
"github.com/facebookincubator/ent/examples/traversal/ent/predicate"
"github.com/facebookincubator/ent/schema/field"
)
// PetDelete is the builder for deleting a Pet entity.
@@ -41,23 +43,23 @@ func (pd *PetDelete) ExecX(ctx context.Context) int {
}
func (pd *PetDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(pd.driver.Dialect())
)
selector := builder.Select().From(sql.Table(pet.Table))
for _, p := range pd.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: pet.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: pet.FieldID,
},
},
}
query, args := builder.Delete(pet.Table).FromSelect(selector).Query()
if err := pd.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := pd.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, pd.driver, spec)
}
// PetDeleteOne is the builder for deleting a single Pet entity.

View File

@@ -10,8 +10,10 @@ import (
"context"
"github.com/facebookincubator/ent/dialect/sql"
"github.com/facebookincubator/ent/dialect/sql/sqlgraph"
"github.com/facebookincubator/ent/examples/traversal/ent/predicate"
"github.com/facebookincubator/ent/examples/traversal/ent/user"
"github.com/facebookincubator/ent/schema/field"
)
// UserDelete is the builder for deleting a User entity.
@@ -41,23 +43,23 @@ func (ud *UserDelete) ExecX(ctx context.Context) int {
}
func (ud *UserDelete) sqlExec(ctx context.Context) (int, error) {
var (
res sql.Result
builder = sql.Dialect(ud.driver.Dialect())
)
selector := builder.Select().From(sql.Table(user.Table))
for _, p := range ud.predicates {
p(selector)
spec := &sqlgraph.DeleteSpec{
Node: &sqlgraph.NodeSpec{
Table: user.Table,
ID: &sqlgraph.FieldSpec{
Type: field.TypeInt,
Column: user.FieldID,
},
},
}
query, args := builder.Delete(user.Table).FromSelect(selector).Query()
if err := ud.driver.Exec(ctx, query, args, &res); err != nil {
return 0, err
if ps := ud.predicates; len(ps) > 0 {
spec.Predicate = func(selector *sql.Selector) {
for i := range ps {
ps[i](selector)
}
}
}
affected, err := res.RowsAffected()
if err != nil {
return 0, err
}
return int(affected), nil
return sqlgraph.DeleteNodes(ctx, ud.driver, spec)
}
// UserDeleteOne is the builder for deleting a single User entity.