rdb

Documentation

Index

• func Describe(names []string, opts []interface{}) (func(string) (string, string, bool), error)
• func Read(source interface{}, opts ...interface{}) (*tables.Table, error)
• func Sink(source interface{}, opts ...interface{}) tables.Sink
• func Source(source interface{}, opts ...interface{}) tables.Lazy
• func Write(source interface{}, t *tables.Table, opts ...interface{}) error
• type Batch
• type Driver
• type IfExists_
• type Query
• type Schema
• type SqlBigint
  • func (s *SqlBigint) Reflect() reflect.Type
  • func (s *SqlBigint) Scan(value interface{}) error
  • func (s *SqlBigint) Value() (reflect.Value, bool)
• type SqlBool
  • func (s *SqlBool) Reflect() reflect.Type
  • func (s *SqlBool) Scan(value interface{}) error
  • func (s *SqlBool) Value() (reflect.Value, bool)
• type SqlDouble
  • func (s *SqlDouble) Reflect() reflect.Type
  • func (s *SqlDouble) Scan(value interface{}) error
  • func (s *SqlDouble) Value() (reflect.Value, bool)
• type SqlFloat
  • func (s *SqlFloat) Reflect() reflect.Type
  • func (s *SqlFloat) Scan(value interface{}) error
  • func (s *SqlFloat) Value() (reflect.Value, bool)
• type SqlInteger
  • func (s *SqlInteger) Reflect() reflect.Type
  • func (s *SqlInteger) Scan(value interface{}) error
  • func (s *SqlInteger) Value() (reflect.Value, bool)
• type SqlScan
• type SqlSmall
  • func (s *SqlSmall) Reflect() reflect.Type
  • func (s *SqlSmall) Scan(value interface{}) error
  • func (s *SqlSmall) Value() (r reflect.Value, ok bool)
• type SqlString
  • func (s *SqlString) Reflect() reflect.Type
  • func (s *SqlString) Scan(value interface{}) error
  • func (s *SqlString) Value() (reflect.Value, bool)
• type SqlTimestamp
  • func (s *SqlTimestamp) Reflect() reflect.Type
  • func (s *SqlTimestamp) Scan(value interface{}) error
  • func (s *SqlTimestamp) Value() (reflect.Value, bool)
• type SqlTypeOpt
  • func AUTOINCREMENT(v string) SqlTypeOpt
  • func BIGINT(v string) SqlTypeOpt
  • func BOOLEAN(v string) SqlTypeOpt
  • func Column(v string) SqlTypeOpt
  • func DATE(v string) SqlTypeOpt
  • func DATETIME(v string) SqlTypeOpt
  • func DECIMAL(v string, prec ...int) SqlTypeOpt
  • func DOUBLE(v string) SqlTypeOpt
  • func FLOAT(v string) SqlTypeOpt
  • func INTEGER(v string) SqlTypeOpt
  • func SMALLINT(v string) SqlTypeOpt
  • func TIMESTAMP(v string) SqlTypeOpt
  • func VARCHAR(v string, length ...int) SqlTypeOpt
  • func (f SqlTypeOpt) As(b string) SqlTypeOpt
  • func (f SqlTypeOpt) PrimaryKey() SqlTypeOpt
• type Table

Functions

func Describe

func Describe(names []string, opts []interface{}) (func(string) (string, string, bool), error)

func Read

func Read(source interface{}, opts ...interface{}) (*tables.Table, error)

func Sink

func Sink(source interface{}, opts ...interface{}) tables.Sink

func Source

func Source(source interface{}, opts ...interface{}) tables.Lazy

func Write

func Write(source interface{}, t *tables.Table, opts ...interface{}) error

Types

type Batch

type Batch int

type Driver

type Driver string

type IfExists_

type IfExists_ int

const (
	ErrorIfExists IfExists_ = iota
	DropIfExists
	AppendIfExists
	InsertUpdateIfExists
)

type Query

type Query string

type Schema

type Schema string

type SqlBigint

type SqlBigint struct {
	sql.NullInt64
}

func (*SqlBigint) Reflect

func (s *SqlBigint) Reflect() reflect.Type

func (*SqlBigint) Scan

