redb.Route.Sql 2.0.2

redb.Route.Sql

SQL database transport for redb.Route. Pure ADO.NET polling consumer, query/batch producer, and stored procedure support. Provider-agnostic — works with PostgreSQL, SQL Server, SQLite, MySQL, and any DbConnection.

Installation

dotnet add package redb.Route.Sql

No additional dependencies — uses System.Data.Common abstractions only.

Usage

URI Format

sql://SELECT * FROM orders WHERE processed = 0?dataSource=main&delay=5000

Fluent DSL

using redb.Route.Sql.Fluent;

// Poll rows from database
From(Sql.Poll("SELECT * FROM orders WHERE processed = 0")
        .DataSource("main")
        .Delay(5000)
        .OnSuccess("UPDATE orders SET processed = 1 WHERE id = :id")
        .MaxMessagesPerPoll(100))
    .Log("Processing order ${header.id}")
    .To("direct://handle");

// Execute SQL (producer)
From("direct://save")
    .To(Sql.Execute("INSERT INTO audit (message, status) VALUES (:body, 'OK')")
        .DataSource("main")
        .Transacted());

// Stored procedure
From("direct://calc")
    .To(Sql.Procedure("sp_calculate_totals")
        .DataSource("main")
        .In("orderId", DbType.Int32)
        .Out("total", DbType.Decimal));

// Batch processing
From("direct://bulk")
    .To(Sql.Execute("INSERT INTO logs (message) VALUES (:body)")
        .DataSource("main")
        .Batch(500)
        .Transacted());

// Explicit parameter binding — override auto-bind with constant or expression
From("direct://update-status")
    .To(Sql.Execute("UPDATE orders SET status = :status WHERE id = :id")
        .DataSource("main")
        .Param("status", "completed")
        .Param("id", Header("orderId")));

Register Data Sources

builder.Services.AddSingleton(sp =>
{
    var registry = new SqlDataSourceRegistry();
    registry.Register("main", () => new NpgsqlConnection(connectionString));
    return registry;
});

Fluent Builder API

Most builder methods (DataSource, ConnectionString, CommandTimeout, OutputHeader, Delay, InitialDelay, RepeatCount, MaxMessagesPerPoll, Batch, Param) accept both constant values and IExpression for runtime resolution.

Three Modes

Part of

redb.Route — ESB & EIP Framework for .NET