statement与preparedStatement 批量操作(转)

摘要:
“);con.setAutoCommit;}catch{e.printStackTrace();try{//rollback:如果发生异常,数据库中所有已完成的操作都将被撤消,然后事务将回滚到事务开始状态,如果(!**/publicclassPreparedStatementCommitAndRollbackTest{publicstaticvoidmain{Connectioncon=null;PreparedSStatementpstm=null;try{//1。与数据库con=JDBCConAndClo建立连接。getConnectionBao();//2.执行sql语句//1)。首先创建PreparedStatement语句:pstm=con.prepareStatement(“insertinstudentvalues(?pstm.addBatch();//2)设置sql语句3pstm.setInt;pstm.setString;pstm.Set String;pstm.setDouble;//3)向此PreparedSStatement对象的批处理命令添加一组参数。

原文:http://blog.csdn.net/etttttss/article/details/16819547

PreparedStatement:

1) addBatch()将一组参数添加到PreparedStatement对象内部。

2) executeBatch()将一批参数提交给数据库来执行,如果全部命令执行成功,则返回更新计数组成的数组。

Statement:

1) addBatch(String sql)方法会在批处理缓存中加入一条sql语句。

2) executeBatch()执行批处理缓存中的所有sql语句。

注意:PreparedStatement中使用批量更新时,要先设置好参数后再使用addBatch()方法加入缓存。批量更新中只能使用更改、删除或插入语句

package com.ambow.day20.jdbc.JDBCTestCommitAndRollback;   
import java.sql.Connection;   
import java.sql.SQLException;   
import java.sql.Statement;   
import com.ambow.day19.jdbc.util.JDBCConAndClo;   
/**//*  
 *1,首先把Auto commit设置为false,不让它自动提交  
 *2,进行手动提交(commit)  
 *3,提交完成后回复现场将Auto commit,还原为true,  
 *4,当异常发生执行catch中SQLException时,记得要rollback(回滚);  
 * */  
public class StatementCommitAndRollbackTest {   
    public static void main(String args[]) {   
        Connection con = null;   
        Statement stm = null;   
        try {   
            con = JDBCConAndClo.getConnectionBao();   
            stm = con.createStatement();   
            con.setAutoCommit(false);   
            // 若不出现异常,则继续执行到try语句完,否则跳转到catch语句中   
            stm.addBatch("insert into student values(23,'tangbao','高数',100)");   
            stm.addBatch("insert into student values(24,'王定','c#',98)");   
            stm.addBatch("insert into student values(25,'王国云','java',90)");   
            stm.addBatch("insert into student values(26,'溜出','英语',89)");   
            stm.addBatch("insert into student values(27,'wqde','java',63)");   
            /**//*  
             * int[] executeBatch() throws  
             * SQLException将一批命令提交给数据库来执行,如果全部命令执行成功,则返回更新计数组成的数组。  
             */  
            stm.executeBatch();   
            System.out.println("插入成功!");   
            // commit:若成功执行完所有的插入操作,则正常结束   
            con.commit();   
            System.out.println("提交成功!");   
            con.setAutoCommit(true);   
  
        } catch (SQLException e) {   
            e.printStackTrace();   
            try {   
    //rollback: 若出现异常,对数据库中所有已完成的操作全部撤销,则回滚到事务开始状态   
                if (!con.isClosed()) {   
                    con.rollback();   
                    System.out.println("提交失败,回滚!");   
                    con.setAutoCommit(true);   
                }   
            } catch (SQLException e1) {   
                e1.printStackTrace();   
            } finally {   
                JDBCConAndClo.closeStatement(stm);   
                JDBCConAndClo.closeConnection(con);   
            }   
        }   
    }   
}   
PreparedStatement批量处理和事务代码如下:   
package com.ambow.day20.jdbc.JDBCTestCommitAndRollback;   
import java.sql.Connection;   
import java.sql.PreparedStatement;   
import java.sql.SQLException;   
import com.ambow.day19.jdbc.util.JDBCConAndClo;   
  
/**//*  
 * PreparedStatement:  
 1.addBatch() 将一组参数添加到 PreparedStatement对象内部  
 2.executeBatch() 将一批参数提交给数据库来执行,如果全部命令执行成功,则返回更新计数组成的数组。  
 *   
 */  
