region.xo.go

package sqlserver

// Code generated by xo. DO NOT EDIT.

import (
	"context"
)

// Region represents a row from 'northwind.region'.
type Region struct {
	RegionID          int16  `json:"region_id"`          // region_id
	RegionDescription string `json:"region_description"` // region_description
	// xo fields
	_exists, _deleted bool
}

// Exists returns true when the Region exists in the database.
func (r *Region) Exists() bool {
	return r._exists
}

// Deleted returns true when the Region has been marked for deletion from
// the database.
func (r *Region) Deleted() bool {
	return r._deleted
}

// Insert inserts the Region to the database.
func (r *Region) Insert(ctx context.Context, db DB) error {
	switch {
	case r._exists: // already exists
		return logerror(&ErrInsertFailed{ErrAlreadyExists})
	case r._deleted: // deleted
		return logerror(&ErrInsertFailed{ErrMarkedForDeletion})
	}
	// insert (manual)
	const sqlstr = `INSERT INTO northwind.region (` +
		`region_id, region_description` +
		`) VALUES (` +
		`@p1, @p2` +
		`)`
	// run
	logf(sqlstr, r.RegionID, r.RegionDescription)
	if _, err := db.ExecContext(ctx, sqlstr, r.RegionID, r.RegionDescription); err != nil {
		return logerror(err)
	}
	// set exists
	r._exists = true
	return nil
}

// Update updates a Region in the database.
func (r *Region) Update(ctx context.Context, db DB) error {
	switch {
	case !r._exists: // doesn't exist
		return logerror(&ErrUpdateFailed{ErrDoesNotExist})
	case r._deleted: // deleted
		return logerror(&ErrUpdateFailed{ErrMarkedForDeletion})
	}
	// update with primary key
	const sqlstr = `UPDATE northwind.region SET ` +
		`region_description = @p1 ` +
		`WHERE region_id = @p2`
	// run
	logf(sqlstr, r.RegionDescription, r.RegionID)
	if _, err := db.ExecContext(ctx, sqlstr, r.RegionDescription, r.RegionID); err != nil {
		return logerror(err)
	}
	return nil
}

// Save saves the Region to the database.
func (r *Region) Save(ctx context.Context, db DB) error {
	if r.Exists() {
		return r.Update(ctx, db)
	}
	return r.Insert(ctx, db)
}

// Upsert performs an upsert for Region.
func (r *Region) Upsert(ctx context.Context, db DB) error {
	switch {
	case r._deleted: // deleted
		return logerror(&ErrUpsertFailed{ErrMarkedForDeletion})
	}
	// upsert
	const sqlstr = `MERGE northwind.region AS t ` +
		`USING (` +
		`SELECT @p1 region_id, @p2 region_description ` +
		`) AS s ` +
		`ON s.region_id = t.region_id ` +
		`WHEN MATCHED THEN ` +
		`UPDATE SET ` +
		`t.region_description = s.region_description ` +
		`WHEN NOT MATCHED THEN ` +
		`INSERT (` +
		`region_id, region_description` +
		`) VALUES (` +
		`s.region_id, s.region_description` +
		`);`
	// run
	logf(sqlstr, r.RegionID, r.RegionDescription)
	if _, err := db.ExecContext(ctx, sqlstr, r.RegionID, r.RegionDescription); err != nil {
		return logerror(err)
	}
	// set exists
	r._exists = true
	return nil
}

// Delete deletes the Region from the database.
func (r *Region) Delete(ctx context.Context, db DB) error {
	switch {
	case !r._exists: // doesn't exist
		return nil
	case r._deleted: // deleted
		return nil
	}
	// delete with single primary key
	const sqlstr = `DELETE FROM northwind.region ` +
		`WHERE region_id = @p1`
	// run
	logf(sqlstr, r.RegionID)
	if _, err := db.ExecContext(ctx, sqlstr, r.RegionID); err != nil {
		return logerror(err)
	}
	// set deleted
	r._deleted = true
	return nil
}

// RegionByRegionID retrieves a row from 'northwind.region' as a Region.
//
// Generated from index 'regions_pkey'.
func RegionByRegionID(ctx context.Context, db DB, regionID int16) (*Region, error) {
	// query
	const sqlstr = `SELECT ` +
		`region_id, region_description ` +
		`FROM northwind.region ` +
		`WHERE region_id = @p1`
	// run
	logf(sqlstr, regionID)
	r := Region{
		_exists: true,
	}
	if err := db.QueryRowContext(ctx, sqlstr, regionID).Scan(&r.RegionID, &r.RegionDescription); err != nil {
		return nil, logerror(err)
	}
	return &r, nil
}