...
|
...
|
@@ -128,9 +128,9 @@ public class SqlOperateServiceImpl implements SqlOperateService { |
|
|
if(sql.endsWith(";")){
|
|
|
sql = sql.substring(0,sql.length()-1);
|
|
|
}
|
|
|
boolean descQueryFlag=false;
|
|
|
if(sql.toLowerCase().startsWith("desc ")){
|
|
|
descQueryFlag=true;
|
|
|
boolean descOrShowFlag=false;
|
|
|
if(sql.toLowerCase().startsWith("desc ")||sql.toLowerCase().startsWith("show ")){
|
|
|
descOrShowFlag=true;
|
|
|
}
|
|
|
|
|
|
log.info("query4Table begin "+sql);
|
...
|
...
|
@@ -160,7 +160,7 @@ public class SqlOperateServiceImpl implements SqlOperateService { |
|
|
st = con.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
|
|
|
st.setFetchSize(FETCH_COUNT_FROM_MYSQL);
|
|
|
//不是desc的查询需要限定数量了
|
|
|
if(!descQueryFlag){
|
|
|
if(!descOrShowFlag){
|
|
|
st.setMaxRows(FETCH_COUNT_FROM_MYSQL);
|
|
|
}
|
|
|
//st.setMaxRows(FETCH_COUNT_FROM_MYSQL);
|
...
|
...
|
@@ -210,7 +210,7 @@ public class SqlOperateServiceImpl implements SqlOperateService { |
|
|
|
|
|
while (rs.next()) {
|
|
|
times++;
|
|
|
if(!descQueryFlag&×>MAX_QUERY_RESULT_COUNT){
|
|
|
if(!descOrShowFlag&×>MAX_QUERY_RESULT_COUNT){
|
|
|
queryDescr="数据量超过limit限制,自动显示前"+MAX_QUERY_RESULT_COUNT+"条";
|
|
|
break;
|
|
|
}
|
...
|
...
|
|