rds

May 22, 2022

Changes in this version

type Config

+ SplitMulti bool

type Rows

+ func (r *Rows) HasNextResultSet() bool

+ func (r *Rows) NextResultSet() error

Apr 15, 2022

Changes in this version

type Config

+ Custom map[string][]string

type Dialect

+ Type func() DialectType

type DialectMySQL

+ func (d *DialectMySQL) Type() DialectType

type DialectPostgres

+ func (d *DialectPostgres) Type() DialectType

+ type DialectType string

+ const DialectTypeMysql

+ const DialectTypePostgres

Apr 13, 2022

Changes in this version

+ var ErrInvalidDSNScheme = fmt.Errorf("this driver requires a DSN scheme of rds://")

Feb 26, 2022

Changes in this version

+ func ConvertDefaults() func(field types.Field) (value interface{}, err error)

Feb 25, 2022

Changes in this version

+ type AWSClientInterface interface

+ BeginTransaction func(ctx context.Context, b *rdsdata.BeginTransactionInput, ...) (*rdsdata.BeginTransactionOutput, error)

+ CommitTransaction func(ctx context.Context, c *rdsdata.CommitTransactionInput, ...) (*rdsdata.CommitTransactionOutput, error)

+ ExecuteStatement func(ctx context.Context, e *rdsdata.ExecuteStatementInput, ...) (*rdsdata.ExecuteStatementOutput, error)

+ RollbackTransaction func(ctx context.Context, r *rdsdata.RollbackTransactionInput, ...) (*rdsdata.RollbackTransactionOutput, error)

Sep 1, 2021

Changes in this version

type Config

+ ParseTime bool

type Connector

+ func (r *Connector) Wakeup() (dialect Dialect, err error)

type Dialect

+ func NewMySQL(config *Config) Dialect

+ func NewPostgres(config *Config) Dialect

Aug 31, 2021

Changes in this version

+ var ErrNoMixedParams = fmt.Errorf("please do not mix ordinal and named parameters")

type Dialect

+ GetFieldConverter func(columnType string) FieldConverter

+ IsIsolationLevelSupported func(level driver.IsolationLevel) bool

+ MigrateQuery func(string, []driver.NamedValue) (*rdsdataservice.ExecuteStatementInput, error)

type DialectMySQL

+ func (d *DialectMySQL) GetFieldConverter(columnType string) FieldConverter

+ func (d *DialectMySQL) IsIsolationLevelSupported(level driver.IsolationLevel) bool

+ func (d *DialectMySQL) MigrateQuery(query string, args []driver.NamedValue) (*rdsdataservice.ExecuteStatementInput, error)

type DialectPostgres

+ func (d *DialectPostgres) GetFieldConverter(columnType string) FieldConverter

+ func (d *DialectPostgres) IsIsolationLevelSupported(level driver.IsolationLevel) bool

+ func (d *DialectPostgres) MigrateQuery(query string, args []driver.NamedValue) (*rdsdataservice.ExecuteStatementInput, error)

+ type FieldConverter func(field *rdsdataservice.Field) (interface{}, error)

type Statement

+ func (s *Statement) ConvertOrdinal(values []driver.Value) []driver.NamedValue

Aug 5, 2021

Changes in this version

+ const DRIVERNAME

+ var ErrClosed = fmt.Errorf("this connection is closed")

+ var ErrNoPositional = fmt.Errorf("only named parameters supported")

+ var SupportedIsolationLevels = map[driver.IsolationLevel]bool

+ func ConvertNamedValue(arg driver.NamedValue) (value *rdsdataservice.SqlParameter, err error)

+ func ConvertNamedValues(args []driver.NamedValue) ([]*rdsdataservice.SqlParameter, error)

+ func NewResult(out *rdsdataservice.ExecuteStatementOutput) driver.Result

+ func NewRows(out *rdsdataservice.ExecuteStatementOutput) driver.Rows

+ func NewTx(transactionID *string, conn *Connection) driver.Tx

+ type Config struct

+ AWSRegion string

+ Database string

+ ResourceArn string

+ SecretArn string

+ func NewConfig(resourceARN string, secretARN string, database string, awsRegion string) (conf *Config)

+ func NewConfigFromDSN(dsn string) (conf *Config, err error)

+ func (o *Config) ToDSN() (string, error)

+ type Connection struct

+ func NewConnection(ctx context.Context, rds rdsdataserviceiface.RDSDataServiceAPI, ...) *Connection

+ func (r *Connection) Begin() (driver.Tx, error)

+ func (r *Connection) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (r *Connection) Close() error

+ func (r *Connection) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

+ func (r *Connection) IsValid() bool

+ func (r *Connection) Ping(ctx context.Context) (err error)

+ func (r *Connection) Prepare(query string) (driver.Stmt, error)

+ func (r *Connection) PrepareContext(ctx context.Context, query string) (*Statement, error)

+ func (r *Connection) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

+ func (r *Connection) ResetSession(_ context.Context) error

+ type Connector struct

+ func NewConnector(d driver.Driver, api rdsdataserviceiface.RDSDataServiceAPI, resourceARN string, ...) *Connector

+ func (r *Connector) Connect(ctx context.Context) (*Connection, error)

+ func (r *Connector) Driver() driver.Driver

+ type Dialect string

+ const DialectMySQL

+ const DialectPostgres

+ func Wakeup(r rdsdataserviceiface.RDSDataServiceAPI, resourceARN string, secretARN string, ...) (dialect Dialect, err error)

+ type Driver struct

+ func NewDriver() *Driver

+ func (r *Driver) Open(name string) (driver.Conn, error)

+ func (r *Driver) OpenConnector(dsn string) (*Connector, error)

+ type Result struct

+ func (r *Result) LastInsertId() (int64, error)

+ func (r *Result) RowsAffected() (int64, error)

+ type Rows struct

+ func (r *Rows) Close() error

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

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

+ type Statement struct

+ func NewStatement(_ context.Context, connection *Connection, sql string) *Statement

+ func (s *Statement) Close() error

+ func (s *Statement) Exec(_ []driver.Value) (driver.Result, error)

+ func (s *Statement) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *Statement) NumInput() int

+ func (s *Statement) Query(args []driver.Value) (driver.Rows, error)

+ func (s *Statement) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)

+ type Tx struct

+ Done bool

+ TransactionID *string

+ func (r *Tx) Commit() error

+ func (r *Tx) Rollback() error