databases

Documentation

Index

• Constants
• func GetStorage(ctx *DatabaseContext, dbname string, tablename string) (storages.IStorage, error)
• func Load(log *xlog.Log, conf *config.Config) error
• type DatabaseContext
  • func NewDatabaseContext(log *xlog.Log, conf *config.Config) *DatabaseContext
• type Databases
  • func NewDatabases(log *xlog.Log, conf *config.Config) *Databases
• type ExecuteFuns
• type IDatabase
  • func DatabaseFactory(ctx *DatabaseContext, node *sqlparser.DBDDL) (IDatabase, error)
  • func GetDatabase(dbname string) (IDatabase, error)
  • func NewMemoryDatabase(ctx *DatabaseContext, node *sqlparser.DBDDL) IDatabase
  • func NewOnDiskDatabase(ctx *DatabaseContext, node *sqlparser.DBDDL) IDatabase
  • func NewOrdinaryDatabase(ctx *DatabaseContext, node *sqlparser.DBDDL) IDatabase
  • func NewSystemDatabase(ctx *DatabaseContext, node *sqlparser.DBDDL) IDatabase
• type MemoryDatabase
  • func (database *MemoryDatabase) Executor() *ExecuteFuns
  • func (database *MemoryDatabase) GetStorage(tablename string) (storages.IStorage, error)
  • func (database *MemoryDatabase) GetTables() []*Table
  • func (database *MemoryDatabase) Load() error
  • func (database *MemoryDatabase) Meta() *MetaFuns
  • func (database *MemoryDatabase) Name() string
• type MetaFuns
• type OnDiskDatabase
  • func (database *OnDiskDatabase) Executor() *ExecuteFuns
  • func (database *OnDiskDatabase) GetStorage(tableName string) (storages.IStorage, error)
  • func (database *OnDiskDatabase) GetTables() []*Table
  • func (database *OnDiskDatabase) Load() error
  • func (database *OnDiskDatabase) Meta() *MetaFuns
  • func (database *OnDiskDatabase) Name() string
• type OrdinaryDatabase
  • func (database *OrdinaryDatabase) Executor() *ExecuteFuns
  • func (database *OrdinaryDatabase) GetStorage(tablename string) (storages.IStorage, error)
  • func (database *OrdinaryDatabase) GetTables() []*Table
  • func (database *OrdinaryDatabase) Load() error
  • func (database *OrdinaryDatabase) Meta() *MetaFuns
  • func (database *OrdinaryDatabase) Name() string
• type SystemDatabase
  • func (database *SystemDatabase) Executor() *ExecuteFuns
  • func (database *SystemDatabase) GetStorage(tableName string) (storages.IStorage, error)
  • func (database *SystemDatabase) GetTables() []*Table
  • func (database *SystemDatabase) Load() error
  • func (database *SystemDatabase) Meta() *MetaFuns
  • func (database *SystemDatabase) Name() string
• type Table
  • func NewTable(conf *config.Config, schema string, table string, engine string, ...) *Table

Constants

const (
	MemoryDatabaseName = "MEMORY"
)

const (
	OrdinaryDatabaseName = "ORDINARY"
)

const (
	SystemDatabaseName = "SYSTEM"
)

Functions

func GetStorage

func GetStorage(ctx *DatabaseContext, dbname string, tablename string) (storages.IStorage, error)

func Load

func Load(log *xlog.Log, conf *config.Config) error

Types

type DatabaseContext

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

func NewDatabaseContext

func NewDatabaseContext(log *xlog.Log, conf *config.Config) *DatabaseContext

type Databases

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

func NewDatabases

func NewDatabases(log *xlog.Log, conf *config.Config) *Databases

type ExecuteFuns

type ExecuteFuns struct {
	CreateDatabase func() error
	DropDatabase   func() error
	CreateTable    func(*sqlparser.DDL) error
	DropTable      func(string) error
}

type IDatabase