public class PreparedStatementCommitAndRollbackTest {   
    public static void main(String args[]) {   
        Connection con = null;   
        PreparedStatement pstm = null;   
  
        try {   
            // 1. 建立与数据库的连接   
            con = JDBCConAndClo.getConnectionBao();   
            // 2. 执行sql语句   
            // 1).先创建PreparedStatement语句(发送slq请求):   
            pstm = con.prepareStatement("insert into student values(?,?,?,?)");   
            con.setAutoCommit(false);//1,首先把Auto commit设置为false,不让它自动提交   
            // 2) 设置sql语句1   
            pstm.setInt(1, 33);   
            pstm.setString(2,"wangqin");   
            pstm.setString(3, "c++");   
            pstm.setDouble(4, 78.5);   
            // 3) 将一组参数添加到此 PreparedStatement 对象的批处理命令中。   
            pstm.addBatch();   
            // 2) 设置sql语句2   
            pstm.setInt(1, 34);   
            pstm.setString(2,"wuytun");   
            pstm.setString(3, "c");   
            pstm.setDouble(4, 77);   
            // 3) 将一组参数添加到此 PreparedStatement 对象的批处理命令中。   
            pstm.addBatch();   
            // 2) 设置sql语句3   
            pstm.setInt(1, 31);   
            pstm.setString(2,"tetet");   
            pstm.setString(3, "c++");   
            pstm.setDouble(4, 90);   
            // 3) 将一组参数添加到此 PreparedStatement 对象的批处理命令中。   
            pstm.addBatch();   
            // 2) 设置sql语句4   
            pstm.setInt(1, 32);   
            pstm.setString(2,"liug");   
            pstm.setString(3, "c");   
            pstm.setDouble(4, 50);   
            // 3) 将一组参数添加到此 PreparedStatement 对象的批处理命令中。   
            pstm.addBatch();   
            // 4) 将一批参数提交给数据库来执行,如果全部命令执行成功,则返回更新计数组成的数组。   
            pstm.executeBatch();   
            System.out.println("插入成功!");   
            // 若成功执行完所有的插入操作,则正常结束   
            con.commit();//2,进行手动提交(commit)   
            System.out.println("提交成功!");   
            con.setAutoCommit(true);//3,提交完成后回复现场将Auto commit,还原为true,   
  
        } catch (SQLException e) {   
            e.printStackTrace();   
            try {   
                // 若出现异常,对数据库中所有已完成的操作全部撤销,则回滚到事务开始状态   
                if(!con.isClosed()){   
                    con.rollback();//4,当异常发生执行catch中SQLException时,记得要rollback(回滚);   
                    System.out.println("插入失败,回滚!");   
                    con.setAutoCommit(true);   
                }   
            } catch (SQLException e1) {   
                e1.printStackTrace();   
            }   
        }finally{   
            JDBCConAndClo.closePreparedStatement(pstm);   
            JDBCConAndClo.closeConnection(con);   
        }   
    }   
}  

免责声明:文章转载自《statement与preparedStatement 批量操作(转)》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇CentOS8系统安装和基本配置ubuntu16安装docker下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

【DB宝41】监控利器PMM的使用--监控MySQL、PG、MongoDB、ProxySQL等

目录 一、PMM简介 二、安装使用 三、监控MySQL数据库MySQL慢查询分析 四、监控PG数据库 五、监控MongoDB数据库 六、监控ProxySQL中间件 一、PMM简介 之前发布过一篇Prometheus+Grafana的文章,连接为:【DB宝36】使用Docker分分钟搭建漂亮的prometheus+grafana监控,今天我们...

解决ArcGIS中因SDE或数据库配置问题而导致服务宕掉的一种思路

文章版权由作者李晓晖和博客园共有,若转载请于明显处标明出处:http://www.cnblogs.com/naaoveGIS/。 1.背景 最近连续有两个项目现场出现了AGS服务荡掉的问题,一个是通州现场,一个是福州现场。 1.1通州现场的问题描述和解决思路 通州现场环境为ArcGIS9.2,使用IMS发布的地图服务,其问题表现为每隔两天左右,其地形图服务...

SonarQube系列一、Linux安装与部署

【前言】 随着项目团队规模日益壮大,项目代码量也越来越多。且不说团队成员编码水平层次不齐,即便是老手,也难免因为代码量的增加和任务的繁重而忽略代码的质量,最终的问题便是bug的增多和代码债务的堆积。因此,代码review便日益提上了日程。当然人工review的效率还是相当低下的,于是我们采用了自动化代码review的工具,便是今天的主角:SonarQube...

二、NOSQL之Memcached缓存服务实战精讲第一部

1.Memcached是一套数据缓存系统或软件。 用于在动态应用系统中缓存数据库的数据,减少数据库的访问压力,达到提升网站系统性能的目的;Memcached在企业应用场景中一般是用来作为数据库的cache服务使用;(但不是专门干这个,还可以干别的,主要是干这个,知道就好) 1)linux有特性,系统内存没有用完,利用这些内存就会缓存起来,所以剩余的内存为...

DB2导入导出 学习笔记

db2pd -osinfodb2mtrk -i -d (for aix)db2 get dbm cfg show detaildb2 get db cfg show detaildb2 get snapshot for all bufferpools导出:connect database then export to "d:code.data" of ix...

saas系统多租户数据隔离的实现(一)数据隔离方案

0. 前言 前几天跟朋友聚会的时候,朋友说他们公司准备自己搞一套saas系统,以实现多个第三方平台的业务接入需求。聊完以后,实在手痒难耐,于是花了两天时间自己实现了两个saas系统多租户数据隔离实现方案。俗话说“独乐乐不如众乐乐”,所以我把我的“研究成果”写出来,让大家乐呵乐呵。 在分享我的研究成果之前,我们先了解一下相关的定义吧。如果对这部分内容熟悉的同...