lesson 9 видео № 3 "NIO":

AlbertoJava · AlbertoJava · commit fa9b1f6c03c6 · 2019-10-07T01:13:21.000+03:00
&#1050;&#1083;&#1072;&#1089;&#1089; AbstractPathStorage &#1087;&#1077;&#1088;&#1077;&#1076;&#1077;&#1083;&#1072;&#1090;&#1100; &#1085;&#1072; Path
diff --git a/src/com/urise/webapp/storage/AbstractPathStorage.java b/src/com/urise/webapp/storage/AbstractPathStorage.java
@@ -0,0 +1,109 @@
+package com.urise.webapp.storage;
+
+import com.urise.webapp.exception.StorageException;
+import com.urise.webapp.model.Resume;
+
+import java.io.*;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+import java.util.function.Consumer;
+
+public abstract class AbstractPathStorage extends AbstractStorage {
+    private Path directory;
+
+    protected AbstractPathStorage(String dir) {
+        Path directory = Paths.get(dir);
+        Objects.requireNonNull(directory, "directory must not null");
+        if (!Files.isDirectory(directory)||!Files.isWritable(directory) ) {
+            throw new IllegalArgumentException(dir + " is not directory or is not writable");
+        }
+        this.directory = directory;
+    }
+
+    protected abstract void doWrite(Resume resume, OutputStream os) throws IOException;
+
+    protected abstract Resume doRead(InputStream is) throws IOException;
+
+    @Override
+    protected void doUpdate(Resume resume, Object searchKey) {
+        File file = (File) searchKey;
+        try {
+            doWrite(resume, new BufferedOutputStream(new FileOutputStream(file)));
+        } catch (IOException e) {
+            throw new StorageException("File write error", resume.getUuid(), e);
+        }
+    }
+
+    @Override
+    protected boolean isExist(Object file) {
+        return ((File) file).exists();
+    }
+
+    @Override
+    protected void doSave(Resume resume, Object file) {
+        File f = ((File) file);
+        try {
+
+            f.createNewFile();
+        } catch (IOException e) {
+            throw new StorageException("Couldn't create file " + f.getAbsolutePath(), f.getName(), e);
+        }
+        doUpdate(resume, f);
+    }
+
+    @Override
+    protected Resume doGet(Object searchKey) {
+        File file = (File) searchKey;
+        try {
+            return doRead(new BufferedInputStream(new FileInputStream(file)));
+        } catch (IOException e) {
+            throw new StorageException("File read error", file.getName(), e);
+        }
+    }
+
+    @Override
+    protected void doDelete(Object searchKey) {
+        File f = (File) searchKey;
+        f.delete();
+//&#1091;&#1076;&#1072;&#1083;&#1103;&#1077;&#1090; &#1092;&#1072;&#1081;&#1083;
+    }
+
+    @Override
+    protected File getSearchKey(String uuid) {
+        return new File(directory, uuid);
+    }
+
+    @Override
+    protected List<Resume> doCopyAll() {
+        //&#1095;&#1080;&#1090;&#1072;&#1077;&#1090; &#1074;&#1089;&#1077; &#1092;&#1072;&#1081;&#1083;&#1099; &#1080; &#1076;&#1077;&#1083;&#1072;&#1077;&#1090; do Read &#1080; &#1074;&#1086;&#1079;&#1074;&#1088;&#1072;&#1097;&#1072;&#1077;&#1090; list
+        List<Resume> resumes = new ArrayList<>();
+        File[] files = directory.listFiles();
+        if (files == null) {
+            return resumes;
+        }
+        for (File f : directory.listFiles()) {
+            resumes.add(doGet(f));
+        }
+        return resumes;
+    }
+
+    @Override
+    public void clear() {
+        try {
+            Files.list(directory).forEach(this::doDelete);
+        } catch (IOException e) {
+            throw new StorageException("Path delete error",null);
+        }
+    }
+
+    @Override
+    public int size() {
+        //&#1082;&#1086;&#1083;&#1080;&#1095;&#1077;&#1089;&#1090;&#1074;&#1086; &#1092;&#1072;&#1083;&#1086;&#1074; &#1074; &#1082;&#1072;&#1090;&#1072;&#1083;&#1086;&#1075;&#1077;
+        File[] files = directory.listFiles();
+        return files == null ? 0 : files.length;
+    }
+}
