orm

Documentation

Index

• func AddDatabase(dbServer, dbName, username, password, charSet string, maxConnNum int, ...) (err *cd.Result)
• func DelDatabase(owner string)
• func Initialize()
• func NewConfig(dbServer, dbName, username, password, charSet string) executor.Config
• func NewExecutor(config executor.Config) (executor.Executor, *cd.Result)
• func NewPool() executor.Pool
• func Uninitialized()
• type CountRunner
  • func NewCountRunner(vModel model.Model, executor executor.Executor, provider provider.Provider, ...) *CountRunner
  • func (s *CountRunner) Count(vFilter model.Filter) (ret int64, err *cd.Result)
• type CreateRunner
  • func NewCreateRunner(vModel model.Model, executor executor.Executor, provider provider.Provider, ...) *CreateRunner
  • func (s *CreateRunner) Create() (err *cd.Result)
• type DeleteRunner
  • func NewDeleteRunner(vModel model.Model, executor executor.Executor, provider provider.Provider, ...) *DeleteRunner
  • func (s *DeleteRunner) Delete() (err *cd.Result)
• type DropRunner
  • func NewDropRunner(vModel model.Model, executor executor.Executor, provider provider.Provider, ...) *DropRunner
  • func (s *DropRunner) Drop() (err *cd.Result)
• type InsertRunner
  • func NewInsertRunner(vModel model.Model, executor executor.Executor, provider provider.Provider, ...) *InsertRunner
  • func (s *InsertRunner) Insert() (ret model.Model, err *cd.Result)
• type Orm
  • func GetOrm(provider provider.Provider, prefix string) (ret Orm, err *cd.Result)
  • func NewOrm(provider provider.Provider, cfg executor.Config, prefix string) (Orm, *cd.Result)
• type QueryRunner
  • func NewQueryRunner(vModel model.Model, executor executor.Executor, provider provider.Provider, ...) *QueryRunner
  • func (s *QueryRunner) Query(filter model.Filter) (ret []model.Model, err *cd.Result)
• type UpdateRunner
  • func NewUpdateRunner(vModel model.Model, executor executor.Executor, provider provider.Provider, ...) *UpdateRunner
  • func (s *UpdateRunner) Update() (ret model.Model, err *cd.Result)

Functions

func AddDatabase

func AddDatabase(dbServer, dbName, username, password, charSet string, maxConnNum int, owner string) (err *cd.Result)

func DelDatabase

func DelDatabase(owner string)

func Initialize

func Initialize()

Initialize InitOrm

func NewConfig

func NewConfig(dbServer, dbName, username, password, charSet string) executor.Config

func NewExecutor

func NewExecutor(config executor.Config) (executor.Executor, *cd.Result)

NewExecutor NewExecutor

func NewPool

func NewPool() executor.Pool

NewPool new executor pool

func Uninitialized

func Uninitialized()

Uninitialized orm

Types

type CountRunner

type CountRunner struct {
	// contains filtered or unexported fields
}

func NewCountRunner

func NewCountRunner(
	vModel model.Model,
	executor executor.Executor,
	provider provider.Provider,
	modelCodec codec.Codec) *CountRunner

func (*CountRunner) Count

func (s *CountRunner) Count(vFilter model.Filter) (ret int64, err *cd.Result)

type CreateRunner

type CreateRunner struct {
	// contains filtered or unexported fields
}

func NewCreateRunner

func NewCreateRunner(vModel model.Model, executor executor.Executor, provider provider.Provider, modelCodec codec.Codec) *CreateRunner

func (*CreateRunner) Create

func (s *CreateRunner) Create() (err *cd.Result)

type DeleteRunner

type DeleteRunner struct {
	QueryRunner
	// contains filtered or unexported fields
}

func NewDeleteRunner

func NewDeleteRunner(
	vModel model.Model,
	executor executor.Executor,
	provider provider.Provider,
	modelCodec codec.Codec,
	deepLevel int) *DeleteRunner

func (*DeleteRunner) Delete

func (s *DeleteRunner) Delete() (err *cd.Result)

type DropRunner

type DropRunner struct {
	// contains filtered or unexported fields
}

func NewDropRunner

func NewDropRunner(vModel model.Model, executor executor.Executor, provider provider.Provider, modelCodec codec.Codec) *DropRunner

func (*DropRunner) Drop

func (s *DropRunner) Drop() (err *cd.Result)

type InsertRunner

type InsertRunner struct {
	QueryRunner
	// contains filtered or unexported fields
}

func NewInsertRunner

func NewInsertRunner(
	vModel model.Model,
	executor executor.Executor,
	provider provider.Provider,
	modelCodec codec.Codec) *InsertRunner

func (*InsertRunner) Insert

func (s *InsertRunner) Insert() (ret model.Model, err *cd.Result)

type Orm

type Orm interface {
	Create(entity model.Model) *cd.Result
	Drop(entity model.Model) *cd.Result
	Insert(entity model.Model) (model.Model, *cd.Result)
	Update(entity model.Model) (model.Model, *cd.Result)
	Delete(entity model.Model) (model.Model, *cd.Result)
	Query(entity model.Model) (model.Model, *cd.Result)
	Count(filter model.Filter) (int64, *cd.Result)
	BatchQuery(filter model.Filter) ([]model.Model, *cd.Result)
	BeginTransaction() *cd.Result
	CommitTransaction() *cd.Result
	RollbackTransaction() *cd.Result
	Release()
}

Orm orm interface

func GetOrm

func GetOrm(provider provider.Provider, prefix string) (ret Orm, err *cd.Result)

GetOrm get orm from pool

func NewOrm

func NewOrm(provider provider.Provider, cfg executor.Config, prefix string) (Orm, *cd.Result)

NewOrm create new Orm

type QueryRunner

type QueryRunner struct {
	// contains filtered or unexported fields
}

func NewQueryRunner

func NewQueryRunner(
	vModel model.Model,
	executor executor.Executor,
	provider provider.Provider,
	modelCodec codec.Codec,
	batchFilter bool,
	deepLevel int) *QueryRunner

func (*QueryRunner) Query

func (s *QueryRunner) Query(filter model.Filter) (ret []model.Model, err *cd.Result)

type UpdateRunner

type UpdateRunner struct {
	QueryRunner
	InsertRunner
	DeleteRunner
	// contains filtered or unexported fields
}

func NewUpdateRunner

func NewUpdateRunner(
	vModel model.Model,
	executor executor.Executor,
	provider provider.Provider,
	modelCodec codec.Codec) *UpdateRunner

func (*UpdateRunner) Update

func (s *UpdateRunner) Update() (ret model.Model, err *cd.Result)