persist

Documentation

Index

• func DefaultJsonModels() string
• func ModelsForTables(db *sqlx.DB, tablesString string) []*models.Model
• func MysqlConnection() *sqlx.DB
• func PostgresConnection(dbEnvVarName string) *sqlx.DB
• func PostgresConnectionByUrl(url string) *sqlx.DB
• func SaveSchema(asBytes []byte)
• func ScanSchema(dbString string) []*models.Model
• func ScanTable(db *sqlx.DB, table string) []*models.Field
• func SelectAll(db *sqlx.DB, sql string) []map[string]any
• type CustomDB
  • func (db *CustomDB) ExecWithLogging(query string, args ...interface{}) (sql.Result, error)

Functions

func DefaultJsonModels

func DefaultJsonModels() string

func ModelsForTables

func ModelsForTables(db *sqlx.DB, tablesString string) []*models.Model

func MysqlConnection

func MysqlConnection() *sqlx.DB

func PostgresConnection

func PostgresConnection(dbEnvVarName string) *sqlx.DB

func PostgresConnectionByUrl

func PostgresConnectionByUrl(url string) *sqlx.DB

func SaveSchema

func SaveSchema(asBytes []byte)

func ScanSchema

func ScanSchema(dbString string) []*models.Model

func ScanTable

func ScanTable(db *sqlx.DB, table string) []*models.Field

func SelectAll

func SelectAll(db *sqlx.DB, sql string) []map[string]any

Types

type CustomDB

type CustomDB struct {
	*sqlx.DB
}

func (*CustomDB) ExecWithLogging

func (db *CustomDB) ExecWithLogging(query string, args ...interface{}) (sql.Result, error)