pgparty

package module

Go to main page

Versions in this module

v1

v1.1.4

Mar 28, 2024

v1.1.3

Mar 1, 2024

v1.1.2

Mar 1, 2024

v1.1.1

Feb 27, 2024

Changes in this version

+ func SQLAlterView(schema, tname string, last, to *modelcols.SQLModel, dbidxs DBIndexDefs) []string

+ func SQLCreateView(pt *PatchView, sqs *modelcols.SQLModel)

+ type MaterializedViewable interface

+ MaterializedView func()

type ModelDesc

+ func (md ModelDesc) IsMaterialized() bool

+ func (md ModelDesc) IsView() bool

+ func (md ModelDesc) ViewQuery(ctx context.Context, sr *PgStore) (string, error)

+ type PatchCreateView struct

+ Materialized bool

+ Query string

+ Schema string

+ Table string

+ func (c PatchCreateView) String() string

+ type PatchDropView struct

+ Schema string

+ Table string

+ func (c PatchDropView) String() string

+ type PatchView struct

+ CreateIndexes []fmt.Stringer

+ CreateViews []fmt.Stringer

+ DropIndexes []fmt.Stringer

+ DropViews []fmt.Stringer

+ Name string

+ Schema string

+ func (pt *PatchView) AddCreateIndexPatch(cp fmt.Stringer)

+ func (pt *PatchView) AddCreateViewPatch(cp fmt.Stringer)

+ func (pt *PatchView) AddDropIndexPatch(cp fmt.Stringer)

+ func (pt *PatchView) AddDropViewPatch(cp fmt.Stringer)

+ func (pt PatchView) Queries() []string

type PgStore

+ func (sr *PgStore) DbConfigTableFromModel(ctx context.Context, md *ModelDesc) (*DbConfigTable, error)

+ func (sr *PgStore) MD2SQLModel(ctx context.Context, md *ModelDesc) (*modelcols.SQLModel, error)

+ func (sr *PgStore) SaveModelConfig(ctx context.Context, md *ModelDesc) error

+ type Viewable interface

+ ViewQuery func() string

v1.0.12

Aug 31, 2022

Changes in this version

+ func IsJsonView(v interface{}) bool

v1.0.11

Aug 29, 2022

v1.0.10

Aug 21, 2022

Changes in this version

+ type Model struct

+ CreatedAt Time

+ DeletedAt NullTime

+ ID UUIDv4

+ UpdatedAt Time

+ func (m *Model) IsIDEmpty() bool

+ func (m *Model) MarkUpdated()

+ type Model58 struct

+ CreatedAt Time

+ DeletedAt NullTime

+ ID UUID58

+ UpdatedAt Time

+ func (m *Model58) IsIDEmpty() bool

+ func (m *Model58) MarkUpdated()

+ type UUID58 UUIDv4

+ func UUID58FromString(s string) (UUID58, error)

+ func UUID58MustFromString(s string) UUID58

+ func UUIDNew58() UUID58

+ func (UUID58) PostgresAllowNull() bool

+ func (UUID58) PostgresDefaultValue() string

+ func (UUID58) PostgresType() string

+ func (u *UUID58) ConvertFrom(v interface{}) error

+ func (u *UUID58) GobDecode(data []byte) error

+ func (u *UUID58) Scan(src interface{}) error

+ func (u *UUID58) UnmarshalJSON(b []byte) error

+ func (u UUID58) GobEncode() ([]byte, error)

+ func (u UUID58) IsZero() bool

+ func (u UUID58) MarshalJSON() ([]byte, error)

+ func (u UUID58) String() string

+ func (u UUID58) Value() (driver.Value, error)

v1.0.9

Aug 19, 2022

Changes in this version

+ func IdentifyPanic() string

+ type ModelQueryEngine struct

+ func (q *ModelQueryEngine[T, R]) ResponseList(rowsGen R) ([]JsonViewer[T], error)

+ type RowsGenerator interface

+ QueryRows func() (*sqlx.Rows, error)

v1.0.8

Aug 16, 2022

Changes in this version

+ type JsonViewErrer interface

+ JsonView func() JsonViewErr[T]

+ type SQLViewErrer interface

+ SQLView func() SQLViewErr[T]

v1.0.7

Aug 14, 2022

Changes in this version

+ type JsonErr struct

+ Err error

type JsonViewErr

+ func (v *JsonViewErr[T]) UnmarshalJSON(b []byte) error

+ func (v JsonViewErr[T]) MarshalJSON() ([]byte, error)

+ type RowScanner interface

+ Scan func(rows sqlx.ColScanner, prefix string) error

type SQLViewErr

+ func (v *SQLViewErr[T]) Scan(rows sqlx.ColScanner, prefix string) error

v1.0.6

Aug 14, 2022

Changes in this version

+ type JsonViewer interface

+ JsonView func() JsonViewErr[T]

+ type SQLViewer interface

+ SQLView func() SQLViewErr[T]

v1.0.5

Aug 14, 2022

Changes in this version

+ type JsonViewErr struct

+ Err error

+ Value *JsonView[T]

+ func (v JsonViewErr[T]) SQLView() SQLViewErr[T]

+ type SQLViewErr struct

+ Err error

+ Value *SQLView[T]

+ func (v SQLViewErr[T]) JsonView() JsonViewErr[T]

v1.0.4

Aug 9, 2022

Changes in this version

