drivers

Documentation

Index

• func ClickHouseConnector(config contracts.Fields, events contracts.EventDispatcher) contracts.DBConnection
• func DollarNParamBindWrapper(sql string) (result string)
• func MysqlConnector(config contracts.Fields, events contracts.EventDispatcher) contracts.DBConnection
• func PostgresSqlConnector(config contracts.Fields, events contracts.EventDispatcher) contracts.DBConnection
• func SqliteConnector(config contracts.Fields, events contracts.EventDispatcher) contracts.DBConnection
• type Base
  • func NewDriver(db *sqlx.DB, dispatcher contracts.EventDispatcher) *Base
  • func WithWrapper(db *sqlx.DB, dispatcher contracts.EventDispatcher, wrapper func(string) string) *Base
  • func (base *Base) Begin() (contracts.DBTx, contracts.Exception)
  • func (base *Base) Transaction(fn func(tx contracts.SqlExecutor) contracts.Exception) (e contracts.Exception)
• type Clickhouse
  • func (c Clickhouse) Begin() (contracts.DBTx, contracts.Exception)
  • func (c Clickhouse) Transaction(f func(executor contracts.SqlExecutor) contracts.Exception) contracts.Exception
• type Mysql
• type PostgresSQL
• type Sqlite
• type TransactionException

Functions

func ClickHouseConnector

func ClickHouseConnector(config contracts.Fields, events contracts.EventDispatcher) contracts.DBConnection

func DollarNParamBindWrapper

func DollarNParamBindWrapper(sql string) (result string)

func MysqlConnector

func MysqlConnector(config contracts.Fields, events contracts.EventDispatcher) contracts.DBConnection

func PostgresSqlConnector

func PostgresSqlConnector(config contracts.Fields, events contracts.EventDispatcher) contracts.DBConnection

func SqliteConnector

func SqliteConnector(config contracts.Fields, events contracts.EventDispatcher) contracts.DBConnection

Types

type Base

type Base struct {
	support.Executor
	// contains filtered or unexported fields
}

func NewDriver

func NewDriver(db *sqlx.DB, dispatcher contracts.EventDispatcher) *Base

func WithWrapper

func WithWrapper(db *sqlx.DB, dispatcher contracts.EventDispatcher, wrapper func(string) string) *Base

func (*Base) Begin

func (base *Base) Begin() (contracts.DBTx, contracts.Exception)

func (*Base) Transaction

func (base *Base) Transaction(fn func(tx contracts.SqlExecutor) contracts.Exception) (e contracts.Exception)

type Clickhouse

type Clickhouse struct {
	support.Executor
}

func (Clickhouse) Begin

func (c Clickhouse) Begin() (contracts.DBTx, contracts.Exception)

func (Clickhouse) Transaction

func (c Clickhouse) Transaction(f func(executor contracts.SqlExecutor) contracts.Exception) contracts.Exception

type Mysql

type Mysql struct {
	*Base
}

type PostgresSQL

type PostgresSQL struct {
	*Base
}

type Sqlite

type Sqlite struct {
	*Base
}

type TransactionException

type TransactionException = exceptions.Exception