imc-vibe/backend/internal/db/sqlc/imc_users.sql.go

233 lines
6.1 KiB
Go

// Code generated by sqlc. DO NOT EDIT.
// versions:
// sqlc v1.30.0
// source: imc_users.sql
package db
import (
"context"
)
const addUserToDomain = `-- name: AddUserToDomain :exec
INSERT INTO imc_users2domains (user_id, domain_id) VALUES (?, ?)
`
type AddUserToDomainParams struct {
UserID uint32 `json:"user_id"`
DomainID uint32 `json:"domain_id"`
}
func (q *Queries) AddUserToDomain(ctx context.Context, arg AddUserToDomainParams) error {
_, err := q.db.ExecContext(ctx, addUserToDomain, arg.UserID, arg.DomainID)
return err
}
const createImcUser = `-- name: CreateImcUser :exec
INSERT INTO imc_users (username, password_hash, role, domain_id) VALUES (?, ?, ?, ?)
`
type CreateImcUserParams struct {
Username string `json:"username"`
PasswordHash string `json:"password_hash"`
Role NullImcUsersRole `json:"role"`
DomainID uint32 `json:"domain_id"`
}
func (q *Queries) CreateImcUser(ctx context.Context, arg CreateImcUserParams) error {
_, err := q.db.ExecContext(ctx, createImcUser,
arg.Username,
arg.PasswordHash,
arg.Role,
arg.DomainID,
)
return err
}
const deleteImcUser = `-- name: DeleteImcUser :exec
DELETE FROM imc_users WHERE id = ?
`
func (q *Queries) DeleteImcUser(ctx context.Context, id uint32) error {
_, err := q.db.ExecContext(ctx, deleteImcUser, id)
return err
}
const getAdditionalDomainsForUser = `-- name: GetAdditionalDomainsForUser :many
SELECT virtual_domains.id, virtual_domains.name, virtual_domains.created_at FROM virtual_domains
JOIN imc_users2domains ON virtual_domains.id = imc_users2domains.domain_id
WHERE imc_users2domains.user_id = ?
`
func (q *Queries) GetAdditionalDomainsForUser(ctx context.Context, userID uint32) ([]VirtualDomain, error) {
rows, err := q.db.QueryContext(ctx, getAdditionalDomainsForUser, userID)
if err != nil {
return nil, err
}
defer rows.Close()
var items []VirtualDomain
for rows.Next() {
var i VirtualDomain
if err := rows.Scan(&i.ID, &i.Name, &i.CreatedAt); err != nil {
return nil, err
}
items = append(items, i)
}
if err := rows.Close(); err != nil {
return nil, err
}
if err := rows.Err(); err != nil {
return nil, err
}
return items, nil
}
const getImcUserByID = `-- name: GetImcUserByID :one
SELECT id, username, password_hash, role, domain_id, created_at FROM imc_users WHERE id = ?
`
func (q *Queries) GetImcUserByID(ctx context.Context, id uint32) (ImcUser, error) {
row := q.db.QueryRowContext(ctx, getImcUserByID, id)
var i ImcUser
err := row.Scan(
&i.ID,
&i.Username,
&i.PasswordHash,
&i.Role,
&i.DomainID,
&i.CreatedAt,
)
return i, err
}
const getImcUserByUsername = `-- name: GetImcUserByUsername :one
SELECT id, username, password_hash, role, domain_id, created_at FROM imc_users WHERE username = ?
`
func (q *Queries) GetImcUserByUsername(ctx context.Context, username string) (ImcUser, error) {
row := q.db.QueryRowContext(ctx, getImcUserByUsername, username)
var i ImcUser
err := row.Scan(
&i.ID,
&i.Username,
&i.PasswordHash,
&i.Role,
&i.DomainID,
&i.CreatedAt,
)
return i, err
}
const getUsersForDomain = `-- name: GetUsersForDomain :many
SELECT imc_users.id, imc_users.username, imc_users.password_hash, imc_users.role, imc_users.domain_id, imc_users.created_at FROM imc_users WHERE domain_id = ?
`
func (q *Queries) GetUsersForDomain(ctx context.Context, domainID uint32) ([]ImcUser, error) {
rows, err := q.db.QueryContext(ctx, getUsersForDomain, domainID)
if err != nil {
return nil, err
}
defer rows.Close()
var items []ImcUser
for rows.Next() {
var i ImcUser
if err := rows.Scan(
&i.ID,
&i.Username,
&i.PasswordHash,
&i.Role,
&i.DomainID,
&i.CreatedAt,
); err != nil {
return nil, err
}
items = append(items, i)
}
if err := rows.Close(); err != nil {
return nil, err
}
if err := rows.Err(); err != nil {
return nil, err
}
return items, nil
}
const getUsersForDomainViaJoin = `-- name: GetUsersForDomainViaJoin :many
SELECT imc_users.id, imc_users.username, imc_users.password_hash, imc_users.role, imc_users.domain_id, imc_users.created_at FROM imc_users
JOIN imc_users2domains ON imc_users.id = imc_users2domains.user_id
WHERE imc_users2domains.domain_id = ?
`
func (q *Queries) GetUsersForDomainViaJoin(ctx context.Context, domainID uint32) ([]ImcUser, error) {
rows, err := q.db.QueryContext(ctx, getUsersForDomainViaJoin, domainID)
if err != nil {
return nil, err
}
defer rows.Close()
var items []ImcUser
for rows.Next() {
var i ImcUser
if err := rows.Scan(
&i.ID,
&i.Username,
&i.PasswordHash,
&i.Role,
&i.DomainID,
&i.CreatedAt,
); err != nil {
return nil, err
}
items = append(items, i)
}
if err := rows.Close(); err != nil {
return nil, err
}
if err := rows.Err(); err != nil {
return nil, err
}
return items, nil
}
const isUserInDomain = `-- name: IsUserInDomain :one
SELECT COUNT(*) as count FROM imc_users2domains WHERE user_id = ? AND domain_id = ?
`
type IsUserInDomainParams struct {
UserID uint32 `json:"user_id"`
DomainID uint32 `json:"domain_id"`
}
func (q *Queries) IsUserInDomain(ctx context.Context, arg IsUserInDomainParams) (int64, error) {
row := q.db.QueryRowContext(ctx, isUserInDomain, arg.UserID, arg.DomainID)
var count int64
err := row.Scan(&count)
return count, err
}
const removeUserFromDomain = `-- name: RemoveUserFromDomain :exec
DELETE FROM imc_users2domains WHERE user_id = ? AND domain_id = ?
`
type RemoveUserFromDomainParams struct {
UserID uint32 `json:"user_id"`
DomainID uint32 `json:"domain_id"`
}
func (q *Queries) RemoveUserFromDomain(ctx context.Context, arg RemoveUserFromDomainParams) error {
_, err := q.db.ExecContext(ctx, removeUserFromDomain, arg.UserID, arg.DomainID)
return err
}
const updateImcUserPassword = `-- name: UpdateImcUserPassword :exec
UPDATE imc_users SET password_hash = ? WHERE id = ?
`
type UpdateImcUserPasswordParams struct {
PasswordHash string `json:"password_hash"`
ID uint32 `json:"id"`
}
func (q *Queries) UpdateImcUserPassword(ctx context.Context, arg UpdateImcUserPasswordParams) error {
_, err := q.db.ExecContext(ctx, updateImcUserPassword, arg.PasswordHash, arg.ID)
return err
}