driver

Documentation

Index

• Constants
• func New(dsAPI sqlAPI.AWSAPI) (asyncSQLDriver.Driver, error)
• func NewSync(dsAPI sqlAPI.AWSAPI) (sqlDriver.Driver, error)
• type Driver
  • func (d *Driver) Closed() bool
  • func (d *Driver) GetAsyncDB() (awsds.AsyncDB, error)
  • func (d *Driver) Open(_ string) (driver.Conn, error)
  • func (d *Driver) OpenDB() (*sql.DB, error)
• type Rows
  • func (r *Rows) Close() error
  • func (r *Rows) ColumnTypeDatabaseTypeName(index int) string
  • func (r *Rows) ColumnTypeNullable(index int) (nullable, ok bool)
  • func (r *Rows) ColumnTypeScanType(index int) reflect.Type
  • func (r *Rows) Columns() []string
  • func (r *Rows) Next(dest []driver.Value) error

Constants

const (
	REDSHIFT_INT                      = "INT"
	REDSHIFT_INT2                     = "INT2"
	REDSHIFT_INT4                     = "INT4"
	REDSHIFT_INT8                     = "INT8"
	REDSHIFT_FLOAT4                   = "FLOAT4"
	REDSHIFT_NUMERIC                  = "NUMERIC"
	REDSHIFT_FLOAT                    = "FLOAT"
	REDSHIFT_FLOAT8                   = "FLOAT8"
	REDSHIFT_BOOL                     = "BOOL"
	REDSHIFT_CHARACTER                = "CHARACTER"
	REDSHIFT_NCHAR                    = "NCHAR"
	REDSHIFT_BPCHAR                   = "BPCHAR"
	REDSHIFT_CHARACTER_VARYING        = "CHARACTER VARYING"
	REDSHIFT_NVARCHAR                 = "NVARCHAR"
	REDSHIFT_TEXT                     = "TEXT"
	REDSHIFT_VARCHAR                  = "VARCHAR"
	REDSHIFT_DATE                     = "DATE"
	REDSHIFT_TIMESTAMP                = "TIMESTAMP"
	REDSHIFT_TIMESTAMP_WITH_TIME_ZONE = "TIMESTAMPTZ"
	REDSHIFT_TIME_WITHOUT_TIME_ZONE   = "TIME"
	REDSHIFT_TIME_WITH_TIME_ZONE      = "TIMETZ"
	REDSHIFT_GEOMETRY                 = "GEOMETRY"
	REDSHIFT_HLLSKETCH                = "HLLSKETCH"
	REDSHIFT_SUPER                    = "SUPER"
	REDSHIFT_NAME                     = "NAME"
)

const DriverName string = "redshift"

Functions

func New

func New(dsAPI sqlAPI.AWSAPI) (asyncSQLDriver.Driver, error)

New registers a new driver with a unique name

func NewSync

func NewSync(dsAPI sqlAPI.AWSAPI) (sqlDriver.Driver, error)

NewSync registers a new synchronous driver with a unique name

Types

type Driver

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

Driver is a sql.Driver

func (*Driver) Closed

func (d *Driver) Closed() bool

func (*Driver) GetAsyncDB

func (d *Driver) GetAsyncDB() (awsds.AsyncDB, error)

func (*Driver) Open

func (d *Driver) Open(_ string) (driver.Conn, error)

Open returns a new driver.Conn using already existing settings

func (*Driver) OpenDB

func (d *Driver) OpenDB() (*sql.DB, error)

type Rows

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

func (*Rows) Close

func (r *Rows) Close() error

Close closes the rows iterator.

func (*Rows) ColumnTypeDatabaseTypeName

func (r *Rows) ColumnTypeDatabaseTypeName(index int) string

ColumnTypeDatabaseTypeName converts a redshift data type to a corresponding go sql type

func (*Rows) ColumnTypeNullable

func (r *Rows) ColumnTypeNullable(index int) (nullable, ok bool)

ColumnTypeNullable returns true if it is known the column may be null, or false if the column is known to be not nullable. If the column nullability is unknown, ok should be false.

func (*Rows) ColumnTypeScanType

func (r *Rows) ColumnTypeScanType(index int) reflect.Type

ColumnTypeScanType returns the value type that can be used to scan types into. For example, the database column type "bigint" this should return "reflect.TypeOf(int64(0))"

func (*Rows) Columns

func (r *Rows) Columns() []string

Columns returns the names of the columns.

func (*Rows) Next

func (r *Rows) Next(dest []driver.Value) error

Next is called to populate the next row of data into the provided slice. The provided slice will be the same size as the Columns() are wide. io.EOF should be returned when there are no more rows.