com.kdayun.z1.core.mybatis.processor

类 DbPluginProcessorBase

java.lang.Object

com.kdayun.z1.core.mybatis.processor.DbPluginProcessorBase

直接已知子类:

DM, JC, MsSql, MySql, Oracle, PG

public class DbPluginProcessorBase
extends java.lang.Object

数据库Sql分页语句处理基类

构造器概要

构造器

构造器和说明
DbPluginProcessorBase()
DbPluginProcessorBase(java.lang.String dbType)

方法概要

限定符和类型	方法和说明
static void	clearPageParams() 清理pageParams
protected java.lang.Boolean	exclude(java.lang.String sql) 排除一些update insert delete 语句
java.lang.String	getAdvSql(java.lang.String[] condition, java.lang.String sql) 得到高级查询的语句.
java.lang.String	getDbType()
protected java.lang.String	getPageDataSQL(java.lang.String sql, java.lang.Object parameterObject)
static PageParams	getPageParams() 获取当前的pageParams
PageParams	getPageParamsForParamObj(java.lang.Object parameterObject, java.lang.String[] condition) 分离出分页参数.
PagingPluginEx	getPlugin()
protected java.lang.String	getSortOrderForParamObj(java.lang.Object parameterObject)
protected java.lang.String	getTotalSQL(java.lang.String currSql, java.lang.String dbType, java.lang.String extSumSqlField, java.util.Map<java.lang.String,java.lang.String> totalFields) 计算总数的SQL, 这里需要根据数据库的类型改写SQL，目前支持MySQL和Oracle
java.lang.Object	intercept(org.apache.ibatis.plugin.Invocation invocation)
protected void	preparePageDataParams(java.sql.PreparedStatement ps, int pageNum, int pageSize, java.lang.String dbType) TODO 需要使用其他数据库需要改写 使用PreparedStatement预编译两个分页参数，如果数据库的规则不一样，需要改写设置的参数规则。
protected java.lang.String	processFunctionSql(java.lang.Object parameterObject, java.lang.String sql) 处理特殊的函数
java.lang.String	processNoPageSql(java.lang.Object parameterObject, java.lang.String sql) 处理非分页的 的参数,排序 特殊函数
protected java.lang.String	processOrderField(java.lang.Object parameterObject, java.lang.String sql) 处理排除字段参数
java.lang.Object	processPageSql(org.apache.ibatis.executor.statement.StatementHandler stmtHandler, org.apache.ibatis.reflection.MetaObject metaStatementHandler, PageParams pageParams, org.apache.ibatis.mapping.BoundSql boundSql) 语句处理函数
void	setDbType(java.lang.String dbType)
void	setPlugin(PagingPluginEx plugin)
void	setTotal(org.apache.ibatis.plugin.Invocation invocation, PageParams pageParams, org.apache.ibatis.reflection.MetaObject metaStatementHandler, org.apache.ibatis.mapping.BoundSql boundSql) 设置分页的总数
protected java.lang.String	setValueWithDbType(java.lang.String adqContion, java.lang.String dbType) 根据不同的数据库组装高级查询，针对时间类型的组装

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

DbPluginProcessorBase

public DbPluginProcessorBase()

DbPluginProcessorBase

public DbPluginProcessorBase(java.lang.String dbType)

方法详细资料

exclude

protected java.lang.Boolean exclude(java.lang.String sql)

排除一些update insert delete 语句

参数:

sql - SQL语句

返回:

true 排除,false不必排除

intercept

public java.lang.Object intercept(org.apache.ibatis.plugin.Invocation invocation)
                           throws java.lang.Throwable

抛出:

java.lang.Throwable

setTotal

public void setTotal(org.apache.ibatis.plugin.Invocation invocation,
                     PageParams pageParams,
                     org.apache.ibatis.reflection.MetaObject metaStatementHandler,
                     org.apache.ibatis.mapping.BoundSql boundSql)
              throws java.lang.Throwable

设置分页的总数

参数:

invocation - 调用

pageParams - 页面参数

metaStatementHandler - metaStatementHandler

boundSql - sql对象

抛出:

java.lang.Throwable - 出错抛出异常

getAdvSql

public java.lang.String getAdvSql(java.lang.String[] condition,
                                  java.lang.String sql)

得到高级查询的语句.

参数:

condition - 条件

sql - sql语句

返回:

查询的语句

getTotalSQL

protected java.lang.String getTotalSQL(java.lang.String currSql,
                                       java.lang.String dbType,
                                       java.lang.String extSumSqlField,
                                       java.util.Map<java.lang.String,java.lang.String> totalFields)
                                throws NotSupportedDbException

计算总数的SQL, 这里需要根据数据库的类型改写SQL，目前支持MySQL和Oracle

参数:

currSql - —— 当前执行的SQL

extSumSql -

返回:

改写后的SQL

抛出:

NotSupportedDbException

setValueWithDbType

protected java.lang.String setValueWithDbType(java.lang.String adqContion,
                                              java.lang.String dbType)

根据不同的数据库组装高级查询，针对时间类型的组装

参数:

adqContion -

返回:

processNoPageSql

public java.lang.String processNoPageSql(java.lang.Object parameterObject,
                                         java.lang.String sql)
                                  throws java.lang.Exception

处理非分页的 的参数,排序 特殊函数

参数:

parameterObject - 参数

sql - sql语句

返回:

返回处理完毕的sql字符串

抛出:

java.lang.Exception - 出错会抛出异常

processOrderField

protected java.lang.String processOrderField(java.lang.Object parameterObject,
                                             java.lang.String sql)
                                      throws java.lang.Exception

处理排除字段参数

参数:

parameterObject - 参数

sql - sql语句

返回:

抛出:

java.lang.Exception

processFunctionSql

protected java.lang.String processFunctionSql(java.lang.Object parameterObject,
                                              java.lang.String sql)
                                       throws java.lang.Exception

处理特殊的函数

参数:

parameterObject - 参数

sql - sql语句

返回:

抛出:

java.lang.Exception - 出错会抛出异常

processPageSql

public java.lang.Object processPageSql(org.apache.ibatis.executor.statement.StatementHandler stmtHandler,
                                       org.apache.ibatis.reflection.MetaObject metaStatementHandler,
                                       PageParams pageParams,
                                       org.apache.ibatis.mapping.BoundSql boundSql)
                                throws java.lang.Exception

语句处理函数

参数:

stmtHandler - StatementHandler

metaStatementHandler - MetaObject

pageParams - PageParams

boundSql - BoundSql

返回:

Object

抛出:

java.lang.Exception - 出错会抛出异常

preparePageDataParams

protected void preparePageDataParams(java.sql.PreparedStatement ps,
                                     int pageNum,
                                     int pageSize,
                                     java.lang.String dbType)
                              throws java.lang.Exception

TODO 需要使用其他数据库需要改写 使用PreparedStatement预编译两个分页参数，如果数据库的规则不一样，需要改写设置的参数规则。目前支持MySQL和Oracle

抛出:

java.sql.SQLException - 出错抛出数据库异常

NotSupportedDbException

java.lang.Exception

getPageDataSQL

protected java.lang.String getPageDataSQL(java.lang.String sql,
                                          java.lang.Object parameterObject)
                                   throws java.lang.Exception

抛出:

java.lang.Exception

getDbType

public java.lang.String getDbType()

setDbType

public void setDbType(java.lang.String dbType)

getPageParamsForParamObj

public PageParams getPageParamsForParamObj(java.lang.Object parameterObject,
                                           java.lang.String[] condition)
                                    throws java.lang.Exception

分离出分页参数.

参数:

parameterObject - --执行参数

condition - 条件

返回:

分页参数

抛出:

java.lang.Exception - 出错会抛出异常

getSortOrderForParamObj

protected java.lang.String getSortOrderForParamObj(java.lang.Object parameterObject)
                                            throws java.beans.IntrospectionException,
                                                   java.lang.IllegalArgumentException,
                                                   java.lang.IllegalAccessException,
                                                   java.lang.reflect.InvocationTargetException

参数:

parameterObject - 参数

返回:

抛出:

java.beans.IntrospectionException

java.lang.reflect.InvocationTargetException

java.lang.IllegalAccessException

java.lang.IllegalArgumentException

date:

2018年9月28日 下午6:49:20

getPlugin

public PagingPluginEx getPlugin()

setPlugin

public void setPlugin(PagingPluginEx plugin)

getPageParams

public static PageParams getPageParams()

获取当前的pageParams

返回:

页面参数

clearPageParams

public static void clearPageParams()

清理pageParams