type JsonView

+ func (jv *JsonView[T]) SQLView() *SQLView[T]

+ func (mo *JsonView[T]) Scan(value interface{}) error

+ func (mo *JsonView[T]) Value() (driver.Value, error)

type SQLView

+ func (sv *SQLView[T]) JsonView() *JsonView[T]

v1.0.3

Jul 16, 2022

Changes in this version

+ func SQLAllowNull(ft reflect.Type) bool

type AnyObjectMap

+ func (u AnyObjectMap) PostgresAllowNull() bool

type BigSerial

+ func (u BigSerial) PostgresAllowNull() bool

type Bool

+ func (Bool) PostgresAllowNull() bool

type Decimal

+ func (Decimal) PostgresTypeWithLenPrec(ln, prec int) string

+ func (u Decimal) PostgresAllowNull() bool

type Float64

+ func (Float64) PostgresAllowNull() bool

type Int64

+ func (Int64) PostgresAllowNull() bool

type JsonB

+ func (u JsonB) PostgresAllowNull() bool

type NullBool

+ func (u NullBool) PostgresAllowNull() bool

type NullDecimal

+ func (NullDecimal) PostgresTypeWithLenPrec(ln, prec int) string

+ func (u NullDecimal) PostgresAllowNull() bool

type NullFloat64

+ func (u NullFloat64) PostgresAllowNull() bool

type NullInt64

+ func (u NullInt64) PostgresAllowNull() bool

type NullJsonB

+ func (u NullJsonB) PostgresAllowNull() bool

type NullString

+ func (u NullString) PostgresAllowNull() bool

type NullText

+ func (u NullText) PostgresAllowNull() bool

type NullTime

+ func (u NullTime) PostgresAllowNull() bool

+ type PostgresNullable interface

+ PostgresAllowNull func() bool

+ type PostgresTyperLn interface

+ PostgresTypeWithLen func(ln int) string

+ type PostgresTyperLnPrec interface

+ PostgresTypeWithLenPrec func(ln, prec int) string

type String

+ func (String) PostgresAllowNull() bool

type StringArray

+ func (u StringArray) PostgresAllowNull() bool

type Text

+ func (u Text) PostgresAllowNull() bool

type Time

+ func (u Time) PostgresAllowNull() bool

type UUID

+ func (UUID[T]) PostgresAllowNull() bool

type UUIDv4

+ func (UUIDv4) PostgresAllowNull() bool

type UUIDv4Array

+ func (UUIDv4Array) PostgresAllowNull() bool

type Uint64Array

+ func (u Uint64Array) PostgresAllowNull() bool

type XID

+ func (XID[T]) PostgresAllowNull() bool

v1.0.2

Jul 12, 2022

Changes in this version

+ func SQLDefaultValue(ft reflect.Type) string

type AnyObjectMap

+ func (AnyObjectMap) PostgresDefaultValue() string

+ func (AnyObjectMap) PostgresType() string

type BigSerial

+ func (BigSerial) PostgresDefaultValue() string

+ func (BigSerial) PostgresType() string

type Bool

+ func (Bool) PostgresDefaultValue() string

+ func (Bool) PostgresType() string

+ func (n *Bool) Scan(value interface{}) error

+ func (n *Bool) SetBool(b bool)

+ func (n *Bool) UnmarshalJSON(b []byte) error

+ func (n Bool) Bool() bool

+ func (n Bool) MarshalJSON() ([]byte, error)

+ func (n Bool) Value() (driver.Value, error)

type Decimal

+ func (Decimal) PostgresDefaultValue() string

+ func (Decimal) PostgresType() string

+ type Decimal152 Decimal

+ func (Decimal152) PostgresType() string

+ type Decimal153 Decimal

+ func (Decimal153) PostgresType() string

+ type Decimal192 Decimal

+ func (Decimal192) PostgresType() string

+ type FD struct

+ V T

+ Valid bool

+ func NewFD(structField reflect.StructField) *FD[T, PT]

+ func (fdt *FD[T, PT]) FD() *FieldDescription

+ func (n *FD[T, PT]) Scan(value any) error

+ func (n *FD[T, PT]) UnmarshalJSON(b []byte) error

+ func (n FD[T, PT]) MarshalJSON() ([]byte, error)

+ func (n FD[T, PT]) PostgresType() string

+ func (n FD[T, PT]) Value() (driver.Value, error)

+ type FieldDescriber interface

+ FD func() *FieldDescription

type FieldDescription

+ JsonOmitEmpty bool

+ JsonSkip bool

type Float64

+ func (Float64) PostgresDefaultValue() string

+ func (Float64) PostgresType() string

+ func (n *Float64) Scan(value interface{}) error

+ func (n *Float64) SetFloat64(f float64)

+ func (n *Float64) UnmarshalJSON(b []byte) error

+ func (n Float64) Float64() float64

+ func (n Float64) MarshalJSON() ([]byte, error)

+ func (n Float64) Value() (driver.Value, error)

type Int64

+ func (Int64) PostgresDefaultValue() string

+ func (Int64) PostgresType() string

+ func (n *Int64) Scan(value interface{}) error

+ func (n *Int64) SetInt(i int)

+ func (n *Int64) UnmarshalJSON(b []byte) error

+ func (n Int64) Int() int

+ func (n Int64) MarshalJSON() ([]byte, error)

+ func (n Int64) Value() (driver.Value, error)

