godb

Apr 24, 2022

Changes in this version

+ var DefaultDictionaryTemplate string

+ var DefaultModelTemplate string

Apr 21, 2022

Changes in this version

type ModelFiledTag

+ IsIgnored bool

Apr 6, 2022

Changes in this version

+ const ConflictActionNothing

+ const ConflictActionUpdate

+ type Insert struct

+ func NewInsert() *Insert

+ func (i *Insert) AddReturning(returning ...string) *Insert

+ func (i *Insert) AddValues(values []any) *Insert

+ func (i *Insert) Columns(column ...string) *Insert

+ func (i *Insert) Conflict() *conflict

+ func (i *Insert) From(from string) *Insert

+ func (i *Insert) GetAllValues() []any

+ func (i *Insert) GetValues(start, end int) []any

+ func (i *Insert) GetWith(name string) *QB

+ func (i *Insert) Into(into string) *Insert

+ func (i *Insert) ResetColumns() *Insert

+ func (i *Insert) ResetFrom() *Insert

+ func (i *Insert) ResetInto() *Insert

+ func (i *Insert) ResetReturning() *Insert

+ func (i *Insert) ResetValues() *Insert

+ func (i *Insert) ResetWith() *Insert

+ func (i *Insert) SQL() (query string, params []any)

+ func (i *Insert) SetValues(index int, values []any) *Insert

+ func (i *Insert) String() string

+ func (i *Insert) With(name string, qb *QB) *Insert

type ModelFiledTag

+ IsCreatedAt bool

+ IsDeletedAt bool

+ IsUpdatedAt bool

Mar 20, 2022

Changes in this version

type Column

+ func (c Column) GetModelFieldTag() (field ModelFiledTag)

Mar 20, 2022

Changes in this version

+ func ModelColumns(model IModel, field ...interface{}) (columns []string)

+ type IModelCrud interface

+ GetDeleteQuery func() string

+ GetInsertQuery func() string

+ GetLoadQuery func() string

+ GetUpdateQuery func() string

+ type ModelFiledTag struct

+ Column string

+ ForeignKey string

+ IsPrimaryKey bool

+ IsRequired bool

+ IsSequence bool

+ IsSystem bool

+ IsUnique bool

+ func ParseModelFiledTag(tag string) (field ModelFiledTag)

+ func (t ModelFiledTag) String() string

Feb 16, 2021

Changes in this version

type Column

+ DefaultTypeValue *string

Dec 8, 2020

Changes in this version

type QB

+ func (f *QB) Except(qb *QB) *QB

+ func (f *QB) ResetExcept() *QB

Sep 25, 2020

Changes in this version

type Column

+ IsByteArray bool

Sep 8, 2020

Changes in this version

type QB

+ SubQuery bool

+ func (f *QB) Intersect(qb *QB) *QB

+ func (f *QB) ResetIntersect() *QB

Aug 24, 2020

Changes in this version

+ func ModelValues(model IModel, columns ...string) (values []interface{})

Aug 24, 2020

Changes in this version

+ func ModelInsertQuery(model IModel, fields ...interface{}) (sql string, columns []string, e porterr.IError)

May 22, 2020

Changes in this version

type QB

+ func (f *QB) ResetUnion() *QB

+ func (f *QB) Union(qb *QB) *QB

May 5, 2020

Changes in this version

type TransactionPool

+ func NewTransactionPool() *TransactionPool

+ func (p *TransactionPool) Count() int

+ func (p *TransactionPool) Get(id TransactionId) *SqlTx

+ func (p *TransactionPool) Reset() *TransactionPool

+ func (p *TransactionPool) Set(id TransactionId, tx *SqlTx) *TransactionPool

+ func (p *TransactionPool) UnSet(id TransactionId) *TransactionPool

Apr 24, 2020

Changes in this version

type Options

+ TransactionTTL time.Duration

type SqlTx

+ func (tx *SqlTx) Commit() error

+ func (tx *SqlTx) Rollback() error

+ type Transaction struct

+ TTL int

+ type TransactionId string

+ func GenTransactionId() TransactionId

+ type TransactionPool map[TransactionId]*SqlTx

Mar 19, 2020

Changes in this version

+ func ModelDeleteQuery(model IModel, condition *Condition) (sql string, e porterr.IError)

Mar 12, 2020

Changes in this version

+ func ModelUpdateQuery(model IModel, condition *Condition, fields ...interface{}) (sql string, params []interface{}, e porterr.IError)

Mar 12, 2020

Changes in this version

+ func ModelColumn(model IModel, field interface{}) string

Mar 7, 2020

Changes in this version

type Column

+ Tags string

Feb 13, 2020

Changes in this version

type Column

+ HasUniqueIndex bool

+ UniqueIndexName *string

Feb 11, 2020

Changes in this version

