Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- synchronized processImport (String url, String importType) throws RuntimeException {
- InputStream stream = new URL(url).openStream();
- BufferedReader reader = new BufferedReader(new InputStreamReader(stream));
- String code;
- int i = 0;
- try {
- List<ComingInHotCode> buffer = new ArrayList<>();
- while((code = reader.readLine()) != null) {
- try {
- buffer.add(new CodeDomainObject([code: code, used: false, type: importType]));
- if (i % 100 == 0) {
- CodeDomainObject.saveAll(buffer);
- buffer.clear();
- }
- } catch (Exception ex) {
- println ("Save error:" + ex.getMessage())
- }
- i++;
- }
- CodeDomainObject.saveAll(buffer);
- } catch (Exception ex) {
- throw ex;
- } finally {
- reader.close();
- stream.close();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement