database

package
v0.2.22 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 26, 2022 License: MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultMaxIdleConns = 10
	DefaultMaxOpenConns = 5
)

Variables

View Source 
var (
	ErrNotImplementation error = errors.New("not implementation")
)

Functions

func Coalesce added in v0.2.22 

func Coalesce(str ...string) string

func ColumnDoc 

func ColumnDoc(tableName string, colDesc *ColumnDesc) string

func Columns 

func Columns(rows *sql.Rows) ([]string, error)

func QueryExecType 

func QueryExecType(prefix, sqlstr string) (string, bool)

QueryExecType is the default way to determine the "EXEC" prefix for a SQL query and whether or not it should be Exec'd or Query'd.

func RegisterFactory 

func RegisterFactory(name dialect.DatabaseDriver, factory Factory)

func RegisterOpen 

func RegisterOpen(name dialect.DatabaseDriver, opener Opener)

func Registered 

func Registered(name dialect.DatabaseDriver) bool

func ScanRows 

func ScanRows(rows *sql.Rows, columnLength int) ([][]string, error)

func SubqueryColumnDoc added in v0.2.5 

func SubqueryColumnDoc(identName string, views []*parseutil.SubQueryView, dbCache *DBCache) string

func SubqueryDoc added in v0.2.5 

func SubqueryDoc(name string, views []*parseutil.SubQueryView, dbCache *DBCache) string

func TableDoc 

func TableDoc(tableName string, cols []*ColumnDesc) string

Types

type ColumnDesc 

type ColumnDesc struct {
	Schema  string
	Table   string
	Name    string
	Type    string
	Null    string
	Key     string
	Default sql.NullString
	Extra   string
}

func (*ColumnDesc) OnelineDesc 

func (cd *ColumnDesc) OnelineDesc() string

type DBCache 

type DBCache struct {
	Schemas           map[string]string
	SchemaTables      map[string][]string
	ColumnsWithParent map[string][]*ColumnDesc
	// contains filtered or unexported fields
}

func (*DBCache) Column 

func (dc *DBCache) Column(tableName, colName string) (*ColumnDesc, bool)

func (*DBCache) ColumnDatabase 

func (dc *DBCache) ColumnDatabase(dbName, tableName string) (cols []*ColumnDesc, ok bool)

func (*DBCache) ColumnDescs 

func (dc *DBCache) ColumnDescs(tableName string) (cols []*ColumnDesc, ok bool)

func (*DBCache) Database 

func (dc *DBCache) Database(dbName string) (db string, ok bool)

func (*DBCache) SortedSchemas 

func (dc *DBCache) SortedSchemas() []string

func (*DBCache) SortedTables 

func (dc *DBCache) SortedTables() []string

func (*DBCache) SortedTablesByDBName 

func (dc *DBCache) SortedTablesByDBName(dbName string) (tbls []string, ok bool)

type DBCacheGenerator 

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

func NewDBCacheUpdater 

func NewDBCacheUpdater(repo DBRepository) *DBCacheGenerator

func (*DBCacheGenerator) GenerateDBCachePrimary 

func (u *DBCacheGenerator) GenerateDBCachePrimary(ctx context.Context) (*DBCache, error)

func (*DBCacheGenerator) GenerateDBCacheSecondary 

func (u *DBCacheGenerator) GenerateDBCacheSecondary(ctx context.Context) (map[string][]*ColumnDesc, error)

type DBConfig 

type DBConfig struct {
	Alias          string                 `json:"alias" yaml:"alias"`
	Driver         dialect.DatabaseDriver `json:"driver" yaml:"driver"`
	DataSourceName string                 `json:"dataSourceName" yaml:"dataSourceName"`
	Proto          Proto                  `json:"proto" yaml:"proto"`
	User           string                 `json:"user" yaml:"user"`
	Passwd         string                 `json:"passwd" yaml:"passwd"`
	Host           string                 `json:"host" yaml:"host"`
	Port           int                    `json:"port" yaml:"port"`
	Path           string                 `json:"path" yaml:"path"`
	DBName         string                 `json:"dbName" yaml:"dbName"`
	Params         map[string]string      `json:"params" yaml:"params"`
	SSHCfg         *SSHConfig             `json:"sshConfig" yaml:"sshConfig"`
}

