执行顺序¶
DolphinDB中，SQL语句各部分的执行顺序大致与其它系统中SQL一致。特别需要注意的是当使用context by子句时，csort关键字或limit / top子句的执行顺序。
以下为DolphinDB中SQL语句各部分的执行顺序：
1. from子句
from子句中的表对象或者 lj，ej，aj 等表连接，会最先被执行。
2. where条件
不符合where过滤条件的行会被舍弃。请注意，这一步仅可处理from子句中的数据，不可使用select子句中不属于from子句对象的新列名，例如计算结果。
3. group by / context by / pivot by子句
经过where条件过滤的行会依据 group by / context by / pivot by子句进行分组。
4. csort关键字（仅为 context by 子句提供）
context by通常与时间序列函数一起使用，每个分组中行的顺序对结果有直接影响。在context by子句后使用csort关键字，对每个组内的数据进行排序。
5. having 条件（若使用了group by / context by子句）
若使用了group by / context by 子句，则对每组使用having条件过滤，不满足条件的组被舍弃。与where条件相同，having条件中亦不可使用select子句中不属于from子句对象的新列名，例如计算结果。
6. select子句
若select子句指定了计算，此时才执行。
7. limit / top子句 （若使用了context by子句）
若使用了context by子句，limit / top 子句应用于每组。若有 n 组且 limit m 或 top m，则最多返回 n*m 行。 此情况下limit / top子句的执行顺序是在order by子句之前；其它情况下的limit / top子句的执行顺序是在order by子句之后。
8. order by子句
由于order by子句的执行顺序在select子句之后，order by子句可使用select子句中不属于from子句对象的新列名，例如计算结果。
9. limit / top 子句 （若未使用context by子句）
若未使用context by子句，则 limit / top 子句应用于前一步的全体结果，其指定范围之外的行被丢弃。
特殊情况：cgroup by 子句
若SQL语句使用cgroup by子句，其执行顺序如下：首先使用过滤条件（若有），然后根据cgroup by的列与group by的列（若有），对select子句中的项目进行分组计算，然后根据order by的列（必须使用，且必须属于group by列或cgroup by列）对分组计算结果进行排序，最后计算累计值。若使用group by，则在每个group by组内计算累计值。
例子
t = table(1 1 1 1 1 2 2 2 2 2 as id, 09:30:00+1 3 2 5 4 5 2 4 3 1 as time, 1 2 3 4 5 6 5 4 3 2 as x);
t;
id |
time |
x |
|---|---|---|
1 |
09:30:01 |
1 |
1 |
09:30:03 |
2 |
1 |
09:30:02 |
3 |
1 |
09:30:05 |
4 |
1 |
09:30:04 |
5 |
2 |
09:30:05 |
6 |
2 |
09:30:02 |
5 |
2 |
09:30:04 |
4 |
2 |
09:30:03 |
3 |
2 |
09:30:01 |
2 |
select *, deltas(x) from t context by id;
id |
time |
x |
deltas_x |
|---|---|---|---|
1 |
09:30:01 |
1 |
|
1 |
09:30:03 |
2 |
1 |
1 |
09:30:02 |
3 |
1 |
1 |
09:30:05 |
4 |
1 |
1 |
09:30:04 |
5 |
1 |
2 |
09:30:05 |
6 |
|
2 |
09:30:02 |
5 |
-1 |
2 |
09:30:04 |
4 |
-1 |
2 |
09:30:03 |
3 |
-1 |
2 |
09:30:01 |
2 |
-1 |
select *, deltas(x) from t context by id csort time;
id |
time |
x |
deltas_x |
|---|---|---|---|
1 |
09:30:01 |
1 |
|
1 |
09:30:02 |
3 |
2 |
1 |
09:30:03 |
2 |
-1 |
1 |
09:30:04 |
5 |
3 |
1 |
09:30:05 |
4 |
-1 |
2 |
09:30:01 |
2 |
|
2 |
09:30:02 |
5 |
3 |
2 |
09:30:03 |
3 |
-2 |
2 |
09:30:04 |
4 |
1 |
2 |
09:30:05 |
6 |
2 |
以上结果说明，使用csort time后，首先在每组中按照time排序，然后计算deltas(x)。
select *, deltas(x) from t context by id csort time limit 3;
id |
time |
x |
deltas_x |
|---|---|---|---|
1 |
09:30:01 |
1 |
|
1 |
09:30:02 |
3 |
2 |
1 |
09:30:03 |
2 |
-1 |
2 |
09:30:01 |
2 |
|
2 |
09:30:02 |
5 |
3 |
2 |
09:30:03 |
3 |
-2 |
以上结果说明，若使用了context by与limit子句，limit子句应用于每组，而非全体结果。
select *, deltas(x) from t context by id csort time order by id, deltas_x desc;
id |
time |
x |
deltas_x |
|---|---|---|---|
1 |
09:30:04 |
5 |
3 |
1 |
09:30:02 |
3 |
2 |
1 |
09:30:03 |
2 |
-1 |
1 |
09:30:05 |
4 |
-1 |
1 |
09:30:01 |
1 |
|
2 |
09:30:02 |
5 |
3 |
2 |
09:30:05 |
6 |
2 |
2 |
09:30:04 |
4 |
1 |
2 |
09:30:03 |
3 |
-2 |
2 |
09:30:01 |
2 |
以上结果说明，因为order by子句的执行顺序在select子句之后，所以order by子句中可以使用select子句中的计算结果deltas_x。
select *, deltas(x) from t context by id csort time order by id, deltas_x desc limit 3;
id |
time |
x |
deltas_x |
|---|---|---|---|
1 |
09:30:02 |
3 |
2 |
1 |
09:30:03 |
2 |
-1 |
1 |
09:30:01 |
1 |
|
2 |
09:30:02 |
5 |
3 |
2 |
09:30:03 |
3 |
-2 |
2 |
09:30:01 |
2 |
以上结果说明，若使用了context by子句，limit子句限制每组内的行数，且在order by子句之前执行。
select * from t order by id, x desc limit 3;
id |
time |
x |
|---|---|---|
1 |
09:30:04 |
5 |
1 |
09:30:05 |
4 |
1 |
09:30:02 |
3 |
以上结果说明，若未使用context by子句，limit子句限制全体结果的行数，且在order by子句之后执行。
select *, deltas(x) from t where x>=3 context by id;
id |
time |
x |
deltas_x |
|---|---|---|---|
1 |
09:30:02 |
3 |
|
1 |
09:30:05 |
4 |
1 |
1 |
09:30:04 |
5 |
1 |
2 |
09:30:05 |
6 |
|
2 |
09:30:02 |
5 |
-1 |
2 |
09:30:04 |
4 |
-1 |
2 |
09:30:03 |
3 |
-1 |
以上结果说明，where条件的执行顺序在select子句之前。以上语句中，先执行where x>=3，再计算deltas(x)，所以每只股票结果中的第一行deltas_x的结果为空。
select *, deltas(x) from t where x>=3 context by id having sum(x)<=12;
id |
time |
x |
deltas_x |
|---|---|---|---|
1 |
09:30:02 |
3 |
|
1 |
09:30:05 |
4 |
1 |
1 |
09:30:04 |
5 |
1 |
以上结果说明，having条件的执行顺序在where条件之后。