postgres

Documentation

Index

• type PostgresAdapter
  • func NewPostgresAdapter(collectionPrefix string, db *sql.DB) *PostgresAdapter
  • func (p *PostgresAdapter) AddFieldIfNotExists(className, fieldName string, fieldType types.M) error
  • func (p *PostgresAdapter) ClassExists(name string) bool
  • func (p *PostgresAdapter) Count(className string, schema, query types.M) (int, error)
  • func (p *PostgresAdapter) CreateClass(className string, schema types.M) (types.M, error)
  • func (p *PostgresAdapter) CreateObject(className string, schema, object types.M) error
  • func (p *PostgresAdapter) DeleteAllClasses() error
  • func (p *PostgresAdapter) DeleteClass(className string) (types.M, error)
  • func (p *PostgresAdapter) DeleteFields(className string, schema types.M, fieldNames []string) error
  • func (p *PostgresAdapter) DeleteObjectsByQuery(className string, schema, query types.M) error
  • func (p *PostgresAdapter) EnsureUniqueness(className string, schema types.M, fieldNames []string) error
  • func (p *PostgresAdapter) Find(className string, schema, query, options types.M) ([]types.M, error)
  • func (p *PostgresAdapter) FindOneAndUpdate(className string, schema, query, update types.M) (types.M, error)
  • func (p *PostgresAdapter) GetAllClasses() ([]types.M, error)
  • func (p *PostgresAdapter) GetClass(className string) (types.M, error)
  • func (p *PostgresAdapter) HandleShutdown()
  • func (p *PostgresAdapter) PerformInitialization(options types.M) error
  • func (p *PostgresAdapter) SetClassLevelPermissions(className string, CLPs types.M) error
  • func (p *PostgresAdapter) UpdateObjectsByQuery(className string, schema, query, update types.M) error
  • func (p *PostgresAdapter) UpsertOneObject(className string, schema, query, update types.M) error

Types

type PostgresAdapter

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

PostgresAdapter postgres 数据库适配器

func NewPostgresAdapter

func NewPostgresAdapter(collectionPrefix string, db *sql.DB) *PostgresAdapter

NewPostgresAdapter ...

func (*PostgresAdapter) AddFieldIfNotExists

func (p *PostgresAdapter) AddFieldIfNotExists(className, fieldName string, fieldType types.M) error

AddFieldIfNotExists 添加字段定义

func (*PostgresAdapter) ClassExists

func (p *PostgresAdapter) ClassExists(name string) bool

ClassExists 检测数据库中是否存在指定类

func (*PostgresAdapter) Count

func (p *PostgresAdapter) Count(className string, schema, query types.M) (int, error)

Count ...

func (*PostgresAdapter) CreateClass

func (p *PostgresAdapter) CreateClass(className string, schema types.M) (types.M, error)

CreateClass 创建类

func (*PostgresAdapter) CreateObject

func (p *PostgresAdapter) CreateObject(className string, schema, object types.M) error

CreateObject 创建对象

func (*PostgresAdapter) DeleteAllClasses

func (p *PostgresAdapter) DeleteAllClasses() error

DeleteAllClasses 删除所有表，仅用于测试

func (*PostgresAdapter) DeleteClass

func (p *PostgresAdapter) DeleteClass(className string) (types.M, error)

DeleteClass 删除指定表

func (*PostgresAdapter) DeleteFields

func (p *PostgresAdapter) DeleteFields(className string, schema types.M, fieldNames []string) error

DeleteFields 删除字段

func (*PostgresAdapter) DeleteObjectsByQuery

func (p *PostgresAdapter) DeleteObjectsByQuery(className string, schema, query types.M) error

DeleteObjectsByQuery 删除符合条件的所有对象

func (*PostgresAdapter) EnsureUniqueness

func (p *PostgresAdapter) EnsureUniqueness(className string, schema types.M, fieldNames []string) error

EnsureUniqueness 创建索引

func (*PostgresAdapter) Find

func (p *PostgresAdapter) Find(className string, schema, query, options types.M) ([]types.M, error)

Find ...

func (*PostgresAdapter) FindOneAndUpdate

func (p *PostgresAdapter) FindOneAndUpdate(className string, schema, query, update types.M) (types.M, error)

FindOneAndUpdate ...

func (*PostgresAdapter) GetAllClasses

func (p *PostgresAdapter) GetAllClasses() ([]types.M, error)

GetAllClasses ...

func (*PostgresAdapter) GetClass

func (p *PostgresAdapter) GetClass(className string) (types.M, error)

GetClass ...

func (*PostgresAdapter) HandleShutdown

func (p *PostgresAdapter) HandleShutdown()

HandleShutdown 关闭数据库

func (*PostgresAdapter) PerformInitialization

func (p *PostgresAdapter) PerformInitialization(options types.M) error

PerformInitialization ...

func (*PostgresAdapter) SetClassLevelPermissions

func (p *PostgresAdapter) SetClassLevelPermissions(className string, CLPs types.M) error

SetClassLevelPermissions 设置类级别权限

func (*PostgresAdapter) UpdateObjectsByQuery

func (p *PostgresAdapter) UpdateObjectsByQuery(className string, schema, query, update types.M) error

UpdateObjectsByQuery ...

func (*PostgresAdapter) UpsertOneObject

func (p *PostgresAdapter) UpsertOneObject(className string, schema, query, update types.M) error

UpsertOneObject 仅用于 config 和 hooks