网站首页 > 精选教程 正文
生活中,你我一定都看到过这种「xx元爆改出租屋」,「爆改小汽车」之类的文章,做为IT人,折腾的劲头一点也不差。
软件开发过程中,你是否有时候,会拿着业务提供的一个个CSV或者JSON的数据文件,写个解析程序,把它们存到数据库里,再在自己的程序里通过数据库读出来?
其实不用这么麻烦,还绕了一个大圈。
今天,我们一起来「爆改」JSON/CSV这类文件,把它们打造成 MySQL一样的关系型数据库,一套SQL查询走天下。:-)
第一步:代码里加入Maven依赖
<dependency>
<groupId>org.apache.calcite</groupId>
<artifactId>calcite-file</artifactId>
<version>1.21.0</version>
</dependency>
通过这一步,你大概就看出来,咱们今天的爆改,主要依赖 Calcite,这个Apache的顶级项目。
来张官网截图感受下:
简单介绍的话,它是个数据库查询和优化的引擎,不负责具体的存储。
所以介绍里人家自己也说了,是你高性能数据库的地基。许多的开源项目是基于它做的,比如大名鼎鼎的这些:
第二步:添加配置文件
配置的JSON 文件,一般是下面这样子:
改造的配置文件,就像行军打仗的地图一样,来告诉我们往哪走,这里的配置文件,对应到关系型数据库里,就像是哪个库,哪些表一样。
{
"version": "1.0",
"defaultSchema": "SALES",
"schemas": [
{
"name": "SALES",
"type": "custom",
"factory": "org.apache.calcite.adapter.file.FileSchemaFactory",
"operand": {
"directory": "sales"
}
}
]
}
其中schemas 表示都有哪些数据库, defaultSchema 当然是默认数据库了。factory 表示当前的数据文件,我们使用哪种Schema的形式进行解析。因为 Calcite 可以支持多种数据格式,通过这个图你也能感受到几分吧。
第三步:JDBC Style
通过 JDBC 的形式就能连接到我们自己的数据库查询了。代码和一般的JDBC类似,区别只在于连接URL的写法上,需要将配置文件的位置声明一下。
public class Demo {
public static void main(String[] args) throws SQLException, ClassNotFoundException {
Class.forName("org.apache.calcite.jdbc.Driver");
Properties config = new Properties();
config.put("model", "./src/main/resources/model.json");
String sql = "select * from hello";
try (Connection con = DriverManager.getConnection("jdbc:calcite:", config)) {
try (Statement stmt = con.createStatement()) {
ResultSet rs = stmt.executeQuery(sql);
while (rs.next()) {
System.out.println(rs.getString(2));
}
}
}
}
}
其中SQL 语句,可以支持条件过滤,join 等所有的标准SQL。
整体项目结构如下:
PS: 忘了提一句,对于CSV文件,第一行需要将各列列名和类型加上,表示数据库表里定义的列。
你说我很忙,不想啰哩啰嗦再写个Java程序,办法也还有。有个程序叫 sqlline,可以方便你在命令行里执行,一个脚本连接到对应的文件数据库之后,就开始你飞一般的SQL表演吧。
sqlline> !connect jdbc:calcite:model=src/main/resources/model.json admin admin
Have fun!
作者:Tomcat那些事儿
原文:https://my.oschina.net/u/4585957/blog/4875292
- 上一篇: 轻松地解析和生成CSV文件
- 下一篇: kettle系列教程之-1读取CSV文件并插入数据库
猜你喜欢
- 2024-12-16 Spring Boot实战:通过Spring Batch处理批量订单数据
- 2024-12-16 这 6 爬虫开源项目 yyds
- 2024-12-16 Python数据分析新纪元!DuckDB1.0正式版尝鲜~
- 2024-12-16 常用Java开发工具介绍
- 2024-12-16 软件测试工具之JMeter教程
- 2024-12-16 一文深度讲解JVM 内存分析工具 MAT及实践(建议收藏)
- 2024-12-16 ElasticSearch数据导入
- 2024-12-16 零代码+逻辑引擎的完美结合,轻松实现复杂业务
- 2024-12-16 省级、地级、县级、乡级和村级多级联动开源实现(附开源地址)
- 2024-12-16 不要错过这8款好用的开源报表工具
你 发表评论:
欢迎- 最近发表
- 标签列表
-
- nginx反向代理 (57)
- nginx日志 (56)
- nginx限制ip访问 (62)
- mac安装nginx (55)
- java和mysql (59)
- java中final (62)
- win10安装java (72)
- java启动参数 (64)
- java链表反转 (64)
- 字符串反转java (72)
- java逻辑运算符 (59)
- java 请求url (65)
- java信号量 (57)
- java定义枚举 (59)
- java字符串压缩 (56)
- java中的反射 (59)
- java 三维数组 (55)
- java插入排序 (68)
- java线程的状态 (62)
- java异步调用 (55)
- java中的异常处理 (62)
- java锁机制 (54)
- java静态内部类 (55)
- java怎么添加图片 (60)
- java 权限框架 (55)
本文暂时没有评论,来添加一个吧(●'◡'●)