abstract_sql

Documentation

Index

• type AbstractSqlStore
  • func (store *AbstractSqlStore) BeginTransaction(ctx context.Context) (context.Context, error)
  • func (store *AbstractSqlStore) CommitTransaction(ctx context.Context) error
  • func (store *AbstractSqlStore) DeleteEntry(ctx context.Context, fullpath util.FullPath) error
  • func (store *AbstractSqlStore) DeleteFolderChildren(ctx context.Context, fullpath util.FullPath) error
  • func (store *AbstractSqlStore) FindEntry(ctx context.Context, fullpath util.FullPath) (*filer.Entry, error)
  • func (store *AbstractSqlStore) InsertEntry(ctx context.Context, entry *filer.Entry) (err error)
  • func (store *AbstractSqlStore) KvDelete(ctx context.Context, key []byte) (err error)
  • func (store *AbstractSqlStore) KvGet(ctx context.Context, key []byte) (value []byte, err error)
  • func (store *AbstractSqlStore) KvPut(ctx context.Context, key []byte, value []byte) (err error)
  • func (store *AbstractSqlStore) ListDirectoryEntries(ctx context.Context, fullpath util.FullPath, startFileName string, ...) (entries []*filer.Entry, err error)
  • func (store *AbstractSqlStore) ListDirectoryPrefixedEntries(ctx context.Context, fullpath util.FullPath, startFileName string, ...) (entries []*filer.Entry, err error)
  • func (store *AbstractSqlStore) RollbackTransaction(ctx context.Context) error
  • func (store *AbstractSqlStore) Shutdown()
  • func (store *AbstractSqlStore) UpdateEntry(ctx context.Context, entry *filer.Entry) (err error)
• type TxOrDB

Types

type AbstractSqlStore

type AbstractSqlStore struct {
	DB                      *sql.DB
	SqlInsert               string
	SqlUpdate               string
	SqlFind                 string
	SqlDelete               string
	SqlDeleteFolderChildren string
	SqlListExclusive        string
	SqlListInclusive        string
}

func (*AbstractSqlStore) BeginTransaction

func (store *AbstractSqlStore) BeginTransaction(ctx context.Context) (context.Context, error)

func (*AbstractSqlStore) CommitTransaction

func (store *AbstractSqlStore) CommitTransaction(ctx context.Context) error

func (*AbstractSqlStore) DeleteEntry

func (store *AbstractSqlStore) DeleteEntry(ctx context.Context, fullpath util.FullPath) error

func (*AbstractSqlStore) DeleteFolderChildren

func (store *AbstractSqlStore) DeleteFolderChildren(ctx context.Context, fullpath util.FullPath) error

func (*AbstractSqlStore) FindEntry

func (store *AbstractSqlStore) FindEntry(ctx context.Context, fullpath util.FullPath) (*filer.Entry, error)

func (*AbstractSqlStore) InsertEntry

func (store *AbstractSqlStore) InsertEntry(ctx context.Context, entry *filer.Entry) (err error)

func (*AbstractSqlStore) KvDelete

func (store *AbstractSqlStore) KvDelete(ctx context.Context, key []byte) (err error)

func (*AbstractSqlStore) KvGet

func (store *AbstractSqlStore) KvGet(ctx context.Context, key []byte) (value []byte, err error)

func (*AbstractSqlStore) KvPut

func (store *AbstractSqlStore) KvPut(ctx context.Context, key []byte, value []byte) (err error)

func (*AbstractSqlStore) ListDirectoryEntries

func (store *AbstractSqlStore) ListDirectoryEntries(ctx context.Context, fullpath util.FullPath, startFileName string, inclusive bool, limit int) (entries []*filer.Entry, err error)

func (*AbstractSqlStore) ListDirectoryPrefixedEntries

func (store *AbstractSqlStore) ListDirectoryPrefixedEntries(ctx context.Context, fullpath util.FullPath, startFileName string, inclusive bool, limit int, prefix string) (entries []*filer.Entry, err error)

func (*AbstractSqlStore) RollbackTransaction

func (store *AbstractSqlStore) RollbackTransaction(ctx context.Context) error

func (*AbstractSqlStore) Shutdown

func (store *AbstractSqlStore) Shutdown()

func (*AbstractSqlStore) UpdateEntry

func (store *AbstractSqlStore) UpdateEntry(ctx context.Context, entry *filer.Entry) (err error)

type TxOrDB

type TxOrDB interface {
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
}