3 接口使用说明

3.1 数据定义接口（DDL）

3.1.1 创建数据库

3.1.1.1 创建数据库

3.1.1.2 示例代码

引入DataSongClient驱动包，实现如下：

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);
boolean result = dataSongClient.createDB(dbName);
System.out.println(result);

注意：dbName只能包含字母或数字且不能以数字开头

3.1.2 创建数据表

3.1.2.1 接口说明

3.1.2.2 示例代码

引入DataSongClient驱动包，实现如下：

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);dataSongClient.setDatabaseName(dbName);//注意需要指定数据库boolean result = dataSongClient.createTable(Student.class);
System.out.println(result);

注意1：首次使用dataSongClient实例，需要制定操作的数据库，指定一次即可。
注意2：表的创建可以直接通过class自动完成，Student定义如下:

@DSStoreType(StoreType.Fulltext)//指定表的存储类型，如fulltext、sql等
@DSTableName(value = "student")//指定数据库名字，可不指定，默认会自动用类名
public class Student extends DataSongBean {@DSFulltextIndexType(FulltextIndexType.None)//设置仅存储，不索引，即不可作为条件检索，节约存储空间private String classid;@DSFulltextIndexType(FulltextIndexType.None)private Date createtime;@DSFulltextIndexType(FulltextIndexType.Whitespace)//设置空格分词private String interest;@DSFulltextIndexType (FulltextIndexType.IK)  //设置中文分词private String name;private int age;//不设置，默认可检索@DSFulltextIndexType(FulltextIndexType.None)private Date birth;
}

1）DataSongBean中内置了内部唯一标识_id，即DataSong所有表都会有一个内置的唯一id。
2）DataSong的所有注解都是“DS”开头，分为类级别和属性级别，如下图所示：

不同的存储类型（DSStoreType）应该对应不同的索引类型（DSFulltextIndexType、DSGraphIndexType、DSMemIndexType、DSNoSqlIndexType、DSSqlIndexType）。其他的属性级别注解不用区分存储类型。

3.1.3 删除数据表

3.1.3.1 接口说明

3.1.3.2 示例代码

引入DataSongClient驱动包，实现如下：

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);dataSongClient.setDatabaseName(dbName);//注意需要指定数据库boolean result = dataSongClient.deleteTable(Student.class);
System.out.println(result);

注意：此删除为物理删除，一经删除，不能恢复。

3.1.4 删除数据库

3.1.4.1 接口说明

3.1.4.2 示例代码

引入DataSongClient驱动包，实现如下：

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);boolean result = dataSongClient.deleteDB(dbName);System.out.println(result);

注意：此删除为物理删除，一经删除，不能恢复。

3.2 数据操作接口（DML）

3.2.1 数据查询接口

3.2.1.1 接口说明

内部查询体系如下：

3.2.1.2 示例代码

（1） 查询条件构建
精确匹配条件:

//写法1.1
TermSearchCondition term = new TermSearchCondition();term.setValue(new int[]{ 6, 7});term.setColumn("age");//写法1.2
TermSearchCondition ageTermSearchCondition  = ConditionBuilder.termCondition("age",  7);//写法2.1
TermSearchCondition interestTermSearchCondition  = ConditionBuilder.termCondition("interest", new String[]{"跳高","篮球"});//写法2.2
TermSearchCondition interestTermSearchCondition  = ConditionBuilder.termCondition("interest", "跳高 篮球");//对查询条件也会自动分词

范围查询条件

//写法1
RangeSearchCondition rangeSearchCondition = new RangeSearchCondition();rangeSearchCondition.setFrom("2021-02-07 18:25:04");
//    rangeSearchCondition.setTo("2021-02-07 18:25:05.6");//可以只设置一边的限制rangeSearchCondition.setColumn("createtime");//写法2
RangeSearchCondition   createtimeRangeSearchCondition = ConditionBuilder.rangeCondition("createtime","2021-03-06 8:25", "2021-03-06 18:25:05.6");

Bool查询条件

BoolSearchCondition boolSearchCondition = new BoolSearchCondition();boolSearchCondition.must(rangeSearchCondition);//.must(ageTermSearchCondition).must(createtimeRangeSearchCondition);

