INNER CODE UNIT · C#

ExposedSqlEventStore

Chinchilla-Software-Com/CQRS · Diagnostics/Cqrs.Diagnostics.EventStoreToEventBusReplay/Program.cs:548

		public class ExposedSqlEventStore
		{
			public ExposedSqlEventStore(SqlEventStore<TAuthenticationToken> sqlEventStore)
			{
				MethodInfo methodInfo = sqlEventStore.GetType().GetMethod("CreateDbDataContext", BindingFlags.Instance | BindingFlags.NonPublic);
				DataContext dbDataContext = (DataContext)methodInfo.Invoke(sqlEventStore, new object[] { null });
				methodInfo = sqlEventStore.GetType().GetMethod("GetEventStoreTable", BindingFlags.Instance | BindingFlags.NonPublic);

				RawQuery = ((Table<EventData>)methodInfo.Invoke(sqlEventStore, new object[] { dbDataContext }))
					.AsQueryable();
			}

			internal IQueryable<EventData> RawQuery { get; set; }
		}
	}

	public static class PredicateBuilder
	{

View source record →