database

Documentation

Index

• func CreateDBConnection(connectionName string, driver *db_interfaces.DatabaseDriver) db_interfaces.DatabaseConnection
• type DB
  • func NewDB(dbm *DatabaseManager, connections map[string]db_interfaces.DatabaseConnection) *DB
  • func (db *DB) AutoMigrate(dst ...interface{}) error
  • func (db *DB) Connection(connectionName string) db_interfaces.DatabaseConnection
  • func (db *DB) DB() *gorm.DB
  • func (db *DB) DefaultConnection() db_interfaces.DatabaseConnection
  • func (db *DB) GetConnectionForModel(model interface{}) db_interfaces.DatabaseConnection
  • func (db *DB) HasConnection(connectionName string) bool
  • func (db *DB) MigrateDriver() (MigrateDB.Driver, error)
  • func (db *DB) Migration(connectionNames ...string) error
  • func (db *DB) SqlDB() (*sql.DB, error)
• type DBConnection
  • func (dc *DBConnection) Config() *db_config.DBConfig
  • func (dc *DBConnection) DB() *gorm.DB
  • func (dc *DBConnection) DriverName() string
  • func (dc *DBConnection) MigrateDriver() (MigrateDB.Driver, error)
  • func (dc *DBConnection) Name() string
  • func (dc *DBConnection) SqlDB() (*sql.DB, error)
• type DatabaseManager
  • func NewDatabaseManager(drivers ...db_interfaces.DatabaseDriver) *DatabaseManager
  • func (dm *DatabaseManager) CreateDatabaseFactory(connectionName string, config db_config.DBConfig) (db_interfaces.DatabaseConnection, error)
  • func (dm *DatabaseManager) RegisterDrivers(drivers ...db_interfaces.DatabaseDriver)
• type Model

Functions

func CreateDBConnection

func CreateDBConnection(connectionName string, driver *db_interfaces.DatabaseDriver) db_interfaces.DatabaseConnection

Types

type DB

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

func NewDB

func NewDB(dbm *DatabaseManager, connections map[string]db_interfaces.DatabaseConnection) *DB

func (*DB) AutoMigrate

func (db *DB) AutoMigrate(dst ...interface{}) error

func (*DB) Connection

func (db *DB) Connection(connectionName string) db_interfaces.DatabaseConnection

func (*DB) DB

func (db *DB) DB() *gorm.DB

func (*DB) DefaultConnection

func (db *DB) DefaultConnection() db_interfaces.DatabaseConnection

func (*DB) GetConnectionForModel

func (db *DB) GetConnectionForModel(model interface{}) db_interfaces.DatabaseConnection

func (*DB) HasConnection

func (db *DB) HasConnection(connectionName string) bool

func (*DB) MigrateDriver

func (db *DB) MigrateDriver() (MigrateDB.Driver, error)

func (*DB) Migration

func (db *DB) Migration(connectionNames ...string) error

func (*DB) SqlDB

func (db *DB) SqlDB() (*sql.DB, error)

type DBConnection

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

DBConnection struct

func (*DBConnection) Config

func (dc *DBConnection) Config() *db_config.DBConfig

func (*DBConnection) DB

func (dc *DBConnection) DB() *gorm.DB

func (*DBConnection) DriverName

func (dc *DBConnection) DriverName() string

func (*DBConnection) MigrateDriver

func (dc *DBConnection) MigrateDriver() (MigrateDB.Driver, error)

func (*DBConnection) Name

func (dc *DBConnection) Name() string

func (*DBConnection) SqlDB

func (dc *DBConnection) SqlDB() (*sql.DB, error)

type DatabaseManager

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

func NewDatabaseManager

func NewDatabaseManager(drivers ...db_interfaces.DatabaseDriver) *DatabaseManager

func (*DatabaseManager) CreateDatabaseFactory

func (dm *DatabaseManager) CreateDatabaseFactory(connectionName string, config db_config.DBConfig) (db_interfaces.DatabaseConnection, error)

func (*DatabaseManager) RegisterDrivers

func (dm *DatabaseManager) RegisterDrivers(drivers ...db_interfaces.DatabaseDriver)

type Model

type Model struct {
	ConnectionName string
}