mirror of
https://github.com/ent/ent.git
synced 2026-05-24 09:31:56 +03:00
entc/gen/sql: move spec creation to a function (#604)
To be shared with batch-create builder
This commit is contained in:
@@ -106,6 +106,19 @@ func (cc *CarCreate) SaveX(ctx context.Context) *Car {
|
||||
}
|
||||
|
||||
func (cc *CarCreate) sqlSave(ctx context.Context) (*Car, error) {
|
||||
c, _spec := cc.createSpec()
|
||||
if err := sqlgraph.CreateNode(ctx, cc.driver, _spec); err != nil {
|
||||
if cerr, ok := isSQLConstraintError(err); ok {
|
||||
err = cerr
|
||||
}
|
||||
return nil, err
|
||||
}
|
||||
id := _spec.ID.Value.(int64)
|
||||
c.ID = int(id)
|
||||
return c, nil
|
||||
}
|
||||
|
||||
func (cc *CarCreate) createSpec() (*Car, *sqlgraph.CreateSpec) {
|
||||
var (
|
||||
c = &Car{config: cc.config}
|
||||
_spec = &sqlgraph.CreateSpec{
|
||||
@@ -151,13 +164,5 @@ func (cc *CarCreate) sqlSave(ctx context.Context) (*Car, error) {
|
||||
}
|
||||
_spec.Edges = append(_spec.Edges, edge)
|
||||
}
|
||||
if err := sqlgraph.CreateNode(ctx, cc.driver, _spec); err != nil {
|
||||
if cerr, ok := isSQLConstraintError(err); ok {
|
||||
err = cerr
|
||||
}
|
||||
return nil, err
|
||||
}
|
||||
id := _spec.ID.Value.(int64)
|
||||
c.ID = int(id)
|
||||
return c, nil
|
||||
return c, _spec
|
||||
}
|
||||
|
||||
@@ -97,6 +97,19 @@ func (gc *GroupCreate) SaveX(ctx context.Context) *Group {
|
||||
}
|
||||
|
||||
func (gc *GroupCreate) sqlSave(ctx context.Context) (*Group, error) {
|
||||
gr, _spec := gc.createSpec()
|
||||
if err := sqlgraph.CreateNode(ctx, gc.driver, _spec); err != nil {
|
||||
if cerr, ok := isSQLConstraintError(err); ok {
|
||||
err = cerr
|
||||
}
|
||||
return nil, err
|
||||
}
|
||||
id := _spec.ID.Value.(int64)
|
||||
gr.ID = int(id)
|
||||
return gr, nil
|
||||
}
|
||||
|
||||
func (gc *GroupCreate) createSpec() (*Group, *sqlgraph.CreateSpec) {
|
||||
var (
|
||||
gr = &Group{config: gc.config}
|
||||
_spec = &sqlgraph.CreateSpec{
|
||||
@@ -134,13 +147,5 @@ func (gc *GroupCreate) sqlSave(ctx context.Context) (*Group, error) {
|
||||
}
|
||||
_spec.Edges = append(_spec.Edges, edge)
|
||||
}
|
||||
if err := sqlgraph.CreateNode(ctx, gc.driver, _spec); err != nil {
|
||||
if cerr, ok := isSQLConstraintError(err); ok {
|
||||
err = cerr
|
||||
}
|
||||
return nil, err
|
||||
}
|
||||
id := _spec.ID.Value.(int64)
|
||||
gr.ID = int(id)
|
||||
return gr, nil
|
||||
return gr, _spec
|
||||
}
|
||||
|
||||
@@ -131,6 +131,19 @@ func (uc *UserCreate) SaveX(ctx context.Context) *User {
|
||||
}
|
||||
|
||||
func (uc *UserCreate) sqlSave(ctx context.Context) (*User, error) {
|
||||
u, _spec := uc.createSpec()
|
||||
if err := sqlgraph.CreateNode(ctx, uc.driver, _spec); err != nil {
|
||||
if cerr, ok := isSQLConstraintError(err); ok {
|
||||
err = cerr
|
||||
}
|
||||
return nil, err
|
||||
}
|
||||
id := _spec.ID.Value.(int64)
|
||||
u.ID = int(id)
|
||||
return u, nil
|
||||
}
|
||||
|
||||
func (uc *UserCreate) createSpec() (*User, *sqlgraph.CreateSpec) {
|
||||
var (
|
||||
u = &User{config: uc.config}
|
||||
_spec = &sqlgraph.CreateSpec{
|
||||
@@ -195,13 +208,5 @@ func (uc *UserCreate) sqlSave(ctx context.Context) (*User, error) {
|
||||
}
|
||||
_spec.Edges = append(_spec.Edges, edge)
|
||||
}
|
||||
if err := sqlgraph.CreateNode(ctx, uc.driver, _spec); err != nil {
|
||||
if cerr, ok := isSQLConstraintError(err); ok {
|
||||
err = cerr
|
||||
}
|
||||
return nil, err
|
||||
}
|
||||
id := _spec.ID.Value.(int64)
|
||||
u.ID = int(id)
|
||||
return u, nil
|
||||
return u, _spec
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user