korm

May 9, 2024

Changes in this version

+ func JSON_ARRAY(values []any, as string, dialect ...string) string

+ func JSON_CAST(value string, as string, dialect ...string) string

+ func JSON_EXTRACT(dataJson string, opt ...JsonOption) string

+ func JSON_OBJECT(values []any, as string, dialect ...string) string

+ func JSON_REMOVE(dataJson string, opt ...JsonOption) string

+ func JSON_SET(dataJson string, opt ...JsonOption) string

+ func SliceToString(slice interface{}) string

+ type JsonOption struct

+ As string

+ Database string

+ Dialect string

+ Params []any

Apr 20, 2024

Changes in this version

+ type DashOpts struct

+ BaseDir string

+ DocsUrl string

+ EmbededStatic embed.FS

+ EmbededTemplates embed.FS

+ MediaDir string

+ PaginatePer int

+ Path string

+ RepoName string

+ RepoUser string

+ ServerOpts *ksbus.ServerOpts

+ StaticDir string

+ TemplatesDir string

Mar 19, 2024

Changes in this version

+ func EnableCheck()

Feb 17, 2024

Changes in this version

+ var IsDashboardCloned = false

+ var IsDocsUsed = false

Jan 6, 2024

Changes in this version

+ var WsSecure = false

Dec 23, 2023

Changes in this version

type BuilderM

+ func (b *BuilderM) NoCache() *BuilderM

type BuilderS

+ func (b *BuilderS[T]) NoCache() *BuilderS[T]

type Selector

+ func (sl *Selector[T]) NoCache() *Selector[T]

Oct 30, 2023

Changes in this version

+ func SetAdminPath(path string)

Oct 10, 2023

Changes in this version

type Selector

+ func (sl *Selector[T]) Database(dbName string) *Selector[T]

+ func (sl *Selector[T]) Debug() *Selector[T]

Jun 20, 2023

Changes in this version

+ var LogsView = func(c *kmux.Context)

May 1, 2023

Changes in this version

+ type KV kstrct.KV

+ type Selector struct

+ func To(dest *[]T, nestedSlice ...bool) *Selector[T]

+ func (sl *Selector[T]) Ctx(ct context.Context) *Selector[T]

+ func (sl *Selector[T]) Named(statement string, args map[string]any, unsafe ...bool) error

+ func (sl *Selector[T]) Query(statement string, args ...any) error

May 1, 2023

Changes in this version

type Build

+ func Named(statement string, args map[string]any, unsafe ...bool) *Build[T]

+ func QueryContext(ctx context.Context, statement string, args ...any) *Build[T]

+ func (nb *Build[T]) Scan(dest *[]T, nested ...bool) *Build[T]

type BuilderM

+ func (b *BuilderM) QueryM(statement string, args ...any) ([]map[string]any, error)

+ func (b *BuilderM) QueryMNamed(statement string, args map[string]any, unsafe ...bool) ([]map[string]any, error)

type BuilderS

+ func (b *BuilderS[T]) QueryS(statement string, args ...any) ([]T, error)

+ func (b *BuilderS[T]) QuerySNamed(statement string, args map[string]any, unsafe ...bool) ([]T, error)

Apr 29, 2023

Changes in this version

+ type Build struct

+ func (nb *Build[T]) Error() error

+ func (nb *Build[T]) To(dest *[]T, nested ...bool) *Build[T]

type BuilderS

+ func (b *BuilderS[T]) ToChan(ptrChan *chan T) ([]T, error)

Apr 25, 2023

Changes in this version

+ func Q(statement string, args ...any) ([]T, error)

Apr 25, 2023

Changes in this version

+ var ErrNoConnection = errors.New("no connection")

+ var ErrNoData = errors.New("no data")

type BuilderM

+ func (b *BuilderM) QueryNamed(statement string, args map[string]any, unsafe ...bool) ([]map[string]any, error)

type BuilderS

