redshiftdatasqldriver

README

redshift-data-sql-driver

Redshift-Data API SQL Driver for Go's database/sql package

Usage

for example:

package main

import (
	"context"
	"database/sql"
	"log"

	_ "github.com/mashiike/redshift-data-sql-driver"
)

func main() {
	db, err := sql.Open("redshift-data", "workgroup(default)/dev?timeout=1m")
	if err != nil {
		log.Fatalln(err)
	}
	defer db.Close()
	rows, err := db.QueryContext(
		context.Background(),
		`SELECT table_schema,table_name,table_type FROM svv_tables WHERE table_schema not like :ignore_schema`,
		sql.Named("ignore_schema", "pg_%"),
	)
	if err != nil {
		log.Fatalln(err)
	}
	for rows.Next() {
		var schema, name, tableType string
		err := rows.Scan(&schema, &name, &tableType)
		if err != nil {
			log.Println(err)
			return
		}
		log.Printf("%s.%s\t%s", schema, name, tableType)
	}
}

The pattern for specifying DSNs is as follows

• with redshift serverless: workgroup([name])/[database]
• with provisoned cluster: [dbuser]@cluster([name])/[database]
• with AWS Secrets Manager: arn:aws:secretsmanager:us-east-1:0123456789012:secret:redshift

The DSN parameters include

• timeout: Timeout for query execution. default = 15m0s
• polling: Interval to check for the end of a running query. default = 10ms
• region: Redshift Data API's region. Default is environment setting

Parameter settings are in the format of URL query parameter

workgroup(default)/dev?timeout=1m&polling=1ms

Unsupported Features

The following functions are not available

BeginTx,Begin

The Redshift Data API does not have an interface for pasting transactions and querying sequentially. Therefore, transactional functionality is not available.

Prepare

Prepared Statements were not supported because the Redshift Data API does not have the concept of connecting to a DB.

LICENSE

MIT

Documentation

Index

• Variables
• func SetDebugLogger(l Logger) error
• func SetLogger(l Logger) error
• type Logger
• type RedshiftDataClient
  • func DefaultRedshiftDataClientConstructor(ctx context.Context, cfg *RedshiftDataConfig) (RedshiftDataClient, error)
• type RedshiftDataConfig
  • func ParseDSN(dsn string) (*RedshiftDataConfig, error)
  • func (cfg *RedshiftDataConfig) String() string
  • func (cfg *RedshiftDataConfig) WithRegion(region string) *RedshiftDataConfig

Variables

var (
	ErrNotSupported = errors.New("not supported")
	ErrDSNEmpty     = errors.New("dsn is empty")
	ErrConnClosed   = errors.New("connection closed")
)

var RedshiftDataClientConstructor func(ctx context.Context, cfg *RedshiftDataConfig) (RedshiftDataClient, error)

Functions

func SetDebugLogger

func SetDebugLogger(l Logger) error

func SetLogger

func SetLogger(l Logger) error

Types

type Logger

type Logger interface {
	Printf(format string, v ...any)
	SetOutput(w io.Writer)
	Writer() io.Writer
}

type RedshiftDataClient

type RedshiftDataClient interface {
	ExecuteStatement(ctx context.Context, params *redshiftdata.ExecuteStatementInput, optFns ...func(*redshiftdata.Options)) (*redshiftdata.ExecuteStatementOutput, error)
	DescribeStatement(ctx context.Context, params *redshiftdata.DescribeStatementInput, optFns ...func(*redshiftdata.Options)) (*redshiftdata.DescribeStatementOutput, error)
	CancelStatement(ctx context.Context, params *redshiftdata.CancelStatementInput, optFns ...func(*redshiftdata.Options)) (*redshiftdata.CancelStatementOutput, error)
	redshiftdata.GetStatementResultAPIClient
}

func DefaultRedshiftDataClientConstructor

func DefaultRedshiftDataClientConstructor(ctx context.Context, cfg *RedshiftDataConfig) (RedshiftDataClient, error)

type RedshiftDataConfig

type RedshiftDataConfig struct {
	ClusterIdentifier *string
	Database          *string
	DbUser            *string
	WorkgroupName     *string
	SecretsARN        *string

	Timeout time.Duration
	Polling time.Duration

	Params             url.Values
	RedshiftDataOptFns []func(*redshiftdata.Options)
}

func ParseDSN

func ParseDSN(dsn string) (*RedshiftDataConfig, error)

func (*RedshiftDataConfig) String

func (cfg *RedshiftDataConfig) String() string

func (*RedshiftDataConfig) WithRegion

func (cfg *RedshiftDataConfig) WithRegion(region string) *RedshiftDataConfig