Clean code
This commit is contained in:
@@ -10,7 +10,6 @@ import Foundation
|
|||||||
import kissdb
|
import kissdb
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
|
||||||
public enum KissDBError: Error {
|
public enum KissDBError: Error {
|
||||||
case general(Int, String)
|
case general(Int, String)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -233,7 +233,7 @@ kiss_bool kiss_db_delete_into(kiss_db_ptr ptr, const void* in_key, kiss_uint in_
|
|||||||
|
|
||||||
kiss_db_item_t item;
|
kiss_db_item_t item;
|
||||||
|
|
||||||
if ((rc = mdb_cursor_get(ptr->cursor, &key, &data, MDB_NEXT_DUP)) == 0) {
|
if ((rc = mdb_cursor_get(ptr->cursor, &key, &data, MDB_SET)) == MDB_SUCCESS) {
|
||||||
do {
|
do {
|
||||||
item.key = key.mv_data;
|
item.key = key.mv_data;
|
||||||
item.key_size = key.mv_size;
|
item.key_size = key.mv_size;
|
||||||
@@ -245,7 +245,7 @@ kiss_bool kiss_db_delete_into(kiss_db_ptr ptr, const void* in_key, kiss_uint in_
|
|||||||
}
|
}
|
||||||
CHECK_RET_ERROR_STMT(mdb_cursor_del(ptr->cursor, 0), false, CLOSE_CURSOR());
|
CHECK_RET_ERROR_STMT(mdb_cursor_del(ptr->cursor, 0), false, CLOSE_CURSOR());
|
||||||
|
|
||||||
} while ((rc = mdb_cursor_get(ptr->cursor, &key, &data, MDB_NEXT_DUP)) == 0);
|
} while ((rc = mdb_cursor_get(ptr->cursor, &key, &data, MDB_NEXT_DUP)) == MDB_SUCCESS);
|
||||||
}
|
}
|
||||||
|
|
||||||
CLOSE_CURSOR();
|
CLOSE_CURSOR();
|
||||||
@@ -308,7 +308,7 @@ kiss_bool kiss_db_select_all(kiss_db_ptr ptr, kiss_select_callback callback, voi
|
|||||||
|
|
||||||
kiss_db_item_t item;
|
kiss_db_item_t item;
|
||||||
|
|
||||||
while ((rc = mdb_cursor_get(ptr->cursor, &key, &data, MDB_NEXT)) == 0) {
|
while ((rc = mdb_cursor_get(ptr->cursor, &key, &data, MDB_NEXT)) == MDB_SUCCESS) {
|
||||||
item.key = key.mv_data;
|
item.key = key.mv_data;
|
||||||
item.key_size = key.mv_size;
|
item.key_size = key.mv_size;
|
||||||
item.data = data.mv_data;
|
item.data = data.mv_data;
|
||||||
|
|||||||
Reference in New Issue
Block a user