java - Hibernate批量插入数据总是插入不完整

查看:88
本文介绍了java - Hibernate批量插入数据总是插入不完整的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

问 题

在利用hibernate向数据库插入数据的时候发现总共2000多条数据只能插入一部分到数据库中,debug的时候发现在循环中确实是建立了对象并且调用了save()方法的
我的代码如下

    Configuration configuration = new Configuration().configure();
    SessionFactory sessionFactory = configuration.buildSessionFactory();
    Session session = sessionFactory.openSession();
    Transaction tx = session.beginTransaction();

    String file = "src/1.xlsx";
    InputStream is = null;
    try {
        is = new FileInputStream(file);
    } catch (FileNotFoundException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    XSSFWorkbook xssfWorkbook = null;
    try {
        xssfWorkbook = new XSSFWorkbook(is);
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    // 获取每一个工作薄
    for (int numSheet = 0; numSheet < xssfWorkbook.getNumberOfSheets(); numSheet++) {
        XSSFSheet xssfSheet = xssfWorkbook.getSheetAt(numSheet);
        if (xssfSheet == null) {
            continue;
        }
        // 获取当前工作薄的每一行

        for (int rowNum = 1; rowNum <= xssfSheet.getLastRowNum(); rowNum++) {
            XSSFRow xssfRow = xssfSheet.getRow(rowNum);
            if (xssfRow != null) {
                XSSFCell one = xssfRow.getCell(0);
                XSSFCell two = xssfRow.getCell(1);
                XSSFCell three = xssfRow.getCell(2);
                String name = getValue(three);
                String code;
                if (getValue(one).equals("沪市"))
                    code = "sh" + getValue(two);
                else
                    code = "sz" + getValue(two);
                StockName2Code s = new StockName2Code();
                s.setCode(code);
                s.setName(name);
                session.save(s);
                if (rowNum % 20 == 0) {
                    session.flush();
                    session.clear();
                }

            }
        }
    }
    tx.commit();
    session.close();
    sessionFactory.close();

我的配置文件如下

` <!DOCTYPE hibernate-configuration PUBLIC

"-//Hibernate/Hibernate Configuration DTD 3.0//EN"  
"http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">

<hibernate-configuration>

<session-factory>
    <!-- Database connection settings -->

    <!-- 表示使用 mysql 数据库驱动类 -->
    <property name="connection.driver_class">com.mysql.jdbc.Driver</property>

    <!-- jdbc 的连接 url 和数据库 -->
    <property name="connection.url">jdbc:mysql://*******/******?useUnicode=true&amp;characterEncoding=UTF-8</property>

    <!-- 数据库用户名 -->
    <property name="connection.username">root</property>

    <!-- 密码(这里为空) -->
    <property name="connection.password">********</property>

    <!-- JDBC connection pool (use the built-in) -->
    <!-- <property name="connection.pool_size">1</property> -->

    <!-- 数据库使用的方言 -->
    <property name="dialect">org.hibernate.dialect.MySQL5Dialect</property>

    <!-- Echo all executed SQL to stdout -->
    <!-- 设置 打印输出 sql 语句 为真 -->
    <property name="show_sql">true</property>

    <!-- 设置格式为 sql -->
    <property name="format_sql">true</property>

    <!-- 第一次加载 hibernate 时根据实体类自动建立表结构,以后自动更新表结构 -->
    <property name="hbm2ddl.auto">update</property>

    <!-- 映射文件 -->
    <mapping class="pojo.StockName2Code" />
</session-factory>

</hibernate-configuration> `

虽然并没有抛出内存用完的异常,但是因为在搜索的时候发现可能是由于hibernate缓存的问题,所以加上了每20条强制刷新的代码块,但是最后发现还是没有效果,插入操作还是只能进行一部分,不知道还有没有什么可能的原因?

解决方案

其实hibernate事没问题的...是我犯了个很低级的错误...我用navicat查看数据库的时候没有看到下一页的按键...麻烦了

这篇关于java - Hibernate批量插入数据总是插入不完整的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!

查看全文
登录 关闭
扫码关注1秒登录
发送“验证码”获取 | 15天全站免登陆