change_sets.sql.go

// Code generated by sqlc. DO NOT EDIT.
// versions:
//   sqlc v1.30.0
// source: change_sets.sql

package postgres

import (
	"context"
	"encoding/json"

	"github.com/jackc/pgx/v5/pgtype"
)

const createChange = `-- name: CreateChange :one

INSERT INTO changes (external_id, change_set_id, change_type, object_type, object_primary_value, object_id,
                     ref_id, object_version, before, after, new_refs,
                     sequence_number)
VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12)
RETURNING id, external_id, change_set_id, change_type, object_type, object_primary_value, object_id, ref_id, object_version, before, after, new_refs, sequence_number, created_at, updated_at
`

type CreateChangeParams struct {
	ExternalID         string          `json:"external_id"`
	ChangeSetID        int32           `json:"change_set_id"`
	ChangeType         string          `json:"change_type"`
	ObjectType         string          `json:"object_type"`
	ObjectPrimaryValue string          `json:"object_primary_value"`
	ObjectID           pgtype.Int4     `json:"object_id"`
	RefID              pgtype.Text     `json:"ref_id"`
	ObjectVersion      pgtype.Int4     `json:"object_version"`
	Before             json.RawMessage `json:"before"`
	After              json.RawMessage `json:"after"`
	NewRefs            []string        `json:"new_refs"`
	SequenceNumber     pgtype.Int4     `json:"sequence_number"`
}

func (q *Queries) CreateChange(ctx context.Context, arg CreateChangeParams) (Change, error) {
	row := q.db.QueryRow(ctx, createChange,
		arg.ExternalID,
		arg.ChangeSetID,
		arg.ChangeType,
		arg.ObjectType,
		arg.ObjectPrimaryValue,
		arg.ObjectID,
		arg.RefID,
		arg.ObjectVersion,
		arg.Before,
		arg.After,
		arg.NewRefs,
		arg.SequenceNumber,
	)
	var i Change
	err := row.Scan(
		&i.ID,
		&i.ExternalID,
		&i.ChangeSetID,
		&i.ChangeType,
		&i.ObjectType,
		&i.ObjectPrimaryValue,
		&i.ObjectID,
		&i.RefID,
		&i.ObjectVersion,
		&i.Before,
		&i.After,
		&i.NewRefs,
		&i.SequenceNumber,
		&i.CreatedAt,
		&i.UpdatedAt,
	)
	return i, err
}

const createChangeSet = `-- name: CreateChangeSet :one

INSERT INTO change_sets (external_id, ingestion_log_id, branch_id, deviation_name)
VALUES ($1, $2, $3, $4)
RETURNING id, external_id, ingestion_log_id, branch_id, deviation_name, created_at, updated_at
`

type CreateChangeSetParams struct {
	ExternalID     string      `json:"external_id"`
	IngestionLogID int32       `json:"ingestion_log_id"`
	BranchID       pgtype.Text `json:"branch_id"`
	DeviationName  pgtype.Text `json:"deviation_name"`
}

func (q *Queries) CreateChangeSet(ctx context.Context, arg CreateChangeSetParams) (ChangeSet, error) {
	row := q.db.QueryRow(ctx, createChangeSet,
		arg.ExternalID,
		arg.IngestionLogID,
		arg.BranchID,
		arg.DeviationName,
	)
	var i ChangeSet
	err := row.Scan(
		&i.ID,
		&i.ExternalID,
		&i.IngestionLogID,
		&i.BranchID,
		&i.DeviationName,
		&i.CreatedAt,
		&i.UpdatedAt,
	)
	return i, err
}

const truncateChangeSets = `-- name: TruncateChangeSets :exec
DELETE FROM change_sets cs1
WHERE cs1.ingestion_log_id = $1
  AND cs1.id NOT IN (
    SELECT cs2.id
    FROM change_sets cs2
    WHERE cs2.ingestion_log_id = $1
    ORDER BY cs2.id DESC
    LIMIT $2
  )
`

type TruncateChangeSetsParams struct {
	IngestionLogID int32 `json:"ingestion_log_id"`
	Limit          int32 `json:"limit"`
}

func (q *Queries) TruncateChangeSets(ctx context.Context, arg TruncateChangeSetsParams) error {
	_, err := q.db.Exec(ctx, truncateChangeSets, arg.IngestionLogID, arg.Limit)
	return err
}