querybuilder

Documentation

Index

• type Acc
• type Context
  • func NewContext(table *schema.Table, index string) *Context
  • func (c *Context) BuildPath(path *parser.DocumentPath) string
  • func (c *Context) ExpressionAttributeNames() map[string]*string
  • func (c *Context) IsKey(field string) bool
  • func (c *Context) NextGeneratedParam() string
  • func (c *Context) NextPositionalParam() (int, string)
• type Empty
• type FilterExpression
• type KeyExpression
• type NamedParams
  • func (p NamedParams) Clone() NamedParams
• type PreparedInsert
  • func PrepareInsert(ctx context.Context, tables *schema.TableLoader, query string) (*PreparedInsert, error)
  • func (p *PreparedInsert) Do(dynamo dynamodbiface.DynamoDBAPI, args []driver.NamedValue) (driver.Result, error)
• type PreparedQuery
  • func PrepareQuery(ctx context.Context, tables *schema.TableLoader, query string) (*PreparedQuery, error)
  • func (pq *PreparedQuery) NewRequest(args []driver.NamedValue) (*dynamodb.QueryInput, error)

Types

type Acc

type Acc struct {
	Key    string
	Filter string
}

type Context

type Context struct {
	HashKey          string
	SortKey          string
	NamedParams      map[string]Empty
	PositionalParams map[int]string
	FixedParams      map[string]interface{}
	Substitutions    map[string]string
	// contains filtered or unexported fields
}

Context tracks expression state as DynamoDB request is built.

func NewContext

func NewContext(table *schema.Table, index string) *Context

func (*Context) BuildPath

func (c *Context) BuildPath(path *parser.DocumentPath) string

BuildPath applies substitutions for reserved keywords in a parser.DocumentPath and marshals it into string format.

func (*Context) ExpressionAttributeNames

func (c *Context) ExpressionAttributeNames() map[string]*string

func (*Context) IsKey

func (c *Context) IsKey(field string) bool

IsKey returns true if the field is a hash key or sort key for the selected table/index.

func (*Context) NextGeneratedParam

func (c *Context) NextGeneratedParam() string

NextGeneratedParam returns the next generated parameter placeholder name. DynamoDB requires concrete values to be passed as expression values, so we simulate expression values by generating placeholders.

func (*Context) NextPositionalParam

func (c *Context) NextPositionalParam() (int, string)

NextPositionalParam returns the next generated positional placeholder name. DynamoDB does not support positional parameters so we simulate it by generating named placeholders.

type Empty

type Empty struct{}

type FilterExpression

type FilterExpression struct{}

type KeyExpression

type KeyExpression struct{}

type NamedParams

type NamedParams map[string]Empty

func (NamedParams) Clone

func (p NamedParams) Clone() NamedParams

type PreparedInsert

type PreparedInsert struct {
	Table       *schema.Table
	Placeholder string
	Values      []map[string]*dynamodb.AttributeValue
}

func PrepareInsert

func PrepareInsert(ctx context.Context, tables *schema.TableLoader, query string) (*PreparedInsert, error)

func (*PreparedInsert) Do

func (p *PreparedInsert) Do(dynamo dynamodbiface.DynamoDBAPI, args []driver.NamedValue) (driver.Result, error)

type PreparedQuery

type PreparedQuery struct {
	Query            *dynamodb.QueryInput
	Limit            int
	Columns          []*parser.ProjectionColumn
	NamedParams      NamedParams
	PositionalParams map[int]string
	FixedParams      map[string]interface{}
}

func PrepareQuery

func PrepareQuery(ctx context.Context, tables *schema.TableLoader, query string) (*PreparedQuery, error)

func (*PreparedQuery) NewRequest

func (pq *PreparedQuery) NewRequest(args []driver.NamedValue) (*dynamodb.QueryInput, error)