type JsonB

+ func (JsonB) PostgresDefaultValue() string

+ func (JsonB) PostgresType() string

+ type JsonView struct

+ Filled []*FieldDescription

+ MD *ModelDesc

+ V T

+ func NewJsonView() (*JsonView[T], error)

+ func (mo *JsonView[T]) IsFilled(structFieldNames ...string) bool

+ func (mo *JsonView[T]) IsFullFilled() bool

+ func (mo *JsonView[T]) MarshalJSON() ([]byte, error)

+ func (mo *JsonView[T]) SetFilled(structFieldNames ...string) error

+ func (mo *JsonView[T]) SetFullFilled()

+ func (mo *JsonView[T]) SetUnfilled(structFieldNames ...string) error

+ func (mo *JsonView[T]) UnmarshalJSON(b []byte) error

+ func (mo *JsonView[T]) Valid() bool

type MD

+ Val T

type ModelDesc

+ func (md ModelDesc) ColumnByStoreName(storeName string) (*FieldDescription, error)

+ type ModelDescriber interface

+ MD func() (*ModelDesc, error)

type NullBool

+ func (NullBool) PostgresDefaultValue() string

+ func (NullBool) PostgresType() string

type NullDecimal

+ func (NullDecimal) PostgresDefaultValue() string

+ func (NullDecimal) PostgresType() string

+ type NullDecimal152 NullDecimal

+ func (NullDecimal152) PostgresType() string

+ type NullDecimal153 NullDecimal

+ func (NullDecimal153) PostgresType() string

+ type NullDecimal192 NullDecimal

+ func (NullDecimal192) PostgresType() string

type NullFloat64

+ func (NullFloat64) PostgresDefaultValue() string

+ func (NullFloat64) PostgresType() string

type NullInt64

+ func (NullInt64) PostgresDefaultValue() string

+ func (NullInt64) PostgresType() string

type NullJsonB

+ func (NullJsonB) PostgresDefaultValue() string

+ func (NullJsonB) PostgresType() string

type NullString

+ func (NullString) PostgresDefaultValue() string

+ func (NullString) PostgresType() string

type NullText

+ func (NullText) PostgresDefaultValue() string

+ func (NullText) PostgresType() string

type NullTime

+ func (u NullTime) PostgresDefaultValue() string

+ func (u NullTime) PostgresType() string

+ type PostgresDefaultValuer interface

+ PostgresDefaultValue func() string

+ type SQLView struct

+ Filled []*FieldDescription

+ MD *ModelDesc

+ V T

+ func NewSQLView() (*SQLView[T], error)

+ func (mo *SQLView[T]) Columns() []string

+ func (mo *SQLView[T]) IsFilled(structFieldNames ...string) bool

+ func (mo *SQLView[T]) IsFullFilled() bool

+ func (mo *SQLView[T]) Scan(rows sqlx.ColScanner, prefix string) error

+ func (mo *SQLView[T]) SetFilled(structFieldNames ...string) error

+ func (mo *SQLView[T]) SetFullFilled()

+ func (mo *SQLView[T]) SetUnfilled(structFieldNames ...string) error

+ func (mo *SQLView[T]) Valid() bool

+ func (mo *SQLView[T]) Values() []interface{}

+ type Scanner interface

+ Scan func(src any) error

type String

+ func (String) PostgresDefaultValue() string

+ func (String) PostgresType() string

+ func (n *String) Scan(value interface{}) error

+ func (n *String) SetString(s string)

+ func (n *String) UnmarshalJSON(b []byte) error

+ func (n String) MarshalJSON() ([]byte, error)

+ func (n String) String() string

+ func (n String) Value() (driver.Value, error)

type StringArray

+ func (StringArray) PostgresDefaultValue() string

+ func (StringArray) PostgresType() string

type Text

+ func (Text) PostgresDefaultValue() string

+ func (Text) PostgresType() string

+ func (u *Text) Scan(src interface{}) error

+ func (u Text) Value() (driver.Value, error)

type Time

+ func (u Time) PostgresDefaultValue() string

+ func (u Time) PostgresType() string

type UUID

+ func (UUID[T]) PostgresDefaultValue() string

type UUIDv4

+ func (UUIDv4) PostgresDefaultValue() string

+ func (UUIDv4) PostgresType() string

type UUIDv4Array

+ func (UUIDv4Array) PostgresDefaultValue() string

+ func (UUIDv4Array) PostgresType() string

type Uint64Array

+ func (Uint64Array) PostgresDefaultValue() string

+ func (Uint64Array) PostgresType() string

+ type Valuer interface

+ PostgresType func() string

+ Value func() (driver.Value, error)

type XID

+ func (XID[T]) PostgresDefaultValue() string

v1.0.1

Jul 4, 2022

Changes in this version

+ func Field(ctx context.Context, modelItem T, defval F, fieldName string) (F, error)

+ func GetByID(ctx context.Context, dest *T, id interface{}) error

+ func UniqAdd(sl []T, av T) []T

+ type AppUUID struct

+ func (u AppUUID) IDPrefix() string

+ type AppXID struct

+ func (u AppXID) XIDPrefix() string

type ModelDesc

+ func (md ModelDesc) CreateElemPtr() interface{}

+ type ModelObject struct

+ func ModelObjectFrom(ctx context.Context, modelItem T) (ModelObject, error)

+ type PgSelect struct

