dialect

Documentation

Index

• Constants
• Variables
• type ConnParams
  • func (p ConnParams) GetAddr(defaultHost string, defaultPort uint16) string
  • func (p ConnParams) StrPort(defaultPort uint16) string
• type Dialect
  • func GetDialectByName(name string) Dialect
• type Mssql
  • func (Mssql) ImporterPath() string
  • func (Mssql) Name() string
  • func (Mssql) ParseDSN(params ConnParams) string
  • func (Mssql) QuoteIdent(ident string) string
• type Mysql
  • func (Mysql) ImporterPath() string
  • func (Mysql) Name() string
  • func (Mysql) ParseDSN(params ConnParams) string
  • func (Mysql) QuoteIdent(ident string) string
• type Oracle
  • func (Oracle) ImporterPath() string
  • func (Oracle) Name() string
  • func (Oracle) ParseDSN(params ConnParams) string
  • func (Oracle) QuoteIdent(ident string) string
• type Postgres
  • func (Postgres) ImporterPath() string
  • func (Postgres) Name() string
  • func (Postgres) ParseDSN(params ConnParams) string
  • func (Postgres) QuoteIdent(ident string) string
• type Redis
  • func NewRedis(addr, opts string) (*Redis, error)
  • func (r *Redis) Connect(verbose bool) (redis.Conn, error)
  • func (r *Redis) GetOptions() []redis.DialOption
  • func (Redis) ImporterPath() string
  • func (Redis) Name() string
  • func (r *Redis) ParseDSN(params ConnParams) string
  • func (r *Redis) ParseOptions(opts string) (err error)
  • func (Redis) QuoteIdent(ident string) string
• type Sqlite
  • func (Sqlite) ImporterPath() string
  • func (Sqlite) Name() string
  • func (Sqlite) ParseDSN(params ConnParams) string
  • func (Sqlite) QuoteIdent(ident string) string
• type Sqlite3
  • func (Sqlite3) Name() string

Constants

const MSSQL_DEFAULT_PORT uint16 = 1433

const MYSQL_DEFAULT_PORT uint16 = 3306

const ORACLE_DEFAULT_PORT uint16 = 1521

const PGSQL_DEFAULT_PORT uint16 = 5432

const REDIS_DEFAULT_PORT uint16 = 6379

Variables

var (
	ConcatWith = utils.ConcatWith
	WrapWith   = utils.WrapWith
)

Types

type ConnParams

type ConnParams struct {
	Host     string                 `json:"host" yaml:"host" toml:"host"`
	Port     int                    `json:"port,omitempty" yaml:"port,omitempty" toml:"port"`
	Username string                 `json:"username,omitempty" yaml:"username,omitempty" toml:"username"`
	Password string                 `json:"password" yaml:"password" toml:"password"`
	Database string                 `json:"database" yaml:"database" toml:"database"`
	Options  map[string]interface{} `json:"options,omitempty" yaml:"options,omitempty" toml:"options"`
}

连接配置

func (ConnParams) GetAddr

func (p ConnParams) GetAddr(defaultHost string, defaultPort uint16) string

func (ConnParams) StrPort

func (p ConnParams) StrPort(defaultPort uint16) string

type Dialect

type Dialect interface {
	Name() string
	ImporterPath() string
	QuoteIdent(ident string) string
	ParseDSN(params ConnParams) string
}

func GetDialectByName

func GetDialectByName(name string) Dialect

type Mssql

type Mssql struct {
}

func (Mssql) ImporterPath

func (Mssql) ImporterPath() string

func (Mssql) Name

func (Mssql) Name() string

func (Mssql) ParseDSN

func (Mssql) ParseDSN(params ConnParams) string

func (Mssql) QuoteIdent

func (Mssql) QuoteIdent(ident string) string

type Mysql

type Mysql struct {
}

func (Mysql) ImporterPath

func (Mysql) ImporterPath() string

func (Mysql) Name

func (Mysql) Name() string

func (Mysql) ParseDSN

func (Mysql) ParseDSN(params ConnParams) string

func (Mysql) QuoteIdent

func (Mysql) QuoteIdent(ident string) string

type Oracle

type Oracle struct {
}

func (Oracle) ImporterPath

func (Oracle) ImporterPath() string

func (Oracle) Name

func (Oracle) Name() string

func (Oracle) ParseDSN

func (Oracle) ParseDSN(params ConnParams) string

func (Oracle) QuoteIdent

func (Oracle) QuoteIdent(ident string) string

type Postgres

type Postgres struct {
}

func (Postgres) ImporterPath

func (Postgres) ImporterPath() string

func (Postgres) Name

func (Postgres) Name() string

func (Postgres) ParseDSN

func (Postgres) ParseDSN(params ConnParams) string

func (Postgres) QuoteIdent

func (Postgres) QuoteIdent(ident string) string

type Redis

type Redis struct {
	Values url.Values
	// contains filtered or unexported fields
}

func NewRedis

func NewRedis(addr, opts string) (*Redis, error)

func (*Redis) Connect

func (r *Redis) Connect(verbose bool) (redis.Conn, error)

func (*Redis) GetOptions

func (r *Redis) GetOptions() []redis.DialOption

func (Redis) ImporterPath

func (Redis) ImporterPath() string

func (Redis) Name

func (Redis) Name() string

func (*Redis) ParseDSN

func (r *Redis) ParseDSN(params ConnParams) string

func (*Redis) ParseOptions

func (r *Redis) ParseOptions(opts string) (err error)

func (Redis) QuoteIdent

func (Redis) QuoteIdent(ident string) string

type Sqlite

type Sqlite struct {
}

func (Sqlite) ImporterPath

func (Sqlite) ImporterPath() string

func (Sqlite) Name

func (Sqlite) Name() string

func (Sqlite) ParseDSN

func (Sqlite) ParseDSN(params ConnParams) string

func (Sqlite) QuoteIdent

func (Sqlite) QuoteIdent(ident string) string

type Sqlite3

type Sqlite3 struct {
	Sqlite
}

func (Sqlite3) Name

func (Sqlite3) Name() string