上亿级数据量-JDBC插入数据库
2013-10-30 09:49
411 查看
转载:http://blog.csdn.net/jzshmyt/article/details/7255761
package com.database; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; /** * 将亿级数据量,通过JDBC方式,插入到数据库中.关键技术说明 * 一、为了避免内存溢出问题,每100万条重新建立一次jdbc连接. * 二、将连接属性设置为不自动提交,每5万条批量执行一次提交. * @author Administrator */ public class Import { private static final String JDBC_URL = "jdbc:oracle:thin:@localhost:1521:orcl"; private static final String JDBC_USER = "ttt"; private static final String JDBC_PASSWORD = "pw123456"; private static final String JDBC_SQL = "insert into tb_test (col1,col2) values (?,?)"; public static void main(String[] args) throws Exception { Class.forName("oracle.jdbc.driver.OracleDriver"); exe(100000005);//1亿数据量测试通过 } public static void exe(int sl) throws SQLException{ int SIZE = 1000000;//每批的记录数(建议值100万) int page = sl/SIZE;//计算批数 for (int i = 0; i < page; i++) {//批量执行 execute(i*SIZE,(i+1)*SIZE); } if(sl%SIZE != 0){ execute(page*SIZE,sl); } } private static void execute(int begin, int end) throws SQLException { Connection conn = null; PreparedStatement pst= null; try { conn = DriverManager.getConnection(JDBC_URL, JDBC_USER,JDBC_PASSWORD); System.out.println("重新打开连接 :" + begin + " - " + end); conn.setAutoCommit(false);// 设置不自动提交 pst = conn.prepareStatement(JDBC_SQL); int recordNum = 0; // 计数器 int commit_size = 50000;// 每次提交记录数5万 for (int i = begin; i < end; i++) { recordNum++; // 计数 pst.setString(1, "n" + i); pst.setString(2, "v" + i); pst.addBatch(); if (recordNum % commit_size == 0) { pst.executeBatch(); conn.commit(); System.out.println("提交:" + i); conn.setAutoCommit(false); pst = conn.prepareStatement(JDBC_SQL); } } if (recordNum % commit_size != 0) { pst.executeBatch(); conn.commit(); System.out.println("提交:" + recordNum); } } catch (SQLException e) { e.printStackTrace(); } finally { try { if (pst != null) pst.close(); } catch (SQLException e) { e.printStackTrace(); }finally{ try{ if (conn != null) conn.close(); System.out.println("成功关闭连接!"); } catch (SQLException e) { e.printStackTrace(); } } } } }
相关文章推荐
- oracle,sqlserver,mysql 命令行 开启、关闭所需要的服务
- Oracle SQL性能优化 之一
- 如何在SQL Server 2008下轻松调试T-SQL语句和存储过程
- Dbutils 多表联合查询不支持别名解决方法
- Oracle对表的基本操作(一) - 创建、修改、删除表
- oracle分析函数之windowing_clause--rows
- sqlserver中的事务和锁详细解析
- Redis 介绍安装
- SQL Server数据库管理员(DBA)的工作内容
- oracle 创建表空间 用户授权
- sql 2000打开企业管理器时报mmc不能打开文件SQL Server Enterprise Manager.MSC解决方案
- sql连接查询中,where关键字的位置讲解
- 如何修改SQL Server占用内存
- sqlserver性能调优经验总结
- Oracle树形查询 ,结果显示一行
- 数据库连接类oracleHelper
- 使用ssh向sqlserver2005数据库中保存image类型的二进制图片
- 复制表的sql语句
- 一个Web报表项目的性能分析和优化实践(一):小试牛刀,统一显示SQL语句执行时间
- 一个Web报表项目的性能分析和优化实践(一):小试牛刀,统一显示SQL语句执行时间