genji

Jan 1, 2020

Changes in this version

type DB

+ DB *database.Database

+ func (db *DB) QueryDocument(q string, args ...interface{}) (document.Document, error)

type Tx

+ func (tx *Tx) QueryDocument(q string, args ...interface{}) (document.Document, error)

Nov 23, 2019

Changes in this version

type DB

+ func (db *DB) QueryRecord(q string, args ...interface{}) (record.Record, error)

+ func (db *DB) SQLDB() *sql.DB

+ type TableConfig struct

+ PrimaryKeyName string

+ PrimaryKeyType value.Type

type Tx

+ func (tx *Tx) QueryRecord(q string, args ...interface{}) (record.Record, error)

+ func (tx Tx) ListTables() ([]string, error)

+ func (tx Tx) ReIndex(indexName string) error

+ func (tx Tx) ReIndexAll() error

Oct 19, 2019

Changes in this version

+ var ErrDuplicateRecord = errors.New("duplicate record")

+ var ErrRecordNotFound = errors.New("record not found")

+ var ErrResultClosed = errors.New("result already closed")

+ func Open(ng engine.Engine) (*sql.DB, error)

+ func OpenDB(db *DB) (*sql.DB, error)

type DB

+ func (db DB) Exec(q string, args ...interface{}) error

+ func (db DB) Query(q string, args ...interface{}) (*Result, error)

+ type Index struct

+ FieldName string

+ IndexName string

+ TableName string

+ Unique bool

+ type ParseError struct

+ Expected []string

+ Found string

+ Message string

+ Pos scanner.Pos

+ func (e *ParseError) Error() string

+ type PrimaryKeyer interface

+ PrimaryKey func() ([]byte, error)

+ type Result struct

+ func (r *Result) Close() error

+ func (r Result) LastInsertId() (int64, error)

+ func (r Result) LastInsertKey() ([]byte, error)

+ func (r Result) RowsAffected() (int64, error)

type Tx

+ func (tx *Tx) Exec(q string, args ...interface{}) error

+ func (tx *Tx) Promote() error

+ func (tx *Tx) Query(q string, args ...interface{}) (*Result, error)

+ func (tx *Tx) Writable() bool

+ func (tx Tx) GetIndex(name string) (*Index, error)

Sep 20, 2019

Changes in this version

type Table

+ func (t Table) CreateIndex(field string, opts index.Options) (index.Index, error)

+ func (t Table) CreateIndexIfNotExists(field string, opts index.Options) (index.Index, error)

+ func (t Table) CreateIndexesIfNotExist(indexes map[string]index.Options) error

+ func (t Table) DropIndex(field string) error

+ func (t Table) GetIndex(field string) (index.Index, error)

+ func (t Table) GetRecord(recordID []byte) (record.Record, error)

+ func (t Table) Indexes() (map[string]index.Index, error)

type Tx

+ func (tx Tx) GetTable(name string) (*Table, error)

+ func (tx Tx) InitTable(name string, r record.Record) (*Table, error)

Aug 11, 2019

Changes in this version

+ var ErrIndexAlreadyExists = errors.New("index already exists")

+ var ErrIndexNotFound = errors.New("index not found")

+ var ErrTableAlreadyExists = errors.New("table already exists")

+ var ErrTableNotFound = errors.New("table not found")

+ func InitTable(tx *Tx, tn TableNamer) error

+ type DB struct

+ func New(ng engine.Engine) (*DB, error)

+ func (db DB) Begin(writable bool) (*Tx, error)

+ func (db DB) Close() error

+ func (db DB) Update(fn func(tx *Tx) error) error

+ func (db DB) UpdateTable(tableName string, fn func(*Table) error) error

+ func (db DB) View(fn func(tx *Tx) error) error

+ func (db DB) ViewTable(tableName string, fn func(*Table) error) error

+ type Table struct

+ func (t Table) AddField(f field.Field) error

+ func (t Table) Delete(recordID []byte) error

+ func (t Table) DeleteField(name string) error

+ func (t Table) Insert(r record.Record) ([]byte, error)

+ func (t Table) Iterate(fn func(recordID []byte, r record.Record) error) error

+ func (t Table) ReIndex(fieldName string) error

+ func (t Table) Record(recordID []byte) (record.Record, error)

+ func (t Table) RenameField(oldName, newName string) error

+ func (t Table) Replace(recordID []byte, r record.Record) error

+ func (t Table) SelectTable(*Tx) (*Table, error)

+ func (t Table) TableName() string

+ func (t Table) Truncate() error

+ type TableNamer interface

+ TableName func() string

+ type Tx struct

+ func (tx Tx) Commit() error

+ func (tx Tx) CreateIndex(tableName, field string, opts index.Options) error

+ func (tx Tx) CreateIndexIfNotExists(table string, field string, opts index.Options) error

+ func (tx Tx) CreateTable(name string) error

+ func (tx Tx) CreateTableIfNotExists(name string) error

+ func (tx Tx) DropIndex(tableName, field string) error

+ func (tx Tx) DropTable(name string) error

+ func (tx Tx) Index(tableName, field string) (index.Index, error)

+ func (tx Tx) Indexes(tableName string) (map[string]index.Index, error)

+ func (tx Tx) Rollback() error

+ func (tx Tx) Table(name string) (*Table, error)