db

Documentation

Index

• Constants
• func EnsureTable(gormDb *gorm.DB, tableName string, model interface{}) error
• func GenerateClickhouseDsn(params ConnectionParams) string
• func GenerateMysqlDsn(params ConnectionParams) string
• func GenerateMzDsn(params ConnectionParams) string
• func GeneratePostgresDsn(params ConnectionParams) string
• type BasePKeylessModel
• type ConnectionParams

Constants

const (
	POSTGRES      = "postgres"
	MATERIALIZE   = "materialize"
	MYSQL         = "mysql"
	CLICKHOUSE    = "clickhouse"
	MONGODB       = "mongodb"
	ELASTICSEARCH = "elasticsearch"
	TIMESCALE     = "timescale"
)

Functions

func EnsureTable

func EnsureTable(gormDb *gorm.DB, tableName string, model interface{}) error

EnsureTable creates a table according to the specified model if it does not already exist.

func GenerateClickhouseDsn

func GenerateClickhouseDsn(params ConnectionParams) string

GenerateClickhouseDsn generates a dsn from the provided connection params

func GenerateMysqlDsn

func GenerateMysqlDsn(params ConnectionParams) string

GenerateMysqlDsn generates a Mysql Dsn from the provided connection params

func GenerateMzDsn

func GenerateMzDsn(params ConnectionParams) string

GenerateMzDsn generates a Materialize dsn from the provided connection params

func GeneratePostgresDsn

func GeneratePostgresDsn(params ConnectionParams) string

GeneratePostgresDsn generates a dsn from the provided connection params

Types

type BasePKeylessModel

type BasePKeylessModel struct {
	CreatedAt time.Time  `json:"-" sql:"index"`
	UpdatedAt time.Time  `json:"-" sql:"index"`
	DeletedAt *time.Time `json:"-" sql:"index"`
}

type ConnectionParams

type ConnectionParams struct {
	Host string
	Port uint16
	Db   string
	User string
	Pass string
}