jdbc入门（二）批量处理

朴灿烈づ我的快乐病毒、 2022-05-15 10:21 133阅读 0赞

package com.ck.jdbc;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class InsertTest2 {
    
    	public static void main(String[] args) throws SQLException {
    		long startTime = System.currentTimeMillis();
    		Connection con = null;		//连接
    		Statement stmt = null; //sql语句对象
    		try {
    			//加载驱动
    			Class.forName("oracle.jdbc.OracleDriver");
    			//建立连接
    			con = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:ORCL","scott","a");
    			//创建sql语句对象
    			String[] sqls = new String[]{
    				"insert into test values(seq_qid.nextval,'807156235','a',18,'男')"	,
    				"insert into test values(seq_qid.nextval,'761643427','b',20,'男')"	,
    				"insert into test values(seq_qid.nextval,'807156230','c',14,'男')"	,
    				"insert into test values(seq_qid.nextval,'807156231','d',22,'男')"	,
    				"insert into test values(seq_qid.nextval,'807156232','e',24,'男')"	,
    				"insert into test values(seq_qid.nextval,'807156233','f',18,'男')"	,
    			};
    			con.setAutoCommit(false);  //关闭自动提交，即开启事务
    			//创建sql语句对象
    			stmt = con.createStatement();
    			for(String sql : sqls){
    				//执行
    				stmt.executeUpdate(sql);
    			}
    			con.commit();	   //提交事务
    		} catch (ClassNotFoundException e) {
    			e.printStackTrace();
    		} catch (SQLException e) {
    			con.rollback();  // 回滚
    			e.printStackTrace();
    		} finally{ //关闭连接
    			if(con != null){
    				con.close();
    			}
    			if(stmt != null){
    				stmt.close();
    			}
    		}
    		long endTime = System.currentTimeMillis();
    		System.out.println("耗时：" + (endTime - startTime));
    	}
    
    }

运行后数据库查询结果：

![70][]

[70]: /images/20220515/c5c97c16e0d74204b8b6080a65a246f1.png