QuerySchemaClass

QuerySchemaClass

        public TA[] QuerySchemaClass<TA>(string query, Func<TA> classCreator, SqlParameter[] parameters) where TA : class {
            if (!IsConnected) throw new Exception("Database is not connected.");
            var cmd = new SqlCommand(query, Connection);
            if (parameters != null && parameters.Length > 0) {
                foreach (var parameter in parameters) {
                    cmd.Parameters.Add(parameter);
                }
            }
            var cs = cmd.ExecuteReader();
            var dt = new List<TA>();
            var classProps = typeof(TA).GetProperties().ToDictionary(x => x.Name);
            if (cs.HasRows) {
                while (cs.Read()) {
                    var row = classCreator();
                    var c = -1;
                    do {
                        c++;
                        var value = cs.GetValue(c);
                        classProps[cs.GetName(c)].SetValue(row, value == DBNull.Value ? null : value);
                    } while (c + 1 != cs.FieldCount);
                    dt.Add(row);
                }
            }
            cs.Close();
            return dt.ToArray();
        }