- 数据类型
- 操作符
- 数学
- 字符串
- 日期时间
- 序列
- 序表
- 循环函数
- 关联运算
- 文件
- 数据库
- 游标
- 程序语句
- 系统与接口
- 集群
- 图形
- 财务
- 外部库
- 组表
-
Function
- #c
- $(db)sql;…
- ${macroExp}
- =expression
- >statement
- [a:b]
- @
- A()
- A. (x)
- [a1,…,an]
- abs()
- acos()
- acosh()
- age()
- align()
- ali_client()
- ali_close()
- ali_query()
- and()
- append()
- array()
- asc()
- asin()
- asinh()
- atan()
- atanh()
- attach()
- avg()
- base64 ()
- between()
- bits()
- bool()
- break {a}
- C
- Cr()
- calc()
- call()
- call path/dfx( … )
- callx()
- cand()
- canvas()
- case()
- ceil()
- ch.()
- channel()
- char()
- clear()
- clipboard ()
- close()
- cmp()
- cor ()
- combin()
- commit()
- concat()
- conj()
- conjx()
- connect()
- contain()
- cos()
- cosh()
- count()
- create()
- cs.( )
- cum()
- cursor()
- date()
- datetime()
- day()
- days()
- decimal()
- delete()
- deq()
- derive()
- dfx ( …)
- diff()
- directory()
- dup()
- elapse()
- end s
- enum()
- env()
- eq()
- error()
- eval()
- es_close ()
- es_delete()
- es_head()
- es_open()
- es_get()
- es_post()
- es_put()
- execute()
- exists()
- exp()
- export()
- f@o(…)
- Faccrint()
- Faccrintm()
- fact()
- false
- Fcoupcd()
- Fcoups()
- Fdb()
- Fddb()
- Fdisc()
- Fduration()
- fetch()
- field()
- file()
- filename()
- fill()
- find()
- Fintrate()
- Firr()
- float()
- floor()
- Fmirr()
- fname()
- fno()
- Fnper()
- Fnpv()
- for
- fork
- format()
- Fpmt()
- Fprice()
- Frate()
- Freceived()
- Fsln()
- Fsyd()
- ftp_cd()
- ftp_client()
- ftp_close()
- ftp_get()
- ftp_mkdir()
- ftp_put()
- func()
- Fv()
- Fvdb()
- Fyield()
- gcd()
- goto C
- group()
- groupi()
- groupn()
- groups()
- groupx()
- hash ()
- hbase_close()
- hbase_cmp()
- hbase_filter()
- hbase_filterlist()
- hbase_get()
- hbase_open()
- hbase_scan()
- hdfsfile()
- hdfs_client()
- hdfs_close()
- hdfs_dir()
- hdfs_file()
- hive_client()
- hive_close()
- hive_cursor()
- hive_execute ()
- hive_query()
- hosts()
- hour()
- httpfile()
- icursor()
- icount()
- id()
- if
- if()
- ifa()
- ifdate()
- ifn()
- ifnumber()
- ifr()
- ifstring()
- ift()
- iftime()
- ifv()
- ifx_close()
- ifx_conn()
- ifx_cursor()
- ifx_listfrag()
- ifx_savefrag()
- ifx_setfrag()
- ifx_takefrag()
- import()
- index()
- inf()
- insert()
- int()
- interval()
- inv()
- invoke()
- isalpha()
- isdigit()
- isect()
- iselect()
- islower()
- isolate()
- isupper()
- iterate()
- join()
- joinx()
- json()
- k()
- k{}
- kafka_close()
- kafka_commit()
- kafka_poll()
- kafka_subscribe()
- key()
- keys()
- lcm()
- left()
- len()
- lg()
- like()
- ln()
- lock()
- long()
- lower()
- m()
- max()
- maxp()
- mcursor()
- md5()
- median()
- memory()
- merge()
- mergex()
- mid()
- millisecond()
- min()
- minp()
- minute()
- modify()
- mongo_close ()
- mongo_open()
- mongo_shell()
- month()
- movefile()
- n.f(x)
- name()
- new()
- news()
- next {a}
- nodes()
- not()
- now()
- null
- number()
- olap_close()
- olap_open()
- olap_query()
- or()
- output()
- p()
- pad()
- parse()
- paste ()
- pdate()
- penum()
- periods()
- permut()
- pfind()
- pi()
- pivot()
- pmax()
- pmin()
- pos()
- power()
- prior()
- proc()
- product()
- property()
- pseg()
- pselect()
- psort()
- ptop()
- push()
- query()
- r.(x)
- r.F
- r.F=x
- rand()
- rands()
- range()
- rank()
- ranki()
- ranks()
- read()
- record()
- redis()
- redis_close()
- redis_cluster()
- redis_get()
- redis_getrange ()
- redis_hkeys ()
- redis_hlen ()
- redis_hmget()
- redis_hvals()
- redis_keys()
- redis_lindex()
- redis_llen()
- redis_lrange()
- redis_pool()
- redis_scard()
- redis_sdiff()
- redis_select()
- redis_sentinel()
- redis_shared()
- redis_sharedpool()
- redis_sinter()
- redis_sismember()
- redis_smembers()
- redis_srandmember()
- redis_strlen ()
- redis_sunion()
- redis_type()
- redis_zcard()
- redis_zcount()
- redis_zrange()
- redis_zrangebyscore()
- redis_zrank()
- redis_zscore()
- regex()
- register()
- rename()
- replace()
- report_config()
- report_exportHtml()
- report_exportPdf()
- report_exportXls()
- report_open()
- report_run()
- reset()
- result
- return xi
- rgb()
- right()
- rollback()
- round()
- row()
- run()
- rvs()
- sap_client ()
- sap_close ()
- sap_cursor ()
- sap_excute ()
- sap_getparam ()
- sap_table ()
- savepoint()
- second()
- segp()
- select()
mergex()
本章节介绍mergex()函数的用法。
CS.mergex()
描述：
针对游标序列成员做归并运算。
语法：
CS.mergex(xi,…)
备注：
CS是对[xi,…]有序的游标的序列，针对其成员输出的对应序列按照xi做有序归并运算。游标中序列的成员必须同构。支持多路游标, 若成员是多路游标，则必须相同路数且同步分段。
选项：
|
@u |
并集运算，CS游标序列的成员按顺序合并到一起组成新的游标,去掉重复的成员。缺省包含所有重复成员。 |
|
@i |
交集运算，返回CS游标序列中共同的成员组成的游标 |
|
@d |
差集运算，从游标CS1中去掉游标CS2&…CSn中的成员后形成的新游标 |
|
@0 |
null排最后 |
参数：
|
CS |
游标组成的序列 |
|
xi |
表达式，如果是按照多字段归并，字段间用逗号分隔，例如:x1,x2... |
返回值：
游标
示例：
|
|
A |
B |
C |
|
||
|
1 |
=demo.cursor("select * from STOCKRECORDS") |
返回取数游标 |
||||
|
2 |
for |
|
||||
|
3 |
|
=A1.fetch(500) |
游标中取数 |
|||
|
4 |
|
if B3==null |
break |
|
||
|
5 |
|
else |
|
|
||
|
6 |
|
|
=B3.sort(STOCKID) |
按STOCKID排序 |
||
|
7 |
|
|
=file("D:\\"+"a"+string(A2)+".txt").export@t(C6) |
每次取的数据存到文件中 |
||
|
8 |
|
|
=B1=B1|file("D:\\"+"a"+string(A2)+".txt") |
文件对象序列
|
||
|
9 |
for B1 |
|
|
|
||
|
10 |
|
=A9.cursor@t() |
|
|
||
|
11 |
|
=C1=C1|B10 |
|
文件游标序列
|
||
|
12 |
=C1.mergex(STOCKID) |
|
|
对序列成员按照成员中的STOCKID有序归并 |
||
|
13 |
=A12.fetch() |
|
|
获取合并后的记录 |
||
|
14 |
=directory@p("D://*.txt") |
|
|
txt文件内容如下：
|
||
|
15 |
for A14 |
|
|
|
||
|
16 |
|
=file(A15).cursor@t() |
=B14=B14|B16 |
|
||
|
17 |
=B14.mergex@i(STOCKID) |
=A17.fetch() |
|
返回共同成员组成的游标，STOCKID有序 |
||
|
18 |
=directory@p("D://*.txt") |
|
|
txt内容同上 |
||
|
19 |
for A18 |
|
|
|
||
|
20 |
|
=file(A19).cursor@t() |
=B18=B18|B20 |
|
||
|
21 |
=B18.mergex@u(STOCKID) |
=A21.fetch() |
|
返回去掉重复的成员后的新游标，STOCKID有序 |
||
|
22 |
=directory@p("D://*.txt") |
|
|
txt内容同上 |
||
|
23 |
for A22 |
|
|
|
||
|
24 |
|
=file(A23).cursor@t() |
=B22=B22|B24 |
|
||
|
25 |
=B22.mergex@d(STOCKID) |
=A25.fetch() |
|
从第一个游标中去掉其他游标的成员后形成的新游标，STOCKID有序 |
||
相关概念：
cs.mergex()
描述：
集群游标归并转成本机单路游标
语法：
cs.mergex(xi,…)
备注：
cs是对[xi,…]有序的集群游标序列，将对应的集群游标按照xi做有序归并运算。
参数：
|
cs |
集群游标组成的序列 |
|
xi |
表达式，如果是按照多字段归并，字段间用逗号分隔，例如:x1,x2... |
返回值：
单路游标
示例：
|
|
A |
|
|
1 |
=file@0("emp2.ctx",["127.0.0.1:8282"]) |
打开集群文件 |
|
2 |
=A1.create() |
打开集群组表 |
|
3 |
=A2.cursor(EID,NAME;EID<8) |
返回集群游标
|
|
4 |
=A3.cursor(EID,NAME;EID>495) |
返回集群游标
|
|
5 |
=[A3,A4].mergex(EID) |
将A3和A4按照EID有序合并返回本地单路游标 |
|
6 |
=A5.fetch() |
|
mcs.mergex()
描述：
多路游标归并转成单路游标
语法：
mcs.mergex(xi,…)
备注：
mcs是对[xi,…]有序的多路游标序列，将对应的多路游标按照xi做有序归并运算。其中多路游必须相同路数且同步分段。
参数：
|
mcs |
多路游标组成的序列 |
|
xi |
表达式，如果是按照多字段归并，字段间用逗号分隔，例如:x1,x2... |
返回值：
单路游标
示例：
|
|
A |
|
|
1 |
=demo.query("select EID,NAME,GENDER,SALARY from EMPLOYEE where EID<6") |
EID有序 |
|
2 |
=demo.query("select EID,NAME,GENDER,SALARY from EMPLOYEE where EID<10 and EID>5") |
EID有序 |
|
3 |
=[A1.cursor(),A2.cursor()].mcursor() |
转成多路游标
|
|
4 |
=[A1.cursor(),A2.cursor()].mcursor() |
同A3 |
|
5 |
=[A3,A4].mergex(EID) |
将A3和A4按照EID有序合并 |
|
6 |
=A5.fetch() |
|