+ func (ps *PgSelect) Field(model Storable, defval any, fieldName string) *PgSelect

+ func (ps *PgSelect) From(model Storable) *PgSelect

type PgStore

+ func (s *PgStore) Select(ctx context.Context) *PgSelect

+ func (sr *PgStore) Field(modelItem Storable, fieldName string) (interface{}, error)

+ func (sr *PgStore) ModelObjectFrom(modelItem Storable) (ModelObject, error)

+ type PostgresTyper interface

+ PostgresType func() string

+ type SomeUUID struct

+ func (u SomeUUID) IDPrefix() string

+ type SomeXID struct

+ func (u SomeXID) XIDPrefix() string

+ type TraceUUID struct

+ func (a TraceUUID) IDPrefix() string

+ type TraceXID struct

+ func (a TraceXID) XIDPrefix() string

+ type UUID UUIDv4

+ func NewUUID() UUID[T]

+ func NilUUID() UUID[T]

+ func ParseUUID(s string) (UUID[T], error)

+ func (UUID[T]) PostgresType() string

+ func (id UUID[T]) String() string

+ func (u *UUID[T]) ConvertFrom(v interface{}) error

+ func (u *UUID[T]) Scan(src interface{}) error

+ func (u *UUID[T]) UnmarshalJSON(b []byte) error

+ func (u UUID[T]) IsZero() bool

+ func (u UUID[T]) MarshalJSON() ([]byte, error)

+ func (u UUID[T]) Value() (driver.Value, error)

+ type UUIDJsonTyped UUID[T]

+ func (u *UUIDJsonTyped[T]) UnmarshalJSON(b []byte) error

+ func (u UUIDJsonTyped[T]) MarshalJSON() ([]byte, error)

+ type UUIDType interface

+ UUIDPrefix func() string

type UUIDv4

+ func UUIDFromString(s string) (UUIDv4, error)

+ func UUIDMustFromString(s string) UUIDv4

+ func UUIDNewV4() UUIDv4

+ type UniqueObjects struct

+ func NewUniqueObjects() *UniqueObjects

+ func (uo *UniqueObjects) AddObject(data ModelObject) error

+ func (uo *UniqueObjects) Close()

+ func (uo *UniqueObjects) CopyObjects() (res []ModelObject)

+ func (uo *UniqueObjects) Object(id interface{}) (ModelObject, bool)

+ func (uo *UniqueObjects) Objects() []ModelObject

+ func (uo *UniqueObjects) Reset()

+ type XID xid.ID

+ func NewXID() XID[T]

+ func NilXID() XID[T]

+ func ParseXID(s string) (XID[T], error)

+ func (XID[T]) PostgresType() string

+ func (id XID[T]) String() string

+ func (u *XID[T]) Scan(src interface{}) error

+ func (u *XID[T]) UnmarshalJSON(b []byte) error

+ func (u XID[T]) MarshalJSON() ([]byte, error)

+ func (u XID[T]) Value() (driver.Value, error)

+ type XIDJsonTyped XID[T]

+ func (u *XIDJsonTyped[T]) UnmarshalJSON(b []byte) error

+ func (u XIDJsonTyped[T]) MarshalJSON() ([]byte, error)

+ type XIDType interface

+ XIDPrefix func() string

v1.0.0

Mar 20, 2022

Changes in this version

+ const BrowserDateFormat

+ const BrowserDateTimeFormat

+ const CreatedAtField

+ const DeletedAtField

+ const DriverPostgreSQL

+ const IDField

+ const ISOTimeFormat

+ const SQL_ColumnsInfo

+ const TagDBName

+ const TagDefVal

+ const TagFullText

+ const TagGinKey

+ const TagKey

+ const TagLen

+ const TagPK

+ const TagPrec

+ const TagSql

+ const TagStore

+ const TagUniqueKey

+ const UpdatedAtField

+ func DeleteShard(ctx context.Context, id string) error

+ func EnsureModelSchema(ctx context.Context, md *ModelDesc) error

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

+ func Field2SQLColumn(f FieldDescription) (modelcols.SQLColumn, modelcols.SQLIndexes, error)

+ func Get(ctx context.Context, query string, dest *T, args ...interface{}) error

+ func GetBuffer() *bytes.Buffer

+ func In(query string, args ...interface{}) (string, []interface{}, error)

+ func IndexEqualDBIndex(tname string, idx modelcols.SQLIndex, dbidx DBIndexDef) bool

+ func IndexesEqualToDBIndexes(sqs *modelcols.SQLModel, dbidxs DBIndexDefs) bool

+ func InitDB(c DatabaseDSN) (*sqlx.DB, error)

+ func IsLoggingQuery(ctx context.Context) bool

+ func IsSimpleProtocol(ctx context.Context) bool

+ func MD2SQLModel(md *ModelDesc) (*modelcols.SQLModel, error)

+ func PutBuffer(b *bytes.Buffer)

+ func Query(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)

+ func Rebind(query string) string

+ func Register(sh Shard, m T) error

+ func Replace(ctx context.Context, modelItem T) error

+ func SQLAlterModel(ctx context.Context, md *ModelDesc, mddbidxs DBIndexDefs, ...) error

+ func SQLAlterTable(schema, tname string, last, to *modelcols.SQLModel, dbcolinfos []DBColInfo, ...) []string