（2） 统计条件构建
说明：统计满足查询条件的数据集中数据的分布情况。基础的单值统计不能多级级联，分组统计支持多级级联，可以类比SQL查询。统计结果是以table的形式返回，同样可以类比SQL查询。所有统计需要设置一个别名Alias，同一个查询中的多个条件，别名不能重复。

均值统计

//写法1
AvgStatisticCondition avgStatisticCondition = new AvgStatisticCondition();
avgStatisticCondition.setAlias("avg");
avgStatisticCondition.setColumn("age");
//写法2
AvgStatisticCondition c1 = ConditionBuilder.avgStatisticCondition("age", "平均值统计");

求和统计

//写法1
SumStatisticCondition sumStatisticCondition = new SumStatisticCondition();
sumStatisticCondition.setAlias("sum");
sumStatisticCondition.setColumn("age");//写法2
SumStatisticCondition c2 = ConditionBuilder.sumStatisticCondition("age", "求和统计");

计数统计

CountStatisticCondition c4 = ConditionBuilder.countStatisticCondition("age", "count统计");

按日期区间分组统计——支持设置下一级

//对createtime列，按天分组统计
DateRangeStatisticCondition dateRangeStatisticCondition = ConditionBuilder.dateRangeStatisticCondition("createtime", "time_statistic", DateInterval.Day);//日期区间可以设置下一级统计
dateRangeStatisticCondition.addChild(c4);
dateRangeStatisticCondition.addChild(c5);

按类型分组统计——支持设置下一级

//对interest列，分组统计
TermStatisticCondition termStatisticCondition = ConditionBuilder.termStatisticConditiontermStatisticCondition.setColumn("interest");termStatisticCondition.setAlias("alias");termStatisticCondition.addChild(c4);termStatisticCondition.addChild(sumStatisticCondition);

（3） 查询

SearchDataRequest searchDataRequest = new SearchDataRequest();//设置查询条件
searchDataRequest.setSearch(boolSearchCondition);
//添加统计条件，允许并行设置多个统计条件，索引采用add方式searchDataRequest.addStatistic(c3);//设置分页searchDataRequest.setStart(0);searchDataRequest.size(5);//设置排序searchDataRequest.sort("birth", SortOrder.ASC);searchDataRequest.sort("createtime", SortOrder.DESC);//设置需要取的列
searchDataRequest.setColumns(new String[] {"interest"});//不设置默认返回所有列DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip, port);dataSongClient.setDatabaseName(dbName);DataSongSearchResult response = dataSongClient.getDataService().searchData(Student.class ,searchDataRequest);//设置实体类，会自动进行翻转//命中总条数System.out.println("符合条件的总条数："+response.getTotal());//解析查询结果（如果有）
for(int i = 0 ; i <response.getItems().size(); i++) {System.out.println(DataSongJsonUtils.toJson(response.getItems().get(i)));}//解析统计结果（如果有）
//返回结构封装成了与jdbc协议中ResultSet一样的结构（即表格结构）
for(int index = 0 ;  index < response.getStatistics().size() ; index++){DataSongResultSet resultSet = (DataSongResultSet) response.getStatistics().get(index);//表头解析，即用户自定义别名ResultSetMetaData rsmd = resultSet.getMetaData();for (int i = 1; i <= rsmd.getColumnCount(); i++) {System.out.print(rsmd.getColumnName(i)+"\t\t");}System.out.println();//结构解析while(resultSet.next()){for(int i=1;i<=rsmd.getColumnCount();i++){System.out.print(resultSet.getObject(i));System.out.print("\t\t");}System.out.println();}
}

3.2.1 数据插入与修改

3.2.1.1 接口说明

3.2.1.2 示例代码

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);dataSongClient.setDatabaseName("test");StudentBean studentBean = new StudentBean();
//    studentBean.set_id("1"); //非必须设置studentBean.setAge(2);studentBean.setClassid("sdf");studentBean.setCreatetime(new Date());studentBean.setName("sdfssdfdf");studentBean.setInterest("足球 篮球 乒乓球");dataSongClient.getDataService().saveData("StudentBean",studentBean); //对于相同_id的数据，会直接覆盖。所以，修改数据时需要把不需要修改的字段也带上，遵循rest规范。//批量插入
List<StudentBean> datas = new ArrayList<>();
dataSongClient.getDataService().batchSaveData( datas);

