0

我有一种从 MySQL 数据库中提取和清理数据的方法。

该过程的下一步是将这些数据移动到 Oracle 数据库。

但是，在从 MySQL 中提取和清理数据的过程中，我与 oracle db 有一个连续的连接。这不是必需的，并且会极大地减慢提取过程。

如何让 java 等到提取/清理过程完成，然后连接到 Oracle？

这是我的代码：

public void ConvertFiles() {

    try {

        connectToDB();

        RawFile tempFile = new RawFile(super.mFileType);
        try {
            ArrayList<String> values = new ArrayList<String>();

            try {
                Statement stmt = conn.createStatement();
                ResultSet result = stmt.executeQuery("SELECT * FROM coffeedata");
                int ii = 0;
                while (result.next()) {
                    ii++;
                    System.out.print("Reading Row:" + ii + "/" + 41429 + "\n");
                    mStore = (result.getString(1));
                    mCategory = (result.getString(2));
                    mName = (result.getString(3));

                    // Add columns 2007 Q1 - Q4 t/m 2009 Q1 - Q2 to ArrayList   


                    for (int i = 4; i < 14; i++) {
                        values.add("" + result.getInt(i));

                    }
                    tempFile.addData(new SQLData(mCategory, mName, values, mStore));

                    try {
                        OracleController.DataToOracle();

                    } catch (Exception e) {
                        System.out.println(e.getMessage());

                    }
                }

                tempFile.CleanCategory();
                mRawFiles.add(tempFile);

            } catch (Exception e) {
                System.out.println(e.getMessage());
                closeDBConnection();

            }
        } catch (Exception e) {
            System.out.println(e.getMessage());
            //return values;
            //System.out.println(values);


        }
    } catch (Exception e) {
        System.out.println(e.getMessage());
    }

为了澄清：我想让这个 Try 等到前一个完成：

try {
    OracleController.DataToOracle();

}
4

1 回答 1

1

重构您的代码并在您想要等待try之后放置您的块。try - catch - finally

try{
    //block that you need to excecute before
} catch { ... }
// Than your block
try {
     OracleController.DataToOracle();
 } catch (Exception e)


                    }
于 2012-12-14T23:55:16.557 回答