+ func SQLCreateModelWithColumns(ctx context.Context, md *ModelDesc, sqs *modelcols.SQLModel) error

+ func SQLCreateTable(pt *PatchTable, md *ModelDesc, schema string) error

+ func SQLCreateTableWithColumns(pt *PatchTable, sqs *modelcols.SQLModel)

+ func SQLType(ft reflect.Type, ln, prec int) string

+ func SaveModelConfig(ctx context.Context, md *ModelDesc) error

+ func Select(ctx context.Context, query string, dest *[]T, args ...interface{}) error

+ func SelectCursorWalk(ctx context.Context, cursorName, selectQuery string, destSlice *[]T, ...) error

+ func SelectShard(ctx context.Context, id string) (context.Context, error)

+ func ToSnakeCase2(str string) string

+ func WalkShards(ctx context.Context, f func(Shard) error) error

+ func WithLoggingQuery(ctx context.Context) context.Context

+ func WithShard(ctx context.Context, s Shard) context.Context

+ func WithShards(ctx context.Context, s *Shards) context.Context

+ func WithSimpleProtocol(ctx context.Context) context.Context

+ func WithTx(ctx context.Context, f func(context.Context) error) error

+ func WithTxInShard(ctx context.Context, shardId string, f func(context.Context) error) error

+ type AnyObjectMap map[string]interface

+ func (f *AnyObjectMap) Scan(value interface{}) error

+ func (f *AnyObjectMap) UnmarshalJSON(b []byte) error

+ func (f AnyObjectMap) ConvertTo(value interface{}) error

+ func (f AnyObjectMap) MarshalJSON() ([]byte, error)

+ func (f AnyObjectMap) String() string

+ func (f AnyObjectMap) Value() (driver.Value, error)

+ type BigSerial sql.NullInt64

+ func (n *BigSerial) ConvertFrom(v interface{}) error

+ func (n *BigSerial) Scan(value interface{}) error

+ func (n *BigSerial) UnmarshalJSON(b []byte) error

+ func (n BigSerial) MarshalJSON() ([]byte, error)

+ func (n BigSerial) Value() (driver.Value, error)

+ type Bool bool

+ func (b *Bool) ConvertFrom(v interface{}) error

+ type CtxShard struct

+ type CtxShards struct

+ type DBColInfo struct

+ CharLen *int

+ IsNullable string

+ Name string

+ NumLen *int

+ NumPrec *int

+ Type string

+ func DBColumnsInfo(ctx context.Context, tx *sqlx.Tx, schema, tname string) ([]DBColInfo, error)

+ type DBIndexDef struct

+ Fields StringArray

+ Name string

+ Schema string

+ Table string

+ func (d DBIndexDef) String() string

+ type DBIndexDefs []DBIndexDef

+ func CurrentSchemaIndexes(ctx context.Context, tablename string) (DBIndexDefs, error)

+ func (idxs DBIndexDefs) FindByName(n string) (DBIndexDef, bool)

+ type DatabaseDSN struct

+ ConnMaxLifetime time.Duration

+ MaxIdleConns int

+ MaxOpenConns int

+ Postgres string

+ type DbConfig []DbConfigTable

+ func NewDbConfig() *DbConfig

+ func (c *DbConfig) LoadAll(ctx context.Context, tx *sqlx.Tx, schema string) error

+ type DbConfigTable struct

+ Storej *modelcols.SQLModel

+ TableName string

+ func DbConfigTableFromModel(md *ModelDesc) (*DbConfigTable, error)

+ func (c *DbConfigTable) IsEmpty() bool

+ func (c *DbConfigTable) LoadTable(ctx context.Context, table string) error

+ func (c DbConfigTable) SaveTable(ctx context.Context) error

+ type Decimal []byte

+ func Float64ToDecimal(v float64) Decimal

+ func NegOne() Decimal

+ func NewDecimalFromAny(v interface{}) (*Decimal, error)

+ func NewDecimalFromFloat64(x float64) Decimal

+ func NewDecimalFromInt(x int) Decimal

+ func NewDecimalFromInt64(x int64) Decimal

+ func NewDecimalFromUint64(x uint64) Decimal

+ func One() Decimal

+ func Zero() Decimal

+ func (d *Decimal) ConvertFrom(v interface{}) error

+ func (d *Decimal) Scan(value interface{}) error

+ func (d *Decimal) SetNumber(dd *decimal.Big)

+ func (d *Decimal) UnmarshalJSON(b []byte) error

+ func (d *Decimal) UnmarshalText(data []byte) error

+ func (d Decimal) GetNumber() (*decimal.Big, error)

+ func (d Decimal) MarshalJSON() ([]byte, error)

+ func (d Decimal) MarshalText() ([]byte, error)

+ func (d Decimal) String() string

+ func (d Decimal) Value() (driver.Value, error)

+ func (x *Decimal) ParseGoType(v interface{})

+ func (x Decimal) Add(d2 Decimal) Decimal

+ func (x Decimal) Bool() bool

+ func (x Decimal) Div(d2 Decimal) Decimal

+ func (x Decimal) Equal(d2 Decimal) bool

+ func (x Decimal) Float() float64

+ func (x Decimal) Int() int64

+ func (x Decimal) Less(d2 Decimal) bool

+ func (x Decimal) LessOrEqual(d2 Decimal) bool

+ func (x Decimal) Mod(d2 Decimal) Decimal

+ func (x Decimal) Mul(d2 Decimal) Decimal

