proxy

type DB interface {
	DBReader
	DBWriter
}

type DBCounter interface {
	Count(view reform.View, tail string, args ...interface{}) (int, error)
}

type DBDeleter interface {
	Delete(record reform.Record) error
	DeleteFrom(view reform.View, tail string, args ...interface{}) (uint, error)
}

type DBFinder interface {
	FindOneTo(str reform.Struct, column string, arg interface{}) error
	FindOneFrom(view reform.View, column string, arg interface{}) (reform.Struct, error)
	FindRows(view reform.View, column string, arg interface{}) (*sql.Rows, error)
	FindAllFrom(view reform.View, column string, args ...interface{}) ([]reform.Struct, error)
	FindByPrimaryKeyTo(record reform.Record, pk interface{}) error
	FindByPrimaryKeyFrom(table reform.Table, pk interface{}) (reform.Record, error)
}

type DBInserter interface {
	Insert(str reform.Struct) error
	InsertColumns(str reform.Struct, columns ...string) error
	InsertMulti(structs ...reform.Struct) error
}

type DBReader interface {
	DBSelector
	DBFinder
	DBCounter
}

type DBSaver interface {
	Save(record reform.Record) error
}

type DBSelector interface {
	SelectOneTo(str reform.Struct, tail string, args ...interface{}) error
	SelectOneFrom(view reform.View, tail string, args ...interface{}) (reform.Struct, error)
	SelectRows(view reform.View, tail string, args ...interface{}) (*sql.Rows, error)
	SelectAllFrom(view reform.View, tail string, args ...interface{}) ([]reform.Struct, error)
}

type DBUpdater interface {
	Update(record reform.Record) error
	UpdateColumns(record reform.Record, columns ...string) error
	UpdateView(str reform.Struct, columns []string, tail string, args ...interface{}) (uint, error)
}

type DBWriter interface {
	DBInserter
	DBUpdater
	DBSaver
	DBDeleter
}

type Proxy interface {
	DB

	// Primary returns primary database node.
	Primary() DB

	// Secondaries returns list of all secondary database nodes.
	Secondaries() []DB

	// Secondary returns the next secondary node.
	Secondary() DB
}