+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 | +1x +1x +1x +1x +1x + +1x + +1x +1x + + + + +1x + + + + + +1x + + + + + +1x +2x + +1x + +1x + | import * as _ from 'lodash';
+import { Data } from './types';
+import { Query } from './query';
+
+/** 前端数据集模块 */
+export class DataSet {
+ private data = [];
+
+ constructor(data: Data) {
+ this.data = data;
+ }
+
+ /**
+ * 数据大小
+ */
+ public size() {
+ return this.data.length;
+ }
+
+ /**
+ * 数据集的字段原信息（暂不处理）
+ */
+ public meta() {
+ return _.uniq(Object.keys(this.data));
+ }
+
+ /**
+ * 开始数据查询
+ */
+ public query() {
+ return new Query(this.data);
+ }
+}
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 | +1x +1x + + + + + + + + + + +1x + + + + + +1x + + + + +1x + + + + + + + + + + +1x + + + + + +6x + + + + | import { Field } from './types';
+
+/**
+ * 聚合求和
+ * @param field
+ */
+export function SUM(field: string): Field {
+ return {
+ aggregate: 'sum',
+ field,
+ };
+}
+
+/**
+ * 聚合 MAX
+ * @param field
+ */
+export function MAX(field: string): Field {
+ return {
+ aggregate: 'max',
+ field,
+ };
+}
+
+/**
+ * 聚合 MIN
+ * @param field
+ */
+export function MIN(field: string): Field {
+ return {
+ aggregate: 'sum',
+ field,
+ };
+}
+
+/**
+ * 无聚合字段
+ * @param field
+ */
+export function RAW(field: string): Field {
+ return {
+ aggregate: 'raw',
+ field,
+ };
+}
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| data-set.ts | +
+
+ |
+ 87.5% | +14/16 | +100% | +0/0 | +60% | +3/5 | +87.5% | +14/16 | +
| field.ts | +
+
+ |
+ 80% | +8/10 | +100% | +0/0 | +50% | +2/4 | +80% | +8/10 | +
| index.ts | +
+
+ |
+ 84.62% | +11/13 | +100% | +0/0 | +60% | +3/5 | +100% | +8/8 | +
| query.ts | +
+
+ |
+ 94.34% | +50/53 | +76.47% | +13/17 | +100% | +11/11 | +94.12% | +48/51 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 | +1x + +1x +1x + | /** data-set */
+export { DataSet } from './data-set';
+
+/** aggregate method */
+export { SUM, MAX, MIN, RAW } from './field';
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 +69 +70 +71 +72 +73 +74 +75 +76 +77 +78 +79 +80 +81 +82 +83 +84 +85 +86 +87 +88 +89 +90 +91 +92 +93 +94 +95 +96 +97 +98 +99 +100 +101 +102 +103 +104 +105 +106 +107 +108 +109 +110 +111 +112 +113 +114 +115 +116 +117 +118 +119 +120 +121 +122 +123 +124 +125 +126 +127 +128 | +1x +1x +1x +1x + + +2x +2x + + + + + +1x +2x +2x +2x +7x + +2x + +7x +1x + + +7x + +2x + + + + + + +1x +1x + + + +1x + + + + + + +1x +1x +1x + + + + + +1x +1x +1x + + + + + + + +1x +2x + + + + + + + +2x + + + + + +1x +2x + +2x +1x + +2x + +1x + +1x +1x +1x +1x +2x + + + + + + + + +2x +1x + +2x +1x + +2x +4x + +2x + +1x + +1x + + + + + + + + + + + | import { Data, Field } from './types';
+import { map, groupBy, orderBy, isEmpty, pick, forIn, maxBy, sumBy, minBy } from 'lodash';
+
+export class Query {
+ private data;
+ // select 数据 ['id', 'score']
+ private _select = [];
+ // 排序字段 { fields : 'score', asc : true}
+ private _orderby;
+ // 分组字段 'subject'
+ private _groupby;
+ // 存储分组
+ private _groupColumn;
+ // 取条数 2
+ private _limit;
+ // 计算字段 { aggregate: 'sum' field: 'score', }
+ private _caculate;
+
+ constructor(data: Data) {
+ this.data = data;
+ }
+
+ /**
+ * 选择字段
+ * @param fields
+ */
+ public select(...fields: Field[]): Query {
+ map(fields, (field) => {
+ // 找出计算值
+ if (field.aggregate !== 'raw') {
+ this._caculate = field;
+ }
+ // 找出所有select值
+ this._select.push(field.field);
+ });
+ return this;
+ }
+
+ /**
+ * 按照字段排序 默认降序
+ * @param field
+ * @param asc
+ */
+ public orderBy(fields: string, asc?: boolean): Query {
+ this._orderby = {
+ fields,
+ asc,
+ };
+ return this;
+ }
+
+ /**
+ * 按照字段分组
+ * @param asc
+ * @param fields
+ */
+ public groupBy(fields: string): Query {
+ this._groupby = fields;
+ return this;
+ }
+
+ /**
+ * 取 n 条数据
+ * @param n
+ */
+ public limit(n: number): Query {
+ this._limit = n;
+ return this;
+ }
+
+ /**
+ * 计算分组聚合信息
+ * @param data 分组数组
+ * @param field 聚合字段
+ * @param data 聚合条件
+ */
+ public caculate(data: [], field: string, operator: string) {
+ switch (operator) {
+ case 'sum':
+ return {
+ field: sumBy(data, field),
+ };
+ case 'min':
+ return minBy(data, field);
+ case 'max':
+ return maxBy(data, field);
+ }
+ }
+
+ /**
+ * 返回最后的查询数据
+ */E
+ public record(): Data {
+ // 处理分组
+ if (this._groupby) this._groupColumn = groupBy(this.data, this._groupby);
+
+ // 处理求值 max min sum
+ if (this._caculate) {
+ // max
+ const type = this._caculate.aggregate;
+ // score
+ const field = this._caculate.field;
+ if (this._groupColumn) {
+ this.data = [];
+ forIn(this._groupColumn, (item) => {
+ this.data.push(this.caculate(item, field, type));
+ });
+ } else {
+ // 当不存在分组的时候，处理原始数据 只有一条数据
+ Ethis.data = [this.caculate(this.data, field, type)];
+ }
+ }
+
+ //处理排序
+ if (this._orderby) this.data = orderBy(this.data, this._orderby.fields, this._orderby.asc);
+
+ //处理 limit
+ if (this._limit) this.data = this.data.slice(0, this._limit);
+
+ //处理select ['id', 'score']
+ if (!isEmpty(this._select)) {
+ this.data = map(this.data, (item) => pick(item, this._select));
+ }
+
+ return this.data;
+ }
+}
+ |