直接上代码:
package
cn.zhou.epet.test;
cn.zhou.epet.test;
import
java.sql.*;
java.sql.*;
public
class Addbatch {
class Addbatch {
public
static void main(String[] args) {
static void main(String[] args) {
Connection connection =
null;
null;
PreparedStatement stmt =
null;
null;
try
{
{
//
加载数据库相关驱动
加载数据库相关驱动
Class.forName("oracle.jdbc.driver.OracleDriver");
//
连接到数据库
连接到数据库
connection =
DriverManager.getConnection(
DriverManager.getConnection(
"jdbc:oracle:thin:@localhost:1521:bdqn",
"epet", "admin");
"epet", "admin");
stmt =
connection
connection
.prepareStatement("insert
into master values(master_seq.nextval,?,?,?)");
into master values(master_seq.nextval,?,?,?)");
connection.setAutoCommit(false);//
Transaction Begin,让程序不自动提交事务
Transaction Begin,让程序不自动提交事务
stmt.setString(1,
"QQ");
"QQ");
stmt.setString(2,
"RR");
"RR");
stmt.setInt(3,
1);
1);
stmt.addBatch();//
添加批处理1
添加批处理1
stmt.setString(1,
"WW");
"WW");
stmt.setString(2,
"EE");
"EE");
stmt.setInt(3,
1);
1);
stmt.addBatch();//
添加批处理2
添加批处理2
stmt.setString(1,
"VV");
"VV");
stmt.setString(2,
"AA");
"AA");
stmt.setInt(3,
1);
1);
stmt.addBatch();//
添加批处理3
添加批处理3
stmt.executeBatch();//
执行批处理
执行批处理
connection.commit();//
提交事务
提交事务
connection.setAutoCommit(true);//
Transaction End,让程序自动提交事务(默认)
Transaction End,让程序自动提交事务(默认)
System.out.println("dd");
} catch
(ClassNotFoundException e) {
(ClassNotFoundException e) {
e.printStackTrace();
System.out.println("未能成功加载驱动类!");
} catch
(SQLException e) {
(SQLException e) {
e.printStackTrace();
System.out.println("执行SQL语句是出现异常！");
try
{
{
if
(connection != null) {
(connection != null) {
connection.rollback();//
事务回滚
事务回滚
connection.setAutoCommit(true);//
让程序自动提交事务(默认)
让程序自动提交事务(默认)
}
} catch
(SQLException e1) {
(SQLException e1) {
e1.printStackTrace();
}
} catch
(Exception e) {
(Exception e) {
e.printStackTrace();
System.out.println("其他异常！");
}
finally {
finally {
try
{
{
if (stmt
!= null) {
!= null) {
stmt.close();
stmt =
null;
null;
}
if
(connection != null) {
(connection != null) {
connection.close();
connection =
null;
null;
}
} catch
(SQLException e2) {
(SQLException e2) {
System.out.println("关闭数据库时出现异常！");
}
}
}
}