func (*DBConfig) Validate added in v0.2.12 

func (c *DBConfig) Validate() error

type DBConnection 

type DBConnection struct {
	Conn    *sql.DB
	SSHConn *ssh.Client
	Driver  dialect.DatabaseDriver
}

func Open 

func Open(cfg *DBConfig) (*DBConnection, error)

func (*DBConnection) Close 

func (db *DBConnection) Close() error

type DBOption 

type DBOption struct {
	MaxIdleConns int
	MaxOpenConns int
}

type DBRepository 

type DBRepository interface {
	Driver() dialect.DatabaseDriver
	CurrentDatabase(ctx context.Context) (string, error)
	Databases(ctx context.Context) ([]string, error)
	CurrentSchema(ctx context.Context) (string, error)
	Schemas(ctx context.Context) ([]string, error)
	SchemaTables(ctx context.Context) (map[string][]string, error)
	DescribeDatabaseTable(ctx context.Context) ([]*ColumnDesc, error)
	DescribeDatabaseTableBySchema(ctx context.Context, schemaName string) ([]*ColumnDesc, error)
	Exec(ctx context.Context, query string) (sql.Result, error)
	Query(ctx context.Context, query string) (*sql.Rows, error)
}

func CreateRepository 

func CreateRepository(driver dialect.DatabaseDriver, db *sql.DB) (DBRepository, error)

func NewMockDBRepository 

func NewMockDBRepository(conn *sql.DB) DBRepository

func NewMssqlDBRepository added in v0.2.20 

func NewMssqlDBRepository(conn *sql.DB) DBRepository

func NewMySQLDBRepository 

func NewMySQLDBRepository(conn *sql.DB) DBRepository

func NewOracleDBRepository added in v0.2.21 

func NewOracleDBRepository(conn *sql.DB) DBRepository

func NewPostgreSQLDBRepository 

func NewPostgreSQLDBRepository(conn *sql.DB) DBRepository

func NewSQLite3DBRepository 

func NewSQLite3DBRepository(conn *sql.DB) DBRepository

type Factory 

type Factory func(*sql.DB) DBRepository

type MockDBRepository 

type MockDBRepository struct {
	MockDatabase                      func(context.Context) (string, error)
	MockDatabases                     func(context.Context) ([]string, error)
	MockDatabaseTables                func(context.Context) (map[string][]string, error)
	MockTables                        func(context.Context) ([]string, error)
	MockDescribeTable                 func(context.Context, string) ([]*ColumnDesc, error)
	MockDescribeDatabaseTable         func(context.Context) ([]*ColumnDesc, error)
	MockDescribeDatabaseTableBySchema func(context.Context, string) ([]*ColumnDesc, error)
	MockExec                          func(context.Context, string) (sql.Result, error)
	MockQuery                         func(context.Context, string) (*sql.Rows, error)
}

func (*MockDBRepository) CurrentDatabase 

func (m *MockDBRepository) CurrentDatabase(ctx context.Context) (string, error)

func (*MockDBRepository) CurrentSchema 

func (m *MockDBRepository) CurrentSchema(ctx context.Context) (string, error)

func (*MockDBRepository) Databases 

func (m *MockDBRepository) Databases(ctx context.Context) ([]string, error)

func (*MockDBRepository) DescribeDatabaseTable 

func (m *MockDBRepository) DescribeDatabaseTable(ctx context.Context) ([]*ColumnDesc, error)

func (*MockDBRepository) DescribeDatabaseTableBySchema 

func (m *MockDBRepository) DescribeDatabaseTableBySchema(ctx context.Context, schemaName string) ([]*ColumnDesc, error)

func (*MockDBRepository) Driver added in v0.2.11 

func (m *MockDBRepository) Driver() dialect.DatabaseDriver

func (*MockDBRepository) Exec 

