diff --git a/src/RocksDb.Extensions/RocksDbAccessor.cs b/src/RocksDb.Extensions/RocksDbAccessor.cs index a8aa34e..52c27ad 100644 --- a/src/RocksDb.Extensions/RocksDbAccessor.cs +++ b/src/RocksDb.Extensions/RocksDbAccessor.cs @@ -352,8 +352,11 @@ public bool HasKey(TKey key) public void Clear() { + var prevColumnFamilyHandle = _columnFamily.Handle; _rocksDbContext.Db.DropColumnFamily(_columnFamily.Name); _columnFamily.Handle = _rocksDbContext.Db.CreateColumnFamily(_rocksDbContext.ColumnFamilyOptions, _columnFamily.Name); + + Native.Instance.rocksdb_column_family_handle_destroy(prevColumnFamilyHandle.Handle); } }