+ func (x Decimal) Negative() Decimal

+ func (x Decimal) Pow(d2 Decimal) Decimal

+ func (x Decimal) RoundHalfUp() int64

+ func (x Decimal) RoundHalfUpTo2Sign() Decimal

+ func (x Decimal) RoundTo(n int, m decimal.RoundingMode) Decimal

+ func (x Decimal) Sub(d2 Decimal) Decimal

+ func (x Decimal) Uint() uint64

+ type ErrorNoTransaction struct

+ func (e ErrorNoTransaction) Error() string

+ type ErrorNotFound struct

+ ID interface{}

+ Message string

+ Type reflect.Type

+ type FieldDescription struct

+ DefVal string

+ ElemType reflect.Type

+ FullTextEnabled bool

+ GinIndexes []string

+ Idx int

+ Indexes []string

+ JsonName string

+ Ln int

+ Name string

+ Nullable bool

+ PK bool

+ Prec int

+ SQLTypeDef string

+ Skip bool

+ SkipReplace bool

+ StructField reflect.StructField

+ UniqIndexes []string

+ func NewFieldDescription(structField reflect.StructField) *FieldDescription

+ func (fd *FieldDescription) IsStored() bool

+ func (fd *FieldDescription) MarshalJSON() ([]byte, error)

+ func (fd *FieldDescription) MarshalText() (text []byte, err error)

+ func (fd FieldDescription) String() string

+ type Float64 float64

+ func (f *Float64) ConvertFrom(v interface{}) error

+ type Int64 int64

+ func (f *Int64) ConvertFrom(v interface{}) error

+ type JsonB struct

+ Val interface{}

+ func NewJsonB(val interface{}) *JsonB

+ func (n *JsonB) ConvertFrom(v interface{}) error

+ func (n *JsonB) Scan(value interface{}) error

+ func (n *JsonB) UnmarshalJSON(b []byte) error

+ func (n JsonB) ConvertTo(value interface{}) error

+ func (n JsonB) MarshalJSON() ([]byte, error)

+ func (n JsonB) Value() (driver.Value, error)

+ type MD struct

+ func (m MD[T]) MD() (*ModelDesc, error)

+ type Mdjs struct

+ Fields []MdjsField

+ Md *ModelDesc

+ ModelName string

+ func ModelsAndFields(ctx context.Context, st *PgStore) ([]Mdjs, error)

+ type MdjsField struct

+ DBName string

+ Desc *FieldDescription

+ Name string

+ Type reflect.Type

+ type MigrationProcessor interface

+ AfterAlterModelError func(ctx context.Context, err error, stx *PgStore, md *ModelDesc, ...) error

+ AfterCommit func(ctx context.Context, stx *PgStore) error

+ AfterCreateNewSchemaTable func(ctx context.Context, stx *PgStore, md *ModelDesc, schema string) error

+ AfterMigrate func(ctx context.Context, stx *PgStore, reg MigrationRegistrator, ...) error

+ type MigrationRegistrator interface

+ CheckStarted func(ctx context.Context, stx *PgStore, schema, migrname string) (bool, error)

+ Start func(ctx context.Context, stx *PgStore, schema, migrname string) error

+ Stop func(ctx context.Context, stx *PgStore, schema, migrname string) error

+ type ModelDesc struct

+ func NewModelDescription(m T) (*ModelDesc, error)

+ func (md *ModelDesc) ColumnPtr(i int) *FieldDescription

+ func (md *ModelDesc) ColumnPtrsCount() int

+ func (md *ModelDesc) CreatedAtField() *FieldDescription

+ func (md *ModelDesc) DeletedAtField() *FieldDescription

+ func (md *ModelDesc) IdField() *FieldDescription

+ func (md *ModelDesc) ReplaceEntries(schema string) ([]string, map[string]ReplaceEntry, error)

+ func (md *ModelDesc) UpdatedAtField() *FieldDescription

+ func (md *ModelDesc) WalkColumnPtrs(f func(i int, v *FieldDescription) error) error

+ func (md ModelDesc) ColumnByFieldName(fieldName string) (*FieldDescription, error)

+ func (md ModelDesc) ColumnByJsonName(jsonName string) (*FieldDescription, error)

+ func (md ModelDesc) ColumnsByFieldNames(fieldNames ...string) (res []*FieldDescription)

+ func (md ModelDesc) CreateSlicePtr() interface{}

+ func (md ModelDesc) ModelType() reflect.Type

+ func (md ModelDesc) StoreName() string

+ func (md ModelDesc) UniqName() string

+ type ModelDescriptorer interface

+ MD func() (*ModelDesc, error)

+ type NullBool sql.NullBool

+ func (n *NullBool) ConvertFrom(v interface{}) error

+ func (n *NullBool) Scan(value interface{}) error

+ func (n *NullBool) UnmarshalJSON(b []byte) error

+ func (n NullBool) MarshalJSON() ([]byte, error)

+ func (n NullBool) Value() (driver.Value, error)

+ type NullDecimal struct

+ Decimal Decimal

+ Valid bool

+ func (d *NullDecimal) ConvertFrom(v interface{}) error

+ func (n *NullDecimal) Scan(value interface{}) error

+ func (n *NullDecimal) UnmarshalJSON(b []byte) error

+ func (n NullDecimal) MarshalJSON() ([]byte, error)

