介绍
SybnDaoDriver 可以作为 mongo, solr, hbase, elastic 等数据源的 jdbc 简易驱动使用.
SybnDaoDriver 的底层实现是 SqlDdlDao, 因此支持 SqlDdlDao 的所有 sql 特性.
SybnDaoDriver 目前只支持 select, show tables 等查询, 暂时只允许单表查询.
因为 SqlDdlDao 短期内暂不考虑支持使用 sql 修改数据, 所以 SybnDaoDriver 短期内也不支持.
如需修改数据,可以使用 SqlDdlDao 中的 commonSave 和 commonUpdate 等方法.
maven 依赖
<dependency>
<groupId>cn.linpengfei.sybnutil</groupId>
<artifactId>sybn-jdbc-driver</artifactId>
<version>0.3.7-SNAPSHOT</version>
</dependency>
jdbc demo
- jdbc 驱动直接查询 mongodb 3.6
// 创建 jdbc 连接
String url = "jdbc:mongo://127.0.0.1:27017/junit_test";
Map<String, String> n = MB.n("user", "junit_test_user", "password", "junit_test_pass");
Properties properties = new SybnProperties(n);
Connection connect = new SybnDaoDriver().connect(url, properties);
// 被执行的 sql
String selectSql = "select * from sybn_junit_crud_test_entry where type = ? limit 1";
// 使用 jdbc 执行此 sql
PreparedStatement selectStatement = connect.prepareStatement(selectSql);
selectStatement.setInt(1, 0); // type = 0
ResultSet selectResultSet = selectStatement.executeQuery();
List<Map<String, Object>> select = HandlerUtil.MAP_LIST_HANDLER.handle(selectResultSet);
selectResultSet.close();
// 打印结果
LogUtil.info("select", select.size(), select);
- 执行日志
08-20 20:30:12.925 [main] INFO org.mongodb.driver.connection - Opened connection [connectionId{localValue:2, serverValue:50}] to 127.0.0.1:27017
08-20 20:30:13.866 [main] INFO cn.sybn.util.base.LogUtil - select 1 [{"msg":"commonSaveOrReplace","date":"2019-08-20 18:14:01","_id":"9999","type":0,"num":9999}]
dataSource demo
- 通过 dataSource 指定驱动包名查询 mongodb 3.6
// 创建 jdbc 连接
String url = "jdbc:mongo://127.0.0.1:27017/junit_test";
BasicDataSource dataSource = new BasicDataSource();
dataSource.setDriverClassName("cn.sybn.util.io.driver.SybnDaoDriver");
dataSource.setUrl(url);
dataSource.setUsername("junit_test_user");
dataSource.setPassword("junit_test_pass");
Connection connect = dataSource.getConnection();
// 被执行的 sql
String selectSql = "select * from sybn_junit_crud_test_entry where type = ? limit 1";
// 使用 jdbc 执行此 sql
PreparedStatement selectStatement = connect.prepareStatement(selectSql);
selectStatement.setInt(1, 0); // type = 0
ResultSet selectResultSet = selectStatement.executeQuery();
List<Map<String, Object>> select = HandlerUtil.MAP_LIST_HANDLER.handle(selectResultSet);
selectResultSet.close();
// 打印结果
LogUtil.info("select", select.size(), select);
- 执行日志
08-20 20:35:46.616 [main] INFO org.mongodb.driver.connection - Opened connection [connectionId{localValue:2, serverValue:52}] to 127.0.0.1:27017
08-20 20:35:47.717 [main] INFO cn.sybn.util.base.LogUtil - select 1 [{"msg":"commonSaveOrReplace","date":"2019-08-20 18:14:01","_id":"9999","type":0,"num":9999}]
数据源支持
- 目前已支持以下数源据:
jdbc:mysql://127.0.0.1:3306/db # 适配 5.X 其他版本未测试
jdbc:mongo://127.0.0.1:27017/db # 适配: 3.6.X 其他版本未测试
jdbc:solr://127.0.0.1:8983/solr # 适配 5.X 以上本文
jdbc:es://127.0.0.1:2181 # 适配: 7.X 其他版本未测试
jdbc:hbase://127.0.0.1:2181 # 适配1.2.X 其他版本未测试
- 即将支持文件数据源,直接将文件当作数据库查询:
直接访问以下任意格式的磁盘文件(支持读取jar包内外的文件,只允许读取白名单中的目录)
jdbc:file://home/user/xxx.xls?startRows=2
jdbc:file://d:/data/xxx.xlsx?startRows=2
jdbc:file://xxx.csv?chatset=GBK # 没有路径时, 从jar内查找文件
jdbc:file://./xxx.json?root=data # 相对路径
直接访问以下任意格式的http请求结果(只允许读取白名单中的url)
jdbc:http://www.linpengfei.cn/xxx.xls?startRows=2
jdbc:http://user:pass@www.linpengfei.cn/xxx.xlsx?startRows=2 # 允许在路径中增加账户密码
jdbc:ftp://www.linpengfei.cn/xxx.csv?chatset=GBK
jdbc:https://www.linpengfei.cn/xxx.json?root=data
jdbc properties 参数支持 V 0.3.7
| 参数 | mysql / gbase | mongo | solr | elastic | hbase |
|---|---|---|---|---|---|
| username | 支持 | 支持 | - | - | - |
| password | 支持 | 支持 | - | - | - |
| socketTimeout | 暂不支持 | 支持 | 不支持 | 支持 | 不支持 |
| socketTimeoutSec | 暂不支持 | 支持 | 不支持 | 支持 | 不支持 |
| authSource | - | 支持 | - | - | - |
