crud

Dec 29, 2019

Changes in this version

type Crud

+ CreateProjectIfNotExist func(ctx context.Context, project string) error

type Module

+ func (m *Module) GetDBType(dbAlias string) (string, error)

Nov 4, 2019

Changes in this version

type Crud

+ DeleteCollection func(ctx context.Context, project, col string) error

+ GetConnectionState func(ctx context.Context, dbType string) bool

type Module

+ func (m *Module) DeleteTable(ctx context.Context, project, dbType, col string) error

+ func (m *Module) GetConnectionState(ctx context.Context, dbType string) bool

Sep 29, 2019

Changes in this version

type Crud

+ DescribeTable func(ctc context.Context, project, dbType, col string) ([]utils.FieldType, []utils.ForeignKeysType, error)

+ GetCollections func(ctx context.Context, project string) ([]utils.DatabaseCollections, error)

+ IsClientSafe func() error

+ RawBatch func(ctx context.Context, batchedQueries []string) error

+ RawExec func(ctx context.Context, project string) error

type Module

+ func (m *Module) CreateProjectIfNotExists(ctx context.Context, project, dbType string) error

+ func (m *Module) DescribeTable(ctx context.Context, dbType, project, col string) ([]utils.FieldType, []utils.ForeignKeysType, error)

+ func (m *Module) GetCollections(ctx context.Context, project, dbType string) ([]utils.DatabaseCollections, error)

+ func (m *Module) InternalCreate(ctx context.Context, dbType, project, col string, req *model.CreateRequest) error

+ func (m *Module) InternalDelete(ctx context.Context, dbType, project, col string, req *model.DeleteRequest) error

+ func (m *Module) InternalUpdate(ctx context.Context, dbType, project, col string, req *model.UpdateRequest) error

+ func (m *Module) RawBatch(ctx context.Context, dbType string, batchedQueries []string) error

+ func (m *Module) SetHooks(hooks *model.CrudHooks)

Jun 21, 2019

Changes in this version

+ type Crud interface

+ Aggregate func(ctx context.Context, project, col string, req *model.AggregateRequest) (interface{}, error)

+ Batch func(ctx context.Context, project string, req *model.BatchRequest) error

+ Close func() error

+ Create func(ctx context.Context, project, col string, req *model.CreateRequest) error

+ Delete func(ctx context.Context, project, col string, req *model.DeleteRequest) error

+ GetDBType func() utils.DBType

+ Read func(ctx context.Context, project, col string, req *model.ReadRequest) (interface{}, error)

+ Update func(ctx context.Context, project, col string, req *model.UpdateRequest) error

+ type Module struct

+ func Init() *Module

+ func (m *Module) Aggregate(ctx context.Context, dbType, project, col string, req *model.AggregateRequest) (interface{}, error)

+ func (m *Module) Batch(ctx context.Context, dbType, project string, req *model.BatchRequest) error

+ func (m *Module) Create(ctx context.Context, dbType, project, col string, req *model.CreateRequest) error

+ func (m *Module) Delete(ctx context.Context, dbType, project, col string, req *model.DeleteRequest) error

+ func (m *Module) GetPrimaryDB() (Crud, error)

+ func (m *Module) Read(ctx context.Context, dbType, project, col string, req *model.ReadRequest) (interface{}, error)

+ func (m *Module) SetConfig(crud config.Crud) error

+ func (m *Module) Update(ctx context.Context, dbType, project, col string, req *model.UpdateRequest) error