fastCSharp/sql/cache/whole/identityArray.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using System;
using System.Collections.Generic;
using fastCSharp.setup.cSharp;

namespace fastCSharp.sql.cache.whole
{
    /// <summary>
    /// 自增ID整表数组缓存
    /// </summary>
    /// <typeparam name="valueType">表格绑定类型</typeparam>
    /// <typeparam name="memberType">数据成员类型</typeparam>
    public abstract class identityArrayBase<valueType, memberType> : identityCache<valueType, memberType>
        where valueType : class
        where memberType : IMemberMap<memberType>
    {
        /// <summary>
        /// 数组长度递增
        /// </summary>
        protected int addLength;
        /// <summary>
        /// 自增ID整表数组缓存
        /// </summary>
        /// <param name="sqlTool">SQL操作工具</param>
        /// <param name="memberMap">数据成员位图</param>
        /// <param name="getIdentity">自增ID获取器</param>
        /// <param name="isReset">是否初始化事件与数据</param>
        /// <param name="addLength">数组长度递增</param>
        public identityArrayBase(sqlTable.sqlToolBase<valueType, memberType> sqlTool, memberType memberMap, func<valueType, int> getIdentity
            , bool isReset, int addLength)
            : base(sqlTool, memberMap, getIdentity, isReset)
        {
            this.addLength = addLength == 0 ? (1 << 16) : (addLength < 1024 ? 1024 : addLength);

            if (isReset)
            {
                sqlTool.OnInsertedLock += onInserted;
                //sqlTool.OnDeletedByIdentityLock += onDelete;
                sqlTool.OnDeletedLock += onDeleted;

                reset();
            }
        }
        /// <summary>
        /// 重新加载数据
        /// </summary>
        /// <param name="values">数据集合</param>
        protected void reset(valueType[] values)
        {
            valueType[] newValues = new valueType[(values.maxKey(value => getIdentity(value), 0) / addLength + 1) * addLength];
            foreach (valueType value in values) newValues[getIdentity(value)] = value;
            this.values = newValues;
            Count = values.Length;
        }
        /// <summary>
        /// 重新加载数据
        /// </summary>
        private void reset()
        {
            reset(SqlTool.Where(null, memberMap).getArray());
        }