一、avatica项目介绍
avatica作为calcite的子项目,提供JDBC、ODBC标准的数据库驱动,通过该项目,我们可以自由构建自研数据库的java驱动,或者通过该项目代理一些非JDBC、ODBC标准的数据库,而不需要改动上层的服务代码。avatica项目核心架构图如下(摘自官网)
二、avatica项目使用
利用avatica的代码,我们搭建一个mysql数据库的proxy server,并使用client代码测试该代理是否成功。
1.服务端代码:进入avatica项目的server module,修改该module下的Main.start(String[] args, int port, HandlerFactory handlerFactory)方法,直接生成自己的meta(我们这里使用项目自带的JdbcMeta),改动代码如下:
Meta meta = new JdbcMeta("jdbc:mysql://xxx.com:3306/xx_db");
Service service = new LocalService(meta);
代码改动之后可以直接启动该proxy server
2.客户端测试代码如下:
Class.forName("org.apache.calcite.avatica.remote.Driver");
Connection conn = DriverManager.getConnection("jdbc:avatica:remote:url=http://localhost:8765","username","password");
Statement statement = conn.createStatement();
ResultSet rs = statement.executeQuery("select count(*) from xxx_table");
while(rs.next()){
System.out.println(rs.getString(1));
}
rs.close();
statement.close();
conn.close();
直接本地启动即可看到测试结果
3.avatica其他connection使用方式和参数可以参考官网:https://calcite.apache.org/avatica/docs/client_reference.html