Documentation ¶
Index ¶
- func CreateAndJournalCollection(collection *relation.Relation, crud flux.CRUD, sqlrunner *SQLRunner) error
- func NewNodeCompiler() *nodeCompiler
- func NewRowDeleter(sqlRunner *SQLRunner) *rowDeleter
- func NewRowUpdater(sqlRunner *SQLRunner) *rowUpdater
- func NewSchemaJournalist(crud flux.CRUD) flux.SchemaJournalist
- func NewSchemaManager(sqlRunner *SQLRunner, journalist flux.SchemaJournalist) flux.SchemaManager
- type RowInserter
- type RowQuerier
- type SQLRunner
- type SelectCompiler
- type TableCreator
- type TableDeleter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewNodeCompiler ¶
func NewNodeCompiler() *nodeCompiler
func NewRowDeleter ¶
func NewRowDeleter(sqlRunner *SQLRunner) *rowDeleter
func NewRowUpdater ¶
func NewRowUpdater(sqlRunner *SQLRunner) *rowUpdater
func NewSchemaJournalist ¶
func NewSchemaJournalist(crud flux.CRUD) flux.SchemaJournalist
func NewSchemaManager ¶
func NewSchemaManager(sqlRunner *SQLRunner, journalist flux.SchemaJournalist) flux.SchemaManager
Types ¶
type RowInserter ¶
type RowInserter struct {
// contains filtered or unexported fields
}
func NewRowInserter ¶
func NewRowInserter(sqlRunner *SQLRunner) *RowInserter
type RowQuerier ¶
type RowQuerier struct {
// contains filtered or unexported fields
}
func NewQuerier ¶
func NewQuerier(sqlRunner *SQLRunner, selectCompiler SelectCompiler) *RowQuerier
func (*RowQuerier) Next ¶
func (query *RowQuerier) Next() (*flux.RecordMap, error)
returns nil if there is no records left
func (*RowQuerier) Query ¶
func (query *RowQuerier) Query() error
type SQLRunner ¶
type SQLRunner struct {
// contains filtered or unexported fields
}
func NewSQLRunner ¶
type SelectCompiler ¶
type TableCreator ¶
type TableCreator struct {
// contains filtered or unexported fields
}
func (*TableCreator) Create ¶
func (creator *TableCreator) Create(table string) error
type TableDeleter ¶
type TableDeleter struct {
// contains filtered or unexported fields
}
func (*TableDeleter) Delete ¶
func (deleter *TableDeleter) Delete(table string) error
Click to show internal directories.
Click to hide internal directories.