wintellect / sterlingdb Goto Github PK

//BaseDatabaseInstance.cs
public ITableDefinition CreateTableDefinition<T, TKey>(Func<T, TKey> keyFunction) where T : class, new()
        {
            return new TableDefinition<T, TKey>(Driver,
                                                ( key => _Load<T>( typeof( T ), key, new CycleCache() ).Result ),
                                                keyFunction);
        }

/// <summary>
        ///     Recursive load operation
        /// </summary>
        /// <param name="type">The type to save (passed to support NULL)</param>
        /// <param name="key">The associated key (for cycle detection)</param>
        /// <param name="br">The reader</param>
        /// <param name="cache">Cycle cache</param>
        public object Load(Type type, object key, BinaryReader br, CycleCache cache)
        {
            _logManager.Log(SterlingLogLevel.Verbose,
                            string.Format("Sterling is de-serializing type {0}", type.FullName), null);

            if (_DeserializeNull(br))
            {
                return null;
            }

            // make a template
            var instance = Activator.CreateInstance(type);

            else
            {
                type = Type.GetType(_typeIndexer(br.ReadInt32()));
                if (instance.GetType() != type)
                {
                    instance = Activator.CreateInstance(type);
                }

                // push to the stack
                cache.Add(type, instance, key);

                // build the reflection cache);
                if (!_propertyCache.ContainsKey(type))
                {
                    //_CacheProperties(type);
                    _CacheProperties(type);
                }
            }

public class MyDatabase : BaseDatabaseInstance
    {
        public const string FeedItemInstanceIdIndex = "FeedItemInstanceIdIndex";
        public const string NotificationInstanceIdIndex = "NotificationInstanceIdIndex";
        public const string NotificationUnreadIndex = "NotificationUnreadIndex";

        protected override List<ITableDefinition> RegisterTables()
        {
            return new List<ITableDefinition>
            {
                CreateTableDefinition<Instance, int>(i => i.Id),
                CreateTableDefinition<FeedItem, int>(f => f.Id)
                    .WithIndex<FeedItem, int, int>(FeedItemInstanceIdIndex, fi => fi.InstanceId),
                CreateTableDefinition<Notification, int>(n => n.Id)
                    .WithIndex<Notification, int, int>(NotificationInstanceIdIndex, n => n.InstanceId)
                    .WithIndex<Notification, bool, int>(NotificationUnreadIndex, n => n.Unread)
            };
        }
    }