func (m *MockDBRepository) Exec(ctx context.Context, query string) (sql.Result, error)

func (*MockDBRepository) Query 

func (m *MockDBRepository) Query(ctx context.Context, query string) (*sql.Rows, error)

func (*MockDBRepository) SchemaTables 

func (m *MockDBRepository) SchemaTables(ctx context.Context) (map[string][]string, error)

func (*MockDBRepository) Schemas 

func (m *MockDBRepository) Schemas(ctx context.Context) ([]string, error)

func (*MockDBRepository) Tables 

func (m *MockDBRepository) Tables(ctx context.Context) ([]string, error)

type MockResult 

type MockResult struct {
	MockLastInsertID func() (int64, error)
	MockRowsAffected func() (int64, error)
}

func (*MockResult) LastInsertId 

func (m *MockResult) LastInsertId() (int64, error)

func (*MockResult) RowsAffected 

func (m *MockResult) RowsAffected() (int64, error)

type MssqlDBRepository added in v0.2.20 

type MssqlDBRepository struct {
	Conn *sql.DB
}

func (*MssqlDBRepository) CurrentDatabase added in v0.2.20 

func (db *MssqlDBRepository) CurrentDatabase(ctx context.Context) (string, error)

func (*MssqlDBRepository) CurrentSchema added in v0.2.20 

func (db *MssqlDBRepository) CurrentSchema(ctx context.Context) (string, error)

func (*MssqlDBRepository) Databases added in v0.2.20 

func (db *MssqlDBRepository) Databases(ctx context.Context) ([]string, error)

func (*MssqlDBRepository) DescribeDatabaseTable added in v0.2.20 

func (db *MssqlDBRepository) DescribeDatabaseTable(ctx context.Context) ([]*ColumnDesc, error)

func (*MssqlDBRepository) DescribeDatabaseTableBySchema added in v0.2.20 

func (db *MssqlDBRepository) DescribeDatabaseTableBySchema(ctx context.Context, schemaName string) ([]*ColumnDesc, error)

func (*MssqlDBRepository) Driver added in v0.2.20 

func (db *MssqlDBRepository) Driver() dialect.DatabaseDriver

func (*MssqlDBRepository) Exec added in v0.2.20 

func (db *MssqlDBRepository) Exec(ctx context.Context, query string) (sql.Result, error)

func (*MssqlDBRepository) Query added in v0.2.20 

func (db *MssqlDBRepository) Query(ctx context.Context, query string) (*sql.Rows, error)

func (*MssqlDBRepository) SchemaTables added in v0.2.20 

func (db *MssqlDBRepository) SchemaTables(ctx context.Context) (map[string][]string, error)

func (*MssqlDBRepository) Schemas added in v0.2.20 

func (db *MssqlDBRepository) Schemas(ctx context.Context) ([]string, error)

func (*MssqlDBRepository) Tables added in v0.2.20 

func (db *MssqlDBRepository) Tables(ctx context.Context) ([]string, error)

type MySQLDBRepository 

type MySQLDBRepository struct {
	Conn *sql.DB
	// contains filtered or unexported fields
}

func (*MySQLDBRepository) CurrentDatabase 

func (db *MySQLDBRepository) CurrentDatabase(ctx context.Context) (string, error)

func (*MySQLDBRepository) CurrentSchema 

func (db *MySQLDBRepository) CurrentSchema(ctx context.Context) (string, error)

func (*MySQLDBRepository) Databases 

func (db *MySQLDBRepository) Databases(ctx context.Context) ([]string, error)

func (*MySQLDBRepository) DescribeDatabaseTable 

func (db *MySQLDBRepository) DescribeDatabaseTable(ctx context.Context) ([]*ColumnDesc, error)

func (*MySQLDBRepository) DescribeDatabaseTableBySchema 

func (db *MySQLDBRepository) DescribeDatabaseTableBySchema(ctx context.Context, schemaName string) ([]*ColumnDesc, error)

func (*MySQLDBRepository) Driver added in v0.2.11 

