我有一种从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();
}
最佳答案
重构代码并将try
块放在要等待的try - catch - finally
之后。
try{
//block that you need to excecute before
} catch { ... }
// Than your block
try {
OracleController.DataToOracle();
} catch (Exception e)
}