func (s *SqlBigint) Scan(value interface{}) error

func (*SqlBigint) Value

func (s *SqlBigint) Value() (reflect.Value, bool)

type SqlBool

type SqlBool struct {
	sql.NullBool
}

func (*SqlBool) Reflect

func (s *SqlBool) Reflect() reflect.Type

func (*SqlBool) Scan

func (s *SqlBool) Scan(value interface{}) error

func (*SqlBool) Value

func (s *SqlBool) Value() (reflect.Value, bool)

type SqlDouble

type SqlDouble struct {
	sql.NullFloat64
}

func (*SqlDouble) Reflect

func (s *SqlDouble) Reflect() reflect.Type

func (*SqlDouble) Scan

func (s *SqlDouble) Scan(value interface{}) error

func (*SqlDouble) Value

func (s *SqlDouble) Value() (reflect.Value, bool)

type SqlFloat

type SqlFloat struct {
	sql.NullFloat64
}

func (*SqlFloat) Reflect

func (s *SqlFloat) Reflect() reflect.Type

func (*SqlFloat) Scan

func (s *SqlFloat) Scan(value interface{}) error

func (*SqlFloat) Value

func (s *SqlFloat) Value() (reflect.Value, bool)

type SqlInteger

type SqlInteger struct {
	sql.NullInt32
}

func (*SqlInteger) Reflect

func (s *SqlInteger) Reflect() reflect.Type

func (*SqlInteger) Scan

func (s *SqlInteger) Scan(value interface{}) error

func (*SqlInteger) Value

func (s *SqlInteger) Value() (reflect.Value, bool)

type SqlScan

type SqlScan interface {
	sql.Scanner
	Value() (reflect.Value, bool)
	Reflect() reflect.Type
}

type SqlSmall

type SqlSmall struct {
	sql.NullInt32
}

func (*SqlSmall) Reflect

func (s *SqlSmall) Reflect() reflect.Type

func (*SqlSmall) Scan

func (s *SqlSmall) Scan(value interface{}) error

func (*SqlSmall) Value

func (s *SqlSmall) Value() (r reflect.Value, ok bool)

type SqlString

type SqlString struct {
	sql.NullString
}

func (*SqlString) Reflect

func (s *SqlString) Reflect() reflect.Type

func (*SqlString) Scan

func (s *SqlString) Scan(value interface{}) error

func (*SqlString) Value

func (s *SqlString) Value() (reflect.Value, bool)

type SqlTimestamp

type SqlTimestamp struct {
	sql.NullTime
}

func (*SqlTimestamp) Reflect

func (s *SqlTimestamp) Reflect() reflect.Type

func (*SqlTimestamp) Scan

func (s *SqlTimestamp) Scan(value interface{}) error

func (*SqlTimestamp) Value

func (s *SqlTimestamp) Value() (reflect.Value, bool)

type SqlTypeOpt

type SqlTypeOpt func(string) (string, string, string, bool)

func AUTOINCREMENT

func AUTOINCREMENT(v string) SqlTypeOpt

func BIGINT

func BIGINT(v string) SqlTypeOpt

func BOOLEAN

func BOOLEAN(v string) SqlTypeOpt

func Column

func Column(v string) SqlTypeOpt

func DATE

func DATE(v string) SqlTypeOpt

func DATETIME

func DATETIME(v string) SqlTypeOpt

func DECIMAL

func DECIMAL(v string, prec ...int) SqlTypeOpt

func DOUBLE

func DOUBLE(v string) SqlTypeOpt

func FLOAT

func FLOAT(v string) SqlTypeOpt

func INTEGER

func INTEGER(v string) SqlTypeOpt

func SMALLINT

func SMALLINT(v string) SqlTypeOpt

func TIMESTAMP

func TIMESTAMP(v string) SqlTypeOpt

func VARCHAR

func VARCHAR(v string, length ...int) SqlTypeOpt

func (SqlTypeOpt) As

func (f SqlTypeOpt) As(b string) SqlTypeOpt

func (SqlTypeOpt) PrimaryKey

func (f SqlTypeOpt) PrimaryKey() SqlTypeOpt

type Table

type Table string