+ func (n NullDecimal) Value() (driver.Value, error)

+ type NullFloat64 sql.NullFloat64

+ func (n *NullFloat64) ConvertFrom(v interface{}) error

+ func (n *NullFloat64) Scan(value interface{}) error

+ func (n *NullFloat64) UnmarshalJSON(b []byte) error

+ func (n NullFloat64) MarshalJSON() ([]byte, error)

+ func (n NullFloat64) Value() (driver.Value, error)

+ type NullInt64 sql.NullInt64

+ func (n *NullInt64) ConvertFrom(v interface{}) error

+ func (n *NullInt64) Scan(value interface{}) error

+ func (n *NullInt64) UnmarshalJSON(b []byte) error

+ func (n NullInt64) MarshalJSON() ([]byte, error)

+ func (n NullInt64) Value() (driver.Value, error)

+ type NullJsonB struct

+ Val interface{}

+ Valid bool

+ func NewNullJsonB(val interface{}) *NullJsonB

+ func (n *NullJsonB) ConvertFrom(v interface{}) error

+ func (n *NullJsonB) Scan(value interface{}) error

+ func (n *NullJsonB) UnmarshalJSON(b []byte) error

+ func (n NullJsonB) ConvertTo(value interface{}) error

+ func (n NullJsonB) MarshalJSON() ([]byte, error)

+ func (n NullJsonB) Value() (driver.Value, error)

+ type NullString sql.NullString

+ func (n *NullString) ConvertFrom(v interface{}) error

+ func (n *NullString) Scan(value interface{}) error

+ func (n *NullString) UnmarshalJSON(b []byte) error

+ func (n NullString) MarshalJSON() ([]byte, error)

+ func (n NullString) Value() (driver.Value, error)

+ type NullText sql.NullString

+ func (n *NullText) ConvertFrom(v interface{}) error

+ func (n *NullText) Scan(value interface{}) error

+ func (n *NullText) UnmarshalJSON(b []byte) error

+ func (n NullText) MarshalJSON() ([]byte, error)

+ func (n NullText) Value() (driver.Value, error)

+ type NullTime struct

+ Time Time

+ Valid bool

+ func (n *NullTime) UnmarshalJSON(b []byte) error

+ func (n NullTime) MarshalJSON() ([]byte, error)

+ func (nt *NullTime) Scan(value interface{}) (err error)

+ func (nt NullTime) String() string

+ func (nt NullTime) Value() (driver.Value, error)

+ func (t *NullTime) ConvertFrom(v interface{}) error

+ type PatchAddColumn struct

+ Col modelcols.SQLColumn

+ func (c PatchAddColumn) String() string

+ type PatchAlterColumnDefVal struct

+ Col modelcols.SQLColumn

+ func (c PatchAlterColumnDefVal) String() string

+ type PatchAlterColumnNullable struct

+ Col modelcols.SQLColumn

+ func (c PatchAlterColumnNullable) String() string

+ type PatchAlterColumnType struct

+ Col modelcols.SQLColumn

+ func (c PatchAlterColumnType) String() string

+ type PatchCreateIndex struct

+ Index modelcols.SQLIndex

+ Schema string

+ Table string

+ func (c PatchCreateIndex) String() string

+ type PatchCreateTable struct

+ Cols modelcols.SQLColumns

+ Schema string

+ Table string

+ func (c PatchCreateTable) String() string

+ type PatchDropIndex struct

+ Force bool

+ Index string

+ Schema string

+ Table string

+ func (c PatchDropIndex) String() string

+ type PatchTable struct

+ AlterCols []fmt.Stringer

+ CreateIndexes []fmt.Stringer

+ CreateTables []fmt.Stringer

+ DropIndexes []fmt.Stringer

+ Name string

+ Schema string

+ UpdateNulls []fmt.Stringer

+ func (pt *PatchTable) AddColumnPatch(cp fmt.Stringer)

+ func (pt *PatchTable) AddCreateIndexPatch(cp fmt.Stringer)

+ func (pt *PatchTable) AddCreateTablePatch(cp fmt.Stringer)

+ func (pt *PatchTable) AddDropIndexPatch(cp fmt.Stringer)

+ func (pt *PatchTable) AddUpdateNullsPatch(cp fmt.Stringer)

+ func (pt PatchTable) Queries() []string

+ type PatchUpdateNulls struct

+ Col modelcols.SQLColumn

+ Schema string

+ Table string

+ func (c PatchUpdateNulls) String() string

+ type PgStore struct

+ func NewPgStore(db *sqlx.DB, schema string) *PgStore

+ func (sr *PgStore) CheckStarted(ctx context.Context, stx *PgStore, schema, migrname string) (bool, error)

+ func (sr *PgStore) Close()

+ func (sr *PgStore) Migrate(ctx context.Context, mProcessor MigrationProcessor) error

+ func (sr *PgStore) PrepExec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (sr *PgStore) PrepGet(ctx context.Context, query string, dest interface{}, args ...interface{}) error

+ func (sr *PgStore) PrepQueryx(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)

+ func (sr *PgStore) PrepSelect(ctx context.Context, query string, dest interface{}, args ...interface{}) error

+ func (sr *PgStore) PrepSelectCursorWalk(ctx context.Context, cursorName, selectQuery string, destSlice interface{}, ...) error

+ func (sr *PgStore) PrepareQuery(ctx context.Context, query string) (string, error)

