Documentation
¶
Index ¶
- func ConvTupleListToValues(schema_ *schema.Schema, result []*tuple.Tuple) [][]*types.Value
- func ConvValueListToIFs(vals [][]*types.Value) [][]interface{}
- func PrintExecuteResults(results [][]*types.Value)
- func ReconstructAllIndexData(c *catalog.Catalog, dman disk.DiskManager, txn *access.Transaction)
- type SamehadaDB
- type SamehadaInstance
- func (si *SamehadaInstance) CloseFilesForTesting()
- func (si *SamehadaInstance) GetBufferPoolManager() *buffer.BufferPoolManager
- func (si *SamehadaInstance) GetCheckpointManager() *concurrency.CheckpointManager
- func (si *SamehadaInstance) GetDiskManager() disk.DiskManager
- func (si *SamehadaInstance) GetLockManager() *access.LockManager
- func (si *SamehadaInstance) GetLogManager() *recovery.LogManager
- func (si *SamehadaInstance) GetTransactionManager() *access.TransactionManager
- func (si *SamehadaInstance) Shutdown(IsRemoveFiles bool)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvTupleListToValues ¶
func ConvValueListToIFs ¶ added in v0.0.2
func PrintExecuteResults ¶
func ReconstructAllIndexData ¶ added in v0.0.2
func ReconstructAllIndexData(c *catalog.Catalog, dman disk.DiskManager, txn *access.Transaction)
Types ¶
type SamehadaDB ¶
type SamehadaDB struct {
// contains filtered or unexported fields
}
func NewSamehadaDB ¶
func NewSamehadaDB(dbName string, memKBytes int) *SamehadaDB
func (*SamehadaDB) ExecuteSQL ¶
func (sdb *SamehadaDB) ExecuteSQL(sqlStr string) (error, [][]interface{})
func (*SamehadaDB) ExecuteSQLRetValues ¶ added in v0.0.2
func (sdb *SamehadaDB) ExecuteSQLRetValues(sqlStr string) (error, [][]*types.Value)
func (*SamehadaDB) ForceCheckpointingForTestcase ¶ added in v0.0.5
func (sdb *SamehadaDB) ForceCheckpointingForTestcase()
func (*SamehadaDB) Shutdown ¶ added in v0.0.2
func (sdb *SamehadaDB) Shutdown()
func (*SamehadaDB) ShutdownForTescase ¶ added in v0.0.5
func (sdb *SamehadaDB) ShutdownForTescase()
type SamehadaInstance ¶
type SamehadaInstance struct {
// contains filtered or unexported fields
}
func NewSamehadaInstance ¶
func NewSamehadaInstance(dbName string, bpoolSize int) *SamehadaInstance
reset program state except for variables on testcase function and db/log file bpoolSize: usable buffer size in frame(=page) num
func NewSamehadaInstanceForTesting ¶
func NewSamehadaInstanceForTesting() *SamehadaInstance
func (*SamehadaInstance) CloseFilesForTesting ¶ added in v0.0.2
func (si *SamehadaInstance) CloseFilesForTesting()
for testing. this method does file closing only in contrast to Shutdown method
func (*SamehadaInstance) GetBufferPoolManager ¶
func (si *SamehadaInstance) GetBufferPoolManager() *buffer.BufferPoolManager
func (*SamehadaInstance) GetCheckpointManager ¶
func (si *SamehadaInstance) GetCheckpointManager() *concurrency.CheckpointManager
func (*SamehadaInstance) GetDiskManager ¶
func (si *SamehadaInstance) GetDiskManager() disk.DiskManager
func (*SamehadaInstance) GetLockManager ¶
func (si *SamehadaInstance) GetLockManager() *access.LockManager
func (*SamehadaInstance) GetLogManager ¶
func (si *SamehadaInstance) GetLogManager() *recovery.LogManager
func (*SamehadaInstance) GetTransactionManager ¶
func (si *SamehadaInstance) GetTransactionManager() *access.TransactionManager
func (*SamehadaInstance) Shutdown ¶ added in v0.0.2
func (si *SamehadaInstance) Shutdown(IsRemoveFiles bool)
functionality is Flushing dirty pages, shutdown of DiskManager and action around DB/Log files
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.