sqldb

Jul 10, 2025

Changes in this version

+ const AndOp

+ const BeginOp

+ const EndOp

+ const IsIn

+ const IsNull

+ const OrOp

+ var ErrDuplicateFound = fmt.Errorf("duplicate record found")

+ var ErrModifiedID = fmt.Errorf("not allowed modification of ID")

+ var ErrNotFound = fmt.Errorf("record not found")

+ func IsDuplicateKeyError(err error) bool

+ func OrderByOp(fieldname string, ascending bool) string

+ func SelectOp(fieldname ...string) string

+ func ToAny[T any](arrOrSingle T) []any

+ type CRUD struct

+ DeleteURL *common.RestURL

+ GetURL *common.RestURL

+ ListURL *common.RestURL

+ Name string

+ PostURL *common.RestURL

+ PutURL *common.RestURL

+ Repository *Repository[T]

+ URLPrefix string

+ func NewCrud[T any](crudHandlerFunc CRUDHandlerFunc, repository *Repository[T], ...) (*CRUD[T], error)

+ func (crud *CRUD[T]) DeleteHandler(w http.ResponseWriter, r *http.Request)

+ func (crud *CRUD[T]) GetHandler(w http.ResponseWriter, r *http.Request)

+ func (crud *CRUD[T]) ListHandler(w http.ResponseWriter, r *http.Request)

+ func (crud *CRUD[T]) PostHandler(w http.ResponseWriter, r *http.Request)

+ func (crud *CRUD[T]) PutHandler(w http.ResponseWriter, r *http.Request)

+ type CRUDHandlerFunc func(restURL *common.RestURL, description string, needsAuth bool, ...)

+ type Repository struct

+ func NewRepository[T any](gorm *gorm.DB) (*Repository[T], error)

+ func (repository *Repository[T]) Delete(id int) error

+ func (repository *Repository[T]) Find(id int) (*T, error)

+ func (repository *Repository[T]) FindAll(offset int, limit int) ([]T, error)

+ func (repository *Repository[T]) FindFirst(where *WhereTerm) (*T, error)

+ func (repository *Repository[T]) Save(record *T) error

+ func (repository *Repository[T]) SaveAll(records []T) error

+ func (repository *Repository[T]) Update(record T) error

+ type WhereItem struct

+ Fieldname string

+ Operator string

+ Value any

+ func (whereItem WhereItem) Build() (string, []any)

+ type WhereTerm struct

+ func NewWhereTerm() *WhereTerm

+ func (whereTerm *WhereTerm) And() *WhereTerm

+ func (whereTerm *WhereTerm) Begin() *WhereTerm

+ func (whereTerm *WhereTerm) End() *WhereTerm

+ func (whereTerm *WhereTerm) Or() *WhereTerm

+ func (whereTerm *WhereTerm) Where(whereItem WhereItem) *WhereTerm

+ func (whereTerm WhereTerm) Build() (string, []any)

May 1, 2025

Changes in this version

+ type AsStringer interface

+ AsString func() string

type FieldBool

+ func (c FieldBool) AsString() string

type FieldInt64

+ func (c FieldInt64) AsString() string

type FieldString

+ func (c FieldString) AsString() string

type FieldTime

+ func (c FieldTime) AsString() string

Dec 9, 2024

Changes in this version

+ var FLagMaxLifetime = common.SystemFlagInt(FlagNameDbMaxLifetime, 0, "Database connection max lifetime")

type SqlDb

+ func (sqlDb *SqlDb) QueryFunc(fn ResultsetFunc, sqlcmd string, args ...any) (int, error)

Dec 1, 2024

Changes in this version

type SqlDB

+ func (sqlDb *SqlDB) Ping(force bool) error

+ func (sqlDb *SqlDB) QueryFunc(fn ResultsetFunc, sqlcmd string, args ...any) (int, error)

Nov 29, 2024

Changes in this version

type SqlDB

+ QueryTimeout time.Duration

+ RevalidateTimeout time.Duration

+ func (sqlDb *SqlDB) Revalidate(force bool) error

Nov 13, 2024

Changes in this version

+ type SqlDB struct

+ Conn *sql.DB

+ DSN string

+ Driver string

+ Isolation sql.IsolationLevel

+ Timeout time.Duration

+ func NewSqlDB(driver, dsn string) (*SqlDB, error)

+ func (sqlDb *SqlDB) Begin() error

+ func (sqlDb *SqlDB) Close() error

+ func (sqlDb *SqlDB) Commit() error

+ func (sqlDb *SqlDB) Execute(sqlcmd string, args ...any) (int64, error)

+ func (sqlDb *SqlDB) Init(driver, dsn string) error

+ func (sqlDb *SqlDB) Open() error

+ func (sqlDb *SqlDB) Query(sqlcmd string, args ...any) (*Resultset, error)

+ func (sqlDb *SqlDB) Rollback() error

