java- 使用 Commit Transaction 插入到 table

Question

我想在我的 java 程序中开始一个交易，以插入到我在 MYSQL 中的 table。

我的代码：

 public void index(String path) throws Exception {   

        PDDocument document = PDDocument.load(new File(path));

            if (!document.isEncrypted()) {

                PDFTextStripper tStripper = new PDFTextStripper();
                String pdfFileInText = tStripper.getText(document);
                String lines[] = pdfFileInText.split("\r?\n");
                for (String line : lines) {
                    String[] words = line.split(" ");


                    String sql="insert IGNORE into  test.indextable values (?,?);";

                       preparedStatement = con.connect().prepareStatement(sql);
                     int i=0;
                    for (String word : words) {

                        // check if one or more special characters at end of string then remove OR
                        // check special characters in beginning of the string then remove
                    // insert every word directly to table db
                      word=word.replaceAll("([\W]+$)|(^[\W]+)", "");
                        preparedStatement.setString(1, path);
                        preparedStatement.setString(2, word);

                        preparedStatement.executeUpdate();
        System.out.print("Add ");



                }


            }

        con.connect().commit();
        preparedStatement.close();
     con.connect().close();

        System.out.println("Successfully commited changes to the database!");

我在连接 class 中将 AutoCommit 设置为 false。但是，当我运行程序时，它通常会在停止之前打印出消息“添加”几次。如果我继续等待，它最终会说：Lock Time Exceeding,please restart transaction.

编辑：

连接方式（不同class）：

public Connection connect() throws Exception {
    Properties props=new Properties();


    InputStream in = getClass().getResourceAsStream("/db.properties");

    props.load(in);
    in.close();



    String driver = props.getProperty("jdbc.driver");
    if(driver!=null){
        Class.forName(driver);

    }

    String url=props.getProperty("jdbc.url");
    String username=props.getProperty("jdbc.username");
    String password=props.getProperty("jdbc.password");

    Connection con = DriverManager.getConnection(url,username,password);
    //con.setAutoCommit(false);

    return con;

}

回滚函数：

 public void rollbackEntries() throws Exception {

       con.connect().rollback();
       System.out.println("Successfully rolled back changes from the database!");


    }

Answer 1

您应该使用相同的连接进行提交

 Connection con =con.connect();
 ....
 con.commit();
 con.close();

顺便说一句，移动到连接池并捕获异常以在发生错误时释放资源

java- 使用 Commit Transaction 插入到 table

java- using Commit Transaction to insert to table

java

mysql

database-connection