+ func (sr *PgStore) Replace(ctx context.Context, modelItem Storable) error

+ func (sr *PgStore) SetUnsafe()

+ func (sr *PgStore) Start(ctx context.Context, stx *PgStore, schema, migrname string) error

+ func (sr *PgStore) Stop(ctx context.Context, stx *PgStore, schema, migrname string) error

+ func (sr PgStore) Begin(ctx context.Context) (*PgStore, error)

+ func (sr PgStore) Commit() error

+ func (sr PgStore) Rollback() error

+ func (sr PgStore) Schema() string

+ func (sr PgStore) String() string

+ func (sr PgStore) Tx() *sqlx.Tx

+ func (sr PgStore) WithBeginTx(ctx context.Context, f func(storeCopy *PgStore) error) (err error)

+ func (sr PgStore) WithTx(ctx context.Context, f func(storeCopy *PgStore) error) (err error)

+ type ReplaceEntry struct

+ Schema string

+ To string

+ Typ reflect.Type

+ type Shard struct

+ ID string

+ Store *PgStore

+ func SetShard(ctx context.Context, id string, db *sqlx.DB, schema string) (Shard, error)

+ func ShardByID(ctx context.Context, id string) (Shard, error)

+ func ShardFromContext(ctx context.Context) (Shard, error)

+ func (s Shard) Migrate(ctx context.Context, mProcessor MigrationProcessor) error

+ func (s Shard) WithTx(ctx context.Context, f func(context.Context) error) error

+ type Shards struct

+ func NewShards(ctx context.Context) (*Shards, context.Context)

+ func ShardsFromContext(ctx context.Context) (*Shards, error)

+ func (s *Shards) DeleteShard(id string)

+ func (s *Shards) SetShard(id string, db *sqlx.DB, schema string) Shard

+ func (s *Shards) ShardByID(id string) (Shard, bool)

+ func (s *Shards) Walk(f func(Shard) error) error

+ func (shs *Shards) AnalyzeAndReplaceQuery(sr *PgStore, query string) (string, map[string]ReplaceEntry, error)

+ type Storable interface

+ StoreName func() string

+ type Store struct

+ func (s *Store) Close()

+ func (s *Store) Init()

+ func (s Store) GetModelDescription(model Storable) (*ModelDesc, bool)

+ func (s Store) GetModelDescriptionByType(typ reflect.Type) (*ModelDesc, bool)

+ func (s Store) ModelDescriptions() map[reflect.Type]*ModelDesc

+ func (s Store) QueryReplacers() map[sqlPattern]map[string]ReplaceEntry

+ func (sr *Store) JSONBuildObjectSQL(md *ModelDesc, prefix string, onlyStructFieldNames ...string) string

+ type String string

+ func (s *String) ConvertFrom(v interface{}) error

+ type StringArray []string

+ func (f *StringArray) Scan(value interface{}) error

+ func (f *StringArray) UnmarshalJSON(b []byte) error

+ func (f StringArray) MarshalJSON() ([]byte, error)

+ func (f StringArray) Value() (driver.Value, error)

+ type Text string

+ func (s *Text) ConvertFrom(v interface{}) error

+ type Time time.Time

+ func NowUTC() Time

+ func (t *Time) ConvertFrom(v interface{}) error

+ func (t *Time) GobDecode(data []byte) error

+ func (t *Time) Scan(value interface{}) (err error)

+ func (t *Time) UnmarshalBinary(data []byte) error

+ func (t *Time) UnmarshalJSON(b []byte) error

+ func (t Time) AssignTo(v reflect.Value)

+ func (t Time) FormatRus(f string) string

+ func (t Time) GobEncode() ([]byte, error)

+ func (t Time) MarshalBinary() ([]byte, error)

+ func (t Time) MarshalJSON() ([]byte, error)

+ func (t Time) Round(d time.Duration) Time

+ func (t Time) String() string

+ func (t Time) Time() time.Time

+ func (t Time) Value() (driver.Value, error)

+ type UUIDv4 struct

+ func FromString(s string) (UUIDv4, error)

+ func NewV4() UUIDv4

+ func (u *UUIDv4) ConvertFrom(v interface{}) error

+ func (u *UUIDv4) GobDecode(data []byte) error

+ func (u *UUIDv4) Scan(src interface{}) error

+ func (u *UUIDv4) UnmarshalJSON(b []byte) error

+ func (u UUIDv4) GobEncode() ([]byte, error)

+ func (u UUIDv4) IsZero() bool

+ func (u UUIDv4) MarshalJSON() ([]byte, error)

+ func (u UUIDv4) String() string

+ func (u UUIDv4) Value() (driver.Value, error)

+ type UUIDv4Array []UUIDv4

+ func (a *UUIDv4Array) Raw() []UUIDv4

+ func (a *UUIDv4Array) Scan(value interface{}) error

+ func (a *UUIDv4Array) UnmarshalJSON(b []byte) error

+ func (a UUIDv4Array) MarshalJSON() ([]byte, error)

+ func (a UUIDv4Array) Value() (driver.Value, error)

+ type Uint64Array []uint64

+ func (f *Uint64Array) Scan(value interface{}) error

+ func (f *Uint64Array) UnmarshalJSON(b []byte) error

+ func (f Uint64Array) MarshalJSON() ([]byte, error)

+ func (f Uint64Array) Value() (driver.Value, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL