Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( ErrUnmatchedDoubleQuote = func(position int) error { return fmt.Errorf("syntax error: unmatched double quote at: %d", position) } ErrUnmatchedSingleQuote = func(position int) error { return fmt.Errorf("syntax error: unmatched single quote at: %d", position) } )
ErrUnmatchedDoubleQuote and ErrUnmatchedSingleQuote are errors returned from ParseRedisCmd
var (
ErrUnsupportedTypeAlias = errors.New("no driver registered for provided type alias")
)
Functions ¶
func NewConnection ¶
func NewConnection(params *core.ConnectionParams) (*core.Connection, error)
NewConnection is a wrapper around core.NewConnection that uses the internal mux for adapter registration.
Types ¶
type BigQuery ¶
type BigQuery struct{}
func (*BigQuery) Connect ¶
Connect creates a BigQuery client connected to the project specified in the url. The format of the url is as follows:
bigquery://[project][?options]
where project is optional. If not set, the project will attempt to be detected from the credentials and current gcloud settings.
The options query parameters map directly to bigquery.QueryConfig fields using kebab-case. For example, MaxBytesBilled becomes max-bytes-billed.
Common options include:
- credentials=path/to/creds.json: Path to credentials file
- max-bytes-billed=integer: Maximum bytes to be billed
- disable-query-cache=bool: Whether to disable query cache
- use-legacy-sql=bool: Whether to use legacy SQL
- location=string: Query location
- enable-storage-read=bool: Enable BigQuery Storage API
For internal testing:
- endpoint=url: Custom endpoint for test containers
If credentials are not specified, they will be located according to the Google Default Credentials process.
func (*BigQuery) GetHelpers ¶
func (*BigQuery) GetHelpers(opts *core.TableOptions) map[string]string
type Clickhouse ¶
type Clickhouse struct{}
func (*Clickhouse) GetHelpers ¶
func (*Clickhouse) GetHelpers(opts *core.TableOptions) map[string]string
type Databricks ¶
type Databricks struct{}
func (*Databricks) Connect ¶
func (d *Databricks) Connect(connectionURL string) (core.Driver, error)
see https://github.com/databricks/databricks-sql-go for more information.
func (*Databricks) GetHelpers ¶
func (d *Databricks) GetHelpers(opts *core.TableOptions) map[string]string
GetHelpers returns a map of helper queries for the given table.
type Duck ¶
type Duck struct{}
func (*Duck) GetHelpers ¶
func (*Duck) GetHelpers(opts *core.TableOptions) map[string]string
type Mongo ¶
type Mongo struct{}
func (*Mongo) GetHelpers ¶
func (*Mongo) GetHelpers(opts *core.TableOptions) map[string]string
type MySQL ¶
type MySQL struct{}
func (*MySQL) GetHelpers ¶
func (*MySQL) GetHelpers(opts *core.TableOptions) map[string]string
type Oracle ¶
type Oracle struct{}
func (*Oracle) GetHelpers ¶
func (*Oracle) GetHelpers(opts *core.TableOptions) map[string]string
type Postgres ¶
type Postgres struct{}
func (*Postgres) GetHelpers ¶
func (*Postgres) GetHelpers(opts *core.TableOptions) map[string]string
type Redis ¶
type Redis struct{}
func (*Redis) GetHelpers ¶
func (*Redis) GetHelpers(opts *core.TableOptions) map[string]string
type Redshift ¶
type Redshift struct{}
func (*Redshift) GetHelpers ¶
func (r *Redshift) GetHelpers(opts *core.TableOptions) map[string]string
type SQLServer ¶
type SQLServer struct{}
func (*SQLServer) GetHelpers ¶
func (*SQLServer) GetHelpers(opts *core.TableOptions) map[string]string
Source Files
¶
- adapters.go
- bigquery.go
- bigquery_driver.go
- clickhouse.go
- clickhouse_driver.go
- databricks.go
- databricks_driver.go
- duck.go
- duck_driver.go
- mongo.go
- mongo_driver.go
- mysql.go
- mysql_driver.go
- oracle.go
- oracle_driver.go
- postgres.go
- postgres_driver.go
- redis.go
- redis_driver.go
- redshift.go
- redshift_driver.go
- sqlite.go
- sqlite_driver.go
- sqlserver.go
- sqlserver_driver.go