entdbadapter

package

Go to main page

Versions in this module

v0

v0.1.3

Jun 4, 2024

v0.1.2

Jun 3, 2024

v0.1.1

Jun 3, 2024

v0.1.0

May 30, 2024

Changes in this version

type Adapter

+ func (d *Adapter) Query(ctx context.Context, query string, args any) ([]*schema.Entity, error)

type EntAdapter

+ Query func(ctx context.Context, query string, args any) ([]*schema.Entity, error)

+ type SQLColumnType interface

+ DatabaseTypeName func() string

+ ScanType func() reflect.Type

type Tx

+ func (tx *Tx) Query(ctx context.Context, query string, args any) ([]*schema.Entity, error)

v0.0.7

Apr 22, 2024

v0.0.6

Apr 22, 2024

v0.0.5

Apr 15, 2024

Changes in this version

+ func NewTestClient(migrationDir string, schemaBuilder *schema.Builder, ...) (_ app.DBClient, err error)

type Adapter

+ func (d *Adapter) SetDriver(driver dialect.Driver)

+ func (d *Adapter) SetSQLDB(db *sql.DB)

+ type EntAdapter interface

+ Close func() error

+ Commit func() error

+ Config func() *app.DBConfig

+ CreateDBModel func(s *schema.Schema, relations ...*schema.Relation) app.Model

+ DB func() *sql.DB

+ Dialect func() string

+ Driver func() dialect.Driver

+ Exec func(ctx context.Context, query string, args, bindValue any) error

+ Hooks func() *app.Hooks

+ IsTx func() bool

+ Migrate func(migration *app.Migration, appendEntTables ...*entSchema.Table) (err error)

+ Model func(name string) (app.Model, error)

+ NewEdgeSpec func(r *schema.Relation, nodeIDs []driver.Value) (*sqlgraph.EdgeSpec, error)

+ NewEdgeStepOption func(r *schema.Relation) (sqlgraph.StepOption, error)

+ Reload func(newSchemaBuilder *schema.Builder, migration *app.Migration) (_ app.DBClient, err error)

+ Rollback func() error

+ SchemaBuilder func() *schema.Builder

+ SetDriver func(driver dialect.Driver)

+ SetSQLDB func(db *sql.DB)

+ Tx func(ctx context.Context) (app.DBClient, error)

type PredicateFN

+ func CreateFieldPredicate(predicate *app.Predicate) (PredicateFN, error)

type Tx

+ func (tx *Tx) Migrate(migration *app.Migration, appendEntTables ...*entSchema.Table) (err error)

+ func (tx *Tx) SetDriver(driver dialect.Driver)

+ func (tx *Tx) SetSQLDB(db *sql.DB)

v0.0.4

Apr 5, 2024

v0.0.3

Apr 5, 2024

v0.0.2

Apr 4, 2024

v0.0.1

Apr 3, 2024

Changes in this version

+ var RelMaps = map[schema.RelationType]sqlgraph.Rel

+ func CreateDBDSN(config *db.DBConfig) string

+ func CreateDebugFN(config *db.DBConfig) func(ctx context.Context, i ...any)

+ func CreateEntColumn(f *schema.Field) *entSchema.Column

+ func GetEntDialect(config *db.DBConfig) (string, error)

+ func NOW(dialect string) any

+ func NewClient(config *db.DBConfig, schemaBuilder *schema.Builder) (_ db.Client, err error)

+ func NewDBAdapter(config *db.DBConfig, schemaBuilder *schema.Builder) (db.Client, error)

+ func NewEntClient(config *db.DBConfig, schemaBuilder *schema.Builder, ...) (_ db.Client, err error)

+ type Adapter struct

+ func (d *Adapter) Close() error

+ func (d *Adapter) Commit() error

+ func (d *Adapter) Config() *db.DBConfig

+ func (d *Adapter) CreateDBModel(s *schema.Schema, relations ...*schema.Relation) db.Model

+ func (d *Adapter) CreateModel(s *schema.Schema, relations ...*schema.Relation) *Model

+ func (d *Adapter) DB() *sql.DB

+ func (d *Adapter) Dialect() string

+ func (d *Adapter) Driver() dialect.Driver

+ func (d *Adapter) Exec(ctx context.Context, query string, args, bindValue any) error

+ func (d *Adapter) Hooks() *db.Hooks

+ func (d *Adapter) IsTx() bool

+ func (d *Adapter) Migrate(migration *db.Migration, appendEntTables ...*entSchema.Table) (err error)

+ func (d *Adapter) Model(name string) (db.Model, error)

+ func (d *Adapter) NewEdgeSpec(r *schema.Relation, nodeIDs []driver.Value) (*sqlgraph.EdgeSpec, error)

+ func (d *Adapter) NewEdgeStepOption(r *schema.Relation) (sqlgraph.StepOption, error)

