170 lines
		
	
	
		
			3.2 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			170 lines
		
	
	
		
			3.2 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| package store
 | |
| 
 | |
| import (
 | |
| 	"sync"
 | |
| 	"time"
 | |
| 
 | |
| 	"github.com/siddontang/ledisdb/config"
 | |
| 	"github.com/siddontang/ledisdb/store/driver"
 | |
| )
 | |
| 
 | |
| type DB struct {
 | |
| 	db   driver.IDB
 | |
| 	name string
 | |
| 
 | |
| 	st *Stat
 | |
| 
 | |
| 	cfg *config.Config
 | |
| 
 | |
| 	lastCommit time.Time
 | |
| 
 | |
| 	m sync.Mutex
 | |
| }
 | |
| 
 | |
| func (db *DB) Close() error {
 | |
| 	return db.db.Close()
 | |
| }
 | |
| 
 | |
| func (db *DB) String() string {
 | |
| 	return db.name
 | |
| }
 | |
| 
 | |
| func (db *DB) NewIterator() *Iterator {
 | |
| 	db.st.IterNum.Add(1)
 | |
| 
 | |
| 	it := new(Iterator)
 | |
| 	it.it = db.db.NewIterator()
 | |
| 	it.st = db.st
 | |
| 
 | |
| 	return it
 | |
| }
 | |
| 
 | |
| func (db *DB) Get(key []byte) ([]byte, error) {
 | |
| 	t := time.Now()
 | |
| 	v, err := db.db.Get(key)
 | |
| 	db.st.statGet(v, err)
 | |
| 	db.st.GetTotalTime.Add(time.Now().Sub(t))
 | |
| 	return v, err
 | |
| }
 | |
| 
 | |
| func (db *DB) Put(key []byte, value []byte) error {
 | |
| 	db.st.PutNum.Add(1)
 | |
| 
 | |
| 	if db.needSyncCommit() {
 | |
| 		return db.db.SyncPut(key, value)
 | |
| 
 | |
| 	} else {
 | |
| 		return db.db.Put(key, value)
 | |
| 
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (db *DB) Delete(key []byte) error {
 | |
| 	db.st.DeleteNum.Add(1)
 | |
| 
 | |
| 	if db.needSyncCommit() {
 | |
| 		return db.db.SyncDelete(key)
 | |
| 	} else {
 | |
| 		return db.db.Delete(key)
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (db *DB) NewWriteBatch() *WriteBatch {
 | |
| 	db.st.BatchNum.Add(1)
 | |
| 	wb := new(WriteBatch)
 | |
| 	wb.wb = db.db.NewWriteBatch()
 | |
| 	wb.st = db.st
 | |
| 	wb.db = db
 | |
| 	return wb
 | |
| }
 | |
| 
 | |
| func (db *DB) NewSnapshot() (*Snapshot, error) {
 | |
| 	db.st.SnapshotNum.Add(1)
 | |
| 
 | |
| 	var err error
 | |
| 	s := &Snapshot{}
 | |
| 	if s.ISnapshot, err = db.db.NewSnapshot(); err != nil {
 | |
| 		return nil, err
 | |
| 	}
 | |
| 	s.st = db.st
 | |
| 
 | |
| 	return s, nil
 | |
| }
 | |
| 
 | |
| func (db *DB) Compact() error {
 | |
| 	db.st.CompactNum.Add(1)
 | |
| 
 | |
| 	t := time.Now()
 | |
| 	err := db.db.Compact()
 | |
| 
 | |
| 	db.st.CompactTotalTime.Add(time.Now().Sub(t))
 | |
| 
 | |
| 	return err
 | |
| }
 | |
| 
 | |
| func (db *DB) RangeIterator(min []byte, max []byte, rangeType uint8) *RangeLimitIterator {
 | |
| 	return NewRangeLimitIterator(db.NewIterator(), &Range{min, max, rangeType}, &Limit{0, -1})
 | |
| }
 | |
| 
 | |
| func (db *DB) RevRangeIterator(min []byte, max []byte, rangeType uint8) *RangeLimitIterator {
 | |
| 	return NewRevRangeLimitIterator(db.NewIterator(), &Range{min, max, rangeType}, &Limit{0, -1})
 | |
| }
 | |
| 
 | |
| //count < 0, unlimit.
 | |
| //
 | |
| //offset must >= 0, if < 0, will get nothing.
 | |
| func (db *DB) RangeLimitIterator(min []byte, max []byte, rangeType uint8, offset int, count int) *RangeLimitIterator {
 | |
| 	return NewRangeLimitIterator(db.NewIterator(), &Range{min, max, rangeType}, &Limit{offset, count})
 | |
| }
 | |
| 
 | |
| //count < 0, unlimit.
 | |
| //
 | |
| //offset must >= 0, if < 0, will get nothing.
 | |
| func (db *DB) RevRangeLimitIterator(min []byte, max []byte, rangeType uint8, offset int, count int) *RangeLimitIterator {
 | |
| 	return NewRevRangeLimitIterator(db.NewIterator(), &Range{min, max, rangeType}, &Limit{offset, count})
 | |
| }
 | |
| 
 | |
| func (db *DB) Stat() *Stat {
 | |
| 	return db.st
 | |
| }
 | |
| 
 | |
| func (db *DB) needSyncCommit() bool {
 | |
| 	if db.cfg.DBSyncCommit == 0 {
 | |
| 		return false
 | |
| 	} else if db.cfg.DBSyncCommit == 2 {
 | |
| 		return true
 | |
| 	} else {
 | |
| 		n := time.Now()
 | |
| 		need := false
 | |
| 		db.m.Lock()
 | |
| 
 | |
| 		if n.Sub(db.lastCommit) > time.Second {
 | |
| 			need = true
 | |
| 		}
 | |
| 		db.lastCommit = n
 | |
| 
 | |
| 		db.m.Unlock()
 | |
| 		return need
 | |
| 	}
 | |
| 
 | |
| }
 | |
| 
 | |
| func (db *DB) GetSlice(key []byte) (Slice, error) {
 | |
| 	if d, ok := db.db.(driver.ISliceGeter); ok {
 | |
| 		t := time.Now()
 | |
| 		v, err := d.GetSlice(key)
 | |
| 		db.st.statGet(v, err)
 | |
| 		db.st.GetTotalTime.Add(time.Now().Sub(t))
 | |
| 		return v, err
 | |
| 	} else {
 | |
| 		v, err := db.Get(key)
 | |
| 		if err != nil {
 | |
| 			return nil, err
 | |
| 		} else if v == nil {
 | |
| 			return nil, nil
 | |
| 		} else {
 | |
| 			return driver.GoSlice(v), nil
 | |
| 		}
 | |
| 	}
 | |
| }
 |