type Condition

+ func (c *Condition) IsEmpty() bool

Feb 10, 2020

Changes in this version

+ type QB struct

+ func NewQB() *QB

+ func (f *QB) AddOrder(expression ...string) *QB

+ func (f *QB) Columns(column ...string) *QB

+ func (f *QB) From(table ...string) *QB

+ func (f *QB) GetArguments() []interface{}

+ func (f *QB) GetWith(name string) *QB

+ func (f *QB) GroupBy(fields ...string) *QB

+ func (f *QB) Having() *Condition

+ func (f *QB) ModelColumns(model ...IModel) *QB

+ func (f *QB) ModelFrom(model ...IModel) *QB

+ func (f *QB) Relate(relation ...string) *QB

+ func (f *QB) ResetColumns() *QB

+ func (f *QB) ResetFrom() *QB

+ func (f *QB) ResetGroupBy() *QB

+ func (f *QB) ResetOrder() *QB

+ func (f *QB) ResetRelations() *QB

+ func (f *QB) ResetWith() *QB

+ func (f *QB) SetPagination(limit int, offset int) *QB

+ func (f *QB) Where() *Condition

+ func (f *QB) With(name string, qb *QB) *QB

+ func (f QB) String() string

Dec 25, 2019

Changes in this version

type Iterator

+ func NewIterator(len int) *Iterator

Dec 12, 2019

Changes in this version

type Column

+ ForeignIsSoft bool

Dec 7, 2019

Changes in this version

+ type IModel interface

+ Columns func() []string

+ Delete func(q Queryer) porterr.IError

+ Load func(q Queryer) porterr.IError

+ Save func(q Queryer) porterr.IError

+ Table func() string

+ Values func() []interface{}

+ type ISoftModel interface

+ SoftDelete func(q Queryer) porterr.IError

+ SoftLoad func(q Queryer) porterr.IError

+ SoftRecover func(q Queryer) porterr.IError

+ type Iterator struct

+ func (c *Iterator) Count() int

+ func (c *Iterator) Cursor() int

+ func (c *Iterator) Next() bool

+ func (c *Iterator) Reset() *Iterator

+ func (c *Iterator) SetCount(count int) *Iterator

type SqlFilter

+ func (f *SqlFilter) Columns(column ...string) *SqlFilter

+ func (f *SqlFilter) From(table ...string) *SqlFilter

+ func (f *SqlFilter) Relate(relation ...string) *SqlFilter

+ func (f *SqlFilter) ResetColumns() *SqlFilter

+ func (f *SqlFilter) ResetFrom() *SqlFilter

+ func (f *SqlFilter) ResetRelations() *SqlFilter

Dec 2, 2019

Changes in this version

type Column

+ IsDeleted bool

Dec 2, 2019

Changes in this version

+ var DefaultSystemColumns = SystemColumns

+ var DefaultSystemColumnsSoft = SystemColumns

type Column

+ IsCreated bool

+ IsIsDeleted bool

+ IsUpdated bool

+ type SystemColumns struct

+ Created string

+ Deleted string

+ Updated string

Nov 21, 2019

Changes in this version

type Condition

+ func (c *Condition) AddArgument(values ...interface{}) *Condition

Oct 10, 2019

Changes in this version

+ type Condition struct

+ func (c *Condition) AddExpression(expression string, values ...interface{}) *Condition

+ func (c *Condition) GetArguments() []interface{}

+ func (c *Condition) Merge(operator string, conditions ...*Condition) *Condition

+ func (c *Condition) String() string

Sep 5, 2019

Changes in this version

type Columns

+ func (c Columns) GetImports() []string

Aug 22, 2019

Changes in this version

type Column

+ IsArray bool

Aug 7, 2019

Changes in this version

+ const ConditionOperatorAnd

+ const ConditionOperatorOr

+ const ConditionOperatorXor

+ func NewSqlCondition(operator string) *condition

type SqlFilter

+ func (f *SqlFilter) Having() *condition

+ func (f *SqlFilter) Where() *condition

Aug 1, 2019

Changes in this version

+ func CreateDictionaryTable(db *DBO) error

+ func CreateModel(schema string, table string, path string) error

+ func CreateModelFile(schema string, table string, path string) (*os.File, string, error)

+ func GenerateDictionaryMapping(path string, db *DBO) error

+ func MakeModel(db *DBO, path string, schema string, table string) error

+ func ParseCrudMethodTemplate(t string, model string, table string, columns Columns) (bytes.Buffer, error)

+ type Column struct

+ DataType string

+ Default *string

+ Description *string

+ ForeignColumnName *string

+ ForeignSchema *string

+ ForeignTable *string

+ Import string

+ IsNullable bool

+ IsPrimaryKey bool

+ Json string

+ ModelName string

+ ModelType string

