进步的途径

/// <summary>
/// 获取列表(任意entity，尽量少的字段)
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="sql"></param>
/// <returns></returns>
public static List<T> FindListBySql<T>(string sql, string dbname) where T : new()
{
    List<T> list = new List<T>();
    object obj;
    IDataReader rd = null;
    try
    {
        rd = RunReader(sql, dbname);

        if (typeof(T) == typeof(int))
        {
            while (rd.Read())
            {
                list.Add((T)rd[0]);
            }
        }
        else if (typeof(T) == typeof(string))
        {
            while (rd.Read())
            {
                list.Add((T)rd[0]);
            }
        }
        else
        {
            IList propertyList = ReflectionUtil.GetPropertyList(typeof(T));

            int fcnt = rd.FieldCount;
            List<string> fileds = new List<string>();
            for (int i = 0; i < fcnt; i++)
            {
                fileds.Add(rd.GetName(i).ToUpper());
            }

            while (rd.Read())
            {
                IDataRecord record = rd;
                obj = new T();


                foreach (PropertyInfo pro in propertyList)
                {
                    if (!fileds.Contains(pro.Name.ToUpper()) || record[pro.Name] == DBNull.Value)
                    {
                        continue;
                    }

                    if (rft.IsInterface(pro.PropertyType, typeof(IEntity)))
                    {
                        if (record[pro.Name].GetType() == typeof(int))
                        {
                            IEntity subOjb = ndb.findById(pro.PropertyType, (int)record[pro.Name]);

                            if (rft.IsInterface(obj.GetType(), typeof(IEntity)))
                            {
                                ((IEntity)obj).set(pro.Name, subOjb);
                            }
                            else
                            {
                                pro.SetValue(obj, Convert.ChangeType(subOjb, pro.PropertyType), null);
                            }
                        }
                    }
                    else
                    {
                        pro.SetValue(obj, record[pro.Name] == DBNull.Value ? null : getReaderValue(record[pro.Name], pro.PropertyType), null);
                    }
                }
                list.Add((T)obj);
            }
        }
    }
    catch (Exception ex)
    {
        logger.Error("sql=>" + sql);
        logger.Error(ex.Message);
        logger.Error(ex.StackTrace);
        throw ex;
    }
    finally
    {
        if (rd != null && !rd.IsClosed)
        {
            rd.Close();
        }
    }
    return list;
}