query

Documentation

Index

• Constants
• func Param(idx int) string
• type SQL
  • func New(db *sql.DB) *SQL
  • func (s *SQL) BeginTx(ctx context.Context, opts *sql.TxOptions) (models.Tx, error)
  • func (s *SQL) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
  • func (s *SQL) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
  • func (s *SQL) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
• type Tx
  • func (t *Tx) Commit() error
  • func (t *Tx) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
  • func (t *Tx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
  • func (t *Tx) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
  • func (t *Tx) Rollback() error

Constants

const AddValidationSession = `insert into
    threepid_validation_sessions (medium, address, clientSecret, mtime)
values
    ($1, $2, $3, $4) RETURNING id;`

const CreateTMPMxid = `` /* 182-byte string literal not displayed */

const CreateTokenSession = `insert into
    threepid_token_auths (validationSession, token, sendAttemptNumber)
values
    ($1, $2, $3)`

const GetAllPeers = `` /* 167-byte string literal not displayed */

const GetAssociationsAfterId = `` /* 174-byte string literal not displayed */

const GetLocal3pid = `SELECT
    COUNT(*)
FROM
    local_threepid_associations
WHERE
    medium = $1
    AND address = $2
    AND mxid = $3;`

const GetPeerByName = `` /* 187-byte string literal not displayed */

const GetSenderForToken = `SELECT
    sender
FROM
    invite_tokens
WHERE
    token = $1;`

const GetSessionByID = `` /* 138-byte string literal not displayed */

const GetTokenSession = `` /* 308-byte string literal not displayed */

const GetTokenSessionByID = `` /* 256-byte string literal not displayed */

const GetTokens = `` /* 163-byte string literal not displayed */

const GlobalAddAssociation = `` /* 265-byte string literal not displayed */

const GlobalGetMxid = `` /* 189-byte string literal not displayed */

const GlobalGetMxids = `` /* 332-byte string literal not displayed */

const GlobalLastIDFromServer = `SELECT
    max(originId),
    count(originId)
FROM
    global_threepid_associations
WHERE
    originServer = $1;`

const GlobalRemoveAssociation = `DELETE FROM
    global_threepid_associations
WHERE
    medium = $1
    AND address = $2`

const LocalAddOrUpdateAssociation = `` /* 356-byte string literal not displayed */

const LocalRemoveAssociation = `` /* 362-byte string literal not displayed */

const MarkTokensAsSent = `UPDATE
    invite_tokens
SET
    sent_ts = $1
WHERE
    medium = $2
    AND address = $3;`

const SetLastSentVersionAndPokeSucceeded = `update
    peers
set
    lastSentVersion = $1,
    lastPokeSucceededAt = $2
WHERE
    name = $3;`

const SetMtime = `update
    threepid_validation_sessions
set
    mtime = $1
WHERE
    id = $2;`

const SetSendAttemptNumber = `update
    threepid_token_auths
set
    sendAttemptNumber = $1
WHERE
    id = $2`

const SetValidated = `update
    threepid_validation_sessions
set
    validated = $1
WHERE
    id = $2;`

const SignedAssociationStringForThreepid = `` /* 192-byte string literal not displayed */

const StoreEphemeralPublicKey = `INSERT INTO
    ephemeral_public_keys (public_key, persistence_ts)
VALUES
    ($1, $2);`

const StoreToken = `INSERT INTO
invite_tokens (
	medium,
	address,
	room_id,
	sender,
	token,
	received_ts
)
VALUES
($1, $2, $3, $4, $5, $6);`

const ValidateEphemeralPublicKey = `UPDATE
    ephemeral_public_keys
SET
    verify_count = verify_count + 1
WHERE
    public_key = $1;`

Functions

func Param

func Param(idx int) string

Types

type SQL

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

SQL implements models.SQL interface based on *sql.DB adding instrumentation and logging.

func New

func New(db *sql.DB) *SQL

func (*SQL) BeginTx

func (s *SQL) BeginTx(ctx context.Context, opts *sql.TxOptions) (models.Tx, error)

func (*SQL) ExecContext

func (s *SQL) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func (*SQL) QueryContext

func (s *SQL) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func (*SQL) QueryRowContext

func (s *SQL) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

type Tx

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

func (*Tx) Commit

func (t *Tx) Commit() error

func (*Tx) ExecContext

func (t *Tx) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func (*Tx) QueryContext

func (t *Tx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func (*Tx) QueryRowContext

func (t *Tx) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

func (*Tx) Rollback

func (t *Tx) Rollback() error