db

Documentation

Index

• Variables
• func MySQLfacotry(_ context.Context, config *dbconfig.DBConfig) (db *aorm.DB, err error)
• func PostgresFactory(ctx context.Context, config *dbconfig.DBConfig) (db *aorm.DB, err error)
• func Sqlite3Factory(_ context.Context, config *dbconfig.DBConfig) (db *aorm.DB, err error)
• type CmdDBConnection
  • func NewCmdDBConnection(cmd *exec.Cmd, closer func(c *CmdDBConnection) error) *CmdDBConnection
  • func (c *CmdDBConnection) Close() error
  • func (c *CmdDBConnection) Do(f func(c RawDBConnection))
  • func (c *CmdDBConnection) Error() *bufio.Reader
  • func (c *CmdDBConnection) In() io.Writer
  • func (c *CmdDBConnection) Open() (err error)
  • func (c *CmdDBConnection) Out() *bufio.Reader
• type Factories
  • func (f Factories) Factory(ctx context.Context, config *dbconfig.DBConfig) (db *aorm.DB, err error)
  • func (f Factories) Register(adapterName string, factory Factory)
• type Factory
• type RawDBConnection
  • func PostgreSQLRawFactory(ctx context.Context, config *dbconfig.DBConfig) (db RawDBConnection, err error)
  • func Sqlite3RawFactory(ctx context.Context, config *dbconfig.DBConfig) (db RawDBConnection, err error)
• type RawFactories
• type RawFactory

Variables

var SystemFactories = Factories{
	"mysql":    MySQLfacotry,
	"postgres": PostgresFactory,
	"sqlite":   Sqlite3Factory,
	"sqlite3":  Sqlite3Factory,
}

var SystemRawFactories = RawFactories{
	"postgres": PostgreSQLRawFactory,
	"sqlite":   Sqlite3RawFactory,
	"sqlite3":  Sqlite3RawFactory,
}

Functions

func MySQLfacotry

func MySQLfacotry(_ context.Context, config *dbconfig.DBConfig) (db *aorm.DB, err error)

func PostgresFactory

func PostgresFactory(ctx context.Context, config *dbconfig.DBConfig) (db *aorm.DB, err error)

func Sqlite3Factory

func Sqlite3Factory(_ context.Context, config *dbconfig.DBConfig) (db *aorm.DB, err error)

Types

type CmdDBConnection

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

func NewCmdDBConnection

func NewCmdDBConnection(cmd *exec.Cmd, closer func(c *CmdDBConnection) error) *CmdDBConnection

func (*CmdDBConnection) Close

func (c *CmdDBConnection) Close() error

func (*CmdDBConnection) Do

func (c *CmdDBConnection) Do(f func(c RawDBConnection))

func (*CmdDBConnection) Error

func (c *CmdDBConnection) Error() *bufio.Reader

func (*CmdDBConnection) In

func (c *CmdDBConnection) In() io.Writer

func (*CmdDBConnection) Open

func (c *CmdDBConnection) Open() (err error)

func (*CmdDBConnection) Out

func (c *CmdDBConnection) Out() *bufio.Reader

type Factories

type Factories map[string]Factory

func (Factories) Factory

func (f Factories) Factory(ctx context.Context, config *dbconfig.DBConfig) (db *aorm.DB, err error)

func (Factories) Register

func (f Factories) Register(adapterName string, factory Factory)

type Factory

type Factory func(ctx context.Context, config *dbconfig.DBConfig) (db *aorm.DB, err error)

type RawDBConnection

type RawDBConnection interface {
	io.Closer
	Open() error
	Error() *bufio.Reader
	Out() *bufio.Reader
	In() io.Writer
	Do(func(c RawDBConnection))
}

func PostgreSQLRawFactory

func PostgreSQLRawFactory(ctx context.Context, config *dbconfig.DBConfig) (db RawDBConnection, err error)

func Sqlite3RawFactory

func Sqlite3RawFactory(ctx context.Context, config *dbconfig.DBConfig) (db RawDBConnection, err error)

type RawFactories

type RawFactories map[string]RawFactory

type RawFactory

type RawFactory func(ctx context.Context, config *dbconfig.DBConfig) (db RawDBConnection, err error)