|
@@ -15,38 +15,52 @@
|
|
*/
|
|
*/
|
|
package com.baomidou.mybatisplus.extension.plugins;
|
|
package com.baomidou.mybatisplus.extension.plugins;
|
|
|
|
|
|
-import com.baomidou.mybatisplus.annotation.DbType;
|
|
|
|
-import com.baomidou.mybatisplus.core.MybatisDefaultParameterHandler;
|
|
|
|
-import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
|
-import com.baomidou.mybatisplus.core.parser.ISqlParser;
|
|
|
|
-import com.baomidou.mybatisplus.core.parser.SqlInfo;
|
|
|
|
-import com.baomidou.mybatisplus.core.toolkit.*;
|
|
|
|
-import com.baomidou.mybatisplus.extension.handlers.AbstractSqlParserHandler;
|
|
|
|
-import com.baomidou.mybatisplus.extension.plugins.pagination.DialectFactory;
|
|
|
|
-import com.baomidou.mybatisplus.extension.plugins.pagination.DialectModel;
|
|
|
|
-import com.baomidou.mybatisplus.extension.toolkit.JdbcUtils;
|
|
|
|
-import com.baomidou.mybatisplus.extension.toolkit.SqlParserUtils;
|
|
|
|
-import lombok.Setter;
|
|
|
|
-import lombok.experimental.Accessors;
|
|
|
|
|
|
+import static java.util.stream.Collectors.joining;
|
|
|
|
+
|
|
|
|
+import java.sql.Connection;
|
|
|
|
+import java.sql.PreparedStatement;
|
|
|
|
+import java.sql.ResultSet;
|
|
|
|
+import java.util.ArrayList;
|
|
|
|
+import java.util.Arrays;
|
|
|
|
+import java.util.List;
|
|
|
|
+import java.util.Map;
|
|
|
|
+import java.util.Properties;
|
|
|
|
+import java.util.function.LongSupplier;
|
|
|
|
+
|
|
import org.apache.ibatis.executor.statement.StatementHandler;
|
|
import org.apache.ibatis.executor.statement.StatementHandler;
|
|
import org.apache.ibatis.mapping.BoundSql;
|
|
import org.apache.ibatis.mapping.BoundSql;
|
|
import org.apache.ibatis.mapping.MappedStatement;
|
|
import org.apache.ibatis.mapping.MappedStatement;
|
|
import org.apache.ibatis.mapping.ParameterMapping;
|
|
import org.apache.ibatis.mapping.ParameterMapping;
|
|
import org.apache.ibatis.mapping.SqlCommandType;
|
|
import org.apache.ibatis.mapping.SqlCommandType;
|
|
-import org.apache.ibatis.plugin.*;
|
|
|
|
|
|
+import org.apache.ibatis.plugin.Interceptor;
|
|
|
|
+import org.apache.ibatis.plugin.Intercepts;
|
|
|
|
+import org.apache.ibatis.plugin.Invocation;
|
|
|
|
+import org.apache.ibatis.plugin.Plugin;
|
|
|
|
+import org.apache.ibatis.plugin.Signature;
|
|
import org.apache.ibatis.reflection.MetaObject;
|
|
import org.apache.ibatis.reflection.MetaObject;
|
|
import org.apache.ibatis.reflection.SystemMetaObject;
|
|
import org.apache.ibatis.reflection.SystemMetaObject;
|
|
import org.apache.ibatis.scripting.defaults.DefaultParameterHandler;
|
|
import org.apache.ibatis.scripting.defaults.DefaultParameterHandler;
|
|
import org.apache.ibatis.session.Configuration;
|
|
import org.apache.ibatis.session.Configuration;
|
|
import org.apache.ibatis.session.RowBounds;
|
|
import org.apache.ibatis.session.RowBounds;
|
|
|
|
|
|
-import java.sql.Connection;
|
|
|
|
-import java.sql.PreparedStatement;
|
|
|
|
-import java.sql.ResultSet;
|
|
|
|
-import java.util.*;
|
|
|
|
-import java.util.function.LongSupplier;
|
|
|
|
|
|
+import com.baomidou.mybatisplus.annotation.DbType;
|
|
|
|
+import com.baomidou.mybatisplus.core.MybatisDefaultParameterHandler;
|
|
|
|
+import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
|
+import com.baomidou.mybatisplus.core.parser.ISqlParser;
|
|
|
|
+import com.baomidou.mybatisplus.core.parser.SqlInfo;
|
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.ArrayUtils;
|
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.ExceptionUtils;
|
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.PluginUtils;
|
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.StringPool;
|
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
|
|
|
+import com.baomidou.mybatisplus.extension.handlers.AbstractSqlParserHandler;
|
|
|
|
+import com.baomidou.mybatisplus.extension.plugins.pagination.DialectFactory;
|
|
|
|
+import com.baomidou.mybatisplus.extension.plugins.pagination.DialectModel;
|
|
|
|
+import com.baomidou.mybatisplus.extension.toolkit.JdbcUtils;
|
|
|
|
+import com.baomidou.mybatisplus.extension.toolkit.SqlParserUtils;
|
|
|
|
|
|
-import static java.util.stream.Collectors.joining;
|
|
|
|
|
|
+import lombok.Setter;
|
|
|
|
+import lombok.experimental.Accessors;
|
|
|
|
|
|
/**
|
|
/**
|
|
* <p>
|
|
* <p>
|
|
@@ -166,7 +180,7 @@ public class PaginationInterceptor extends AbstractSqlParserHandler implements I
|
|
|
|
|
|
LongSupplier supplier = page.getSupplier();
|
|
LongSupplier supplier = page.getSupplier();
|
|
boolean orderBy = true;
|
|
boolean orderBy = true;
|
|
- if (page.getTotal() == 0) {
|
|
|
|
|
|
+ if (page.getTotal() < 0) {
|
|
// total 为0 才进行 count
|
|
// total 为0 才进行 count
|
|
SqlInfo sqlInfo = SqlParserUtils.getOptimizeCountSql(page.optimizeCountSql(), sqlParser, originalSql);
|
|
SqlInfo sqlInfo = SqlParserUtils.getOptimizeCountSql(page.optimizeCountSql(), sqlParser, originalSql);
|
|
orderBy = sqlInfo.isOrderBy();
|
|
orderBy = sqlInfo.isOrderBy();
|