presto

Documentation

Index

• Constants
• func CreateTable(queryer db.Queryer, catalog, schema, tableName string, columns []Column, ...) error
• func CreateTableAs(queryer db.Queryer, catalog, schema, tableName string, columns []Column, ...) error
• func CreateView(queryer db.Queryer, catalog, schema, viewName string, query string, ...) error
• func DeleteFrom(queryer db.Queryer, tableName string) error
• func DropTable(queryer db.Queryer, catalog, schema, tableName string, ignoreNotExists bool) error
• func DropView(queryer db.Queryer, catalog, schema, viewName string, ignoreNotExists bool) error
• func FormatInsertQuery(target, query string) string
• func FullyQualifiedTableName(catalog, schema, tableName string) string
• func GenerateGetRowsSQL(tableName string, columns []Column) string
• func GenerateGetRowsSQLWithWhere(tableName string, columns []Column, whereClause string) string
• func GenerateOrderBySQL(columns []Column) string
• func GenerateQuotedColumnsListSQL(columns []Column) string
• func InsertInto(queryer db.Queryer, tableName, query string) error
• type Column
  • func QueryMetadata(queryer db.Queryer, catalog, schema, tableName string) ([]Column, error)
• type PartitionSpec
• type Row
  • func ExecuteSelect(queryer db.Queryer, query string) ([]Row, error)
  • func GetRows(queryer db.Queryer, tableName string, columns []Column) ([]Row, error)
  • func GetRowsWhere(queryer db.Queryer, tableName string, columns []Column, whereClause string) ([]Row, error)
• type TablePartition

Constants

const (
	// TimestampFormat is the time format string used to produce Presto timestamps.
	TimestampFormat = "2006-01-02 15:04:05.000"
)

Functions

func CreateTable

func CreateTable(queryer db.Queryer, catalog, schema, tableName string, columns []Column, comment string, properties map[string]string, ignoreExists bool) error

func CreateTableAs

func CreateTableAs(queryer db.Queryer, catalog, schema, tableName string, columns []Column, comment string, properties map[string]string, ignoreExists bool, query string) error

func CreateView

func CreateView(queryer db.Queryer, catalog, schema, viewName string, query string, replace bool) error

func DeleteFrom

func DeleteFrom(queryer db.Queryer, tableName string) error

func DropTable

func DropTable(queryer db.Queryer, catalog, schema, tableName string, ignoreNotExists bool) error

func DropView

func DropView(queryer db.Queryer, catalog, schema, viewName string, ignoreNotExists bool) error

func FormatInsertQuery

func FormatInsertQuery(target, query string) string

func FullyQualifiedTableName

func FullyQualifiedTableName(catalog, schema, tableName string) string

func GenerateGetRowsSQL

func GenerateGetRowsSQL(tableName string, columns []Column) string

func GenerateGetRowsSQLWithWhere

func GenerateGetRowsSQLWithWhere(tableName string, columns []Column, whereClause string) string

func GenerateOrderBySQL

func GenerateOrderBySQL(columns []Column) string

func GenerateQuotedColumnsListSQL

func GenerateQuotedColumnsListSQL(columns []Column) string

func InsertInto

func InsertInto(queryer db.Queryer, tableName, query string) error

Types

type Column

type Column struct {
	Name string `json:"name"`
	Type string `json:"type"`
}

func QueryMetadata

func QueryMetadata(queryer db.Queryer, catalog, schema, tableName string) ([]Column, error)

QueryMetadata executes a "DESCRIBE" Presto query against an existing, fully-qualified table name to determine that table's column information.

type PartitionSpec

type PartitionSpec map[string]string

type Row

type Row map[string]interface{}

func ExecuteSelect

func ExecuteSelect(queryer db.Queryer, query string) ([]Row, error)

ExecuteSelectQuery performs the query on the table target. It's expected target has the correct schema.

func GetRows

func GetRows(queryer db.Queryer, tableName string, columns []Column) ([]Row, error)

func GetRowsWhere

func GetRowsWhere(queryer db.Queryer, tableName string, columns []Column, whereClause string) ([]Row, error)

type TablePartition

type TablePartition struct {
	Location      string        `json:"location"`
	PartitionSpec PartitionSpec `json:"partitionSpec"`
}