| | |
| | | protected String _password; |
| | | protected String _orgSchema; |
| | | protected boolean _testMode = false; |
| | | protected int _testCount = -1; |
| | | protected int _testCount = -1; |
| | | |
| | | public abstract void execute(JobExecutionContext context) throws JobExecutionException; |
| | | |
| | |
| | | } |
| | | } |
| | | |
| | | protected OracleConvertJobContext prepareJobContext() |
| | | { |
| | | return new OracleConvertJobContext(); |
| | | } |
| | | protected abstract AbstractOracleJobContext prepareJobContext(String filterPath); |
| | | |
| | | protected static byte[] getBytesFromBLOB(BLOB blob) throws SQLException |
| | | { |
| | |
| | | byte[] chunk = new byte[optimalSize]; |
| | | InputStream is = blob.getBinaryStream(0); |
| | | ByteBuffer buffer = null; // ByteBuffer.allocate(optimalSize); |
| | | int len = 0; |
| | | int len; |
| | | |
| | | try |
| | | { |
| | |
| | | } |
| | | |
| | | is.close(); |
| | | |
| | | assert buffer != null; |
| | | buffer.position(0); |
| | | raw = buffer.array(); |
| | | } catch (IOException e) |