[Spring 지하철 노선도 - 1,2단계] 기론(김규철) 미션 제출합니다.

README.md

@@ -37,3 +37,19 @@
 ## 📝 License
 
 This project is [MIT](https://github.com/woowacourse/atdd-subway-map/blob/master/LICENSE) licensed.
+
+
+## 기능 구현 목록
+
+- 지하철 역
+- [x] 지하철역 생성 시 이미 등록된 이름으로 요청한다면 에러를 응답
+
+- 지하철 노선
+- [x] 동일한 노선 생성 불가
+- api
+- [x] post - /lines 등록 - name, color
+- [x] get - /lines - List - id, name, color 
+- [ ] get - /lines/{id} - id, name, color
+- [ ] put - /lines/{id} - name, color
+- [ ] delete - /lines/{id}
+

src/main/java/wooteco/subway/SubwayApplication.java

@@ -6,8 +6,8 @@
 @SpringBootApplication
 public class SubwayApplication {
 
-	public static void main(String[] args) {
-		SpringApplication.run(SubwayApplication.class, args);
-	}
+    public static void main(String[] args) {
+        SpringApplication.run(SubwayApplication.class, args);
+    }
 
 }

src/main/java/wooteco/subway/dao/LineRepository.java

@@ -0,0 +1,23 @@
+package wooteco.subway.dao;
+
+import wooteco.subway.domain.Line;
+
+import java.util.List;
+import java.util.Optional;
+
+public interface LineRepository {
+
+    Line save(Line line);
+
+    List<Line> findAll();
+
+    Optional<Line> findById(Long id);
+
+    Optional<Line> findByName(String name);
+
+    void update(Long id, Line line);
+
+    void deleteById(Long id);
+
+    boolean existByName(String name);
+}

src/main/java/wooteco/subway/dao/LineRepositoryImpl.java

@@ -0,0 +1,102 @@
+package wooteco.subway.dao;
+
+import org.springframework.jdbc.core.RowMapper;
+import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
+import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
+import org.springframework.jdbc.core.namedparam.SqlParameterSource;
+import org.springframework.jdbc.core.simple.SimpleJdbcInsert;
+import org.springframework.stereotype.Repository;
+import wooteco.subway.domain.Line;
+
+import javax.sql.DataSource;
+import java.util.List;
+import java.util.Optional;
+
+@Repository
+public class LineRepositoryImpl implements LineRepository {
+
+    private final NamedParameterJdbcTemplate namedParameterJdbcTemplate;
+    private final SimpleJdbcInsert simpleJdbcInsert;
+
+    private RowMapper<Line> rowMapper() {
+        return (resultSet, rowNum) -> {
+            long id = resultSet.getLong("id");
+            String name = resultSet.getString("name");
+            String color = resultSet.getString("color");
+            return new Line(id, name, color);
+        };
+    }
+
+    public LineRepositoryImpl(DataSource dataSource) {
+        this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);
+        this.simpleJdbcInsert = new SimpleJdbcInsert(dataSource)
+                .withTableName("line")
+                .usingGeneratedKeyColumns("id");
+    }
+
+    @Override
+    public Line save(final Line line) {
+        SqlParameterSource parameters = new MapSqlParameterSource()
+                .addValue("name", line.getName())
+                .addValue("color", line.getColor());
+
+        long id = simpleJdbcInsert.executeAndReturnKey(parameters).longValue();
+        return new Line(id, line.getName(), line.getColor());
+    }
+
+    @Override
+    public List<Line> findAll() {
+        String sql = "SELECT * FROM line";
+        return namedParameterJdbcTemplate.query(sql, rowMapper());
+    }
+
+    @Override
+    public Optional<Line> findById(final Long id) {
+        String sql = "SELECT * FROM line WHERE id = :id";
+        SqlParameterSource parameters = new MapSqlParameterSource("id", id);
+        List<Line> lines = namedParameterJdbcTemplate.query(sql, parameters, rowMapper());
+        return getOptional(lines);
+    }
+
+    @Override
+    public Optional<Line> findByName(final String name) {
+        String sql = "SELECT * FROM line WHERE name = :name";
+        SqlParameterSource parameters = new MapSqlParameterSource("name", name);
+        List<Line> lines = namedParameterJdbcTemplate.query(sql, parameters, rowMapper());
+        return getOptional(lines);
+    }
+
+    private Optional<Line> getOptional(List<Line> lines) {
+        if (lines.isEmpty()) {
+            return Optional.empty();
+        }
+        return Optional.ofNullable(lines.get(0));
+    }
+
+    @Override
+    public void update(final Long id, final Line line) {
+        String sql = "UPDATE line SET name = :name,  color = :color WHERE id = :id";
+
+        SqlParameterSource nameParameters = new MapSqlParameterSource()
+                .addValue("id", id)
+                .addValue("name", line.getName())
+                .addValue("color", line.getColor());
+
+        namedParameterJdbcTemplate.update(sql, nameParameters);
+    }
+
+    @Override
+    public void deleteById(Long id) {
+        String sql = "DELETE FROM line WHERE id = :id";
+        SqlParameterSource parameters = new MapSqlParameterSource("id", id);
+        namedParameterJdbcTemplate.update(sql, parameters);
+    }
+
+    @Override
+    public boolean existByName(String name) {
+        final String sql = "SELECT COUNT(*) FROM line WHERE name = :name";
+        SqlParameterSource parameters = new MapSqlParameterSource("name", name);
+        Integer count = namedParameterJdbcTemplate.queryForObject(sql, parameters, Integer.class);
+        return count != 0;
+    }
+}

src/main/java/wooteco/subway/dao/StationRepository.java

@@ -0,0 +1,21 @@
+package wooteco.subway.dao;
+
+import wooteco.subway.domain.Station;
+
+import java.util.List;
+import java.util.Optional;
+
+public interface StationRepository {
+
+    Station save(final Station station);
+
+    List<Station> findAll();
+
+    void deleteById(Long id);
+
+    Optional<Station> findByName(String name);
+
+    Optional<Station> findById(Long id);
+
+    boolean existByName(String name);
+}

src/main/java/wooteco/subway/dao/StationRepositoryImpl.java

@@ -0,0 +1,87 @@
+package wooteco.subway.dao;
+
+import org.springframework.jdbc.core.RowMapper;
+import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
+import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
+import org.springframework.jdbc.core.namedparam.SqlParameterSource;
+import org.springframework.jdbc.core.simple.SimpleJdbcInsert;
+import org.springframework.stereotype.Repository;
+import wooteco.subway.domain.Station;
+
+import javax.sql.DataSource;
+import java.util.List;
+import java.util.Optional;
+
+@Repository
+public class StationRepositoryImpl implements StationRepository {
+
+    private final NamedParameterJdbcTemplate namedParameterJdbcTemplate;
+    private final SimpleJdbcInsert simpleJdbcInsert;
+
+    private RowMapper<Station> rowMapper() {
+        return (resultSet, rowNum) -> {
+            long id = resultSet.getLong("id");
+            String name = resultSet.getString("name");
+            return new Station(id, name);
+        };
+    }
+
+    public StationRepositoryImpl(DataSource dataSource) {
+        this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);
+        this.simpleJdbcInsert = new SimpleJdbcInsert(dataSource)
+                .withTableName("station")
+                .usingGeneratedKeyColumns("id");
+    }
+
+    @Override
+    public Station save(final Station station) {
+        SqlParameterSource parameters = new MapSqlParameterSource()
+                .addValue("name", station.getName());
+        Long id = simpleJdbcInsert.executeAndReturnKey(parameters).longValue();
+        return new Station(id, station.getName());
+    }
+
+    @Override
+    public List<Station> findAll() {
+        String sql = "SELECT * FROM station";
+        RowMapper<Station> stationRowMapper = rowMapper();
+        return namedParameterJdbcTemplate.query(sql, stationRowMapper);
+    }
+
+    @Override
+    public void deleteById(final Long id) {
+        String sql = "DELETE FROM station WHERE id = :id";
+        namedParameterJdbcTemplate.update(sql, new MapSqlParameterSource("id", id));
+    }
+
+    @Override
+    public Optional<Station> findByName(final String name) {
+        String sql = "SELECT * FROM station WHERE name = :name";
+        SqlParameterSource parameters = new MapSqlParameterSource("name", name);
+        List<Station> stations = namedParameterJdbcTemplate.query(sql, parameters, rowMapper());
+        return getOptional(stations);
+    }
+
+    @Override
+    public Optional<Station> findById(Long id) {
+        String sql = "SELECT * FROM station WHERE id = :id";
+        SqlParameterSource parameters = new MapSqlParameterSource("id", id);
+        List<Station> stations = namedParameterJdbcTemplate.query(sql, parameters, rowMapper());
+        return getOptional(stations);
+    }
+
+    private Optional<Station> getOptional(List<Station> stations) {
+        if (stations.isEmpty()) {
+            return Optional.empty();
+        }
+        return Optional.ofNullable(stations.get(0));
+    }
+
+    @Override
+    public boolean existByName(String name) {
+        final String sql = "SELECT COUNT(*) FROM station WHERE name = :name";
+        SqlParameterSource parameters = new MapSqlParameterSource("name", name);
+        Integer count = namedParameterJdbcTemplate.queryForObject(sql, parameters, Integer.class);
+        return count != 0;
+    }
+}

src/main/java/wooteco/subway/domain/Line.java

@@ -0,0 +1,45 @@
+package wooteco.subway.domain;
+
+import java.util.Objects;
+
+public class Line {
+
+    private final Long id;
+    private final String name;
+    private final String color;
+
+    public Line(String name, String color) {
+        this(null, name, color);
+    }
+
+    public Line(Long id, String name, String color) {
+        this.id = id;
+        this.name = name;
+        this.color = color;
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public String getColor() {
+        return color;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        Line line = (Line) o;
+        return Objects.equals(name, line.name);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(name);
+    }
+}

src/main/java/wooteco/subway/domain/Station.java

@@ -1,27 +1,39 @@
 package wooteco.subway.domain;
 
+import java.util.Objects;
+
 public class Station {
-    private Long id;
-    private String name;
+    private final Long id;
+    private final String name;
 
-    public Station() {
+    public Station(String name) {
+        this(null, name);
     }
 
     public Station(Long id, String name) {
         this.id = id;
         this.name = name;
     }
 
-    public Station(String name) {
-        this.name = name;
-    }
-
     public Long getId() {
         return id;
     }
 
     public String getName() {
         return name;
     }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        Station station = (Station) o;
+        return Objects.equals(name, station.name);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(name);
+    }
 }