system

package
v0.0.4 Latest Latest
Warning

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

 Go to latest Published: Mar 30, 2022 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateConfigFile 

func CreateConfigFile(specifiedPath string) error

func ParsePast 

func ParsePast(str string) (string, error)

Types

type Config 

type Config struct {
	DefaultConnection string `yaml:"default_connection"`
	Connections       []ConnectionConfig
}

func LoadConfig 

func LoadConfig(specifiedPath string) (*Config, error)

func (*Config) FindConnection 

func (c *Config) FindConnection(targetConnectionName string) (*ConnectionConfig, error)

func (*Config) ToString 

func (c *Config) ToString() string

type ConnectionConfig 

type ConnectionConfig struct {
	Name          string
	Driver        string
	Hostname      string
	Port          string
	Username      string
	Password      string
	Database      string
	SSHKeyPath    string
	SSHHost       string
	SSHPort       string
	SSHUser       string
	SSHPassphrase string
}

func (*ConnectionConfig) CreateDatabaseConnection 

func (connection *ConnectionConfig) CreateDatabaseConnection() (*DatabaseConnection, error)

func (*ConnectionConfig) Override 

func (connection *ConnectionConfig) Override(prioritizedConnection *ConnectionConfig, overridePort bool, overrideSSHPort bool) (*ConnectionConfig, error)

func (*ConnectionConfig) ToString 

func (connection *ConnectionConfig) ToString() string

type DB 

type DB struct {
	Host     string
	Port     string
	User     string
	Password string
	DBName   string
}

type DatabaseAccessPoint 

type DatabaseAccessPoint struct {
	Username string
	Password string
	Host     string
	Port     int
	Schema   string
}

func (*DatabaseAccessPoint) CreateDatabaseConnection 

func (dap *DatabaseAccessPoint) CreateDatabaseConnection() (*DatabaseConnection, error)

type DatabaseAccessPointHub 

type DatabaseAccessPointHub interface {
	CreateDatabaseConnection() (*DatabaseConnection, error)
}

type DatabaseAccessPointOnSSH 

type DatabaseAccessPointOnSSH struct {
	DB  *DB
	SSH *SSH
}

func (*DatabaseAccessPointOnSSH) CreateDatabaseConnection 

func (dapOnSsh *DatabaseAccessPointOnSSH) CreateDatabaseConnection() (*DatabaseConnection, error)

type DatabaseConnection 

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

func (*DatabaseConnection) Close 

func (c *DatabaseConnection) Close()

func (*DatabaseConnection) Ping 

func (c *DatabaseConnection) Ping() error

func (*DatabaseConnection) SelectDateRelatedColumnValues 

func (c *DatabaseConnection) SelectDateRelatedColumnValues(table string, stmtInWhereIn string, ignoreColumns []string) ([]string, [][]string, error)

func (*DatabaseConnection) SelectDateRelatedColumnValuesNowAndToBeUpdated 

func (c *DatabaseConnection) SelectDateRelatedColumnValuesNowAndToBeUpdated(table string, interval QueryBuilderSourcePartOfInterval, stmtInWhereIn string, ignoreColumns []string) ([]string, [][]string, [][]string, error)

func (*DatabaseConnection) SelectDateRelatedColumnValuesToBeUpdated 

func (c *DatabaseConnection) SelectDateRelatedColumnValuesToBeUpdated(table string, interval QueryBuilderSourcePartOfInterval, stmtInWhereIn string, ignoreColumns []string) ([]string, [][]string, error)

func (*DatabaseConnection) SelectDateRelatedColumns 

func (c *DatabaseConnection) SelectDateRelatedColumns(table string, ignoreColumns []string) ([]string, error)

func (*DatabaseConnection) SelectPrimaryKeyColumns 

func (c *DatabaseConnection) SelectPrimaryKeyColumns(table string) ([]string, error)

func (*DatabaseConnection) SelectToUpdate 

func (c *DatabaseConnection) SelectToUpdate(table string, interval QueryBuilderSourcePartOfInterval, stmtInWhereIn string, ignoreColumns []string) ([]string, [][]string, []string, [][]string, [][]string, error)

func (*DatabaseConnection) SelectToUpdateQueryBuilder 

func (c *DatabaseConnection) SelectToUpdateQueryBuilder(table string, interval QueryBuilderSourcePartOfInterval, stmtInWhereIn string, ignoreColumns []string) (string, []string, error)

func (*DatabaseConnection) SelectToUpdateToString 

func (c *DatabaseConnection) SelectToUpdateToString(table string, interval QueryBuilderSourcePartOfInterval, stmtInWhereIn string, ignoreColumns []string) (string, error)

func (*DatabaseConnection) Update 

func (c *DatabaseConnection) Update(table string, interval QueryBuilderSourcePartOfInterval, stmtInWhereIn string, ignoreColumns []string) error

func (*DatabaseConnection) UpdateQueryBuilder 

func (c *DatabaseConnection) UpdateQueryBuilder(table string, interval QueryBuilderSourcePartOfInterval, stmtInWhereIn string, ignoreColumns []string) (string, error)

type QueryBuilderSourceForColumnValues 

type QueryBuilderSourceForColumnValues struct {
	QueryBuilderSourceForSchemaInformation
	// contains filtered or unexported fields
}

type QueryBuilderSourceForSchemaInformation 

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

type QueryBuilderSourcePartOfInterval 

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

func ParseInterval 

func ParseInterval(past string, future string) (*QueryBuilderSourcePartOfInterval, error)

type QueryBuilderSourceToUpdate 

type QueryBuilderSourceToUpdate struct {
	QueryBuilderSourceForColumnValues
	QueryBuilderSourcePartOfInterval
}

type SSH 

type SSH struct {
	Key        string
	Host       string
	Port       string
	User       string
	Passphrase string
}

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.