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"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.