PreparedStatement 批量更新,插入数据到Oracle mysql

Oracle 前端之家
前端之家收集整理的这篇文章主要介绍了PreparedStatement 批量更新,插入数据到Oracle mysql，前端之家小编觉得挺不错的，现在分享给大家，也给大家做个参考。
  1. /**
  2. *更新数据库已有的customer信息
  3. *@paramList<CustomerBean>
  4. *@return
  5. */
  6. publicintupdateExistsInfo(List<CustomerBean>updateList){
  7. //查询的sql语句
  8. Stringsql="updatet_customersetLICENSE_KEY=?,CORPORATE_NAME=?,INTEGRATED_CLASSIFICATION=?,BOSSHEAD=?,"+
  9. "CONTACT_PHONE=?,ORDER_FREQUENCY=?,CONTACT_ADDRESS=?,USER_ID=?whereCUSTOMER_ID=?";
  10. //插入需要的数据库对象
  11. Connectionconn=null;
  12. PreparedStatementpstmt=null;
  14. try{
  15. conn=newDBSource().getConnection();
  16. //设置事务属性
  17. conn.setAutoCommit(false);
  18. pstmt=conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
  19. for(CustomerBeancbean:updateList){
  20. pstmt.setString(1,cbean.getLicense_key());
  21. pstmt.setString(2,cbean.getCorporate_name());
  22. 3,cbean.getIntegrated_classification());
  23. 4,cbean.getBosshead());
  24. 5,cbean.getContact_phone());
  25. 6,cbean.getOrder_frequency());
  26. 7,cbean.getContact_address());
  27. pstmt.setInt(8,cbean.getUser_id());
  28. pstmt.setInt(9,cbean.getCustomer_id());
    29. @H_403_189@ pstmt.addBatch(); @H_403_189@ } @H_301_197@int[]tt=pstmt.executeBatch();
  29. System.out.println("update:"+tt.length);
  30. //提交，设置事务初始值
  31. conn.commit();
  32. conn.setAutoCommit(true);
  33. //插入成功，返回
    34. @H_301_197@returntt.length;
  35. }catch(sqlExceptionex){
  36. //提交失败，执行回滚操作
  37. conn.rollback();
    38. @H_403_189@ }catch(sqlExceptione){
  38. e.printStackTrace();
  39. System.err.println("updateExistsInfo回滚执行失败!!!");
  40. }
  41. ex.printStackTrace();
  42. System.err.println("updateExistsInfo执行失败");
  43. //插入失败返回标志0
    44. @H_301_197@return0;
  44. finally{
  45. //关闭资源
  46. if(pstmt!=null)pstmt.close();
    47. @H_301_197@if(conn!=null)conn.close();
  47. catch(sqlExceptione){
  48. e.printStackTrace();
  49. System.err.println("资源关闭失败!!!");
  50. /**
  51. *插入数据中没有的customer信息
  52. *@paramList<CustomerBean>
  53. *@return
  54. */
    55. @H_301_197@intinsertNewInfo(List<CustomerBean>insertList){
  55. Stringsql="insertintot_customer(CUSTOMER_ID,108); list-style-type:decimal-leading-zero; color:inherit; line-height:18px; margin:0px!important; padding:0px 3px 0px 10px!important; list-style-position:outside!important"> "LICENSE_KEY,CORPORATE_NAME,INTEGRATED_CLASSIFICATION,BOSSHEAD,CONTACT_PHONE,"+
  56. "ORDER_FREQUENCY,CONTACT_ADDRESS,USER_ID,CUSTOMER_NUM,CUSTOMER_CODING,108); list-style-type:decimal-leading-zero; color:inherit; line-height:18px; margin:0px!important; padding:0px 3px 0px 10px!important; list-style-position:outside!important"> "INVESTIGATION_TIME,SMS_REC_FLAG,WAP_FLAG,PRICE_GATHERING_FLAG,SOCIETY_STOCK_FLAG,248); line-height:18px; margin:0px!important; padding:0px 3px 0px 10px!important; list-style-position:outside!important"> "REGION_TYPE)"+
  57. "VALUES(CUSTOMER.NEXTVAL,248); line-height:18px; margin:0px!important; padding:0px 3px 0px 10px!important; list-style-position:outside!important"> "?,?,108); list-style-type:decimal-leading-zero; color:inherit; line-height:18px; margin:0px!important; padding:0px 3px 0px 10px!important; list-style-position:outside!important"> "?,248); line-height:18px; margin:0px!important; padding:0px 3px 0px 10px!important; list-style-position:outside!important"> "TO_DATE(?,'YYYY-MM-DD'),108); list-style-type:decimal-leading-zero; color:inherit; line-height:18px; margin:0px!important; padding:0px 3px 0px 10px!important; list-style-position:outside!important"> "?)";
  58. //插入需要的数据库对象
  59. Connectionconn= PreparedStatementpstmt=try{
  60. conn=newDBSource().getConnection();
  61. pstmt=conn.prepareStatement(sql,ResultSet.CONCUR_READ_ONLY);
  62. for(CustomerBeancbean:insertList){
  63. "gyyc00000");//
  64. 10,"95000000");//
  65. 11,getToday());
  66. 12,cbean.getSms_rec_flag());
  67. 13,cbean.getRegion_type());
  68. pstmt.addBatch();
  69. int[]tt=pstmt.executeBatch();
  70. System.out.println("insert:"+tt.length);
  71. //提交，设置事务初始值
  72. conn.commit();
    73. @H_301_197@true);
  73. //插入成功，返回
  74. returntt.length;
    75. @H_301_197@catch(sqlExceptionex){
  75. //提交失败，执行回滚操作
  76. conn.rollback();
  77. System.err.println("insertNewInfo回滚执行失败!!!");
  78. ex.printStackTrace();
  79. System.err.println("insertNewInfo执行失败");
  80. //插入失败返回标志0
  81. 0;
    82. @H_301_197@finally{
  82. //关闭资源
    83. @H_301_197@null)pstmt.close();
  83. null)conn.close();
    84. @H_403_189@ System.err.println("资源关闭失败!!!");
  84. }