说明：插入时表名不是必须显示的指定，可以根据数据类型自动解析对应的表名。

3.2.2 数据删除

3.2.2.1 接口说明

3.2.2.2 示例代码

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);
dataSongClient.setDatabaseName("test");boolean result = dataSongClient.getDataService().deleteData(StudentBean.class, "11"); //表名可以是类，可以是字符串System.out.println(result);//批量删除写法如下：
List<String> ids = Arrays.asList(new String[]{"11","12","13"});
long result = dataSongClient.getDataService().batchDeleteData(StudentBean.class, ids); //库名可以是类，可以是字符串

3.2.3 数据检索

老版接口，功能更全，使用起来比较繁琐，不推荐使用。

3.2.4数据获取

3.2.4.1 接口说明

3.2.4.2 代码示例

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);
dataSongClient.setDatabaseName("test");//实质库名StudentBean result = dataSongClient.getDataService().getData(StudentBean.class, "1"); //表名可以是类，可以是字符串。如果是字符串返回的是json格式System.out.println( DataSongJsonUtils.toJson(result));//如果是批量获取，写法如下
List<String> ids = Arrays.asList(new String[]{"1","2","3"});
List<StudentBean> result = dataSongClient.getDataService().batchGetData(StudentBean.class, ids); //表名可以是类，可以是字符串

3.2.5 数据清空

3.2.5.1 接口说明

3.2.5.2 代码示例

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);
dataSongClient.setDatabaseName("test");boolean result = dataSongClient.getDataService().clearData(StudentBean.class); //表名可以是类，可以是字符串System.out.println( result);

3.3 文件操作接口

3.3.1 文件本地上传

3.3.1.1 接口说明

3.3.1.2 代码示例

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);
dataSongClient.setDatabaseName("test");String id = dataSongClient.getFileService().uploadFile(StudentBean.class,"D:\\新建文本文档.txt"); //对于相同_id的数据，会直接覆盖System.out.println( id);

3.3.2 文件删除

3.3.2.1 接口说明

3.3.2.2 代码示例

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);
dataSongClient.setDatabaseName("test");
boolean id = dataSongClient.getFileService().deleteFile(StudentBean.class,"dddddddd");
System.out.println( id);

3.3.3 文件下载

3.3.3.1 接口说明

3.3.3.1 代码示例

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);
dataSongClient.setDatabaseName("test");boolean id = dataSongClient.getFileService().downloadFile(StudentBean.class,"dddddddd","d://ddd.txt");System.out.println( id);

3.3.4 文件流式上传

3.3.4.1 接口说明

3.3.4.2 代码示例

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);
dataSongClient.setDatabaseName("test");FileInputStream inputStream = new FileInputStream(new File("D:\\新建文本文档.txt"));//流也可以通过浏览器回传的流获取String id = dataSongClient.getFileService().uploadFile(StudentBean.class,"新建文本文档.txt",inputStream); //对于相同_id的数据，会直接覆盖System.out.println( id);

3.3.5 文件流式下载

3.3.5.1 接口说明

3.3.5.2 代码示例

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);
dataSongClient.setDatabaseName("test");InputStream inputStream = dataSongClient.getFileService().downloadFileStream(StudentBean.class,"dddddddd");System.out.println( inputStream);

3.3.6 文件预览

3.3.6.1 接口说明

3.3.6.2 代码示例

DataSongClient dataSongClient = DataSongHttpClient.getInstance(ip,port);
dataSongClient.setDatabaseName("test");boolean result = dataSongClient.getFileService().previewFile(StudentBean.class,"dddddddd", servletResponse);System.out.println( result);

DataSong大数据智能管理平台 用户手册-开发部分相关推荐

1. 大数据平台常用组件_这款大数据智能服务平台火了！全自动化配置30+款开源大数据组件...

   在互联网市场的头部效应下,企业所面临的竞争压力越来越大,如何有效解决获客成本高.用户黏性低.变现能力弱等问题,正是越来越多的企业开始构建大数据平台的初衷.但由于大数据解决方案所涉及的组件错综复杂.技术 ...

