👁 Image
Apache.Calcite.Data 1.0.3

Apache.Calcite.Data

👁 NuGet

Apache.Calcite.Data is a native, in-process ADO.NET provider for Apache Calcite — the SQL parser, optimizer, and execution framework that powers many leading database and data-virtualization products.

The Calcite engine runs directly inside your .NET process via IKVM. There is no JDBC driver, no Avatica server, and no separate process. SQL flows from your DbConnection straight into Calcite's planner.

Why use this?

• Standard ADO.NET — works with any code that understands DbConnection / DbCommand / DbDataReader, including Dapper, EF Core conventions, and generic data-access layers.
• Federated queries — join CSV files, in-memory collections, REST adapters, JDBC databases, and custom Calcite schemas in a single SQL statement.
• Rich SQL — standards-conformant SQL with window functions, lateral joins, MATCH_RECOGNIZE, and much more.
• Code-driven schemas — register .NET objects as Calcite schemas, tables, and user-defined functions at runtime via the SchemaPlus API; no JSON model required.
• No external dependencies — everything runs in-process; no server to provision or maintain.

Supported platforms

Targets .NET 8 and is verified on .NET 8 and .NET 10.

Install

dotnet add package Apache.Calcite.Data

Quick start — inline JSON model

The quickest way to connect is with an inline Calcite model that wires up one or more adapters:

using Apache.Calcite.Data;

const string model = """
{
 "version": "1.0",
 "defaultSchema": "SALES",
 "schemas": [
 {
 "name": "SALES",
 "type": "custom",
 "factory": "org.apache.calcite.adapter.csv.CsvSchemaFactory",
 "operand": { "directory": "sales" }
 }
 ]
}
""";

await using var conn = new CalciteConnection($"Model=inline:{model}");
await conn.OpenAsync();

await using var cmd = conn.CreateCommand();
cmd.CommandText = "SELECT \"NAME\", \"DEPTNO\" FROM \"EMPS\" WHERE \"DEPTNO\" = 10";

await using var reader = await cmd.ExecuteReaderAsync();
while (await reader.ReadAsync())
 Console.WriteLine($"{reader.GetString(0)}\t{reader.GetInt32(1)}");

Quick start — model file

Point Model at a JSON file on disk:

await using var conn = new CalciteConnection("Model=path/to/model.json;Schema=SALES");
await conn.OpenAsync();

Parameterized queries

Calcite uses positional ? placeholders (ODBC-style). Parameters are matched to placeholders by the order they are added to Parameters; the ParameterName is informational only.

await using var cmd = conn.CreateCommand();
cmd.CommandText = "SELECT \"NAME\" FROM \"EMPS\" WHERE \"DEPTNO\" = ? AND \"SALARY\" > ?";
cmd.Parameters.Add(new CalciteParameter("deptno", 10));
cmd.Parameters.Add(new CalciteParameter("salary", 50_000m));

await using var reader = await cmd.ExecuteReaderAsync();
while (await reader.ReadAsync())
 Console.WriteLine(reader.GetString(0));

Code-driven schemas

Register .NET objects as Calcite schemas directly — no JSON model required:

using org.apache.calcite.schema;

await using var conn = new CalciteConnection();
await conn.OpenAsync();

SchemaPlus root = conn.RootSchema;
root.add("MEM", new MyCustomSchema()); // any org.apache.calcite.schema.Schema implementation

await using var cmd = conn.CreateCommand();
cmd.CommandText = "SELECT * FROM \"MEM\".\"USERS\" ORDER BY \"ID\"";
await using var reader = await cmd.ExecuteReaderAsync();

Using DbDataSource (.NET 7+)

CalciteDataSource implements the modern DbDataSource pattern for dependency-injection and pooled-connection scenarios:

using Apache.Calcite.Data;

await using var dataSource = new CalciteDataSource("Model=path/to/model.json");

await using var conn = await dataSource.OpenConnectionAsync();
await using var cmd = conn.CreateCommand();
cmd.CommandText = "SELECT COUNT(*) FROM \"ORDERS\"";
var count = await cmd.ExecuteScalarAsync();
Console.WriteLine($"Order count: {count}");

Using DbProviderFactory

using System.Data.Common;
using Apache.Calcite.Data;

// Register once at startup.
DbProviderFactories.RegisterFactory("Apache.Calcite.Data", CalciteProviderFactory.Instance);

// Resolve anywhere.
var factory = DbProviderFactories.GetFactory("Apache.Calcite.Data");
await using var conn = factory.CreateConnection()!;
conn.ConnectionString = "Model=path/to/model.json";
await conn.OpenAsync();

Connection string reference

All keys are exposed as typed properties on CalciteConnectionStringBuilder. Unknown keys are preserved and forwarded to the engine.

Identifier casing

Calcite's default lexer (Lex=ORACLE) follows standard SQL rules:

Most built-in adapters (CSV, JDBC against H2/HSQLDB/Oracle) expose names in upper case, so unquoted identifiers work naturally with them.

If your schema uses mixed- or lower-case names, quote them:

cmd.CommandText = """SELECT "Name", "DeptNo" FROM "Emps" WHERE "DeptNo" = 10""";

Or switch to a case-insensitive lexer:

// Lex=MYSQL_ANSI: unquoted identifiers are left unchanged, matching is case-insensitive.
await using var conn = new CalciteConnection("Model=inline:{...};Lex=MYSQL_ANSI");

Accessing the Calcite engine directly

CalciteConnection exposes Calcite-native objects as typed .NET properties for advanced scenarios:

These properties are only valid while the connection is open.

Related packages

Further reading

• Apache Calcite documentation
• Calcite adapters
• Calcite model JSON reference
• Source repository

License

Apache License 2.0.