type IDatabase interface {
	Name() string
	Load() error
	Meta() *MetaFuns
	Executor() *ExecuteFuns
	GetTables() []*Table
	GetStorage(string) (storages.IStorage, error)
}

func DatabaseFactory

func DatabaseFactory(ctx *DatabaseContext, node *sqlparser.DBDDL) (IDatabase, error)

func GetDatabase

func GetDatabase(dbname string) (IDatabase, error)

func NewMemoryDatabase

func NewMemoryDatabase(ctx *DatabaseContext, node *sqlparser.DBDDL) IDatabase

func NewOnDiskDatabase

func NewOnDiskDatabase(ctx *DatabaseContext, node *sqlparser.DBDDL) IDatabase

func NewOrdinaryDatabase

func NewOrdinaryDatabase(ctx *DatabaseContext, node *sqlparser.DBDDL) IDatabase

func NewSystemDatabase

func NewSystemDatabase(ctx *DatabaseContext, node *sqlparser.DBDDL) IDatabase

type MemoryDatabase

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

func (*MemoryDatabase) Executor

func (database *MemoryDatabase) Executor() *ExecuteFuns

func (*MemoryDatabase) GetStorage

func (database *MemoryDatabase) GetStorage(tablename string) (storages.IStorage, error)

func (*MemoryDatabase) GetTables

func (database *MemoryDatabase) GetTables() []*Table

func (*MemoryDatabase) Load

func (database *MemoryDatabase) Load() error

func (*MemoryDatabase) Meta

func (database *MemoryDatabase) Meta() *MetaFuns

func (*MemoryDatabase) Name

func (database *MemoryDatabase) Name() string

type MetaFuns

type MetaFuns struct {
	GetDBName       func() string
	GetDataPath     func() string
	GetEngineName   func() string
	GetMetaDataPath func() string
}

type OnDiskDatabase

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

func (*OnDiskDatabase) Executor

func (database *OnDiskDatabase) Executor() *ExecuteFuns

func (*OnDiskDatabase) GetStorage

func (database *OnDiskDatabase) GetStorage(tableName string) (storages.IStorage, error)

func (*OnDiskDatabase) GetTables

func (database *OnDiskDatabase) GetTables() []*Table

func (*OnDiskDatabase) Load

func (database *OnDiskDatabase) Load() error

func (*OnDiskDatabase) Meta

func (database *OnDiskDatabase) Meta() *MetaFuns

func (*OnDiskDatabase) Name

func (database *OnDiskDatabase) Name() string

type OrdinaryDatabase

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

func (*OrdinaryDatabase) Executor

func (database *OrdinaryDatabase) Executor() *ExecuteFuns

func (*OrdinaryDatabase) GetStorage

func (database *OrdinaryDatabase) GetStorage(tablename string) (storages.IStorage, error)

func (*OrdinaryDatabase) GetTables

func (database *OrdinaryDatabase) GetTables() []*Table

func (*OrdinaryDatabase) Load

func (database *OrdinaryDatabase) Load() error

func (*OrdinaryDatabase) Meta

func (database *OrdinaryDatabase) Meta() *MetaFuns

func (*OrdinaryDatabase) Name

func (database *OrdinaryDatabase) Name() string

type SystemDatabase

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

func (*SystemDatabase) Executor

func (database *SystemDatabase) Executor() *ExecuteFuns

func (*SystemDatabase) GetStorage

func (database *SystemDatabase) GetStorage(tableName string) (storages.IStorage, error)

func (*SystemDatabase) GetTables

func (database *SystemDatabase) GetTables() []*Table

func (*SystemDatabase) Load

func (database *SystemDatabase) Load() error

func (*SystemDatabase) Meta

func (database *SystemDatabase) Meta() *MetaFuns

func (*SystemDatabase) Name

func (database *SystemDatabase) Name() string

type Table

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

func NewTable

func NewTable(conf *config.Config,
	schema string,
	table string,
	engine string,
	node *sqlparser.DDL,
	storage storages.IStorage) *Table