gistfile1.txt

23840 2014-05-07 10:14:55Z [ 5] NEventStore.SqlPersistenceWireup                                                 DEBUG: Using SQL connection factory of type '{Redacted}.{Redacted}.Application.Host.SqlConnectionFactory'.
23840 2014-05-07 10:14:55Z [ 5] NEventStore.SqlPersistenceWireup                                                 TRACE: Configuring SQL engine to auto-detect dialect.
23840 2014-05-07 10:14:55Z [ 5] NEventStore.SqlPersistenceWireup                                                 DEBUG: Registering SQL dialect of type 'NEventStore.Persistence.Sql.SqlDialects.MsSqlDialect'.
23840 2014-05-07 10:14:55Z [ 5] NEventStore.SqlPersistenceWireup                                                 DEBUG: Persistence engine configured to page every '2147483647' records.
23840 2014-05-07 10:17:44Z [ 5] NEventStore.PersistenceWireup                                                    DEBUG: Configuring persistence engine to initialize.
23840 2014-05-07 10:17:44Z [ 5] NEventStore.PersistenceWireup                                                    DEBUG: Configuring persistence engine to enlist in ambient transactions using TransactionScope.
23840 2014-05-07 10:17:44Z [ 5] NEventStore.EventUpconverterWireup                                               DEBUG: Configuring the store to upconvert events when fetched.
23840 2014-05-07 10:17:44Z [ 5] NEventStore.SynchronousDispatchSchedulerWireup                                   DEBUG: Configuring the store to dispatch messages synchronously.
23840 2014-05-07 10:17:44Z [ 5] NEventStore.SynchronousDispatchSchedulerWireup                                   DEBUG: Registering dispatcher of type 'NEventStore.Dispatcher.NullDispatcher'.
23840 2014-05-07 10:17:44Z [ 5] NEventStore.SynchronousDispatchSchedulerWireup                                   DEBUG: Registering dispatcher of type '{Redacted}.EventSourcing.NEventStore.DefaultCommitDispatcher'.
23840 2014-05-07 10:17:44Z [ 5] NEventStore.EventUpconverterWireup                                               DEBUG: Configuring the store to upconvert events when fetched.
23840 2014-05-07 10:17:44Z [ 5] NEventStore.EventUpconverterWireup                                               DEBUG: Will scan for event upconverters from the following assemblies: ', System.Linq.Enumerable+<DistinctIterator>d__81`1[System.Reflection.Assembly]'
23840 2014-05-07 10:17:47Z [ 5] NEventStore.PersistenceWireup                                                    DEBUG: Building the persistence engine.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlPersistenceEngine                                 DEBUG: Participating in connection with ambient transaction scope of 
23840 2014-05-07 10:17:47Z [ 5] NEventStore.PersistenceWireup                                                    DEBUG: Initializing the configured persistence engine.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlPersistenceEngine                                 DEBUG: Initializing storage engine.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlPersistenceEngine                                 TRACE: Executing command.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlDialects.CommonDbStatement                        TRACE: Creating command.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlDialects.CommonDbStatement                        TRACE: Command has client-controlled transaction: False.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlDialects.CommonDbStatement                        TRACE: Command text to be executed: IF EXISTS(SELECT * FROM sysobjects WHERE name='Commits' AND xtype = 'U') RETURN;

CREATE TABLE [dbo].[Commits]
(
       [BucketId] [varchar](40) NOT NULL,
       [StreamId] [char](40) NOT NULL,
       [StreamIdOriginal] [nvarchar](1000) NOT NULL,
       [StreamRevision] [int] NOT NULL CHECK ([StreamRevision] > 0),
       [Items] [tinyint] NOT NULL CHECK ([Items] > 0),
       [CommitId] [uniqueidentifier] NOT NULL CHECK ([CommitId] != 0x0),
       [CommitSequence] [int] NOT NULL CHECK ([CommitSequence] > 0),
       [CommitStamp] [datetime2] NOT NULL,
       [CheckpointNumber] [bigint] IDENTITY NOT NULL,
       [Dispatched] [bit] NOT NULL DEFAULT (0),
       [Headers] [varbinary](MAX) NULL CHECK ([Headers] IS NULL OR DATALENGTH([Headers]) > 0),
       [Payload] [varbinary](MAX) NOT NULL CHECK (DATALENGTH([Payload]) > 0),
       CONSTRAINT [PK_Commits] PRIMARY KEY CLUSTERED ([CheckpointNumber])
);
CREATE UNIQUE NONCLUSTERED INDEX [IX_Commits_CommitSequence] ON Commits (BucketId, StreamId, CommitSequence);
CREATE UNIQUE NONCLUSTERED INDEX [IX_Commits_CommitId] ON [dbo].[Commits] ([BucketId], [StreamId], [CommitId]);
CREATE UNIQUE NONCLUSTERED INDEX [IX_Commits_Revisions] ON [dbo].[Commits] ([BucketId], [StreamId], [StreamRevision], [Items]);
CREATE INDEX [IX_Commits_Dispatched] ON [dbo].[Commits] ([Dispatched]);
CREATE INDEX [IX_Commits_Stamp] ON Commits ([CommitStamp]);

CREATE TABLE [dbo].[Snapshots]
(
       [BucketId] [char](40) NOT NULL,
       [StreamId] [char](40) NOT NULL,
       [StreamRevision] [int] NOT NULL CHECK ([StreamRevision] > 0),
       [Payload] [varbinary](MAX) NOT NULL CHECK (DATALENGTH([Payload]) > 0),
       CONSTRAINT [PK_Snapshots] PRIMARY KEY CLUSTERED ([BucketId], [StreamId], [StreamRevision])
);
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlPersistenceEngine                                 TRACE: Command executed, -1 rows affected.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlDialects.CommonDbStatement                        TRACE: Disposing SQL statement resources, including any transactions and connections.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Dispatcher.SynchronousDispatchScheduler                               INFO: Starting dispatch scheduler.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Dispatcher.SynchronousDispatchScheduler                              DEBUG: Initializing persistence engine.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Dispatcher.SynchronousDispatchScheduler                              DEBUG: Getting undispatched commits from persistence engine.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlPersistenceEngine                                 DEBUG: Getting the list of all undispatched commits.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlPersistenceEngine                                 TRACE: Executing query.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlDialects.CommonDbStatement                        TRACE: Executing query with max page size of 2147483647.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlDialects.CommonDbStatement                        TRACE: Creating command.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlDialects.CommonDbStatement                        TRACE: Command has client-controlled transaction: False.
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlDialects.CommonDbStatement                        TRACE: Command text to be executed: WITH [cte] AS
   ( SELECT BucketId, StreamId, StreamIdOriginal, StreamRevision, CommitId, CommitSequence, CommitStamp, CheckpointNumber, Headers, Payload
  , ROW_NUMBER() OVER (ORDER BY CheckpointNumber) AS [row] FROM Commits
 WHERE Dispatched = 0
  )

SELECT *
  FROM [cte]
 WHERE [row] BETWEEN @Skip + 1
                 AND @Limit + @Skip;
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlDialects.CommonDbStatement                        TRACE: Binding parameter '@Limit' with value: 2147483647
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlDialects.CommonDbStatement                        TRACE: Binding parameter '@Skip' with value: 0
23840 2014-05-07 10:17:47Z [ 5] NEventStore.Persistence.Sql.SqlDialects.PagedEnumerationCollection               DEBUG: Enumeration of paged results threw exception of type 'System.Data.SqlClient.SqlException'.