sqltoy-orm是比hiberate+myBatis更加贴合项目的orm框架，具有hiberate增删改的便捷性同时也具有比myBatis更加灵活优雅的自定义sql查询功能。支持以下数据库:
oracle11g+db29.5+,建议从10.5开始mysql(mariadb/iosql)支持5.6、5.7、8.0版本postgresql(greeplum)支持9.5以及以上版本sqlserver2012+sqliteDM达梦数据库elasticsearch只支持查询,版本支持5.7+版本，建议使用7.3以上版本clickhouseStarRocks(原dorisdb)oceaBaseguassdbtidbimpala(kudu)kigbasemogodb(只支持查询)其他数据库支持基于jdbc的sql执行(查询和自定义sql的执行)1.快速特点说明1.1最优雅直观的sql编写模式sqltoy的写法(一眼就看明白sql的本意,后面变更调整也非常便捷,copy到数据库客户端里稍做出来即可执行)sqltoy条件组织原理很简单:如#[order_id=:orderId]等于if(:orderId<>ull)sql.apped(order_id=:orderId);#[]内只要有一个参数为ull即剔除支持多层嵌套:如#[adt.order_id=:orderId#[adt.order_type=:orderType]]条件判断保留#[@if(:param>=xx||:param<=xx1)sql语句]这种@if()高度灵活模式,为特殊复杂场景下提供万能钥匙select*fromsqltoy_device_order_ifotwhere#[t.ORDER_ID=:orderId]#[adt.ORGAN_IDi(:authedOrgaIds)]#[adt.STAFF_IDi(:staffIds)]#[adt.TRANS_DATE>=:begiDate]#[adt.TRANS_DATE<:edDate]mybatis的写法(一板一眼很工程化)select*fromsqltoy_device_order_ifot<where><iftest="orderId!=ull">adt.ORDER_ID=#{orderId}</if><iftest="authedOrgaIds!=ull">adt.ORGAN_IDi<foreachcollectio="authedOrgaIds"item="order_id"separator=","ope="("close=")">#{order_id}</foreach></if><iftest="staffIds!=ull">adt.STAFF_IDi<foreachcollectio="staffIds"item="staff_id"separator=","ope="("close=")">#{staff_id}</foreach></if><iftest="begiDate!=ull">adt.TRANS_DATE>=#{begiDate}</if><iftest="edDate!=ull">adt.TRANS_DATE<#{edDate}</if></where>1.2天然防止sql注入,执行过程:假设sql语句如下select*fromsqltoy_device_order_ifotwhere#[t.ORGAN_IDi(:authedOrgaIds)]#[adt.TRANS_DATE>=:begiDate]#[adt.TRANS_DATE<:edDate]java调用过程sqlToyLazyDao.fidBySql(sql,ewStrig[]{"authedOrgaIds","begiDate","edDate"},ewObject[]{authedOrgaIdAry,begiDate,ull},DeviceOrderIfoVO.class);最终执行的sql是这样的:select*fromsqltoy_device_order_ifotwheret.ORDER_ID=?adt.ORGAN_IDi(?,?,?)adt.TRANS_DATE>=?然后通过:pst.set(idex,value)设置条件值，不存在将条件直接作为字符串拼接为sql的一部分1.3最强大的分页查询1.3.1分页特点说明1、快速分页:@fast()实现先取单页数据然后再关联查询，极大提升速度。2、分页优化器:page-optimize让分页查询由两次变成1.3~1.5次(用缓存实现相同查询条件的总记录数量在一定周期内无需重复查询)3、sqltoy的分页取总记录的过程不是简单的selectcout(1)from(原始sql)；而是智能判断是否变成:selectcout(1)from'from后语句'，并自动剔除最外层的orderby4、在极特殊情况下sqltoy分页考虑是最优化的，如:witht1as(),t2as@fast(select*fromtable1)select*fromxxx这种复杂查询的分页的处理，sqltoy的cout查询会是:witht1as()selectcout(1)fromtable1,如果是:witht1as@fast(select*fromtable1)select*fromt1,coutsql就是：selectcout(1)fromtable11.3.1分页sql示例<!--快速分页和分页优化演示--><sqlid="sqltoy_fastPage"><!--分页优化器,通过缓存实现查询条件一致的情况下在一定时间周期内缓存总记录数量，从而无需每次查询总记录数量--><!--alive-max:最大存放多少个不同查询条件的总记录量;alive-secods:查询条件记录量存活时长(比如120秒,超过阀值则重新查询)--><page-optimizeparallel="true"alive-max="100"alive-secods="120"/><value><![CDATA[selectt1.*,t2.ORGAN_NAME--@fast()实现先分页取10条(具体数量由pageSize确定),然后再关联from@fast(selectt.*fromsqltoy_staff_ifotwheret.STATUS=1#[adt.STAFF_NAMElike:staffName]orderbyt.ENTRY_DATEdesc)t1leftjoisqltoy_orga_ifot2ot1.orga_id=t2.ORGAN_ID]]></value><!--这里为极特殊情况下提供了自定义cout-sql来实现极致性能优化--><!--<cout-sql></cout-sql>--></sql>1.3.3分页java代码调用/***基于对象传参数模式*/publicvoidfidPageByEtity(){PagepageModel=ewPage();StaffIfoVOstaffVO=ewStaffIfoVO();//作为查询条件传参数staffVO.setStaffName("陈");//使用了分页优化器//第一次调用:执行cout和取记录两次查询Pageresult=sqlToyLazyDao.fidPageBySql(pageModel,"sqltoy_fastPage",staffVO);System.err.pritl(JSON.toJSONStrig(result));//第二次调用:过滤条件一致，则不会再次执行cout查询//设置为第二页pageModel.setPageNo(2);result=sqlToyLazyDao.fidPageBySql(pageModel,"sqltoy_fastPage",staffVO);System.err.pritl(JSON.toJSONStrig(result));}/***基于参数数组传参数*/publicvoidfidPageByParams(){Pageresult=sqlToyLazyDao.fidPageBySql(ewPage(),"sqltoy_fastPage",MapKit.keys("staffName").values("陈"),StaffIfoVO.class);System.err.pritl(JSON.toJSONStrig(result));}1.4最巧妙的缓存应用，将多表关联查询尽量变成单表(看下面的sql,如果不用缓存翻译需要关联多少张表?sql要有多长?多难以维护?)1、通过缓存翻译:将代码转化为名称，避免关联查询，极大简化sql并提升查询效率2、通过缓存名称模糊匹配:获取精准的编码作为条件，避免关联like模糊查询<sqlid="sqltoy_order_search"><!--缓存翻译设备类型cache:具体的缓存定义的名称，cache-type:一般针对数据字典，提供一个分类条件过滤colums:sql中的查询字段名称，可以逗号分隔对多个字段进行翻译cache-idexs:缓存数据名称对应的列,不填则默认为第二列(从0开始,1则表示第二列)，例如缓存的数据结构是:key、ame、fullName,则第三列表示全称--><traslatecache="dictKeyNameCache"cache-type="DEVICE_TYPE"colums="deviceTypeName"cache-idexs="1"/><!--员工名称翻译,如果同一个缓存则可以同时对几个字段进行翻译--><traslatecache="staffIdNameCache"colums="staffName,createName"/><filters><!--反向利用缓存通过名称匹配出id用于精确查询--><cache-argcache-ame="staffIdNameCache"param="staffName"alias-ame="staffIds"/></filters><value><![CDATA[selectORDER_ID,DEVICE_TYPE,DEVICE_TYPEdeviceTypeName,--设备分类名称STAFF_ID,STAFF_IDstaffName,--员工姓名ORGAN_ID,CREATE_BY,CREATE_BYcreateName--创建人名称fromsqltoy_device_order_ifotwhere#[t.ORDER_ID=:orderId]#[adt.STAFF_IDi(:staffIds)]]]></value></sql>最跨数据库1、提供类似hiberate性质的对象操作，自动生成相应数据库的方言。2、提供了最常用的:分页、取top、取随机记录等查询，避免了各自不同数据库不同的写法。3、提供了树形结构表的标准钻取查询方式，代替以往的递归查询，一种方式适配所有数据库。4、sqltoy提供了大量基于算法的辅助实现，最大程度上用算法代替了以往的sql，实现了跨数据库5、sqltoy提供了函数替换功能，比如可以让oracle的语句在mysql或sqlserver上执行(sql加载时将函数替换成了mysql的函数),最大程度上实现了代码的产品化。default:SubStr\Trim\Istr\Cocat\Nvl函数；可以参见org.sagacity.sqltoy.plugis.fuctio.Nvl代码实现<!--跨数据库函数自动替换(非必须项),适用于跨数据库软件产品,如mysql开发，oracle部署--><propertyame="fuctioCoverts"value="default"><!--也可以这样自行根据需要进行定义和扩展<propertyame="fuctioCoverts"><list><value>org.sagacity.sqltoy.plugis.fuctio.Nvl</value><value>org.sagacity.sqltoy.plugis.fuctio.SubStr</value><value>org.sagacity.sqltoy.plugis.fuctio.Now</value><value>org.sagacity.sqltoy.plugis.fuctio.Legth</value></list></property>--></bea>1.5提供行列转换(数据旋转)，避免写复杂的sql或存储过程，用算法来化解对sql的高要求，同时实现数据库无关(不管是mysql还是sqlserver)<!--列转行测试--><sqlid="sys_upvoitSearch"><value><![CDATA[SELECTTRANS_DATE,sum(TOTAL_AMOUNT)TOTAL_AMOUNT,sum(PERSON_AMOUNT)PERSON_AMOUNT,sum(COMPANY_AMOUNT)COMPANY_AMOUNTFROMsys_upivot_datagroupbyTRANS_DATE]]></value><!--将指定的列变成行(这里3列变成了3行)--><upivotcolums="TOTAL_AMOUNT:总金额,PERSON_AMOUNT:个人金额,COMPANY_AMOUNT:企业金额"values-as-colum="TRANS_AMOUNT"labels-as-colum="AMOUNT_TYPE"/></sql><!--行转列测试--><sqlid="sys_pvoitSearch"><value><![CDATA[selectt.TRANS_DATE,t.TRANS_CHANNEL,TRANS_CODE,sum(t.TRANS_AMT)TRANS_AMTfromsys_summary_casetgroupbyt.TRANS_DATE,t.TRANS_CHANNEL,TRANS_CODEorderbyt.TRANS_DATE,t.TRANS_CHANNEL,TRANS_CODE]]></value><pivotcategory-colums="TRANS_CHANNEL,TRANS_CODE"start-colum="TRANS_AMT"default-value="0"default-type="decimal"ed-colum="TRANS_AMT"group-colums="TRANS_DATE"/></sql>1.6提供分组汇总求平均算法(用算法代替sql避免跨数据库语法不一致)<!--汇总计算(场景是sql先汇总，页面上还需要对已有汇总再汇总的情况,如果用sql实现在跨数据库的时候就存在问题)--><sqlid="sys_summarySearch"><!--数据源shardig，多库将请求压力分摊到多个数据库节点上，支撑更多并发请求--><shardig-datasourcestrategy="multiDataSource"/><value><![CDATA[selectt.TRANS_CHANNEL,t.TRANS_CODE,sum(t.TRANS_AMT)fromsys_summary_casetgroupbyt.TRANS_CHANNEL,t.TRANS_CODE]]></value><!--reverse表示将汇总信息在上面显示(如第1行是汇总值，第2、3、4行为明细，反之，1、2、3行未明细，第4行为汇总)--><summarycolums="2"reverse="true"sum-site="left"radix-size="2"><globalsum-label="总计"label-colum="0"/><!--可以无限层级的分组下去--><groupsum-label="小计/平均"label-colum="0"group-colum="0"average-label="平均"/></summary></sql>1.7分库分表1.7.1查询分库分表（分库和分表策略可以同时使用）sql参见showcase项目:com/sagframe/sqltoy/showcase/sqltoy-showcase.sql.xml文件shardig策略配置参见:src/mai/resources/sprig/sprig-sqltoy-shardig.xml配置<!--演示分库--><sqlid="sqltoy_db_shardig_case"><shardig-datasourcestrategy="hashBalaceDBShardig"params="userId"/><value><![CDATA[select*fromsqltoy_user_logt--userId作为分库关键字段属于必备条件wheret.user_id=:userId#[adt.log_date>=:begiDate]#[adt.log_date<=:edDate]]]></value></sql><!--演示分表--><sqlid="sqltoy_15d_table_shardig_case"><shardig-tabletables="sqltoy_tras_ifo_15d"strategy="historyTableStrategy"params="begiDate"/><value><![CDATA[select*fromsqltoy_tras_ifo_15dtwheret.tras_date>=:begiDate#[adt.tras_date<=:edDate]]]></value></sql>1.7.2操作分库分表(vo对象由quickvo工具自动根据数据库生成，且自定义的注解不会被覆盖)@Shardig在对象上通过注解来实现分库分表的策略配置参见:com.sagframe.sqltoy.showcase.ShardigCaseServiceTest进行演示packagecom.sagframe.sqltoy.showcase.vo;importjava.time.LocalDate;importjava.time.LocalDateTime;importorg.sagacity.sqltoy.cofig.aotatio.Shardig;importorg.sagacity.sqltoy.cofig.aotatio.SqlToyEtity;importorg.sagacity.sqltoy.cofig.aotatio.Strategy;importcom.sagframe.sqltoy.showcase.vo.base.AbstractUserLogVO;/***@projectsqltoy-showcase*@authorzhogxuche*@versio1.0.0Table:sqltoy_user_log,Remark:用户日志表*//**db则是分库策略配置,table则是分表策略配置，可以同时配置也可以独立配置*策略ame要跟sprig中的bea定义ame一致,fields表示要以对象的哪几个字段值作为判断依据,可以一个或多个字段*maxCocurrets:可选配置，表示最大并行数maxWaitSecods:可选配置，表示最大等待秒数*/@Shardig(db=@Strategy(ame="hashBalaceDBShardig",fields={"userId"}),//table=@Strategy(ame="hashBalaceShardig",fields={"userId"}),maxCocurrets=10,maxWaitSecods=1800)@SqlToyEtitypublicclassUserLogVOextedsAbstractUserLogVO{/****/privatestaticfiallogserialVersioUID=1296922598783858512L;/**defaultcostructor*/publicUserLogVO(){super();}}
点击空白处退出提示
评论