func (db *MySQLDBRepository) Driver() dialect.DatabaseDriver

func (*MySQLDBRepository) Exec 

func (db *MySQLDBRepository) Exec(ctx context.Context, query string) (sql.Result, error)

func (*MySQLDBRepository) Query 

func (db *MySQLDBRepository) Query(ctx context.Context, query string) (*sql.Rows, error)

func (*MySQLDBRepository) SchemaTables 

func (db *MySQLDBRepository) SchemaTables(ctx context.Context) (map[string][]string, error)

func (*MySQLDBRepository) Schemas 

func (db *MySQLDBRepository) Schemas(ctx context.Context) ([]string, error)

func (*MySQLDBRepository) Tables 

func (db *MySQLDBRepository) Tables(ctx context.Context) ([]string, error)

type MySQLViaSSHDialer 

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

func (*MySQLViaSSHDialer) Dial 

func (d *MySQLViaSSHDialer) Dial(ctx context.Context, addr string) (net.Conn, error)

type Opener 

type Opener func(*DBConfig) (*DBConnection, error)

type OracleDBRepository added in v0.2.21 

type OracleDBRepository struct {
	Conn *sql.DB
}

func (*OracleDBRepository) CurrentDatabase added in v0.2.21 

func (db *OracleDBRepository) CurrentDatabase(ctx context.Context) (string, error)

func (*OracleDBRepository) CurrentSchema added in v0.2.21 

func (db *OracleDBRepository) CurrentSchema(ctx context.Context) (string, error)

func (*OracleDBRepository) Databases added in v0.2.21 

func (db *OracleDBRepository) Databases(ctx context.Context) ([]string, error)

func (*OracleDBRepository) DescribeDatabaseTable added in v0.2.21 

func (db *OracleDBRepository) DescribeDatabaseTable(ctx context.Context) ([]*ColumnDesc, error)

func (*OracleDBRepository) DescribeDatabaseTableBySchema added in v0.2.21 

func (db *OracleDBRepository) DescribeDatabaseTableBySchema(ctx context.Context, schemaName string) ([]*ColumnDesc, error)

func (*OracleDBRepository) Driver added in v0.2.21 

func (db *OracleDBRepository) Driver() dialect.DatabaseDriver

func (*OracleDBRepository) Exec added in v0.2.21 

func (db *OracleDBRepository) Exec(ctx context.Context, query string) (sql.Result, error)

func (*OracleDBRepository) Query added in v0.2.21 

func (db *OracleDBRepository) Query(ctx context.Context, query string) (*sql.Rows, error)

func (*OracleDBRepository) SchemaTables added in v0.2.21 

func (db *OracleDBRepository) SchemaTables(ctx context.Context) (map[string][]string, error)

func (*OracleDBRepository) Schemas added in v0.2.21 

func (db *OracleDBRepository) Schemas(ctx context.Context) ([]string, error)

func (*OracleDBRepository) Tables added in v0.2.21 

func (db *OracleDBRepository) Tables(ctx context.Context) ([]string, error)

type PostgreSQLDBRepository 

type PostgreSQLDBRepository struct {
	Conn *sql.DB
}

func (*PostgreSQLDBRepository) CurrentDatabase 

func (db *PostgreSQLDBRepository) CurrentDatabase(ctx context.Context) (string, error)

func (*PostgreSQLDBRepository) CurrentSchema 

func (db *PostgreSQLDBRepository) CurrentSchema(ctx context.Context) (string, error)

func (*PostgreSQLDBRepository) Databases 

func (db *PostgreSQLDBRepository) Databases(ctx context.Context) ([]string, error)

func (*PostgreSQLDBRepository) DescribeDatabaseTable 

func (db *PostgreSQLDBRepository) DescribeDatabaseTable(ctx context.Context) ([]*ColumnDesc, error)

func (*PostgreSQLDBRepository) DescribeDatabaseTableBySchema 

func (db *PostgreSQLDBRepository) DescribeDatabaseTableBySchema(ctx context.Context, schemaName string) ([]*ColumnDesc, error)

