Fix delete
parent
4c704f078d
commit
59116761f5
|
@ -132,13 +132,7 @@ func (db MDB) Get(key []byte) ([]byte, error) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db MDB) Del(start, finish []byte) error {
|
func (db MDB) Del(start, finish []byte) error {
|
||||||
tx, err := db.env.BeginTxn(nil, 0)
|
itr := db.iterator(false)
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
defer tx.Commit()
|
|
||||||
|
|
||||||
itr := db.iterator(true)
|
|
||||||
defer itr.Close()
|
defer itr.Close()
|
||||||
|
|
||||||
count := 0
|
count := 0
|
||||||
|
@ -148,9 +142,7 @@ func (db MDB) Del(start, finish []byte) error {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
||||||
// TODO: We should be using one cursor instead of two
|
err := itr.c.Del(0)
|
||||||
// transactions, but deleting using a cursor, crashes
|
|
||||||
err = tx.Del(db.db, itr.key, nil)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue