sql ddl dao 通用查询引擎

// sql 语句
String sqlFind = "select * from sybn_junit_base where id between '2018-03-20' and '2018-03-21'";
String sqlCount = "select count(*) from sybn_junit_base where id between '2018-03-20' and '2018-03-21'";

// 1. 以url形式构造不同数据库实例执行查询
// mysql / mongo / solr / HBase 数据量大时, 可以使用 StreamDao 以 Stream 流形式返回数据
SqlDdlDao dao = new DbutilDaoImpl("jdbc:mysql://账户:密码@192.168.4.31:3306,192.168.4.32:3306/demo"); // sql
SqlDdlDao dao = new MongoDaoImpl("mongodb://账户:密码@192.168.4.31:27017,192.168.4.32:27017/demo"); // mongo
SqlDdlDao dao = new SolrDaoImpl("solr://192.168.7.71:2181,192.168.7.72:2181/solr"); // solr
SqlDdlDao dao = new HBaseDaoImpl("hbase://192.168.7.71,192.168.7.72/hbase-unsecure"); // HBase
List<Map<String, Object>> sqlFindListMap = dao.sqlFindListMap(sqlFind);
List<SybnJunitBase> sqlFindList = dao.sqlFindList(sqlFind, SybnJunitBase.class);
long count = dao.sqlCount(sqlCount);

// 2. 直接查询jvm中的数据
List<Map<String, Object>> sqlFindListMap = DatasSqlDdlEngine.sqlFindListMap(list, sqlFind);
List<SybnJunitBase> sqlFindList = DatasSqlDdlEngine.sqlFindList(list, sqlFind, SybnJunitBase.class);

Set<String> udfNames = SybnUdfUtil.getUdfNames();
// 截止 2019-07-24 支持的 udf 完整列表为: (不区分大小写) ["toint","compare","upper","topercent","replace","weekday","subdate","convert","curdate","from_days","tofloat","substring","date_sub","toset","cast","trim","todate","now","str_to_date","tolowercase","tolist","ifnull","md5_16","adddate","todouble","concat_ws","nvl","lower","timestampdiff","concat","replaceall","splitsubstring","date_add","tolong","dayofweek","date_format","calc","touppercase","tostring","to_days","md5"]

SqlDdlDao dao = new DbutilDaoImpl("jdbc:mysql://username:password@192.168.4.31:3306,192.168.4.32:3306/demo"); // sql
SqlDdlDao dao = new MongoDaoImpl("mongodb://username:password@192.168.4.31:27017,192.168.4.32:27017/demo"); // mongo
SqlDdlDao dao = new SolrDaoImpl("solr://192.168.7.71:2181,192.168.7.72:2181/solr"); // solr
SqlDdlDao dao = new HBaseDaoImpl("hbase://192.168.7.71,192.168.7.72/hbase-unsecure"); // HBase

SqlDdlDao dao = new DbutilDaoImpl("jdbc:mysql://192.168.4.31:3306/demo", "username", "password"); // sql
SqlDdlDao dao = new MongoDaoImpl("mongodb://192.168.4.31:27017/demo", "username", "password", "authDatabase"); // mongo

SqlDdlDao dao = new DbutilDaoConfImpl("sql.demo@db.properties"); // sql
SqlDdlDao dao = new MongoDaoConfImpl("mongo.demo@db.properties"); // mongo
SqlDdlDao dao = new SolrDaoConfImpl("solr.demo@db.properties"); // solr
SqlDdlDao dao = new HBaseDaoConfImpl("hbase.demo@db.properties"); // HBasemongo

// 从 properties 中读取 sql.test 构造dao
Properties properties = new SybnCoreProperties().load("db.properties");
DbutilDao dao2 = new DbutilStreamDaoPropertiesImpl(sybnDbProperties, "test");

SqlDdlDao dao = new DbutilDaoPropertiesImpl(properties, "sql.demo"); // sql
SqlDdlDao dao = new MongoDaoPropertiesImpl(properties, "mongo.demo"); // mongo
SqlDdlDao dao = new SolrDaoPropertiesImpl(properties, "solr.demo"); // solr
SqlDdlDao dao = new HBaseDaoPropertiesImpl(properties, "hbase.demo"); // HBasemongo

@Resource(name="sql_demo") 
DataSource dataSource;

@Resource(name="mongo_demo") 
MongoTemplate mongoTemplate

// ... ...

SqlDdlStreamDao dao = new DbutilStreamDaoImpl("spring_sql", dataSource);
SqlDdlStreamDao dao = new MongoStreamDaoImpl("spring_mongo", mongoTemplate.getDb);

// 执行 sql 查询 List<Map<String, Object>> 格式数据
List<Map<String, Object>> sqlFindListMap = dao.sqlFindListMap(sqlFind);
// 执行 sql 查询 List<bean> 格式数据
List<SybnJunitBase> sqlFindList = dao.sqlFindList(sqlFind, SybnJunitBase.class);

// 执行 sql 查询 Stream<Map<String, Object>> 格式数据
Stream<Map<String, Object>> sqlFindStreamMap = dao.sqlFindStreamMap(sqlFind);
// 消费流
sqlFindStreamMap.count();
// 关闭流 (必须关闭流从而释放数据库连接)
sqlFindStreamMap.close();
// 执行 sql 查询 Stream<bean> 格式数据
Stream<SybnJunitBase> sqlFindStream = dao.sqlFindStream(sqlFind, SybnJunitBase.class);
// 消费流
sqlFindStream.count();
// 关闭流 (必须关闭流从而释放数据库连接)
sqlFindStream.close();

// 执行 count
long count = dao.sqlCount(sqlCount);