+ func (b *BuilderS[T]) QueryNamed(statement string, args map[string]any, unsafe ...bool) ([]T, error)

Apr 23, 2023

Changes in this version

+ var ExportCSVView = func(c *kmux.Context)

type TableEntity

+ Fkeys []kormFkey

Apr 18, 2023

Changes in this version

+ func UnsafeNamedQuery(query string, args map[string]any) (string, error)

Apr 16, 2023

Changes in this version

+ func AdaptNamedParams(dialect, statement string, variables map[string]any) (string, []any, error)

+ func ExecContext(ctx context.Context, dbName, query string, args ...any) error

+ func ExecContextNamed(ctx context.Context, query string, args map[string]any, dbName ...string) error

+ func ExecNamed(query string, args map[string]any, dbName ...string) error

+ func QueryNamed(statement string, args map[string]any, dbName ...string) ([]map[string]any, error)

+ func QueryNamedS(statement string, args map[string]any, dbName ...string) ([]T, error)

+ func WrapConn(conn driver.Conn, hooks Hooks) driver.Conn

type BuilderM

+ func (b *BuilderM) WhereNamed(query string, args map[string]any) *BuilderM

type BuilderS

+ func (b *BuilderS[T]) WhereNamed(query string, args map[string]any) *BuilderS[T]

type ExecerQueryerContext

+ func (conn ExecerQueryerContext) Begin() (driver.Tx, error)

+ func (conn ExecerQueryerContext) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (conn ExecerQueryerContext) Close() error

+ func (conn ExecerQueryerContext) Exec(query string, args []driver.Value) (driver.Result, error)

+ func (conn ExecerQueryerContext) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

+ func (conn ExecerQueryerContext) Prepare(query string) (driver.Stmt, error)

+ func (conn ExecerQueryerContext) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ func (conn ExecerQueryerContext) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

type ExecerQueryerContextWithSessionResetter

+ func (conn ExecerQueryerContextWithSessionResetter) Begin() (driver.Tx, error)

+ func (conn ExecerQueryerContextWithSessionResetter) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (conn ExecerQueryerContextWithSessionResetter) Close() error

+ func (conn ExecerQueryerContextWithSessionResetter) Exec(query string, args []driver.Value) (driver.Result, error)

+ func (conn ExecerQueryerContextWithSessionResetter) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

+ func (conn ExecerQueryerContextWithSessionResetter) Prepare(query string) (driver.Stmt, error)

+ func (conn ExecerQueryerContextWithSessionResetter) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ func (conn ExecerQueryerContextWithSessionResetter) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

type SessionResetter

+ func (conn SessionResetter) Begin() (driver.Tx, error)

+ func (conn SessionResetter) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (conn SessionResetter) Close() error

+ func (conn SessionResetter) Prepare(query string) (driver.Stmt, error)

+ func (conn SessionResetter) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

Apr 8, 2023

Changes in this version

+ func LogQueries()

+ func Wrap(driver driver.Driver, hooks Hooks) driver.Driver

+ type Conn struct

+ Conn driver.Conn

+ func (conn *Conn) Begin() (driver.Tx, error)

