internal/endtoend/testdata/wrap_errors/sqlite/db/query.sql.go - main - githubmirror/sqlc

internal/endtoend/testdata/wrap_errors/sqlite/db/query.sql.go
128 строк3 KB
Kyle Gray
Release 1.31.1 (#4407)
22 апр 2026, 17:52
22 апр 2026, 17:52a95e91d
// Code generated by sqlc. DO NOT EDIT.
// versions:
//   sqlc v1.31.1
// source: query.sql

package authors

import (
	"context"
	"database/sql"
	"fmt"
)

const createAuthor = `-- name: CreateAuthor :execlastid
INSERT INTO authors (
          name, bio
) VALUES (
  ?1, ?2
)
`

type CreateAuthorParams struct {
	Name string
	Bio  sql.NullString
}

func (q *Queries) CreateAuthor(ctx context.Context, arg CreateAuthorParams) (int64, error) {
	result, err := q.db.ExecContext(ctx, createAuthor, arg.Name, arg.Bio)
	if err != nil {
		return 0, fmt.Errorf("query CreateAuthor: %w", err)
	}
	return result.LastInsertId()
}

const deleteAuthorExec = `-- name: DeleteAuthorExec :exec
DELETE FROM authors
WHERE id = ?1
`

func (q *Queries) DeleteAuthorExec(ctx context.Context, id int64) error {
	_, err := q.db.ExecContext(ctx, deleteAuthorExec, id)
	if err != nil {
		err = fmt.Errorf("query DeleteAuthorExec: %w", err)
	}
	return err
}

const deleteAuthorExecLastID = `-- name: DeleteAuthorExecLastID :execlastid
DELETE FROM authors
WHERE id = ?1
`

func (q *Queries) DeleteAuthorExecLastID(ctx context.Context, id int64) (int64, error) {
	result, err := q.db.ExecContext(ctx, deleteAuthorExecLastID, id)
	if err != nil {
		return 0, fmt.Errorf("query DeleteAuthorExecLastID: %w", err)
	}
	return result.LastInsertId()
}

const deleteAuthorExecResult = `-- name: DeleteAuthorExecResult :execresult
DELETE FROM authors
WHERE id = ?1
`

func (q *Queries) DeleteAuthorExecResult(ctx context.Context, id int64) (sql.Result, error) {
	result, err := q.db.ExecContext(ctx, deleteAuthorExecResult, id)
	if err != nil {
		err = fmt.Errorf("query DeleteAuthorExecResult: %w", err)
	}
	return result, err
}

const deleteAuthorExecRows = `-- name: DeleteAuthorExecRows :execrows
DELETE FROM authors
WHERE id = ?1
`

func (q *Queries) DeleteAuthorExecRows(ctx context.Context, id int64) (int64, error) {
	result, err := q.db.ExecContext(ctx, deleteAuthorExecRows, id)
	if err != nil {
		return 0, fmt.Errorf("query DeleteAuthorExecRows: %w", err)
	}
	return result.RowsAffected()
}

const getAuthor = `-- name: GetAuthor :one
SELECT id, name, bio FROM authors
WHERE id = ?1 LIMIT 1
`

func (q *Queries) GetAuthor(ctx context.Context, id int64) (Author, error) {
	row := q.db.QueryRowContext(ctx, getAuthor, id)
	var i Author
	err := row.Scan(&i.ID, &i.Name, &i.Bio)
	if err != nil {
		err = fmt.Errorf("query GetAuthor: %w", err)
	}
	return i, err
}

const listAuthors = `-- name: ListAuthors :many
SELECT id, name, bio FROM authors
ORDER BY name
`

func (q *Queries) ListAuthors(ctx context.Context) ([]Author, error) {
	rows, err := q.db.QueryContext(ctx, listAuthors)
	if err != nil {
		return nil, fmt.Errorf("query ListAuthors: %w", err)
	}
	defer rows.Close()
	var items []Author
	for rows.Next() {
		var i Author
		if err := rows.Scan(&i.ID, &i.Name, &i.Bio); err != nil {
			return nil, fmt.Errorf("query ListAuthors: %w", err)
		}
		items = append(items, i)
	}
	if err := rows.Close(); err != nil {
		return nil, fmt.Errorf("query ListAuthors: %w", err)
	}
	if err := rows.Err(); err != nil {
		return nil, fmt.Errorf("query ListAuthors: %w", err)
	}
	return items, nil
}