func (*PostgreSQLDBRepository) Driver added in v0.2.11 

func (db *PostgreSQLDBRepository) Driver() dialect.DatabaseDriver

func (*PostgreSQLDBRepository) Exec 

func (db *PostgreSQLDBRepository) Exec(ctx context.Context, query string) (sql.Result, error)

func (*PostgreSQLDBRepository) Query 

func (db *PostgreSQLDBRepository) Query(ctx context.Context, query string) (*sql.Rows, error)

func (*PostgreSQLDBRepository) SchemaTables 

func (db *PostgreSQLDBRepository) SchemaTables(ctx context.Context) (map[string][]string, error)

func (*PostgreSQLDBRepository) Schemas 

func (db *PostgreSQLDBRepository) Schemas(ctx context.Context) ([]string, error)

func (*PostgreSQLDBRepository) Tables 

func (db *PostgreSQLDBRepository) Tables(ctx context.Context) ([]string, error)

type Proto 

type Proto string
const (
	ProtoTCP  Proto = "tcp"
	ProtoUDP  Proto = "udp"
	ProtoUnix Proto = "unix"
)

type SQLite3DBRepository 

type SQLite3DBRepository struct {
	Conn *sql.DB
}

func (*SQLite3DBRepository) CurrentDatabase 

func (db *SQLite3DBRepository) CurrentDatabase(ctx context.Context) (string, error)

func (*SQLite3DBRepository) CurrentSchema 

func (db *SQLite3DBRepository) CurrentSchema(ctx context.Context) (string, error)

func (*SQLite3DBRepository) Databases 

func (db *SQLite3DBRepository) Databases(ctx context.Context) ([]string, error)

func (*SQLite3DBRepository) DescribeDatabaseTable 

func (db *SQLite3DBRepository) DescribeDatabaseTable(ctx context.Context) ([]*ColumnDesc, error)

func (*SQLite3DBRepository) DescribeDatabaseTableBySchema 

func (db *SQLite3DBRepository) DescribeDatabaseTableBySchema(ctx context.Context, schemaName string) ([]*ColumnDesc, error)

func (*SQLite3DBRepository) Driver added in v0.2.11 

func (db *SQLite3DBRepository) Driver() dialect.DatabaseDriver

func (*SQLite3DBRepository) Exec 

func (db *SQLite3DBRepository) Exec(ctx context.Context, query string) (sql.Result, error)

func (*SQLite3DBRepository) Query 

func (db *SQLite3DBRepository) Query(ctx context.Context, query string) (*sql.Rows, error)

func (*SQLite3DBRepository) SchemaTables 

func (db *SQLite3DBRepository) SchemaTables(ctx context.Context) (map[string][]string, error)

func (*SQLite3DBRepository) Schemas 

func (db *SQLite3DBRepository) Schemas(ctx context.Context) ([]string, error)

func (*SQLite3DBRepository) Tables 

func (db *SQLite3DBRepository) Tables(ctx context.Context) ([]string, error)

type SSHConfig 

type SSHConfig struct {
	Host       string `json:"host" yaml:"host"`
	Port       int    `json:"port" yaml:"port"`
	User       string `json:"user" yaml:"user"`
	PassPhrase string `json:"passPhrase" yaml:"passPhrase"`
	PrivateKey string `json:"privateKey" yaml:"privateKey"`
}

func (*SSHConfig) ClientConfig 

func (s *SSHConfig) ClientConfig() (*ssh.ClientConfig, error)

func (*SSHConfig) Endpoint 

func (s *SSHConfig) Endpoint() string

func (*SSHConfig) Validate added in v0.2.12 

func (c *SSHConfig) Validate() error

type Worker 

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

func NewWorker 

func NewWorker() *Worker

func (*Worker) Cache 

func (w *Worker) Cache() *DBCache

func (*Worker) ReCache 

func (w *Worker) ReCache(ctx context.Context, repo DBRepository) error

func (*Worker) Start 

func (w *Worker) Start()

func (*Worker) Stop 

func (w *Worker) Stop()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.