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. pstmt.addBatch();
  30. }
  31. int[]tt=pstmt.executeBatch();
  32. System.out.println("update:"+tt.length);
  33. //提交，设置事务初始值
  34. conn.commit();
  35. conn.setAutoCommit(true);
  36. //插入成功，返回
  37. returntt.length;
  39. }catch(sqlExceptionex){
  40. //提交失败，执行回滚操作
  41. conn.rollback();
  42. }catch(sqlExceptione){
  43. e.printStackTrace();
  44. System.err.println("updateExistsInfo回滚执行失败!!!");
  45. }
  46. ex.printStackTrace();
  47. System.err.println("updateExistsInfo执行失败");
  48. //插入失败返回标志0
  49. return0;
  50. finally{
  51. //关闭资源
  52. if(pstmt!=null)pstmt.close();
  53. if(conn!=null)conn.close();
  54. catch(sqlExceptione){
  55. e.printStackTrace();
  56. System.err.println("资源关闭失败!!!");
  57. /**
  58. *插入数据中没有的customer信息
  59. *@paramList<CustomerBean>
  60. *@return
  61. */
  62. intinsertNewInfo(List<CustomerBean>insertList){
  63. 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,"+
  64. "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)"+
  65. "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"> "?)";
  66. //插入需要的数据库对象
  67. Connectionconn= PreparedStatementpstmt=try{
  68. conn=newDBSource().getConnection();
  69. pstmt=conn.prepareStatement(sql,ResultSet.CONCUR_READ_ONLY);
  70. for(CustomerBeancbean:insertList){
  71. "gyyc00000");//
  72. 10,"95000000");//
  73. 11,getToday());
  74. 12,cbean.getSms_rec_flag());
  75. 13,cbean.getRegion_type());
  76. pstmt.addBatch();
  77. int[]tt=pstmt.executeBatch();
  78. System.out.println("insert:"+tt.length);
  79. //提交，设置事务初始值
  80. conn.commit();
  81. true);
  82. //插入成功，返回
  83. returntt.length;
  84. catch(sqlExceptionex){
  85. //提交失败，执行回滚操作
  86. conn.rollback();
  87. System.err.println("insertNewInfo回滚执行失败!!!");
  88. ex.printStackTrace();
  89. System.err.println("insertNewInfo执行失败");
  90. //插入失败返回标志0
  91. 0;
  92. finally{
  93. //关闭资源
  94. null)pstmt.close();
  95. null)conn.close();
  96. System.err.println("资源关闭失败!!!");
  97. }
使用Java JDBC基本的API批量插入数据到数据库中
  1. importjava.sql.Connection;
  2. importjava.sql.Statement;
  3. //...
  4. Connectionconnection=newgetConnection();
  5. Statementstatemenet=connection.createStatement();
  6. for(Employeeemployee:employees){
  7. Stringquery="insertintoemployee(name,city)values('"
  8. +employee.getName()+"','"+employee.getCity+"')";
  9. statemenet.addBatch(query);
  10. }
  11. statemenet.executeBatch();
  12. statemenet.close();
  13. connection.close();
  14. 请注意我们是如何从Employee对象中的数据动态创建查询并在批处理中添加，插入一气呵成。完美！是不是？
    等等......你必须思考什么关于sql注入？这样动态创建的查询sql注入是很容易的。并且每个插入查询每次都被编译。
    为什么不使用PreparedStatement而不是简单的声明。是的，这是个解决方案。下面是sql注入安全批处理。
    sql Injection Safe Batch - sql注入安全批处理
    思考一下下面代码:
    [java] view plain copy
    1. importjava.sql.Connection;
    2. importjava.sql.PreparedStatement;
    3. //...
    4. Stringsql="insertintoemployee(name,city,phone)values(?,?)";
    5. Connectionconnection=newgetConnection();
    6. PreparedStatementps=connection.prepareStatement(sql);
    7. for(Employeeemployee:employees){
    8. ps.setString( ps.setString(
    9. ps.addBatch();
    10. }
    11. ps.executeBatch();
    12. ps.close();
    13. 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. intcount=0;
    5. for(Employeeemployee:employees){
    7. ps.addBatch();
    8. if(++count%batchSize==0){
    9. ps.executeBatch();
    10. }
    11. ps.executeBatch();//insertremainingrecords
    12. connection.close();
这才是理想的解决方案，它避免了sql注入和内存不足的问题。看看我们如何递增计数器计数，一旦BATCHSIZE 达到 1000，我们调用executeBatch（）提交。
原文链接：https://www.f2er.com/oracle/208304.html

猜你在找的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玄学问题登录不上开启远程访问