sql

Documentation

Index

• Constants
• func NewMySQLRowReader(r *sql.Rows) (execute.RowReader, error)
• func NewPostgresRowReader(r *sql.Rows) (execute.RowReader, error)
• func UInt8ToFloat(a []uint8) (float64, error)
• func UInt8ToInt64(a []uint8) (int64, error)
• type FromSQLOpSpec
  • func (s *FromSQLOpSpec) Kind() flux.OperationKind
• type FromSQLProcedureSpec
  • func (s *FromSQLProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *FromSQLProcedureSpec) Kind() plan.ProcedureKind
• type MySQLRowReader
  • func (m *MySQLRowReader) ColumnNames() []string
  • func (m *MySQLRowReader) ColumnTypes() []flux.ColType
  • func (m *MySQLRowReader) GetNextRow() ([]values.Value, error)
  • func (m *MySQLRowReader) InitColumnNames(names []string)
  • func (m *MySQLRowReader) InitColumnTypes(types []*sql.ColumnType)
  • func (m *MySQLRowReader) Next() bool
  • func (m *MySQLRowReader) SetColumnTypes(types []flux.ColType)
  • func (m *MySQLRowReader) SetColumns(i []interface{})
• type PostgresRowReader
  • func (m *PostgresRowReader) ColumnNames() []string
  • func (m *PostgresRowReader) ColumnTypes() []flux.ColType
  • func (m *PostgresRowReader) GetNextRow() ([]values.Value, error)
  • func (m *PostgresRowReader) InitColumnNames(n []string)
  • func (m *PostgresRowReader) InitColumnTypes(types []*sql.ColumnType)
  • func (m *PostgresRowReader) Next() bool
  • func (m *PostgresRowReader) SetColumns(i []interface{})
• type SQLIterator
  • func (c *SQLIterator) Close() error
  • func (c *SQLIterator) Connect() error
  • func (c *SQLIterator) Decode() (flux.Table, error)
  • func (c *SQLIterator) Fetch() (bool, error)

Constants

const FromSQLKind = "fromSQL"

Functions

func NewMySQLRowReader

func NewMySQLRowReader(r *sql.Rows) (execute.RowReader, error)

func NewPostgresRowReader

func NewPostgresRowReader(r *sql.Rows) (execute.RowReader, error)

func UInt8ToFloat

func UInt8ToFloat(a []uint8) (float64, error)

func UInt8ToInt64

func UInt8ToInt64(a []uint8) (int64, error)

Types

type FromSQLOpSpec

type FromSQLOpSpec struct {
	DriverName     string `json:"driverName,omitempty"`
	DataSourceName string `json:"dataSourceName,omitempty"`
	Query          string `json:"query,omitempty"`
}

func (*FromSQLOpSpec) Kind

func (s *FromSQLOpSpec) Kind() flux.OperationKind

type FromSQLProcedureSpec

type FromSQLProcedureSpec struct {
	plan.DefaultCost
	DriverName     string
	DataSourceName string
	Query          string
}

func (*FromSQLProcedureSpec) Copy

func (s *FromSQLProcedureSpec) Copy() plan.ProcedureSpec

func (*FromSQLProcedureSpec) Kind

func (s *FromSQLProcedureSpec) Kind() plan.ProcedureKind

type MySQLRowReader

type MySQLRowReader struct {
	Cursor *sql.Rows

	NextFunc func() bool
	// contains filtered or unexported fields
}

func (*MySQLRowReader) ColumnNames

func (m *MySQLRowReader) ColumnNames() []string

func (*MySQLRowReader) ColumnTypes

func (m *MySQLRowReader) ColumnTypes() []flux.ColType

func (*MySQLRowReader) GetNextRow

func (m *MySQLRowReader) GetNextRow() ([]values.Value, error)

func (*MySQLRowReader) InitColumnNames

func (m *MySQLRowReader) InitColumnNames(names []string)

func (*MySQLRowReader) InitColumnTypes

func (m *MySQLRowReader) InitColumnTypes(types []*sql.ColumnType)

func (*MySQLRowReader) Next

func (m *MySQLRowReader) Next() bool

Prepares MySQLRowReader to return rows

func (*MySQLRowReader) SetColumnTypes

func (m *MySQLRowReader) SetColumnTypes(types []flux.ColType)

func (*MySQLRowReader) SetColumns

func (m *MySQLRowReader) SetColumns(i []interface{})

type PostgresRowReader

type PostgresRowReader struct {
	Cursor *sql.Rows
	// contains filtered or unexported fields
}

func (*PostgresRowReader) ColumnNames

func (m *PostgresRowReader) ColumnNames() []string

func (*PostgresRowReader) ColumnTypes

func (m *PostgresRowReader) ColumnTypes() []flux.ColType

func (*PostgresRowReader) GetNextRow

func (m *PostgresRowReader) GetNextRow() ([]values.Value, error)

func (*PostgresRowReader) InitColumnNames

func (m *PostgresRowReader) InitColumnNames(n []string)

func (*PostgresRowReader) InitColumnTypes

func (m *PostgresRowReader) InitColumnTypes(types []*sql.ColumnType)

func (*PostgresRowReader) Next

func (m *PostgresRowReader) Next() bool

func (*PostgresRowReader) SetColumns

func (m *PostgresRowReader) SetColumns(i []interface{})

type SQLIterator

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

func (*SQLIterator) Close

func (c *SQLIterator) Close() error

func (*SQLIterator) Connect

func (c *SQLIterator) Connect() error

func (*SQLIterator) Decode

func (c *SQLIterator) Decode() (flux.Table, error)

func (*SQLIterator) Fetch

func (c *SQLIterator) Fetch() (bool, error)