2. 基于炼铁大数据智能互联平台推动传统工业转型升级

   基于炼铁大数据智能互联平台推动传统工业转型升级 赵宏博1,2,刘伟1,李永杰1,王强1,吴建1 1. 北京北科亿力科技有限公司,北京 100102 2. 北京东方国信科技股份有限公司,北京 10010 ...

3. 大快搜索城市运河大数据政务管理平台案例解读

   2019独角兽企业重金招聘Python工程师标准>>> 大快搜索城市运河大数据政务管理平台案例解读 大数据在政务当中的应用对于提高问题解决的效率可谓大有帮助,但政务大数据平台的应用开 ...

4. 网龙入股大数据智能教育平台 -- “爱多分”

   拓展智能教育布局  深化大数据应用 香港2018年11月14日电 /美通社/ -- 全球领先的互联网社区创建者 -- 网龙网络控股有限公司 ("网龙"或"本公司" ...

5. 企业大数据CDH管理平台搭建方案

   1 基本介绍 1.1 概述 Hadoop的发行版本有很多,有华为发行版,Intel发行版,Cloudera发行版(CDH),MapR版本,以及HortonWorks版本等.所有发行版都是基于Apach ...

6. 深度解析大数据可视化管理平台的监控功能

   在上一篇的文章中已经明确说过DKM作为大快发行版DKhadoop的管理平台,它的四大功能分别是:管理功能,监控功能,诊断功能和集成功能.管理功能已经给大家列举了一些做了说明,今天就DKM平台的监控功能 ...

7. 智慧交通大数据可视化管理平台建设方案

   "智慧交通大数据可视化与虚拟仿真突发事件应对管理决策服务平台"是一个针对交通管控单位的综合型辅助管理决策服务平台和三维仿真突发事件应对系统,系统以实际的交通设备和运输能力分布为基础 ...

8. 31页大数据治理管理平台解决方案合集

   以下为部分内容,文档获取方式见文末 背景与需求分析随着各地正在逐渐成立大数据中心,并响应职责与市大数据中心对应,来推进各区公共数据的统采集.归集.整合.共享.开放和应用,建设各区数据资产,改善和解决数 ...

9. 战疫之下的“大数据+网格化”管理，谁在颠覆“智能城市”的路径？

   文 | 陈选滨 来源丨智能相对论(ID:aixdlun) 如果说过去"智能城市"的重点仍放在顶层设计架构,那么在此次防疫工作的紧急需求下,这一项目便不得不以另一种更快的方式下沉,落 ...

最新文章

1. html div坐标定位,html div位置和显示
2. IDEA配置NodeJS项目遇到问题及解决
3. iis 程序池设置及详解-20180720
4. python进程池multiprocessing.Pool运行错误：The freeze_support() line can be omitted if the program is not g
5. java开发面试复试_java开发实习生面试经历
6. Vue-CLI——自定义title解决方案
7. QT绘制散点图(2)
8. PHP设置文本框背景透明度,如何给background-image设置透明度？
9. javascript number转string不用科学计数法_[JavaScript]之数据类型篇
10. JSP、Servlet、Tomcat、JDK、J2EE版本比较
11. 学java要背的单词_学习JAVA必背的8类常用单词
12. 敏捷项目管理流程-Scrum框架最全总结
13. 组合枚举——妖梦拼木棒(洛谷 P3799)
14. 受疫情影响：中国智能手机市场Q1出货量下滑严重
15. Ext.chart.Chart 显示图标 -- 本地数据
16. 求水面面积（C语言）
17. VS2005 使用过程中有用的一些快捷键和小技巧
18. Caffe环境搭建指北
19. Adam自适应矩估计
20. Studio 3T破解方式

热门文章

1. Web安全之防止短信炸弹
2. 前进永无止境！Pipeline更新又双叒叕来了！
3. 利用DncZeus框架开发UWB室内定位网关
4. python ftp上传/下载文件，带进度条显示
5. javascript闭包的前世今生
6. OpenWrt 网络设置（六）
7. windows 下 用 dos 备份 oracle 数据库，并删除七天前的备份
8. NGS数据过滤之trimmomatic
9. 水晶报表 发布 部署
10. Unix.Trojan.DDoS_XOR-1、Linux.Trojan.Agent（Linux.BackDoor.Gates.5）木马清理