RocksDb.Net 11.0.4.1

RocksDb.Net

A modern C# wrapper for RocksDB, the high-performance embedded key-value store developed by Meta. Built on .NET's LibraryImport source generator with zero-copy spans and deterministic disposal.

Features

• Full RocksDB C API coverage — 1,000+ auto-generated P/Invoke bindings from the official rocksdb/c.h header
• Modern .NET — targets .NET 10, uses LibraryImport, ReadOnlySpan<byte>, and ref struct iterators
• Idiomatic C# API — IDisposable handles, properties, string overloads, LINQ-compatible iterators
• Column families — create, drop, and operate on multiple column families
• Merge operators — built-in UInt64Add and custom merge operator support
• Compaction filters — filter or transform key-value pairs during compaction
• Transactions — WriteBatch and WriteBatchWithIndex for atomic multi-key operations
• Backups & checkpoints — BackupEngine and Checkpoint for point-in-time snapshots
• SST file ingestion — bulk-load data with SstFileWriter
• Bloom/Ribbon filters — configurable filter policies for point lookups
• Event listeners — observe flush, compaction, and background error events
• Cross-platform — ships native binaries via the RocksDb.Net.Runtimes package

Requirements

• .NET 10 SDK (or later)
• RocksDB native binaries (provided by the RocksDb.Net.Runtimes NuGet package)

Quick Start

Install

dotnet add package RocksDb.Net

Basic Usage

using RocksDbNet;

using var options = new DbOptions { CreateIfMissing = true };
using var db = RocksDb.Open(options, "mydb");

// Write
db.Put("hello", "world");

// Read
string? value = db.GetString("hello");
Console.WriteLine(value); // "world"

// Delete
db.Delete("hello");

Iteration

using var iterator = db.NewIterator();
iterator.SeekToFirst();

foreach (var entry in iterator)
{
    Console.WriteLine($"{entry.CurrentKey} = {entry.CurrentValue}");
}

Column Families

using var options = new DbOptions
{
    CreateIfMissing = true,
    CreateMissingColumnFamilies = true
};

var descriptors = new List<ColumnFamilyDescriptor>
{
    new("default"),
    new("logs"),
    new("metrics")
};

using var db = RocksDb.Open(options, "mydb", descriptors);

var logsCf = db.GetColumnFamily("logs");
db.Put("entry1", "data", logsCf);

WriteBatch (Atomic Operations)

using var batch = new WriteBatch();
batch.Put("key1", "val1")
     .Put("key2", "val2")
     .Delete("old_key");

db.Write(batch);

Snapshots

using var snapshot = db.NewSnapshot();
using var readOpts = new ReadOptions();
readOpts.SetSnapshot(snapshot);

// Reads see the database state at snapshot time
string? val = db.GetString("key", readOptions: readOpts);

Merge Operators

// Built-in UInt64 addition
using var options = new DbOptions { CreateIfMissing = true };
options.SetUInt64AddMergeOperator();
using var db = RocksDb.Open(options, "counters");

db.Merge("visits", BitConverter.GetBytes(1UL));
db.Merge("visits", BitConverter.GetBytes(5UL));

ulong total = BitConverter.ToUInt64(db.Get("visits"));
// total == 6

Backup & Restore

using var engine = BackupEngine.Open("backups");
engine.CreateNewBackup(db);

// Later: restore
engine.RestoreDbFromLatestBackup("restored_db");

SST File Ingestion

using var envOpts = new EnvOptions();
using var dbOpts = new DbOptions();
using var writer = SstFileWriter.Create(envOpts, dbOpts);

writer.Open("data.sst");
writer.Put("key1", "val1"); // Keys must be in sorted order
writer.Put("key2", "val2");
writer.Finish();

db.IngestExternalFile(new[] { "data.sst" });

Bloom Filters

using var tableOptions = new BlockBasedTableOptions();
tableOptions.SetFilterPolicy(FilterPolicy.CreateBloom(10));

using var options = new DbOptions { CreateIfMissing = true };
options.BlockBasedTableFactory = tableOptions;

using var db = RocksDb.Open(options, "filtered_db");

Samples

The Samples/ directory contains runnable examples:

Run any sample with:

dotnet run --project Samples/Simple

Architecture

RocksDb.Net/
├── Native/
│   ├── NativeMethods.g.cs       # Auto-generated P/Invoke bindings (1,047 functions)
│   ├── NativeMethods.Helpers.cs  # Native library resolver and helpers
│   └── NativeResolver.cs         # Platform-specific library loading
├── RocksDb.cs                    # Main database class
├── DbOptions.cs                  # Database configuration options
├── WriteBatch.cs                 # Atomic write operations
├── Iterator.cs                   # Key-value iteration
├── ColumnFamilyHandle.cs         # Column family management
├── BackupEngine.cs               # Backup and restore
├── Checkpoint.cs                 # Database checkpoints
├── SstFileWriter.cs              # SST file creation for bulk loading
├── MergeOperator.cs              # Custom merge operators
├── CompactionFilter.cs           # Compaction-time key filtering
├── EventListener.cs              # Database event notifications
└── ...                           # Options, filters, cache, etc.

Building from Source

git clone https://github.com/user/RocksDb.Net.git
cd RocksDb.Net
dotnet build
dotnet test

The P/Invoke bindings in NativeMethods.g.cs are auto-generated from the RocksDB C header. To regenerate:

dotnet run --project tools/NativeMethodsGenerator -- \
    --version 11.0.4 \
    --output RocksDb.Net/Native/NativeMethods.g.cs

License

See LICENSE for details.