queries

package
v0.0.0-...-e364c34 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 18, 2023 License: AGPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PrepareAllQueries

func PrepareAllQueries(ctx context.Context, p preparer) error

PrepareAllQueries executes a PREPARE statement for all pggen generated SQL queries in querier files. Typical usage is as the AfterConnect callback for pgxpool.Config

pgx will use the prepared statement if available. Calling PrepareAllQueries is an optional optimization to avoid a network round-trip the first time pgx runs a query if pgx statement caching is enabled.

Types

type ChannelConfigRow

type ChannelConfigRow struct {
	Starboard     int64  `json:"starboard"`
	Disabled      bool   `json:"disabled"`
	Emoji         string `json:"emoji"`
	ReactionLimit int    `json:"reaction_limit"`
	AllowSelfStar bool   `json:"allow_self_star"`
}

type DBQuerier

type DBQuerier struct {
	// contains filtered or unexported fields
}

func NewQuerier

func NewQuerier(conn genericConn) *DBQuerier

NewQuerier creates a DBQuerier that implements Querier. conn is typically *pgx.Conn, pgx.Tx, or *pgxpool.Pool.

func NewQuerierConfig

func NewQuerierConfig(conn genericConn, cfg QuerierConfig) *DBQuerier

NewQuerierConfig creates a DBQuerier that implements Querier with the given config. conn is typically *pgx.Conn, pgx.Tx, or *pgxpool.Pool.

func (*DBQuerier) AddReaction

func (q *DBQuerier) AddReaction(ctx context.Context, userID int64, messageID int64) (pgconn.CommandTag, error)

AddReaction implements Querier.AddReaction.

func (*DBQuerier) AddReactionBatch

func (q *DBQuerier) AddReactionBatch(batch genericBatch, userID int64, messageID int64)

AddReactionBatch implements Querier.AddReactionBatch.

func (*DBQuerier) AddReactionScan

func (q *DBQuerier) AddReactionScan(results pgx.BatchResults) (pgconn.CommandTag, error)

AddReactionScan implements Querier.AddReactionScan.

func (*DBQuerier) ChannelConfig

func (q *DBQuerier) ChannelConfig(ctx context.Context, channelID int64, guildID int64) (ChannelConfigRow, error)

ChannelConfig implements Querier.ChannelConfig.

func (*DBQuerier) ChannelConfigBatch

func (q *DBQuerier) ChannelConfigBatch(batch genericBatch, channelID int64, guildID int64)

ChannelConfigBatch implements Querier.ChannelConfigBatch.

func (*DBQuerier) ChannelConfigScan

func (q *DBQuerier) ChannelConfigScan(results pgx.BatchResults) (ChannelConfigRow, error)

ChannelConfigScan implements Querier.ChannelConfigScan.

func (*DBQuerier) GetStarboard

func (q *DBQuerier) GetStarboard(ctx context.Context, messageID int64) (GetStarboardRow, error)

GetStarboard implements Querier.GetStarboard.

func (*DBQuerier) GetStarboardBatch

func (q *DBQuerier) GetStarboardBatch(batch genericBatch, messageID int64)

GetStarboardBatch implements Querier.GetStarboardBatch.

func (*DBQuerier) GetStarboardScan

func (q *DBQuerier) GetStarboardScan(results pgx.BatchResults) (GetStarboardRow, error)

GetStarboardScan implements Querier.GetStarboardScan.

func (*DBQuerier) HasOverride

func (q *DBQuerier) HasOverride(ctx context.Context, channelID int64) (bool, error)

HasOverride implements Querier.HasOverride.

func (*DBQuerier) HasOverrideBatch

func (q *DBQuerier) HasOverrideBatch(batch genericBatch, channelID int64)

HasOverrideBatch implements Querier.HasOverrideBatch.

func (*DBQuerier) HasOverrideScan

func (q *DBQuerier) HasOverrideScan(results pgx.BatchResults) (bool, error)

HasOverrideScan implements Querier.HasOverrideScan.

func (*DBQuerier) InsertStarboard

func (q *DBQuerier) InsertStarboard(ctx context.Context, params InsertStarboardParams) (InsertStarboardRow, error)

InsertStarboard implements Querier.InsertStarboard.

func (*DBQuerier) InsertStarboardBatch

func (q *DBQuerier) InsertStarboardBatch(batch genericBatch, params InsertStarboardParams)

InsertStarboardBatch implements Querier.InsertStarboardBatch.

func (*DBQuerier) InsertStarboardScan

func (q *DBQuerier) InsertStarboardScan(results pgx.BatchResults) (InsertStarboardRow, error)

InsertStarboardScan implements Querier.InsertStarboardScan.

func (*DBQuerier) ReactionCount

func (q *DBQuerier) ReactionCount(ctx context.Context, messageID int64) (int64, error)

