美文网首页
JDBC批处理

JDBC批处理

作者: 白纸糊 | 来源:发表于2019-04-02 16:16 被阅读0次

    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.Statement;
    import java.util.Arrays;

    public class OracleDemo {
    private static final String DBDRIVER = "oracle.jdbc.driver.OracleDriver";
    private static final String DBURL = "jdbc:oracle:thin:@localhost:1521:acehzh";
    private static final String USER = "scott";
    private static final String PASSWORD = "tiger";

    public static void main(String[] args) throws Exception {
        // 1.加载数据库驱动
        Class.forName(DBDRIVER);
        // 2.链接数据库
        Connection conn = DriverManager.getConnection(DBURL, USER, PASSWORD);
        // 3.操作数据库
        Statement sta = conn.createStatement();
        sta.addBatch("INSERT INTO member(mid,name) VALUES(myseq.nextval,'测试员A')");
        sta.addBatch("INSERT INTO member(mid,name) VALUES(myseq.nextval,'测试员B')");
        sta.addBatch("INSERT INTO member(mid,name) VALUES(myseq.nextval,'测试员C')");
        sta.addBatch("INSERT INTO member(mid,name) VALUES(myseq.nextval,'测试员D')");
        int[] result = sta.executeBatch();
        System.out.println(Arrays.toString(result));
        conn.close();
    }
    

    }
    ==============分割线===============

    范例2:利用事务处理

    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.Statement;
    import java.util.Arrays;

    public class OracleDemo {
    private static final String DBDRIVER = "oracle.jdbc.driver.OracleDriver";
    private static final String DBURL = "jdbc:oracle:thin:@localhost:1521:acehzh";
    private static final String USER = "scott";
    private static final String PASSWORD = "tiger";

    public static void main(String[] args) throws Exception {
        // 1.加载数据库驱动
        Class.forName(DBDRIVER);
        // 2.链接数据库
        Connection conn = DriverManager.getConnection(DBURL, USER, PASSWORD);
        // 3.操作数据库
        Statement sta = conn.createStatement();
        conn.setAutoCommit(false);
        try {           
            sta.addBatch("INSERT INTO member(mid,name) VALUES(myseq.nextval,'测试员A')");
            sta.addBatch("INSERT INTO member(mid,name) VALUES(myseq.nextval,'测试员B')");
            sta.addBatch("INSERT INTO member(mid,name) VALUES(myseq.nextval,'测试员C')");
            sta.addBatch("INSERT INTO member(mid,name) VALUES(myseq.nextval,'测试员D')");
            int[] result = sta.executeBatch();
            System.out.println(Arrays.toString(result));
            conn.commit();//如果没有错误就会提交
        } catch (Exception e) {
            e.printStackTrace();
            conn.rollback();
        }
        
        conn.close();
    }
    

    相关文章

      网友评论

          本文标题:JDBC批处理

          本文链接:https://www.haomeiwen.com/subject/rdvgbqtx.html