datasource

Documentation

Index

• Constants
• func MustBindDB(db DB) *sql.DB
• type BeanDBAware
• type DB
• type DBAwarePostProcessorBean
  • func (p *DBAwarePostProcessorBean) PostProcessorAfterInitialization(bean interface{}, beanName string) error
  • func (p *DBAwarePostProcessorBean) PostProcessorBeforeInitialization(bean interface{}, beanName string) error
• type DataSource
  • func NewDataSource(name ...string) DataSource
• type DataSourceDriver
• type DataSourceProperties
• type MySqlDriver
  • func (d *MySqlDriver) Open(properties *DataSourceProperties) (DB, error)

Constants

const PropertiesPath = "application.datasource"

Functions

func MustBindDB

func MustBindDB(db DB) *sql.DB

Types

type BeanDBAware

type BeanDBAware interface {
	bean.Bean
	DataSource() string
	SetDB(db DB)
}

type DB

type DB interface{}

type DBAwarePostProcessorBean

type DBAwarePostProcessorBean struct {
	types.Component `name:"db_aware_post_processor_bean"`
	DataSources     []DataSource `wire:""`
}

func (*DBAwarePostProcessorBean) PostProcessorAfterInitialization

func (p *DBAwarePostProcessorBean) PostProcessorAfterInitialization(bean interface{}, beanName string) error

func (*DBAwarePostProcessorBean) PostProcessorBeforeInitialization

func (p *DBAwarePostProcessorBean) PostProcessorBeforeInitialization(bean interface{}, beanName string) error

type DataSource

type DataSource interface {
	bean.Bean
	DB() DB
}

func NewDataSource

func NewDataSource(name ...string) DataSource

type DataSourceDriver

type DataSourceDriver interface {
	bean.Bean
	Type() string
	Driver() string
	Open(properties *DataSourceProperties) (DB, error)
}

type DataSourceProperties

type DataSourceProperties struct {
	types.AutoConfigure `name:"datasource_properties" prefix:"application.datasource"`
	Type                string `yaml:"type"`
	Driver              string `yaml:"driver"`
	ConnMaxLifeTime     int64  `yaml:"max_life_time"`
	ConnMaxIdleTime     int64  `yaml:"max_idle_time"`
	MaxIdleConns        int    `yaml:"max_idle_conn"`
	MaxOpenConns        int    `yaml:"max_open_conn"`
	Url                 string `yaml:"url"`
	Username            string `yaml:"username"`
	Password            string `yaml:"password"`
}

type MySqlDriver

type MySqlDriver struct {
	types.DataSourceDriver `name:"datasource_driver:mysql" type:"database/sql" driver:"github.com/go-sql-driver/mysql"`
}

func (*MySqlDriver) Open

func (d *MySqlDriver) Open(properties *DataSourceProperties) (DB, error)