使用Java JDBC基本的API批量插入数据到数据库中
    @H_301_197@importjava.sql.Connection;
  1. importjava.sql.Statement;
  2. //...
  3. Connectionconnection=newgetConnection();
  4. Statementstatemenet=connection.createStatement();
  5. for(Employeeemployee:employees){
  6. Stringquery="insertintoemployee(name,city)values('"
  7. +employee.getName()+"','"+employee.getCity+"')";
  8. statemenet.addBatch(query);
  9. }
  10. statemenet.executeBatch();
  11. statemenet.close();
  12. connection.close();
  13. 请注意我们是如何从Employee对象中的数据动态创建查询并在批处理中添加，插入一气呵成。完美！是不是？
    等等......你必须思考什么关于sql注入？这样动态创建的查询sql注入是很容易的。并且每个插入查询每次都被编译。
    为什么不使用PreparedStatement而不是简单的声明。是的，这是个解决方案。下面是sql注入安全批处理。
    sql Injection Safe Batch - sql注入安全批处理
    思考一下下面代码:
    [java] view plain copy
      @H_301_197@importjava.sql.Connection;
    1. importjava.sql.PreparedStatement;
    2. //...
    3. Stringsql="insertintoemployee(name,city,phone)values(?,?)";
    4. Connectionconnection=newgetConnection();
    5. PreparedStatementps=connection.prepareStatement(sql);
      6. @H_301_197@for(Employeeemployee:employees){
    6. ps.setString( ps.setString(
    7. ps.addBatch();
    8. }
    9. ps.executeBatch();
    10. ps.close();
    11. connection.close();
    看看上面的代码。漂亮。我们使用的java.sql.PreparedStatement和在批处理中添加INSERT查询。这是你必须实现批量插入逻辑的解决方案，而不是上述Statement那个。
    这一解决方案仍然存在一个问题。考虑这样一个场景，在您想要插入到数据库使用批处理上万条记录。嗯，可能产生的OutOfMemoryError：

    java.lang.OutOfMemoryError: Java heap space
    com.MysqL.jdbc.ServerPreparedStatement$BatchedBindValues.<init>(ServerPreparedStatement.java:72)
    com.MysqL.jdbc.ServerPreparedStatement.addBatch(ServerPreparedStatement.java:330)
    org.apache.commons.dbcp.DelegatingPreparedStatement.addBatch(DelegatingPreparedStatement.java:171)

    这是因为你试图在一个批次添加所有语句，并一次插入。最好的办法是将执行分批次。看看下面的解决方案
    Smart Insert: Batch within Batch - 智能插入：将整批分批
    这是一个简单的解决方案。考虑批量大小为1000，每1000个查询语句为一批插入提交。
    copy
      Stringsql="insertintoemployee(name,?)";
    1. newgetConnection();
    2. PreparedStatementps=connection.prepareStatement(sql);
    3. finalintbatchSize=1000;
      4. @H_301_197@intcount=0;
    4. for(Employeeemployee:employees){
    6. ps.addBatch();
      7. @H_301_197@if(++count%batchSize==0){
    7. ps.executeBatch();
    8. }
    9. ps.executeBatch();//insertremainingrecords
    10. connection.close();
这才是理想的解决方案，它避免了sql注入和内存不足的问题。看看我们如何递增计数器计数，一旦BATCHSIZE 达到 1000，我们调用executeBatch（）提交。

猜你在找的Oracle相关文章

[Oracle]记一次由sequence引发的enq sv-contention等待事件
数据库版本：11.2.0.4 RAC(1)问题现象从EM里面可以看到，在23号早上8：45~8：55时，数据库...
oracle统计信息的锁定与解锁
（一）问题背景最近在对一个大约200万行数据的表查看执行计划时，发现存在异常，理论上应该...
【转】RMAN删除过期备份或非过期备份
（一）删除备份--DELETE命令用于删除RMAN备份记录及相应的物理文件。当使用RMAN执行备份操...
数据恢复顾问（DRA）
（1）DRA介绍 数据恢复顾问（Data Recovery Advise）是一个诊断和修复数据库的工具，DRA能...
RMAN备份与恢复（一）--认识RMAN
RMAN（Recovery Manager）是Oracle恢复管理器的简称，是集数据库备份（backup）、修复（re...
RMAN备份与恢复（二）--RMAN常用操作学习
（1）连接目标数据库 在RMAN中可以建立与目标数据库或恢复目录数据库的连接。与目标数据库...
ORA-00245问题总结
（1）问题描述 在进行数据库归档备份时（备份归档日志文件和控制文件），有时成功，有时失...
使用RMAN对数据文件进行恢复
（1）备份数据库 在使用RMAN进行数据库恢复之前，先用RMAN进行全库备份 （2）删除数据文件...
Oracle使用fy_recover_data恢复truncate删除的数据
(一)truncate操作概述在生产中，truncate是使用较多的命令，在使用不当的情况下，往往会造...
备份与恢复（四）--RMAN使用恢复目录catalog来保存档案资料库
（一）恢复目录概述RMAN档案资料库用于存储数据库备份、修复以及恢复所需的信息。这些信息...
MySQLMsSQLOracleSqlitePostgre SQLMariadbMongoDBNoSQLHBaseJDBC
undo日志persistent-cmysql-error-postal-codesql-match-almysql-5.6mysql-8.0database-tri安装路径系统错误data_dir丢失文件主从同步sql_mode数据库目录匿名用户character_seID归零数据库位置查询表重复字段查询字段截断日志SUSPECT7391Remote ServeLinked Serve玄学问题登录不上开启远程访问