Projac Syntax v2

RedisProjectionSyntaxCompare.cs

using System;
using System.Net;
using NUnit.Framework;
using Projac.Redis;
using Recipes.Shared;
using StackExchange.Redis;

namespace Recipes.RedisIntegration
{
    public class Usage
    {
        public static RedisProjection Projection = new RedisProjectionBuilder().
            When<PortfolioAdded>((connection, message) =>
            {
                var db = connection.GetDatabase();
                return db.HashSetAsync(message.Id.ToString("N"), "Name", message.Name);
            }).
            When<PortfolioRemoved>((connection, message) =>
            {
                var db = connection.GetDatabase();
                return db.HashDeleteAsync(message.Id.ToString("N"), "Name");
            }).
            When<PortfolioRenamed>((connection, message) =>
            {
                var db = connection.GetDatabase();
                return db.HashSetAsync(message.Id.ToString("N"), "Name", message.Name);
            }).
            Build();

        public class PortfolioProjection : RedisProjection2
        {
            public PortfolioProjection()
            {
                When<PortfolioAdded>((connection, message) =>
                {
                    var db = connection.GetDatabase();
                    return db.HashSetAsync(message.Id.ToString("N"), "Name", message.Name);
                });

                When<PortfolioRemoved>((connection, message) =>
                {
                    var db = connection.GetDatabase();
                    return db.HashDeleteAsync(message.Id.ToString("N"), "Name");
                });

                When<PortfolioRenamed>((connection, message) =>
                {
                    var db = connection.GetDatabase();
                    return db.HashSetAsync(message.Id.ToString("N"), "Name", message.Name);
                });
            }
        }
    }
}

SqlProjectionSyntaxCompare.cs

using Paramol.SqlClient;
using Projac;
using Recipes.Shared;

namespace Recipes.Sql
{
    public static class Usage
    {
        public static readonly SqlProjection Portfolio = new SqlProjectionBuilder().
            When<PortfolioAdded>(@event =>
                TSql.NonQueryStatement(
                    "INSERT INTO [Portfolio] ([Id], [Name], [PhotoCount]) VALUES (@P1, @P2, 0)",
                    new { P1 = TSql.UniqueIdentifier(@event.Id), P2 = TSql.NVarChar(@event.Name, 40) }
                    )).
            When<PortfolioRemoved>(@event =>
                TSql.NonQueryStatement(
                    "DELETE FROM [Portfolio] WHERE [Id] = @P1",
                    new { P1 = TSql.UniqueIdentifier(@event.Id) }
                    )).
            When<PortfolioRenamed>(@event =>
                TSql.NonQueryStatement(
                    "UPDATE [Portfolio] SET [Name] = @P2 WHERE [Id] = @P1",
                    new { P1 = TSql.UniqueIdentifier(@event.Id), P2 = TSql.NVarChar(@event.Name, 40) }
                    )).
            Build();

        public class PortfolioProjection : SqlProjection2
        {
            public PortfolioProjection()
            {
                When<PortfolioAdded>(@event =>
                    TSql.NonQueryStatement(
                        "INSERT INTO [Portfolio] ([Id], [Name], [PhotoCount]) VALUES (@P1, @P2, 0)",
                        new {P1 = TSql.UniqueIdentifier(@event.Id), P2 = TSql.NVarChar(@event.Name, 40)}
                        ));

                When<PortfolioRemoved>(@event =>
                    TSql.NonQueryStatement(
                        "DELETE FROM [Portfolio] WHERE [Id] = @P1",
                        new {P1 = TSql.UniqueIdentifier(@event.Id)}
                        ));

                When<PortfolioRenamed>(@event =>
                    TSql.NonQueryStatement(
                        "UPDATE [Portfolio] SET [Name] = @P2 WHERE [Id] = @P1",
                        new {P1 = TSql.UniqueIdentifier(@event.Id), P2 = TSql.NVarChar(@event.Name, 40)}
                        ));
            }
        }
    }
}