+ func (d *Adapter) Reload(newSchemaBuilder *schema.Builder, migration *db.Migration) (_ db.Client, err error)

+ func (d *Adapter) Rollback() error

+ func (d *Adapter) SchemaBuilder() *schema.Builder

+ func (d *Adapter) Tx(ctx context.Context) (db.Client, error)

+ type Column struct

+ type Model struct

+ func (m *Model) Clone() db.Model

+ func (m *Model) Column(name string) (*Column, error)

+ func (m *Model) Create(e *schema.Entity) (_ uint64, err error)

+ func (m *Model) CreateFromJSON(json string) (_ uint64, err error)

+ func (m *Model) DBColumns() []string

+ func (m *Model) GetEntTable() *entSchema.Table

+ func (m *Model) Mutation(skipTxs ...bool) (db.Mutation, error)

+ func (m *Model) Name() string

+ func (m *Model) Query(predicates ...*db.Predicate) db.Query

+ func (m *Model) Schema() *schema.Schema

+ func (m *Model) SetClient(client db.Client) db.Model

+ type Mutation struct

+ func (m *Mutation) Create(e *schema.Entity) (_ uint64, err error)

+ func (m *Mutation) Delete() (affected int, err error)

+ func (m *Mutation) GetRelationEntityIDs(fieldName string, fieldValue any) ([]driver.Value, error)

+ func (m *Mutation) ProcessFieldAdd(k string, v any) error

+ func (m *Mutation) ProcessFieldClear(k string, v any) error

+ func (m *Mutation) ProcessFieldExpr(k string, v any) error

+ func (m *Mutation) ProcessUpdateBlockAdd(fieldValue any) error

+ func (m *Mutation) ProcessUpdateBlockClear(fieldValue any) error

+ func (m *Mutation) ProcessUpdateBlockExpr(fieldValue any) error

+ func (m *Mutation) ProcessUpdateBlockSet(fieldValue any) error

+ func (m *Mutation) ProcessUpdateFieldSet(k string, v any) error

+ func (m *Mutation) Update(e *schema.Entity) (affected int, err error)

+ func (m *Mutation) Where(predicates ...*db.Predicate) db.Mutation

+ type PredicateFN func(*sql.Selector) *sql.Predicate

+ type Query struct

+ func (q *Query) Count(options *db.CountOption, ctxs ...context.Context) (int, error)

+ func (q *Query) First(ctxs ...context.Context) (*schema.Entity, error)

+ func (q *Query) Get(ctxs ...context.Context) ([]*schema.Entity, error)

+ func (q *Query) Limit(limit uint) db.Query

+ func (q *Query) Offset(offset uint) db.Query

+ func (q *Query) Only(ctxs ...context.Context) (*schema.Entity, error)

+ func (q *Query) Options() *db.QueryOptions

+ func (q *Query) Order(order ...string) db.Query

+ func (q *Query) Select(fields ...string) db.Query

+ func (q *Query) Where(predicates ...*db.Predicate) db.Query

+ type Tx struct

+ func NewTx(ctx context.Context, client db.Client) (*Tx, error)

+ func (tx *Tx) Close() error

+ func (tx *Tx) Commit() error

+ func (tx *Tx) Config() *db.DBConfig

+ func (tx *Tx) CreateDBModel(s *schema.Schema, relations ...*schema.Relation) db.Model

+ func (tx *Tx) DB() *sql.DB

+ func (tx *Tx) Dialect() string

+ func (tx *Tx) Driver() dialect.Driver

+ func (tx *Tx) Exec(ctx context.Context, query string, args any, bindValue any) error

+ func (tx *Tx) Hooks() *db.Hooks

+ func (tx *Tx) IsTx() bool

+ func (tx *Tx) Model(name string) (db.Model, error)

+ func (tx *Tx) NewEdgeSpec(r *schema.Relation, nodeIDs []driver.Value) (*sqlgraph.EdgeSpec, error)

+ func (tx *Tx) NewEdgeStepOption(r *schema.Relation) (sqlgraph.StepOption, error)

+ func (tx *Tx) Reload(newSchemaBuilder *schema.Builder, migration *db.Migration) (db.Client, error)

+ func (tx *Tx) Rollback() error

+ func (tx *Tx) SchemaBuilder() *schema.Builder

+ func (tx *Tx) Tx(ctx context.Context) (t db.Client, err error)

+ type TxDriver struct

+ func (tx *TxDriver) Close() error

+ func (tx *TxDriver) Commit() error

+ func (tx *TxDriver) Dialect() string

+ func (tx *TxDriver) Exec(ctx context.Context, query string, args, v any) error

+ func (tx *TxDriver) ID() string

+ func (tx *TxDriver) Query(ctx context.Context, query string, args, v any) error

+ func (tx *TxDriver) Rollback() error

+ func (tx *TxDriver) Tx(context.Context) (dialect.Tx, error)

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