@@ -144,7 +144,7 @@ func (w *Worker) checkerr(err error, db *bdb.Db) {
144
144
145
145
func (w * Worker ) bdbSet (req * bdbSetReq ) {
146
146
table , name := bdb .SplitKey (req .key )
147
- db , err := w .getdb (table , bdb .DBTYPE_HASH )
147
+ db , err := w .getdb (table , bdb .DBTYPE_BTREE )
148
148
if err != nil {
149
149
req .resp <- bdbSetResp {err }
150
150
} else {
@@ -173,7 +173,7 @@ func (w *Worker) bdbSetEx(req *bdbSetReq) {
173
173
}
174
174
}
175
175
if w .expireindex == nil {
176
- w .expireindex , err = w .dbenv .GetDb ("__expire.index" , bdb .DBTYPE_HASH )
176
+ w .expireindex , err = w .dbenv .GetDb ("__expire.index" , bdb .DBTYPE_BTREE )
177
177
if err != nil {
178
178
log .Error ("worker|GetDb|%s" , err .Error ())
179
179
req .resp <- bdbSetResp {err }
@@ -206,7 +206,7 @@ func (w *Worker) bdbSetEx(req *bdbSetReq) {
206
206
}
207
207
208
208
table , name := bdb .SplitKey (req .key )
209
- db , err := w .getdb (table , bdb .DBTYPE_HASH )
209
+ db , err := w .getdb (table , bdb .DBTYPE_BTREE )
210
210
if err != nil {
211
211
w .checkerr (err , db )
212
212
req .resp <- bdbSetResp {err }
@@ -230,7 +230,7 @@ func (w *Worker) bdbSetEx(req *bdbSetReq) {
230
230
231
231
func (w * Worker ) bdbGet (req * bdbGetReq ) {
232
232
table , name := bdb .SplitKey (req .key )
233
- db , err := w .getdb (table , bdb .DBTYPE_HASH )
233
+ db , err := w .getdb (table , bdb .DBTYPE_BTREE )
234
234
if err != nil {
235
235
req .resp <- bdbGetResp {nil , err }
236
236
} else {
@@ -250,7 +250,7 @@ func (w *Worker) bdbGet(req *bdbGetReq) {
250
250
251
251
func (w * Worker ) bdbIncrBy (req * bdbIncrByReq ) {
252
252
table , name := bdb .SplitKey (req .key )
253
- db , err := w .getdb (table , bdb .DBTYPE_HASH )
253
+ db , err := w .getdb (table , bdb .DBTYPE_BTREE )
254
254
if err != nil {
255
255
req .resp <- bdbIncrByResp {0 , err }
256
256
} else {
0 commit comments