Advertisement
Guest User

Untitled

a guest
Oct 23rd, 2016
62
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.91 KB | None | 0 0
  1. synchronized processImport (String url, String importType) throws RuntimeException {
  2.  
  3. InputStream stream = new URL(url).openStream();
  4. BufferedReader reader = new BufferedReader(new InputStreamReader(stream));
  5.  
  6. String code;
  7. int i = 0;
  8. try {
  9. List<ComingInHotCode> buffer = new ArrayList<>();
  10. while((code = reader.readLine()) != null) {
  11. try {
  12. buffer.add(new CodeDomainObject([code: code, used: false, type: importType]));
  13. if (i % 100 == 0) {
  14. CodeDomainObject.saveAll(buffer);
  15. buffer.clear();
  16. }
  17.  
  18. } catch (Exception ex) {
  19. println ("Save error:" + ex.getMessage())
  20. }
  21. i++;
  22. }
  23. CodeDomainObject.saveAll(buffer);
  24.  
  25. } catch (Exception ex) {
  26. throw ex;
  27. } finally {
  28. reader.close();
  29. stream.close();
  30. }
  31. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement