生活中,你我一定都看到过这种「xx元爆改出租屋」,「爆改小汽车」之类的文章,做为IT人,折腾的劲头一点也不差 。
软件开发过程中,你是否有时候,会拿着业务提供的一个个CSV或者JSON的数据文件,写个解析程序,把它们存到数据库里,再在自己的程序里通过数据库读出来?
其实不用这么麻烦,还绕了一个大圈 。
今天,我们一起来「爆改」JSON/CSV这类文件,把它们打造成 MySQL一样的关系型数据库,一套SQL查询走天下 。:-)
第一步:代码里加入Maven依赖
通过这一步,你大概就看出来,咱们今天的爆改,主要依赖 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那些事儿
- together bnb攻略 together bnb百度百科
- 广东高校有多少所 广东高校名单大全
- 我叫mt第七季 我叫mt手游
- 流金岁月剧情分集介绍 流金岁月剧情分集介绍百度百科
- 少林传奇 少林传世百度百科
- 小菊的春天片尾曲歌名 小菊的春天百度百科
- 我的世界自定义npcmod百科 我的世界自定义NPC指令代码
- 绿豆刷机神器 绿豆刷机神器百科
- 暗疮百度百科 暗疮是怎么引起的图片
- 小说万古神兽 万古神兽百度百科
特别声明:本站内容均来自网友提供或互联网,仅供参考,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。
