Method createWithTransaction

lib/gcpspanner/client.go:599–633

(
	_ context.Context,
	txn *spanner.ReadWriteTransaction,
	req CreateRequest,
	opts ...CreateOption)

}

func (c *entityCreator[M, CreateRequest, SpannerStruct]) createWithTransaction(
	_ context.Context,
	txn *spanner.ReadWriteTransaction,
	req CreateRequest,
	opts ...CreateOption) (*string, error) {
	options := &createOptions{
		id: "",
	}
	for _, opt := range opts {
		opt(options)
	}

	var entityID string
	if options.id != "" {
		entityID = options.id
	} else {
		entityID = uuid.NewString()
	}

	var mapper M
	entity, err := mapper.NewEntity(entityID, req)
	if err != nil {
		return nil, err
	}
	m, err := spanner.InsertStruct(mapper.Table(), entity)
	if err != nil {
		return nil, errors.Join(ErrInternalMutationFailure, err)
	}
	err = txn.BufferWrite([]*spanner.Mutation{m})
	if err != nil {
		return nil, errors.Join(ErrInternalMutationFailure, err)
	}

	return &entityID, nil
}

// syncableEntityMapper is composed for the entitySynchronizer. It needs
// methods to read all entities, handle keys, merge, and delete by struct.