abstract_sql

Documentation

Index

• Constants
• func GenDirAndName(key []byte) (dirStr string, dirHash int64, name string)
• type AbstractSqlStore
  • func (store *AbstractSqlStore) BeginTransaction(ctx context.Context) (context.Context, error)
  • func (store *AbstractSqlStore) CanDropWholeBucket() bool
  • func (store *AbstractSqlStore) CommitTransaction(ctx context.Context) error
  • func (store *AbstractSqlStore) CreateTable(ctx context.Context, bucket string) 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, dirPath util.FullPath, startFileName string, ...) (lastFileName string, err error)
  • func (store *AbstractSqlStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPath util.FullPath, startFileName string, ...) (lastFileName string, err error)
  • func (store *AbstractSqlStore) OnBucketCreation(bucket string)
  • func (store *AbstractSqlStore) OnBucketDeletion(bucket string)
  • 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 SqlGenerator
• type TxOrDB

Constants

const (
	DEFAULT_TABLE = "filemeta"
)

Functions

func GenDirAndName

func GenDirAndName(key []byte) (dirStr string, dirHash int64, name string)

Types

type AbstractSqlStore

type AbstractSqlStore struct {
	SqlGenerator
	DB                 *sql.DB
	SupportBucketTable bool
	// contains filtered or unexported fields
}

func (*AbstractSqlStore) BeginTransaction

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

func (*AbstractSqlStore) CanDropWholeBucket

func (store *AbstractSqlStore) CanDropWholeBucket() bool

func (*AbstractSqlStore) CommitTransaction

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

func (*AbstractSqlStore) CreateTable

func (store *AbstractSqlStore) CreateTable(ctx context.Context, bucket string) 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, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error)

func (*AbstractSqlStore) ListDirectoryPrefixedEntries

func (store *AbstractSqlStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, prefix string, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error)

func (*AbstractSqlStore) OnBucketCreation

func (store *AbstractSqlStore) OnBucketCreation(bucket string)

func (*AbstractSqlStore) OnBucketDeletion

func (store *AbstractSqlStore) OnBucketDeletion(bucket string)

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 SqlGenerator

type SqlGenerator interface {
	GetSqlInsert(tableName string) string
	GetSqlUpdate(tableName string) string
	GetSqlFind(tableName string) string
	GetSqlDelete(tableName string) string
	GetSqlDeleteFolderChildren(tableName string) string
	GetSqlListExclusive(tableName string) string
	GetSqlListInclusive(tableName string) string
	GetSqlCreateTable(tableName string) string
	GetSqlDropTable(tableName string) string
}

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)
}