Nov 8, 2024

Changes in this version

type Database

+ Conn *sql.DB

Jun 13, 2024

Changes in this version

+ func DatabaseDrivers() []string

+ type Database struct

+ DSN string

+ Driver string

+ Isolation sql.IsolationLevel

+ Timeout time.Duration

+ func NewDatabase(driver, dsn string) (*Database, error)

+ func (database *Database) Begin() error

+ func (database *Database) Close() error

+ func (database *Database) Commit() error

+ func (database *Database) Execute(sqlcmd string, args ...any) (int64, error)

+ func (database *Database) Init(driver, dsn string) error

+ func (database *Database) Open() error

+ func (database *Database) Query(sqlcmd string, args ...any) (*Resultset, error)

+ func (database *Database) Rollback() error

type Resultset

+ func (rs *Resultset) Get(row int, fieldName string) (Field, error)

Jul 7, 2025

Changes in this version

+ const FlagNameDbMaxIdle

+ const FlagNameDbMaxLifetime

+ const FlagNameDbMaxOpen

+ const FlagNameDbPingTimeout

+ const FlagNameDbQueryTimeout

+ var FlagDbMaxIdle = common.SystemFlagInt(FlagNameDbMaxIdle, 0, "Database max idle connections")

+ var FlagDbPingTimeout = common.SystemFlagInt(FlagNameDbPingTimeout, 3 * 1000, "Database ping timeout")

+ var FlagDbQueryTimeout = common.SystemFlagInt(FlagNameDbQueryTimeout, 120 * 1000, "Database query timeout")

+ var FlagMaxLifetime = common.SystemFlagInt(FlagNameDbMaxLifetime, 0, "Database connection max lifetime")

+ var FlagMaxOpen = common.SystemFlagInt(FlagNameDbMaxOpen, 0, "Database max open connections")

+ type Field struct

+ IsNull bool

+ Value any

+ func (f Field) String() string

+ type FieldBool struct

+ func NewFieldBool(v ...bool) FieldBool

+ func (c *FieldBool) Bool() bool

+ func (c *FieldBool) SetBool(v bool)

+ func (c *FieldBool) SetNull()

+ func (c *FieldBool) UnmarshalJSON(data []byte) error

+ func (c FieldBool) MarshalJSON() ([]byte, error)

+ func (c FieldBool) String() string

+ type FieldInt64 struct

+ func NewFieldInt64(v ...int64) FieldInt64

+ func (c *FieldInt64) Int64() int64

+ func (c *FieldInt64) SetInt64(v int64)

+ func (c *FieldInt64) SetNull()

+ func (c *FieldInt64) UnmarshalJSON(data []byte) error

+ func (c FieldInt64) MarshalJSON() ([]byte, error)

+ func (c FieldInt64) String() string

+ type FieldString struct

+ func NewFieldString(v ...string) FieldString

+ func (c *FieldString) GetString(v string)

+ func (c *FieldString) SetField(other FieldString)

+ func (c *FieldString) SetNull()

+ func (c *FieldString) SetString(v string)

+ func (c *FieldString) UnmarshalJSON(data []byte) error

+ func (c FieldString) MarshalJSON() ([]byte, error)

+ func (c FieldString) String() string

+ type FieldTime struct

+ func NewFieldTime(v ...time.Time) FieldTime

+ func (c *FieldTime) SetNull()

+ func (c *FieldTime) SetTime(v time.Time)

+ func (c *FieldTime) Time() time.Time

+ func (c *FieldTime) UnmarshalJSON(data []byte) error

+ func (c FieldTime) MarshalJSON() ([]byte, error)

+ func (c FieldTime) String() string

+ type Resultset struct

+ ColumnNames []string

+ ColumnTypes []*sql.ColumnType

+ RowCount int

+ Rows any

+ func (rs *Resultset) FieldByIndex(row int, col int) Field

+ func (rs *Resultset) FieldByName(row int, fieldName string) Field

+ type ResultsetFunc func(rs *Resultset) error

+ type SqlDb struct

+ DSN string

+ Driver string

+ func NewSqlDb(driver, dsn string) (*SqlDb, error)

+ func (sqlDb *SqlDb) Begin() error

+ func (sqlDb *SqlDb) Close() error

+ func (sqlDb *SqlDb) Commit() error

+ func (sqlDb *SqlDb) Execute(sqlcmd string, args ...any) (int64, error)

+ func (sqlDb *SqlDb) Health() error

+ func (sqlDb *SqlDb) Init(driver, dsn string) error

+ func (sqlDb *SqlDb) Open() error

+ func (sqlDb *SqlDb) Query(sqlcmd string, args ...any) (*Resultset, error)

+ func (sqlDb *SqlDb) QueryPaged(fn ResultsetFunc, pageRowCount int, sqlcmd string, args ...any) (int, error)

+ func (sqlDb *SqlDb) Rollback() error