database

Documentation

Index

• type ClickHouse
  • func (t *ClickHouse) Exec(ctx context.Context, query string, args ...interface{}) error
  • func (t *ClickHouse) GetDb() interface{}
  • func (t *ClickHouse) Init(app interfaces.IService) error
  • func (t *ClickHouse) Query(ctx context.Context, query string, args ...interface{}) (interfaces.SQLRows, error)
  • func (t *ClickHouse) QueryRow(ctx context.Context, query string, args ...interface{}) (interfaces.SQLRow, error)
  • func (t *ClickHouse) Stop() error
  • func (t *ClickHouse) String() string
• type PGSQLRows
  • func (t *PGSQLRows) Close() error
  • func (t *PGSQLRows) Next() bool
  • func (t *PGSQLRows) Scan(dest ...any) error
• type Postgres
  • func (t *Postgres) Exec(ctx context.Context, query string, args ...interface{}) error
  • func (t *Postgres) GetDb() interface{}
  • func (t *Postgres) Init(app interfaces.IService) error
  • func (t *Postgres) Query(ctx context.Context, query string, args ...interface{}) (interfaces.SQLRows, error)
  • func (t *Postgres) QueryRow(ctx context.Context, query string, args ...interface{}) (interfaces.SQLRow, error)
  • func (t *Postgres) Stop() error
  • func (t *Postgres) String() string
• type Sqlite3
  • func (t *Sqlite3) Exec(ctx context.Context, query string, args ...interface{}) error
  • func (t *Sqlite3) GetDb() interface{}
  • func (t *Sqlite3) Init(app interfaces.IService) error
  • func (t *Sqlite3) Query(ctx context.Context, query string, args ...interface{}) (interfaces.SQLRows, error)
  • func (t *Sqlite3) QueryRow(ctx context.Context, query string, args ...interface{}) (interfaces.SQLRow, error)
  • func (t *Sqlite3) Stop() error
  • func (t *Sqlite3) String() string

Types

type ClickHouse

type ClickHouse struct {
	Name     string
	Database string
	User     string
	Password string
	Hosts    string
	// contains filtered or unexported fields
}

func (*ClickHouse) Exec

func (t *ClickHouse) Exec(ctx context.Context, query string, args ...interface{}) error

func (*ClickHouse) GetDb

func (t *ClickHouse) GetDb() interface{}

func (*ClickHouse) Init

func (t *ClickHouse) Init(app interfaces.IService) error

func (*ClickHouse) Query

func (t *ClickHouse) Query(ctx context.Context, query string, args ...interface{}) (interfaces.SQLRows, error)

func (*ClickHouse) QueryRow

func (t *ClickHouse) QueryRow(ctx context.Context, query string, args ...interface{}) (interfaces.SQLRow, error)

func (*ClickHouse) Stop

func (t *ClickHouse) Stop() error

func (*ClickHouse) String

func (t *ClickHouse) String() string

type PGSQLRows

type PGSQLRows struct {
	Rows pgx.Rows
}

func (*PGSQLRows) Close

func (t *PGSQLRows) Close() error

func (*PGSQLRows) Next

func (t *PGSQLRows) Next() bool

func (*PGSQLRows) Scan

func (t *PGSQLRows) Scan(dest ...any) error

type Postgres

type Postgres struct {
	Name     string
	Database string
	URI      string
	// contains filtered or unexported fields
}

func (*Postgres) Exec

func (t *Postgres) Exec(ctx context.Context, query string, args ...interface{}) error

func (*Postgres) GetDb

func (t *Postgres) GetDb() interface{}

func (*Postgres) Init

func (t *Postgres) Init(app interfaces.IService) error

func (*Postgres) Query

func (t *Postgres) Query(ctx context.Context, query string, args ...interface{}) (interfaces.SQLRows, error)

func (*Postgres) QueryRow

func (t *Postgres) QueryRow(ctx context.Context, query string, args ...interface{}) (interfaces.SQLRow, error)

func (*Postgres) Stop

func (t *Postgres) Stop() error

func (*Postgres) String

func (t *Postgres) String() string

type Sqlite3

type Sqlite3 struct {
	Name     string
	Database string
	// contains filtered or unexported fields
}

func (*Sqlite3) Exec

func (t *Sqlite3) Exec(ctx context.Context, query string, args ...interface{}) error

func (*Sqlite3) GetDb

func (t *Sqlite3) GetDb() interface{}

func (*Sqlite3) Init

func (t *Sqlite3) Init(app interfaces.IService) error

func (*Sqlite3) Query

func (t *Sqlite3) Query(ctx context.Context, query string, args ...interface{}) (interfaces.SQLRows, error)

func (*Sqlite3) QueryRow

func (t *Sqlite3) QueryRow(ctx context.Context, query string, args ...interface{}) (interfaces.SQLRow, error)

func (*Sqlite3) Stop

func (t *Sqlite3) Stop() error

func (*Sqlite3) String

func (t *Sqlite3) String() string