+ func (conn *Conn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (conn *Conn) Close() error

+ func (conn *Conn) Prepare(query string) (driver.Stmt, error)

+ func (conn *Conn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ type Driver struct

+ func (drv *Driver) Open(name string) (driver.Conn, error)

+ type ErrorHook func(ctx context.Context, err error, query string, args ...interface{}) error

+ type ExecerContext struct

+ func (conn *ExecerContext) Exec(query string, args []driver.Value) (driver.Result, error)

+ func (conn *ExecerContext) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

+ type ExecerQueryerContext struct

+ type ExecerQueryerContextWithSessionResetter struct

+ type Hook func(ctx context.Context, query string, args ...interface{}) (context.Context, error)

+ type Hooks interface

+ After func(ctx context.Context, query string, args ...interface{}) (context.Context, error)

+ Before func(ctx context.Context, query string, args ...interface{}) (context.Context, error)

+ type OnErrorer interface

+ OnError func(ctx context.Context, err error, query string, args ...interface{}) error

+ type QueryerContext struct

+ func (conn *QueryerContext) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

+ type SessionResetter struct

+ type Stmt struct

+ Stmt driver.Stmt

+ func (stmt *Stmt) Close() error

+ func (stmt *Stmt) Exec(args []driver.Value) (driver.Result, error)

+ func (stmt *Stmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (stmt *Stmt) NumInput() int

+ func (stmt *Stmt) Query(args []driver.Value) (driver.Rows, error)

+ func (stmt *Stmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)

Feb 21, 2023

Changes in this version

+ var StaticUrl = "/static"

Feb 17, 2023

Changes in this version

+ type DocsError struct

+ Error string

+ type DocsSuccess struct

+ Success string

Feb 15, 2023

Changes in this version

+ var DocsUrl = "docs"

+ func WithEmbededDocs(embeded embed.FS, dirPath string, ...) *ksbus.Server

Feb 15, 2023

Changes in this version

+ var DocsPath = "docs"

Feb 15, 2023

Changes in this version

+ func DownloadFile(filepath string, url string) error

+ func WithDocs(handlerMiddlewares ...func(handler kmux.Handler) kmux.Handler) *ksbus.Server

Feb 14, 2023

Changes in this version

+ func DisableGzip()

+ func WithMetrics(httpHandler http.Handler) *ksbus.Server

+ func WithPprof(path ...string) *ksbus.Server

Feb 7, 2023

Changes in this version

+ func IsValidEmail(email string) bool

Feb 6, 2023

Changes in this version

+ func WithShell()

Jan 30, 2023

Changes in this version

type BuilderS

+ func ModelTable(tableName string, model ...T) *BuilderS[T]

Jan 25, 2023

Changes in this version

+ func RegisterTable(table TableRegistration[T]) error

+ type RegisterBuilder func(modelBuilder *BuilderS[T]) *BuilderS[T]

type TableRegistration

+ BuilderGetAll func(modelBuilder *BuilderS[T]) *BuilderS[T]

+ BuilderGetOne func(modelBuilder *BuilderS[T]) *BuilderS[T]

Jan 24, 2023

Changes in this version

+ var ApiIndexHandler = func(c *kmux.Context)

+ var BASIC_AUTH_PASS = "testnotsetshouldbeset"

+ var BASIC_AUTH_USER = "notset"

+ var BasicAuth = func(handler kmux.Handler) kmux.Handler

+ type ModelApi struct

+ func WithAPI(rootPath string, middws ...func(handler kmux.Handler) kmux.Handler) (*ModelApi, error)

+ func (ma *ModelApi) RegisterTable(table TableRegistration) error

+ type TableRegistration struct

+ Methods []string

+ Middws []func(handler kmux.Handler) kmux.Handler

+ SelectedColumns []string

+ TableName string

+ func (tr *TableRegistration) HaveMethod(method string) bool

Jan 19, 2023

Changes in this version

+ func QueryS(dbName string, statement string, args ...any) ([]T, error)

+ func StorageSize(dbName string) float64

Jan 16, 2023

Changes in this version

+ var ErrBigData = kmap.ErrLargeData

+ func SetCacheMaxMemory(megaByte int)

Jan 14, 2023

Changes in this version

+ func DifferenceBetweenSlices(slice1 []T, slice2 []T) []T

+ func GetMemoryTableAndDB(tbName string, dbName ...string) (TableEntity, DatabaseEntity, error)

+ func RemoveFromSlice(slice *[]T, elemsToRemove ...T)

Jan 12, 2023

Changes in this version

+ var ErrTableNotFound = errors.New("unable to find tableName")

+ func Transaction(dbName ...string) (*sql.Tx, error)

Jan 7, 2023

Changes in this version

type BuilderM

+ func (b *BuilderM) InsertR(rowData map[string]any) (map[string]any, error)

type BuilderS

+ func (b *BuilderS[T]) AddRelated(relatedTable string, whereRelatedTable string, whereRelatedArgs ...any) (int, error)

+ func (b *BuilderS[T]) All() ([]T, error)

+ func (b *BuilderS[T]) BulkInsert(models ...*T) ([]int, error)

+ func (b *BuilderS[T]) Context(ctx context.Context) *BuilderS[T]

+ func (b *BuilderS[T]) Database(dbName string) *BuilderS[T]

+ func (b *BuilderS[T]) Debug() *BuilderS[T]

+ func (b *BuilderS[T]) Delete() (int, error)

+ func (b *BuilderS[T]) DeleteRelated(relatedTable string, whereRelatedTable string, whereRelatedArgs ...any) (int, error)

+ func (b *BuilderS[T]) Drop() (int, error)

+ func (b *BuilderS[T]) GetRelated(relatedTable string, dest any) error

+ func (b *BuilderS[T]) Insert(model *T) (int, error)

+ func (b *BuilderS[T]) InsertR(model *T) (T, error)

+ func (b *BuilderS[T]) JoinRelated(relatedTable string, dest any) error

+ func (b *BuilderS[T]) Limit(limit int) *BuilderS[T]

+ func (b *BuilderS[T]) One() (T, error)

+ func (b *BuilderS[T]) OrderBy(fields ...string) *BuilderS[T]

+ func (b *BuilderS[T]) Page(pageNumber int) *BuilderS[T]

+ func (b *BuilderS[T]) Query(query string, args ...any) *BuilderS[T]

+ func (b *BuilderS[T]) Select(columns ...string) *BuilderS[T]

+ func (b *BuilderS[T]) Set(query string, args ...any) (int, error)

+ func (b *BuilderS[T]) Where(query string, args ...any) *BuilderS[T]

Jan 6, 2023

Changes in this version

+ func OnDelete(fn func(database, table string, query string, args ...any) error)

+ func OnDrop(fn func(database, table string) error)

+ func OnInsert(fn DbHook)

+ func OnSet(fn DbHook)

+ type DbHook func(database, table string, data map[string]any) error

Jan 4, 2023

Changes in this version

+ var AdminPathNameGroup = "/admin"

Jan 4, 2023

Changes in this version

+ var Admin = func(handler kmux.Handler) kmux.Handler

+ var AllModelsGet = func(c *kmux.Context)

+ var AllModelsSearch = func(c *kmux.Context)

+ var AssetsDir = "assets"

+ var Auth = func(handler kmux.Handler) kmux.Handler

+ var CreateModelView = func(c *kmux.Context)

+ var DeleteRowPost = func(c *kmux.Context)

+ var DropTablePost = func(c *kmux.Context)

+ var EmbededDashboard = false

+ var ExportView = func(c *kmux.Context)

+ var ImportView = func(c *kmux.Context)

+ var IndexView = func(c *kmux.Context)

+ var LoginPOSTView = func(c *kmux.Context)

+ var LoginView = func(c *kmux.Context)

+ var LogoutView = func(c *kmux.Context)

+ var LogsGetView = func(c *kmux.Context)

+ var ManifestView = func(c *kmux.Context)

+ var MediaDir = "media"

+ var OfflineView = func(c *kmux.Context)

+ var PaginationPer = 10

+ var Pprof = false

+ var RepoName = "kago-assets"

+ var RepoUser = "kamalshkeir"

+ var RobotsTxtView = func(c *kmux.Context)

+ var ServiceWorkerView = func(c *kmux.Context)

+ var SingleModelGet = func(c *kmux.Context)

+ var StaticDir = path.Join(AssetsDir, "/", "static")

+ var TemplatesDir = path.Join(AssetsDir, "/", "templates")

+ var UpdateRowPost = func(c *kmux.Context)

+ func WithDashboard(staticAndTemplatesEmbeded ...embed.FS) *ksbus.Server

+ type User struct

+ CreatedAt time.Time

+ Email string

+ Id int

+ Image string

+ IsAdmin bool

+ Password string

+ Uuid string

Dec 31, 2022

Changes in this version

type Builder

+ func (b *Builder[T]) BulkInsert(models ...*T) (int, error)

type BuilderM

+ func (b *BuilderM) BulkInsert(rowsData ...map[string]any) (int, error)

Dec 31, 2022

Changes in this version

+ func Benchmark(f func(), name string, iterations int)

Dec 22, 2022

Changes in this version

+ func Exec(dbName, query string, args ...any) error

+ func ManyToMany(table1, table2 string, dbName ...string) error

+ func Shutdown(dbNames ...string) error

type Builder

+ func (b *Builder[T]) AddRelated(relatedTable string, whereRelatedTable string, whereRelatedArgs ...any) (int, error)

+ func (b *Builder[T]) DeleteRelated(relatedTable string, whereRelatedTable string, whereRelatedArgs ...any) (int, error)

+ func (b *Builder[T]) GetRelated(relatedTable string, dest any) error

+ func (b *Builder[T]) JoinRelated(relatedTable string, dest any) error

type BuilderM

+ func (b *BuilderM) AddRelated(relatedTable string, whereRelatedTable string, whereRelatedArgs ...any) (int, error)

+ func (b *BuilderM) DeleteRelated(relatedTable string, whereRelatedTable string, whereRelatedArgs ...any) (int, error)

+ func (b *BuilderM) GetRelated(relatedTable string, dest *[]map[string]any) error

+ func (b *BuilderM) JoinRelated(relatedTable string, dest *[]map[string]any) error

+ type Dialect = string

Dec 17, 2022

Changes in this version

type Builder

+ func BuilderStruct(tableName ...string) *Builder[T]

Dec 10, 2022

Changes in this version

+ func SnakeCaseToTitle(str string) (camelCase string)

Nov 19, 2022

Changes in this version

+ var MaxIdleConns = 10

+ var MaxIdleTime = 12 * time.Hour

+ var MaxLifetime = 30 * time.Minute

+ var MaxOpenConns = 10

Nov 19, 2022

Changes in this version

+ func New(dbType, dbName string, dbDSN ...string) error

+ func NewFromConnection(dbType, dbName string, conn *sql.DB) error

+ func WithBus(bus *ksbus.Server) *ksbus.Server

Nov 11, 2022

Changes in this version

+ func GetConnection(dbName ...string) (any, bool)

+ func NewMongoDatabaseFromConnection(dbName string, dbConn *mongo.Client) (*mongo.Database, error)

Nov 11, 2022

Changes in this version

+ const Blue

+ const CACHE_TOPIC

+ const COCKROACH

+ const Green

+ const MARIA

+ const MIGRATION_FOLDER

+ const MONGO

+ const MYSQL

+ const Magenta

+ const POSTGRES

+ const Red

+ const SQLITE

+ const Yellow

+ var Debug = false

+ var DefaultDB = ""

+ var FlushCacheEvery = 30 * time.Minute

+ var MigrationAutoCheck = true

+ func AddTrigger(onTable, col, bf_af_UpdateInsertDelete string, ofColumn, stmt string, ...)

+ func AutoMigrate(tableName string, dbName ...string) error

+ func BeforeDataWS(...)

+ func BeforeServersData(fn func(data any, conn *ws.Conn))

+ func Difference(slice1 []T, slice2 []T) []T

+ func DisableCache()

+ func DisableCheck()

+ func DropTrigger(onField, tableName string, dbName ...string)

+ func ExecSQL(dbName, query string, args ...any) error

+ func FlushCache()

+ func GenerateUUID() (string, error)

+ func GetAllColumnsTypes(table string, dbName ...string) map[string]string

+ func GetAllTables(dbName ...string) []string

+ func GetConstraints(db *DatabaseEntity, tableName string) map[string][]string

+ func GetMONGOClient(dbName ...string) *mongo.Client

+ func GetMONGOConnection(dbName ...string) *mongo.Database

+ func GetSQLConnection(dbName ...string) *sql.DB

+ func InitShell() bool

+ func LinkModel(to_table_name string, db *DatabaseEntity)

+ func NewBusServerKORM() *ksbus.Server

+ func NewDatabaseFromDSN(dbType, dbName string, dbDSN ...string) error

+ func NewSQLDatabaseFromConnection(dbType, dbName string, conn *sql.DB) error

+ func Query(dbName string, statement string, args ...any) ([]map[string]interface{}, error)

+ func RunEvery(t time.Duration, function any)

+ func ShutdownDatabases(databasesName ...string) error

+ func SliceContains(elems []T, vs ...T) bool

+ func SliceRemove(slice *[]T, elemsToRemove ...T)

+ func StringContains(s string, subs ...string) bool

+ func ToSnakeCase(str string) string

+ type Builder struct

+ func BuilderS(tableName ...string) *Builder[T]

+ func Model(tableName ...string) *Builder[T]

+ func (b *Builder[T]) All() ([]T, error)

+ func (b *Builder[T]) Context(ctx context.Context) *Builder[T]

+ func (b *Builder[T]) Database(dbName string) *Builder[T]

+ func (b *Builder[T]) Debug() *Builder[T]

+ func (b *Builder[T]) Delete() (int, error)

+ func (b *Builder[T]) Drop() (int, error)

+ func (b *Builder[T]) Insert(model *T) (int, error)

+ func (b *Builder[T]) Limit(limit int) *Builder[T]

+ func (b *Builder[T]) One() (T, error)

+ func (b *Builder[T]) OrderBy(fields ...string) *Builder[T]

+ func (b *Builder[T]) Page(pageNumber int) *Builder[T]

+ func (b *Builder[T]) Query(query string, args ...any) *Builder[T]

+ func (b *Builder[T]) Select(columns ...string) *Builder[T]

+ func (b *Builder[T]) Set(query string, args ...any) (int, error)

+ func (b *Builder[T]) Where(query string, args ...any) *Builder[T]

+ type BuilderM struct

+ func BuilderMap(tableName string) *BuilderM

+ func Table(tableName string) *BuilderM

+ func (b *BuilderM) All() ([]map[string]any, error)

+ func (b *BuilderM) Context(ctx context.Context) *BuilderM

+ func (b *BuilderM) Database(dbName string) *BuilderM

+ func (b *BuilderM) Debug() *BuilderM

+ func (b *BuilderM) Delete() (int, error)

+ func (b *BuilderM) Drop() (int, error)

+ func (b *BuilderM) Insert(fields_comma_separated string, fields_values ...any) (int, error)

+ func (b *BuilderM) Limit(limit int) *BuilderM

+ func (b *BuilderM) One() (map[string]any, error)

+ func (b *BuilderM) OrderBy(fields ...string) *BuilderM

+ func (b *BuilderM) Page(pageNumber int) *BuilderM

+ func (b *BuilderM) Query(query string, args ...any) *BuilderM

+ func (b *BuilderM) Select(columns ...string) *BuilderM

+ func (b *BuilderM) Set(query string, args ...any) (int, error)

+ func (b *BuilderM) Where(query string, args ...any) *BuilderM

+ type DatabaseEntity struct

+ Conn *sql.DB

+ Dialect string

+ MongoConn *mongo.Database

+ Name string

+ Tables []TableEntity

+ func GetMemoryDatabase(dbName string) (*DatabaseEntity, error)

+ func GetMemoryDatabases() []DatabaseEntity

+ type TableEntity struct

+ Columns []string

+ ModelTypes map[string]string

+ Name string

+ Pk string

+ Tags map[string][]string

+ Types map[string]string

+ func GetMemoryTable(tbName string, dbName ...string) (TableEntity, error)

+ func GetMemoryTables(dbName ...string) ([]TableEntity, error)