ReactionCount implements Querier.ReactionCount.

func (*DBQuerier) ReactionCountBatch

func (q *DBQuerier) ReactionCountBatch(batch genericBatch, messageID int64)

ReactionCountBatch implements Querier.ReactionCountBatch.

func (*DBQuerier) ReactionCountScan

func (q *DBQuerier) ReactionCountScan(results pgx.BatchResults) (int64, error)

ReactionCountScan implements Querier.ReactionCountScan.

func (*DBQuerier) RemoveAllReactions

func (q *DBQuerier) RemoveAllReactions(ctx context.Context, messageID int64) (pgconn.CommandTag, error)

RemoveAllReactions implements Querier.RemoveAllReactions.

func (*DBQuerier) RemoveAllReactionsBatch

func (q *DBQuerier) RemoveAllReactionsBatch(batch genericBatch, messageID int64)

RemoveAllReactionsBatch implements Querier.RemoveAllReactionsBatch.

func (*DBQuerier) RemoveAllReactionsScan

func (q *DBQuerier) RemoveAllReactionsScan(results pgx.BatchResults) (pgconn.CommandTag, error)

RemoveAllReactionsScan implements Querier.RemoveAllReactionsScan.

func (*DBQuerier) RemoveReaction

func (q *DBQuerier) RemoveReaction(ctx context.Context, userID int64, messageID int64) (pgconn.CommandTag, error)

RemoveReaction implements Querier.RemoveReaction.

func (*DBQuerier) RemoveReactionBatch

func (q *DBQuerier) RemoveReactionBatch(batch genericBatch, userID int64, messageID int64)

RemoveReactionBatch implements Querier.RemoveReactionBatch.

func (*DBQuerier) RemoveReactionScan

func (q *DBQuerier) RemoveReactionScan(results pgx.BatchResults) (pgconn.CommandTag, error)

RemoveReactionScan implements Querier.RemoveReactionScan.

func (*DBQuerier) RemoveStarboard

func (q *DBQuerier) RemoveStarboard(ctx context.Context, messageID int64) (pgconn.CommandTag, error)

RemoveStarboard implements Querier.RemoveStarboard.

func (*DBQuerier) RemoveStarboardBatch

func (q *DBQuerier) RemoveStarboardBatch(batch genericBatch, messageID int64)

RemoveStarboardBatch implements Querier.RemoveStarboardBatch.

func (*DBQuerier) RemoveStarboardScan

func (q *DBQuerier) RemoveStarboardScan(results pgx.BatchResults) (pgconn.CommandTag, error)

RemoveStarboardScan implements Querier.RemoveStarboardScan.

func (*DBQuerier) StarboardMessage

func (q *DBQuerier) StarboardMessage(ctx context.Context, id int64) (StarboardMessageRow, error)

StarboardMessage implements Querier.StarboardMessage.

func (*DBQuerier) StarboardMessageBatch

func (q *DBQuerier) StarboardMessageBatch(batch genericBatch, id int64)

StarboardMessageBatch implements Querier.StarboardMessageBatch.

func (*DBQuerier) StarboardMessageScan

func (q *DBQuerier) StarboardMessageScan(results pgx.BatchResults) (StarboardMessageRow, error)

StarboardMessageScan implements Querier.StarboardMessageScan.

func (*DBQuerier) WithTx

func (q *DBQuerier) WithTx(tx pgx.Tx) (*DBQuerier, error)

WithTx creates a new DBQuerier that uses the transaction to run all queries.

type GetStarboardRow

type GetStarboardRow struct {
	MessageID   int64 `json:"message_id"`
	ChannelID   int64 `json:"channel_id"`
	GuildID     int64 `json:"guild_id"`
	StarboardID int64 `json:"starboard_id"`
}

type InsertStarboardParams

type InsertStarboardParams struct {
	MessageID   int64
	ChannelID   int64
	GuildID     int64
	StarboardID int64
}

type InsertStarboardRow

type InsertStarboardRow struct {
	MessageID   int64 `json:"message_id"`
	ChannelID   int64 `json:"channel_id"`
	GuildID     int64 `json:"guild_id"`
	StarboardID int64 `json:"starboard_id"`
}

type Querier

