做品牌折扣微信推广的网站,我要买房网,昆明行业网站建设,烟台专业做网站的公司生活中#xff0c;你我一定都看到过这种「xx元爆改出租屋」#xff0c;「爆改小汽车」之类的文章#xff0c;做为IT人#xff0c;折腾的劲头一点也不差。软件开发过程中#xff0c;你是否有时候#xff0c;会拿着业务提供的一个个CSV或者JSON的数据文件#xff0c;写个解…生活中你我一定都看到过这种「xx元爆改出租屋」「爆改小汽车」之类的文章做为IT人折腾的劲头一点也不差。软件开发过程中你是否有时候会拿着业务提供的一个个CSV或者JSON的数据文件写个解析程序把它们存到数据库里再在自己的程序里通过数据库读出来其实不用这么麻烦还绕了一个大圈。今天我们一起来「爆改」JSON/CSV这类文件把它们打造成 MySQL一样的关系型数据库一套SQL查询走天下。:-)第一步代码里加入Maven依赖 org.apache.calcite calcite-file 1.21.0通过这一步你大概就看出来咱们今天的爆改主要依赖 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:modelsrc/main/resources/model.json admin adminHave fun!作者Tomcat那些事儿原文https://my.oschina.net/u/4585957/blog/4875292