+ Name string

+ Schema string

+ Sequence *string

+ Table string

+ type Columns []Column

+ func GetTableColumns(schema string, table string) (*Columns, error)

+ type Connection interface

+ GetConnMaxLifetime func() int

+ GetDbType func() string

+ GetMaxConnection func() int

+ GetMaxIdleConns func() int

+ String func() string

+ type ConnectionConfig struct

+ ConnectionIdleLifetime int

+ Host string

+ MaxConnections int

+ MaxIdleConnections int

+ Name string

+ Password string

+ Port int

+ User string

+ func (cc *ConnectionConfig) GetConnMaxLifetime() int

+ func (cc *ConnectionConfig) GetMaxConnection() int

+ func (cc *ConnectionConfig) GetMaxIdleConns() int

+ type DBO struct

+ Connection Connection

+ func (dbo *DBO) Begin() (*SqlTx, error)

+ func (dbo *DBO) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (dbo *DBO) Prepare(query string) (*SqlStmt, error)

+ func (dbo *DBO) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (dbo *DBO) QueryRow(query string, args ...interface{}) *sql.Row

+ func (dbo *DBO) RunInTransaction(callback TxCallback) (interface{}, error)

+ func (dbo DBO) Init() (*DBO, error)

+ type DictionaryModel struct

+ Code string

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ Id int

+ Label *string

+ Type string

+ UpdatedAt *time.Time

+ func (m *DictionaryModel) Columns() []string

+ func (m *DictionaryModel) SearchDictionary(q Queryer, filter SqlFilter) (*[]DictionaryModel, []int, error)

+ func (m *DictionaryModel) Values() (values []interface{})

+ type IMigrationFile interface

+ Down func(tx *SqlTx) error

+ GetVersion func() string

+ Up func(tx *SqlTx) error

+ type Logger interface

+ Print func(v ...interface{})

+ Printf func(format string, v ...interface{})

+ Println func(v ...interface{})

+ type Migration struct

+ Config ConnectionConfig

+ DBO *DBO

+ MigrationPath string

+ Registry *MigrationRegistry

+ RegistryPath string

+ RegistryXPath string

+ func (m *Migration) CreateMigrationFile(class string, name string) error

+ func (m *Migration) Downgrade(class string, version string) error

+ func (m *Migration) GetTemplate() *template.Template

+ func (m *Migration) InitMigration(class string) error

+ func (m *Migration) Upgrade(class string) error

+ type MigrationRegistry map[string][]IMigrationFile

+ type Options struct

+ Debug bool

+ Logger Logger

+ type PostgresConnectionConfig struct

+ BinaryParameters bool

+ SSLMode string

+ func (pcc *PostgresConnectionConfig) GetDbType() string

+ func (pcc *PostgresConnectionConfig) String() string

+ type Queryer interface

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

+ Prepare func(query string) (*SqlStmt, error)

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

+ QueryRow func(query string, args ...interface{}) *sql.Row

+ type SqlFilter struct

+ func NewSqlFilter() *SqlFilter

+ func (f *SqlFilter) AddExpression(expression string, values []interface{}) *SqlFilter

+ func (f *SqlFilter) AddFiledFilter(field string, condition string, value interface{}) *SqlFilter

+ func (f *SqlFilter) AddInFilter(field string, values []interface{}) *SqlFilter

+ func (f *SqlFilter) AddNotInFilter(field string, values []interface{}) *SqlFilter

+ func (f *SqlFilter) AddOrFilters(filter ...*SqlFilter) *SqlFilter

+ func (f *SqlFilter) AddOrder(field string, direction string) *SqlFilter

+ func (f *SqlFilter) GetArguments() []interface{}

+ func (f *SqlFilter) GroupBy(fields ...string) *SqlFilter

+ func (f *SqlFilter) ResetGroupBy() *SqlFilter

+ func (f *SqlFilter) ResetOrder() *SqlFilter

+ func (f *SqlFilter) SetPagination(limit int, offset int) *SqlFilter

+ func (f SqlFilter) GetWithWhere() string

+ func (f SqlFilter) String() string

+ type SqlStmt struct

+ func (st *SqlStmt) Exec(args ...interface{}) (sql.Result, error)

+ func (st *SqlStmt) Query(args ...interface{}) (*sql.Rows, error)

+ func (st *SqlStmt) QueryRow(args ...interface{}) *sql.Row

+ type SqlTx struct

+ func (tx *SqlTx) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (tx *SqlTx) Prepare(query string) (*SqlStmt, error)

+ func (tx *SqlTx) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (tx *SqlTx) QueryRow(query string, args ...interface{}) *sql.Row

+ func (tx *SqlTx) Stmt(stmt *SqlStmt) *SqlStmt

+ type TxCallback func(tx *SqlTx) (interface{}, error)