网站开发总体功能设计,wordpress注册邮件问题,广告设计公司绩效考核,项目交流平台为了提升用户体验#xff0c;降低用户学习成本和脚本迁移复杂度#xff0c;自 1.30.17 / 2.00.5 版本开始#xff0c;DolphinDB 逐步支持了标准化 SQL 的书写方法#xff1b;并于 1.30.22 / 2.00.10 版本起#xff0c;对标准 SQL 的常用语法和关键字实现了兼容。
1. 与标…为了提升用户体验降低用户学习成本和脚本迁移复杂度自 1.30.17 / 2.00.5 版本开始DolphinDB 逐步支持了标准化 SQL 的书写方法并于 1.30.22 / 2.00.10 版本起对标准 SQL 的常用语法和关键字实现了兼容。
1. 与标准 SQL 的兼容性
在脚本层面自 1.30.22 / 2.00.10 版本起DolphinDB SQL 开始支持
关键字全大写或全小写的书写方式脚本的换行不影响语法解析但存在两种特殊情况 组合关键字不允许拆分如 order by, group by, context by, pivot by, union all, inner join, nulls first 等。不使用 as 指定字段别名时别名与原字段之间不能换行。 注意 SQL 语句中的数据库或数据表名称是大小写敏感的。 本章三个小节分别以列表形式说明 DolphinDB 对标准 SQL 语法的支持
包含
对 SQL-92 常用关键字的支持性对 SQL 类型及类型转换函数的支持性非 SQL-92 标准的常用关键字支持表
1.1 常用的 ANSI SQL-92 关键字支持表
下表共统计了 92 项常用的 ANSI SQL-92 关键字支持 60 项。其中在不支持的 30 项中5 项部分兼容7项与约束相关在分析项目中没有太大的使用价值10 项有替代方案。
√表示兼容 ×不兼容 ○部分兼容 “说明” 字段会给出对应函数或可替代的方案 keyword按 A-Z 排列兼容性说明CHECK×不支持约束CONSTRAINT×不支持约束CONTAINS×用 LIKE 替代DEFAULT×不支持默认值ESCAPE×暂不支持 ESCAPE 定义转义符EXCEPT×暂不支持 EXCEPT用 WHERE 替代过滤EXEC×存在同名关键字但是作用不同EXTRACT×通过内置日期函数截取日期/时间的某个部分FOREIGN×不支持外键GLOBAL×不支持定义 GLOBAL TEMPORARY TABLEIDENTITY×需要自定义标识列或者用 rowNo 替代INTERSECT×暂不支持取交集用 WHERE 过滤LAST×fetch orientation 的关键字之一表示取最后几行记录。目前 DolphinDB 仅支持在 CONTEXT BY LIMIT 中指定取最后几行记录。注内部存在同名关键字 LAST 用于排序时指定空值位置用法 NULLS LAST。NATURAL×不支持 NATURAL JOIN用 INNER JOIN 替代OUTER×直接用 LEFT JOIN, RIGHT JOIN, FULL JOIN 替代OVERLAPS×用 EXITS 替代POSITION×用 strpos 替代PRIMARY×不支持主键REFERENCES×不支持外键RESTRICT×不支持约束删除SOME×用 ANY 替代SPACE×TRANSLATE×用 strReplace 或 regexReplace 替代UNIQUE×不支持唯一约束VIEW×不支持视图ADD√ALTER..ADD..ALL√ALTER√AND√ANY√AS√ASC√BETWEEN√BY√CASE√CAST / CONVERT√对应 cast 函数COALESCE√COLUMN√COUNT√CREATE√CROSS√CROSS JOINDELETE√DESC√DISTINCT√DROP√ELSE√CASE WHEN..THEN..ELSE ENDEND√CASE WHEN..THEN..ELSE ENDEXISTS√FALSE√falseFROM√FULL√FULL JOINGROUP√HAVING√IF√IFIN√INNER√INNER JOININSERT√IS√IS NULLJOIN√LEFT√LEFT JOIN, 字符串函数 leftLIKE√LOWER√对应 lower 函数MAX / MIN√对应 maxmin 函数NOT√NULL√NULLIF√对应 nullIf 函数ON√JOIN .. ONOR√ORDER√REPEAT√对应 repeat 函数RIGHT√字符串 right 函数SELECT√SET√SUBSTRING√对应 substr 函数SUM√对应 sum 函数TABLE√TEMPORARY√THEN√TRIM√对应 trim 函数TRUE√trueUNION√UPDATE√UPPER√对应函数 upperVALUES√INSERT INTO .. VALUES ..WHEN√WHERE√WITH√CHARACTER_LENGTH○对应 strlen 函数FETCH○用 TOP / LIMIT 子句替代FIRST○fetch orientation 的关键字之一可以用 TOP/LIMIT 替代注内部存在同名关键字 FIRST 用于排序时指定空值位置用法 NULLS FIRST。TRANSACTION○对应 TRANSACTION 关键字WHILE○用内部 FOR 或 DO-WHILE 代替
需要注意 DolphinDB 内部的权限管理机制是一套独立的机制和 SQL 不直接挂钩因此此处关键字不包含权限相关的关键字如GRANT, DENY 等。 1.2 SQL 类型及相关类型转换函数的支持表
keyword按 A-Z 排列兼容性说明CHAR / CHARACTER 类型○对应 STRING, SYMBOL 类型DATE 类型○对应 DATE 类型或 date 函数DATETIME 类型○对应 DATETIME 类型DAY 函数○对应函数 dayOfMonthDECIMAL / DEC / NUMERIC 类型○对应 DECIMAL32, DECIMAL64, DECIMAL128DOUBLE 类型○对应 DOUBLE 类型FLOAT / REAL 类型○对应 FLOAT 类型HOUR 函数○对应 hour 函数INT / INTEGER 类型○对应 INT, SHORT, LONGINTERVAL 关键字×用 temporalAdd 的 DURATION 替代MINUTE 函数○对应 minuteOfHour 函数MONTH 函数○对应 monthOfYear 函数SECOND 函数○对应 secondOfMinute 函数TIME 类型○对应 SECOND 类型TIMESTAMP 类型○对应 DATETIME 类型VARCHAR 类型○对应 STRING, SYMBOL 类型YEAR 类型×不支持年类型YEAR 函数○对应 year 函数
1.3 非 SQL-92 标准的常用关键字支持表
DolphinDB 针对分布式计算提供了很多特有的关键字也根据应用场景提供了一些特色的 join 方法。
keyword按 A-Z 排列说明asof join按时间列就近连接context by类似 OVER 开窗函数用于分组计算cgroup by累计分组计算exec生成一个标量、向量或矩阵map分区内单独计算partition选择分区pivot by / unpivot类似 Oracle 的 PIVOT用于宽表和窄表的转换sample随机选取分区top / limit取前 n 条记录其中 limit 和 context by 搭配使用可以取分组的前 n 条或后 n 条记录truncate删除数据window join窗口连接
DolphinDB 还提供了一些辅助 SQL 查询的 HINT 关键字
keyword说明[HINT_LOCAL]添加该关键字后仅获取在本地所有节点数据的查询结果。[HINT_HASH]group by 分组默认优先采用哈希算法。[HINT_KEEPORDER]添加该关键字后context by 分组后计算的输出结果顺序将和输入保持一致。[HINT_SEQ]添加该关键字后SQL 语句将在分区间串行执行。[HINT_NOMERGE]添加该关键字后map 的查询结果不再汇总成一张内存表返回给客户端而是直接返回分区表的句柄。[HINT_PRELOAD]仅 TSDB 引擎支持该关键字添加后where 语句进行条件过滤前会先将所有数据列加载到内存后再进行过滤。[HINT_EXPLAIN]添加该关键字后系统将打印 SQL 语句的执行过程便于 SQL 查询中实时监测查询的速度和执行的顺序。[HINT_SORT]添加该关键字后group by 分组时将采用排序算法进行。[HINT_VECTORIZED]添加该关键字后group by 分组时将采用向量化运算vectorization。
2. 数据准备
本章将简单介绍如何在 DolphinDB 中以标准 SQL 的方式编写脚本。为了便于用户实践理解本章的所有案例均采用统一的数据库和数据表建库建表语句请参见 2.2 章节。
2.1 数据集说明
本文的示例采用了 HR人力资源数据集做为案例数据集见节尾进行演示包含以下几个表
数据集存储形式countries维度表departments维度表employees维度表jobs维度表job_history分布式表HASH(EMPLOYEE_ID)locations维度表regions维度表
每个表的字段及类型如下
countries
Column NameTypeCOUNTRY_IDSYMBOLCOUNTRY_NAMESTRINGREGION_IDINT
departments
Column NameTypeDEPARTMENT_IDINTDEPARTMENT_NAMESTRINGMANAGER_IDINTLOCATION_IDINT
employees
Column NameTypeEMPLOYEE_IDINTFIRST_NAMESTRINGLAST_NAMESTRINGEMAILSTRINGPHONE_NUMBERSTRINGHIRE_DATEDATEJOB_IDSYMBOLSALARYINTCOMMISSION_PCTDOUBLEMANAGER_IDINTDEPARTMENT_IDINT
jobs
Column NameTypeJOB_IDSYMBOLJOB_TITLESTRINGMIN_SALARYINTMAX_SALARYINT
job_history
Column NameTypeEMPLOYEE_IDINTSTART_DATEDATEEND_DATEDATEJOB_IDSYMBOLDEPARTMENT_IDINT
locations
Column NameTypeLOCATION_IDINTSTREET_ADDRESSSTRINGPOSTAL_CODELONGCITYSTRINGSTATE_PROVINCESTRINGCOUNTRY_IDSYMBOL
regions
Column NameTypeREGION_IDINTREGION_NAMESTRING
数据文件
COUNTRIES.csvDEPARTMENTS.csvEMPLOYEES.csvJOB_HISTORY.csvJOBS.csvLOCATIONS.csvREGIONS.csv
2.2 建库建表
在 DolphinDB 中既可以通过符合标准 SQL 语言习惯的脚本建库建表也可以通过 DolphinDB 内置的函数接口建库建表。
1创建数据库
create database dfs://hr partitioned by HASH([INT, 10])
2创建数据表
2创建数据表
此处以创建表 job_history 为例进行说明。完整的建表脚本见附件
create_db_table_sql.txt
STEP 1创建分布式表
// 通过标准 SQL 的方式创建
create table dfs://hr.job_history (EMPLOYEE_ID INT,START_DATE DATE,END_DATE DATE,JOB_ID SYMBOL,DEPARTMENT_ID INT
)
partitioned by EMPLOYEE_ID
STEP 2导入数据
DolphinDB 的 INSERT INTO 语句仅支持内存表的数据追加对于维度表、分布式表需要通过tableInsert或者append!接口进行追加。
job_history_tmploadText(dirJOB_HISTORY.csv)
job_history loadTable(dfs://hr, job_history)job_history.append!(job_history_tmp)
2.3 修改表字段 注DolphinDB 与其他关系型数据库、NoSQL、NewSQL 数据库不同的是数据库、编程语言和分布式计算三者融为一体。这种设计使得 DolphinDB 可以一站式轻量化的解决大数据问题。但是引用数据库和表时因为与脚本中的变量名可能会冲突故不能直接用数据库或表名称必须使用 loadTable 函数加载数据表。 DolphinDB 支持通过 ALTER 语句对字段进行增加、删除、重命名的操作。
alter table tableObj add columnName columnType;
alter table tableObj drop [column] columnName;
alter table tableObj rename [column] columnName to newColumnName;
上述三个语句也可以分别用 DolphinDB 函数 addColumn, dropColumns!, rename! 实现。
注意对于分布式表仅 OLAP 引擎支持删除和重命名操作。
1新增字段
给 employees 表增加一列全名 “FULL_NAME” 列并更新该列的数据。
employees loadTable(dfs://hr, employees) // 加载表 employeesalter table employees add FULL_NAME STRING
employees loadTable(dfs://hr, employees) // 增加列后需要重新加载表
update employees set FULL_NAMEFIRST_NAME LAST_NAME
select * from employees 2重命名字段
将 “FULL_NAME” 列重命名为 EMPLOYEE_NAME。
alter table employees rename FULL_NAME to EMPLOYEE_NAME
employees loadTable(dfs://hr, employees) // 重命名列后需要重新加载表
select * from employees 3删除字段
删除上文新增的 EMPLOYEE_NAME 字段。
alter table employees drop EMPLOYEE_NAME
employees loadTable(dfs://hr, employees) // 删除列后需要重新加载表
select * from employees 2.4 删除库表
1删除数据库
drop database if exists dfs://hr
2删除数据表
drop table if exists dfs://hr.job_history
3. SQL 关键字
注下文的表变量均是通过 tbNameloadTable(“dfs://hr“, tbName) 加载得到的为了说明的简洁该步骤已被省略。 3.1 谓词
谓词指的是返回值为真值的函数DolphinDB 支持谓词的关键字有(not) in, (not) like, between, (not) exists, is (not) nullL。
(1) (not) in
选取 employees 表中 EMPLOYEE_ID 为 [101, 103, 152] 的对应记录。
select * from employees where EMPLOYEE_ID in [101, 103, 152];
选取 employees 表中 EMPLOYEE_ID 不在 100~150 的对应记录。
select * from employees where EMPLOYEE_ID not in 100..150;
(2) (not) like
选取 employees 表中 PHONE_NUMBER 以 “515” 开头的对应记录。
select * from employees where PHONE_NUMBER like 515%;
选取 employees 表中 JOB_ID 不以 “AD” 开头的对应记录。
select * from employees where JOB_ID not like AD%;
(3) between
统计 2006 年雇佣的职员人数。
select count(*) from employees where date(HIRE_DATE) between 2006.01.01 and 2006.12.31 // output: 24
(4) (not) exists
注由于 exists 暂不支持在分布式查询中使用下述脚本先将维度表和分布式表赋值给内存表再进行查询。 job_history select * from loadTable(dfs://hr, job_history)
employees select * from loadTable(dfs://hr, employees)
查询记录在 job_history 表中的 employees 表的职员对应的记录。
select * from employees where exists(select * from job_history where employees.EMPLOYEE_ID in job_history.EMPLOYEE_ID)
查询记录不在 job_history 表中的 employees 表的职员对应的记录。
select * from employees where not exists(select * from job_history where employees.EMPLOYEE_ID in job_history.EMPLOYEE_ID)
(5) is (not) nullL
查询存在经理的部门对应的记录。
select * from departments where MANAGER_ID is not null
查询任务百分比为空的职员对应的记录。
select * from employees where COMMISSION_PCT is null
3.2 distinct
distinct 关键字添加在 select / exec 语句后用于去除重复值并返回唯一值distinct value。
注支持在分布式查询中使用但暂不支持 distinct 与 group by, context by 或 pivot by 配合使用。 需要注意 DolphinDB 中存在同名的函数 distinct若在 SQL 中使用 distinct 函数则不保证返回结果的顺序且默认将结果列的列名重命名为 distinct_colName。
select distinct COUNTRY_ID from locations // (1)
select distinct(COUNTRY_ID) from locations // (2) 在函数中应用 distinct统计唯一值的数量。
select count(distinct JOB_ID) from employees // output: 19
对多列应用 distinct取 DEPARTMENT_ID, MANAGER_ID 的唯一值。
select distinct DEPARTMENT_ID, MANAGER_ID from employees
3.3 any / all
支持使用 any / all 进行谓词比较谓词包括, !, , , , .
any
查询和采购部门任意职工薪水相同的职工信息。
select * from employees
where salary
any(select salary from employeeswhere department_id 30)
order by employee_id all
查询薪水大于等于 IT 部门的最低薪水的员工信息。 select * from employeeswhere salary all (select salary from employees where department_id60)order by employee_id 注目前不支持形如 ALL (1400, 3000) 这样的比较。
3.4 order by 支持 nulls first / last
支持在 order by 子句中对空值字段进行 first/last 排序。
查询职工表并按经理 ID 排序没有经理的职工优先。
select * from employees
order by manager_id asc nulls first 查询职工表并按经理 ID 排序没有经理的职工放至最后。
select * from employees
order by manager_id asc nulls last 3.5 支持 with 语句
with 子句可以极大地提高 SQL 的可读性并且通过 with 生成可复用的中间表提高一些复杂 SQL 的执行效率。
查询财务部门已经工作5年以上薪水8000以上的职员列表并按薪水从高到低排序。该查询先查询财务部门工作5年以上的职工生成临时表 employees_with_salary_increase并在 employees_with_salary_increase 的基础上继续查询薪水在8000以上的职工信息生成 employees_with_raise表最终在 employees_with_raise 表上查询并得到最终结果。
//search for the employees that has worked more than 5 years and with a good salary
with employees_with_salary_increase as ( select employee_id, salary, year(now()) as current_year, case when year(now()) - year(hire_date) 5 then 1 else 0 end as has_5_years from employees where department_id 100 ), employees_with_raise as ( select employee_id, salary, has_5_years from employees_with_salary_increase where salary 8000 and has_5_years 1 )
select employee_id, salary, has_5_years
from employees_with_raise
order by salary desc; 如上在后续的版本中通过使用 with 语句我们可以将复杂的查询过程分解成多个步骤并且将这些步骤的结果进行临时存储。这可以大大简化查询过程并且提高查询效率。
3.6 集合运算
支持集合的并运算包括 union、union all。
将地区信息表与部门信息表合并查询查询所有的地区 ID可能存在重复记录。
union all
select location_id from locations
union all
select location_id from departments
order by location_id union
将地区信息表与部门信息表合并查询查询非重复的地区 ID。
select location_id from locations
union
select location_id from departments
order by location_id 4. join 增强
join 在分析场景应用广泛尤其是在数据仓库维度建模中通过 join 来生成大宽表服务于应用层。在之前的版中join 有诸多限制比如不支持类型不匹配的字段只支持分布式表之间关联等。DolphinDB 2.00.10 版本大大提升了 join 的功能。在标准SQL中join 的语法主要定义在 SQL92, SQL99 中SQL99 的可读性更高功能更加完备被广泛采用。
SQL92 关联特性
分类语法DolphinDB支持情况笛卡尔积from t1,t2√等值连接from t1,t2 where t1.id t2.id√非等值连接from t1,t2 where t1.id op t2.idop 包括, ,, , between…and√外连接左连接from t1, t2 where t1.id t2.id()右连接from t1, t2 where t1.id() t2.idX自连接from t t1, t t2 where t1.id op t2.idop 包括,, ,, , between…and√
SQL99 关联特性
分类语法DolphinDB支持情况交叉连接笛卡尔积t1 cross join t2√等值连接t1 [inner] join t2 on t1.id t2.id√非等值连接t1 join t2 on t1.id t2.idop包括, ,, , , between…andX外连接左连接t1 left join t2右连接t1 right join t2全连接t1 full join t2√自然连接t1 natural join t2Xusing 连接t1 [inner] join t2 using(id)X自连接t t1 join t t2 on t1.id op t2.idop 包括,, ,, , , between…and√
4.1 标准 SQL 的各种类型的关联、笛卡尔积
具体包括 cross join、inner join、left join、right join、full join。除标准SQL的关联之外还拓展了 left semi join左半连接。
cross join笛卡尔积
获取职工的两两信息表可以基于此结果集做一些关联分析。
1 . SQL 92
select *
from employees a, employees b
where a.employee_id b.employee_id
2 . SQL99 select * from employees across join employees bwhere a.employee_id b.employee_id inner join
职工表自关联获取职工、经理 ID 信息。
1 . SQL92
select e1.employee_id, e1.manager_id
from employees e1, employees e2
where e1.manager_id e2.employee_id
order by e1.employee_id, e1.manager_id 2 . SQL99
select e1.employee_id, e1.manager_id
from employees e1
inner join employees e2
on e1.manager_id e2.employee_id
order by e1.employee_id, e1.manager_id left join
职工表自关联获取职工 ID经理 ID包括没有上级经理的职工。
select e1.employee_id, e1.last_name, e2.last_name as manager_name
from employees e1
left join employees e2
on e1.manager_id e2.employee_id left semi join
left semi join 不属于标准 SQL 的范畴但应用广泛且在分布式环境有较好的性能故予以支持。
获取部门信息并展示一个薪水在2500以上的员工信息。
select department_id, department_name,employee_id, first_name, last_name, salary
from departments
left semi join employees // or left semijoin
on departments.department_id employees.department_id and employees.salary 2500
order by department_id right join
获取职工薪水、部门信息包括那些没有所属部门的职工。 select department_id, employee_id, first_name, last_name, salaryfrom departments right join employeeson departments.department_id employees.department_id and employees.salary 2500order by department_id full join
展示所有部门的职工信息包括没有员工的部门和没有所属部门的员工。 select department_id, department_name, employee_id, first_name, last_name, salaryfrom departments afull join employees bon a.department_id b.department_id 4.2 表类型拓展
参与 join 的表类型支持内存表、分布式表、维度表、非相关子查询单表、多表 join 的子查询的临时表。
查找各职员的工作历史信息, 测试各类型的表进行关联查询的兼容性情况。
select j.job_id, j.job_title, j.min_salary, h.start_date, h.end_date
from jobs j
left join job_history h
on h.job_id j.job_id
类型内存表分布式表维度表子查询内存表√√√√分布式表√√√√维度表√√√√子查询√√√√
4.3 多表级联 join
现在你可以将任意多个表 join之前的版本只能支持两个分区表的 join来拼接一些大宽表。
关联查询职工表、部门表获取详细的职工信息包括个人、经理、部门相关信息。 select a.employee_id, a.last_name, a.manager_id, b.last_name as manager_name, a.department_id, c.department_namefrom employees ainner join employees b on a.manager_id b.employee_id inner join departments c on a.department_id c.department_id 4.4 on 条件拓展
查询职工的工作历史并将 FI_ACCOUNTAC_ACCOUNT 都视为 AC_ACCOUNT会计。
select employee_id, j.job_id, j.job_title, j.min_salary, h.start_date, h.end_date
from job_history h
left join jobs j
on j.job_id case when h.job_id in (FI_ACCOUNT, AC_ACCOUNT) then FI_ACCOUNT else h.job_id end
order by employee_id 支持在 join 的条件列上做如下转换
函数case when支持整型与 STRING/SYMBOL 类型字段 join
注目前仍然不支持 on 12 这样的常量表达式对开发、框架代码可能有一些影响。
5. SQL 方言(dialect)兼容
Oracle、MySQL 等传统数据库在遵循 SQL 规范的前提下都有各自的扩展特性并且存在行为不一致的同名函数。以 substr/concat 函数为例
MySQL 执行 select substr(HelloWorld,0,4) 会返回空值Oracle 执行 select substr(HelloWorld,0,4) from dual 返回 Hell两者输入一致但是输出不一致。MySQL 中 concat 可以拼接多个字符串select concat(my, s, ql, 8)Oracle 中 concat 只能拼接两个字符串两者函数名称一致但是签名不一样。
为此DolphinDB 开发了一整套框架使得用户可以指定每个 session 选择兼容的 SQL 方言。目前已支持 Oracle 和 MySQL。其中在 Oracle 模式下已经实现了一系列的 Oracle 函数在 MySQL 模式下实现的函数还较少。后续版本会继续开发进一步提升兼容率。
5.1 脚本使用 SQL 方言
方言模式可以在客户端工具 session 级别进行指定设置后按指定的 SQL 方言进行解析执行。以 DolphinDB GUI 环境为例
设置 File → Preferences → Always show sqlStd dropDown(√) 选择对应的 SQL 方言即可目前支持 Oracle、MySQL、DolphinDB 三种模式。
下面示例以 Oracle模式按部门统计职工薪水情况包括部门信息、职工人数等
select d.department_id, d.department_name, count(a.employee_id) as num_of_employee_id,sum(a.salary) as total_salary, avg(a.salary) as avg_salary, max(a.salary) as max_salary,decode(a.job_id, IT_PROG , Programmer, FI_ACCOUNT, Accountant, Others) as job_title
from employees a
inner join departments d
on a.department_id d.department_id
group by d.department_id, d.department_name, decode(a.job_id, IT_PROG , Programmer, FI_ACCOUNT, Accountant, Others) as job_title 上述代码使用了 Oracle 的 decode 函数除此之外目前还支持 concat, sysdate, nvl, to_char, to_date, to_number, regexp_like, trunc, asciistrinstrrow_number。通过设置 SQL 方言使用 Oracle 的应用程序迁移至 DolphinDB 时SQL 代码迁移成本大大降低。 MySQL 模式的使用方式类似方言选项选择 MySQL 即可。目前 MySQL 只支持 sysdate() 函数后续版本会逐步提高兼容性。
5.2 API 使用 SQL 方言
Java API
使用 Java API 时可以在构造 DBconnection 对象时输入 SqlstdEnum, 包括 DolphinDBOracleMySQL。
package com.dolphindb.sqlstd;import com.xxdb.DBConnection;
import com.xxdb.comm.SqlStdEnum;
import com.xxdb.data.Entity;
import java.io.IOException;public class OracleMode {public static void main(String[] args) throws IOException {DBConnection connection new DBConnection(SqlStdEnum.Oracle);connection.connect(192.168.1.206, 11702, admin, 123456);String sql String.format(select employee_id, first_name, last_name, \n decode(job_id, IT_PROG , Programmer, FI_ACCOUNT, Accountant, Others) as jobs_title\n from loadTable(%s, %s) a, \dfs://hr\, \employees\);Entity result connection.run(sql);System.out.println(result.getString());}
}
JDBC
使用 jdbc 时需要在 url 上增加配置项 sqlStd。
spring.datasource.urljdbc:dolphindb://192.168.1.206:11702?databasePathdfs://hrsqlStdOracle
spring.datasource.usernameadmin
spring.datasource.password123456
spring.datasource.driver-class-namecom.dolphindb.jdbc.Driver
6. 总结
DolphinDB自1.30.22 / 2.00.10 版本起对标准 SQL 的常用语法和关键字实现了兼容包括
大小写兼容SQL 关键字支持全大写或全小写字段名大小写不敏感但数据库名/表名还是大小写敏感SQL 语句换行解析支持在 SQL 语句中任意位置的换行支持谓词支持的关键字有 (not) in, (not) like, (not ) between and, (not) exists, is (not) nulldistinct 支持多列distinct 支持对多个字段一起去重暂不支持与 group by, context by, pivot by 联用order by 支持 nulls first/last支持 with as 语句支持 is null, is not null支持 union、union all支持 any、all支持多表 join支持的 join 包括 cross join, inner join, left join, right join, full join, left semi joinleft semijoin 也支持 。 支持用 comma (,) 来表示 cross joina join b如果后面没有跟 on 条件表示 cross join否则表示 inner join。on 条件列支持函数、 case when以前只能是表的某一个字段。支持整型与字符串类型的 join。支持 join 对象是子查询支持多分区表的 join以前只能支持两分区表的 join支持子查询。 join 的表可以是内存表、分区表、维度表、单表子查询、多表 join 的子查询。暂不支持子查询使用父查询的字段
另外针对 Oracle、MySQL 等传统数据库在遵循 SQL 规范的前提下都有各自的扩展特性、特别是有同名函数但行为不一致的情况DolphinDB 开发了一整套框架使得用户可以为每个会话(session)选择兼容的 SQL 方言目前在 Oracle 模式下已经实现了一系列的 Oracle 函数。 后续版本 DolphinDB 会继续进行 SQL 标准化的开发进一步提升兼容率。例如对于在 SQL-2003 标准中引入的开窗函数将会在下个主要版本2.00.11支持。
