java循环读取mysql并存入java集合里

如果数据库数据过大,用java读取数据库,分页存入集合,每分页一次集合就被调用一次,这个java实现的方式是怎么样的?直接
直接在sql语句上面加个for循环吗?for(){
String sql = "SELECT ID,name, url From websites limit " + (i * 2) + ",2;";......}

4个回答

 import java.sql.Connection;
import java.sql.DriverManager;

public class DBHelper {

    private static final String driver = "com.mysql.jdbc.Driver";//数据库驱动
    private static final String url = "jdbc:mysql://localhost:3306/gumysql?useUnicon=true&characterEncoding=UTF-8";
    private static final String username = "root";
    private static final String password = "root";

    static
    {
        try 
        {
            Class.forName(driver);
        }
        catch (Exception e)
        {

            e.printStackTrace();
        }
    }

    private static Connection conn = null;
    //单例模式返回数据库连接
    public static Connection getConnection() throws Exception
    {
        if(conn == null)
        {
            conn = DriverManager.getConnection(url, username, password);
            return conn;
        }
        else
        {
            return conn;
        }
    }
}

 import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

public class ReadDBPage {

    /**
     * @param pageNo   表示第几页
     * @param pageSize 表示每页的数量
     * @return
     */
    public List<String> query(int pageNo, int pageSize) {
        //计算起始值,比如假如每页条数为5,第一页是0 - 4,第二页是5 - 9;。。。。
        int pageStart = (pageNo - 1) * pageSize;
        Connection conn = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        String sql = " select * from compare limit ?,?; ";
        List<String> mapList = new ArrayList<String>();
        try {
            conn = DBHelper.getConnection();
            stmt = conn.prepareStatement(sql);
            //把参数设置到 ?号里面
            stmt.setInt(1, pageStart);
            stmt.setInt(2, pageSize);
            rs = stmt.executeQuery();
            while (rs.next()) {
                mapList.add(rs.getString("id"));
            }
            return mapList;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        } finally {
            if (rs != null) {
                try {
                    rs.close();
                    rs = null;
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            if (stmt != null) {
                try {
                    stmt.close();
                    stmt = null;
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }

}

 import java.util.List;

public class Bootstrap {

    public static void main(String args[]){
        ReadDBPage read = new ReadDBPage();

        //查询第1页的数据,每页数据为5条
        List<String> strList = read.query(1,5);

        //查询第2页的数据,每页数据为5条
        List<String> strList2 = read.query(2,5);

        //查询第2页的数据,每页数据为4条
        List<String> strList3 = read.query(2,4);

        System.out.println(strList);

        System.out.println(strList2);

        System.out.println(strList3);

    }
}

还拿你昨天的数据库举例
图片说明

运行结果为
图片说明

考虑到你要循环查询修改了一下,望采纳 ,DBHelper还用之前的。

 import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

public class ReadDBPage {

    /**
     * 查询总条数
     * @return
     */
    public Long querySize() {
        Connection conn = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        String sql = " select count(*) as num from compare; ";
        Long size = 0L;
        try {
            conn = DBHelper.getConnection();
            stmt = conn.prepareStatement(sql);
            rs = stmt.executeQuery();
            while (rs.next()) {
                size = rs.getLong("num");
            }
            return size;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        } finally {
            if (rs != null) {
                try {
                    rs.close();
                    rs = null;
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            if (stmt != null) {
                try {
                    stmt.close();
                    stmt = null;
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }


    /**
     * @param pageNo   表示第几页
     * @param pageSize 表示每页的数量
     * @return
     */
    public List<String> query(int pageNo, int pageSize) {
        //计算起始值,比如假如每页条数为5,第一页是0 - 4,第二页是5 - 9;。。。。
        int pageStart = (pageNo - 1) * pageSize;
        Connection conn = null;
        PreparedStatement stmt = null;
        ResultSet rs = null;
        String sql = " select * from compare limit ?,?; ";
        List<String> mapList = new ArrayList<String>();
        try {
            conn = DBHelper.getConnection();
            stmt = conn.prepareStatement(sql);
            //把参数设置到 ?号里面
            stmt.setInt(1, pageStart);
            stmt.setInt(2, pageSize);
            rs = stmt.executeQuery();
            while (rs.next()) {
                mapList.add(rs.getString("id"));
            }
            return mapList;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        } finally {
            if (rs != null) {
                try {
                    rs.close();
                    rs = null;
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            if (stmt != null) {
                try {
                    stmt.close();
                    stmt = null;
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }

}

import java.util.ArrayList;
import java.util.List;

public class Bootstrap {

    public static void main(String args[]){
        ReadDBPage read = new ReadDBPage();

        //查询数据库中总条数
        Long allSize = read.querySize();

        System.out.println("数据库中总数为:"+ allSize +" 条");

        List<String> allList = new ArrayList<String>();

        int pageSize = 5;//定义每页的条数

        //计算循环次数,即总页数  Math.ceil为向上取整
        int pages = (int) Math.ceil(allSize/(pageSize*1.0));
        System.out.println("总页数为:"+ pages +" 页");

        for(int i=1;i<=pages;i++){
            List<String> onePageList = read.query(i,pageSize);
            allList.addAll(onePageList);
            System.out.println("第"+ i +"页的数据为:"+ onePageList);
        }

        System.out.println("总数据为:"+ allList);
    }
}



执行结果为
图片说明

qq_29777207
张音乐 回复ggx1abc: 你按照我第二次贴的代码执行就可以了啊,还是说你有新的需求
接近 2 年之前 回复
qq_29777207
张音乐 回复ggx1abc: 你QQ号是什么,我加你好友,不太明白你的意思
接近 2 年之前 回复
ggx1abc
gu123xin 回复qq_29777207ReadDBPage类型中的方法查询(int, int)不适用于arguments (),我是想将DBPage替代那个ReadDB,可是在main函数里面引用maplist,要怎么样在DBPage里面引用这个集合
接近 2 年之前 回复
qq_29777207
张音乐 回复ggx1abc: 报什么错啊?
接近 2 年之前 回复
ggx1abc
gu123xin 回复qq_29777207哥如果ReadDBPage提前之前写的ReadDB,mapList怎么样在main函数里面调用,ReadDBPage read = new ReadDBPage(); Long allSize = read.querySize(); List<String> mapList = read. query();query会报错
接近 2 年之前 回复
qq_29777207
张音乐 回复ggx1abc: 不客气
接近 2 年之前 回复
ggx1abc
gu123xin 谢谢,大佬,麻烦你了
接近 2 年之前 回复

不是很明白你说的循环查找是什么意思,但是个人建议,还是能少查数据库一次就少查一次,然后在程序中对数据进行封装,因为牵扯到性能和效率的问题,还有数据库连接超时的配置。

ggx1abc
gu123xin 因为数据库数据太大,需要查找某或者多个字段下面的内容,还要存入集合和文本数据比较,如果不分批次分页然后循环历遍,找不完全,目前我只能想到这个方法,本人初学者一个,如果还有什么好的方法欢迎指教
接近 2 年之前 回复

SELECT ID,name, url From websites limit start ,len 分别在代码层计算好开始行跟分页的条目数,例如第一页数据start=0,len=20获取20条,获取第二页数据则start=20,len=20.前端只要传入一个页码然后乘20即可得到开始行

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问
相关内容推荐