type Querier interface {
	ChannelConfig(ctx context.Context, channelID int64, guildID int64) (ChannelConfigRow, error)
	// ChannelConfigBatch enqueues a ChannelConfig query into batch to be executed
	// later by the batch.
	ChannelConfigBatch(batch genericBatch, channelID int64, guildID int64)
	// ChannelConfigScan scans the result of an executed ChannelConfigBatch query.
	ChannelConfigScan(results pgx.BatchResults) (ChannelConfigRow, error)

	HasOverride(ctx context.Context, channelID int64) (bool, error)
	// HasOverrideBatch enqueues a HasOverride query into batch to be executed
	// later by the batch.
	HasOverrideBatch(batch genericBatch, channelID int64)
	// HasOverrideScan scans the result of an executed HasOverrideBatch query.
	HasOverrideScan(results pgx.BatchResults) (bool, error)

	StarboardMessage(ctx context.Context, id int64) (StarboardMessageRow, error)
	// StarboardMessageBatch enqueues a StarboardMessage query into batch to be executed
	// later by the batch.
	StarboardMessageBatch(batch genericBatch, id int64)
	// StarboardMessageScan scans the result of an executed StarboardMessageBatch query.
	StarboardMessageScan(results pgx.BatchResults) (StarboardMessageRow, error)

	AddReaction(ctx context.Context, userID int64, messageID int64) (pgconn.CommandTag, error)
	// AddReactionBatch enqueues a AddReaction query into batch to be executed
	// later by the batch.
	AddReactionBatch(batch genericBatch, userID int64, messageID int64)
	// AddReactionScan scans the result of an executed AddReactionBatch query.
	AddReactionScan(results pgx.BatchResults) (pgconn.CommandTag, error)

	RemoveReaction(ctx context.Context, userID int64, messageID int64) (pgconn.CommandTag, error)
	// RemoveReactionBatch enqueues a RemoveReaction query into batch to be executed
	// later by the batch.
	RemoveReactionBatch(batch genericBatch, userID int64, messageID int64)
	// RemoveReactionScan scans the result of an executed RemoveReactionBatch query.
	RemoveReactionScan(results pgx.BatchResults) (pgconn.CommandTag, error)

	ReactionCount(ctx context.Context, messageID int64) (int64, error)
	// ReactionCountBatch enqueues a ReactionCount query into batch to be executed
	// later by the batch.
	ReactionCountBatch(batch genericBatch, messageID int64)
	// ReactionCountScan scans the result of an executed ReactionCountBatch query.
	ReactionCountScan(results pgx.BatchResults) (int64, error)

	RemoveAllReactions(ctx context.Context, messageID int64) (pgconn.CommandTag, error)
	// RemoveAllReactionsBatch enqueues a RemoveAllReactions query into batch to be executed
	// later by the batch.
	RemoveAllReactionsBatch(batch genericBatch, messageID int64)
	// RemoveAllReactionsScan scans the result of an executed RemoveAllReactionsBatch query.
	RemoveAllReactionsScan(results pgx.BatchResults) (pgconn.CommandTag, error)

	RemoveStarboard(ctx context.Context, messageID int64) (pgconn.CommandTag, error)
	// RemoveStarboardBatch enqueues a RemoveStarboard query into batch to be executed
	// later by the batch.
	RemoveStarboardBatch(batch genericBatch, messageID int64)
	// RemoveStarboardScan scans the result of an executed RemoveStarboardBatch query.
	RemoveStarboardScan(results pgx.BatchResults) (pgconn.CommandTag, error)

	InsertStarboard(ctx context.Context, params InsertStarboardParams) (InsertStarboardRow, error)
	// InsertStarboardBatch enqueues a InsertStarboard query into batch to be executed
	// later by the batch.
	InsertStarboardBatch(batch genericBatch, params InsertStarboardParams)
	// InsertStarboardScan scans the result of an executed InsertStarboardBatch query.
	InsertStarboardScan(results pgx.BatchResults) (InsertStarboardRow, error)

	GetStarboard(ctx context.Context, messageID int64) (GetStarboardRow, error)
	// GetStarboardBatch enqueues a GetStarboard query into batch to be executed
	// later by the batch.
	GetStarboardBatch(batch genericBatch, messageID int64)
	// GetStarboardScan scans the result of an executed GetStarboardBatch query.
	GetStarboardScan(results pgx.BatchResults) (GetStarboardRow, error)
}

Querier is a typesafe Go interface backed by SQL queries.

Methods ending with Batch enqueue a query to run later in a pgx.Batch. After calling SendBatch on pgx.Conn, pgxpool.Pool, or pgx.Tx, use the Scan methods to parse the results.

type QuerierConfig

type QuerierConfig struct {
	// DataTypes contains pgtype.Value to use for encoding and decoding instead
	// of pggen-generated pgtype.ValueTranscoder.
	//
	// If OIDs are available for an input parameter type and all of its
	// transitive dependencies, pggen will use the binary encoding format for
	// the input parameter.
	DataTypes []pgtype.DataType
}

type StarboardMessageRow

type StarboardMessageRow struct {
	MessageID   int64 `json:"message_id"`
	ChannelID   int64 `json:"channel_id"`
	GuildID     int64 `json:"guild_id"`
	StarboardID int64 `json:"starboard_id"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL