Method CreateWithTransaction

server/resource/resource_create.go:1000–1044

(obj interface{}, req api2go.Request, transaction *sqlx.Tx)

}

func (dbResource *DbResource) CreateWithTransaction(obj interface{}, req api2go.Request, transaction *sqlx.Tx) (api2go.Responder, error) {
	data := obj.(api2go.Api2GoModel)
	//log.Printf("Create object request: [%v] %v", dbResource.model.GetTableName(), data.Data)

	for _, bf := range dbResource.ms.BeforeCreate {
		//log.Printf("Invoke BeforeCreate [%v][%v] on Create Request", bf.String(), dbResource.model.GetName())
		data.SetType(dbResource.model.GetName())
		responseData, err := bf.InterceptBefore(dbResource, &req, []map[string]interface{}{data.GetAttributes()}, transaction)
		if err != nil {
			log.Warnf("Error from BeforeCreate[%v]: %v", bf.String(), err)
			return nil, err
		}
		if responseData == nil {
			return nil, errors.New(fmt.Sprintf("No object to act upon after %v", bf.String()))
		}
	}

	createdResource, err := dbResource.CreateWithoutFilter(obj, req, transaction)
	if err != nil {
		return NewResponse(nil, nil, 500, nil), err
	}

	for _, bf := range dbResource.ms.AfterCreate {
		log.Tracef("Invoke AfterCreate [%v][%v] on Create Request", bf.String(), dbResource.model.GetName())
		results, err := bf.InterceptAfter(dbResource, &req, []map[string]interface{}{createdResource}, transaction)
		if err != nil {
			log.Errorf("Error from AfterCreate[%v] middleware: %v", bf.String(), err)
		}
		if len(results) < 1 {
			createdResource = nil
		} else {
			createdResource = results[0]
		}
	}

	n1 := dbResource.model.GetName()
	c1 := dbResource.model.GetColumns()
	p1 := dbResource.model.GetDefaultPermission()
	r1 := dbResource.model.GetRelations()
	return NewResponse(nil,
		api2go.NewApi2GoModelWithData(n1, c1, p1, r1, createdResource),
		201, nil,
	), nil

}

func (dbResource *DbResource) Create(obj interface{}, req api2go.Request) (api2go.Responder, error) {
	data := obj.(api2go.Api2GoModel)