Mon, 01 Jun 2020 14:46:58 +0200
improves issue overview and adds progress information
1 /*
2 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
3 *
4 * Copyright 2018 Mike Becker. All rights reserved.
5 *
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted provided that the following conditions are met:
8 *
9 * 1. Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer.
11 *
12 * 2. Redistributions in binary form must reproduce the above copyright
13 * notice, this list of conditions and the following disclaimer in the
14 * documentation and/or other materials provided with the distribution.
15 *
16 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
17 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
20 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
21 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
22 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
23 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
24 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
25 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
26 * POSSIBILITY OF SUCH DAMAGE.
27 *
28 */
29 package de.uapcore.lightpit.dao.postgres;
31 import de.uapcore.lightpit.dao.VersionDao;
32 import de.uapcore.lightpit.entities.Project;
33 import de.uapcore.lightpit.entities.Version;
34 import de.uapcore.lightpit.entities.VersionStatus;
36 import java.sql.Connection;
37 import java.sql.PreparedStatement;
38 import java.sql.ResultSet;
39 import java.sql.SQLException;
40 import java.util.ArrayList;
41 import java.util.List;
42 import java.util.Objects;
44 public final class PGVersionDao implements VersionDao {
46 private final PreparedStatement insert, update, list, find;
48 public PGVersionDao(Connection connection) throws SQLException {
49 list = connection.prepareStatement(
50 "select versionid, project, p.name as projectname, v.name, ordinal, status " +
51 "from lpit_version v " +
52 "join lpit_project p on v.project = p.projectid " +
53 "where project = ? " +
54 "order by ordinal desc, lower(v.name) desc");
56 find = connection.prepareStatement(
57 "select versionid, project, p.name as projectname, v.name, ordinal, status " +
58 "from lpit_version v " +
59 "join lpit_project p on v.project = p.projectid " +
60 "where versionid = ?");
62 insert = connection.prepareStatement(
63 "insert into lpit_version (project, name, ordinal, status) values (?, ?, ?, ?::version_status)"
64 );
65 update = connection.prepareStatement(
66 "update lpit_version set name = ?, ordinal = ?, status = ?::version_status where versionid = ?"
67 );
68 }
70 private Version mapColumns(ResultSet result) throws SQLException {
71 final var project = new Project(result.getInt("project"));
72 project.setName(result.getString("projectname"));
73 final var version = new Version(result.getInt("versionid"));
74 version.setProject(project);
75 version.setName(result.getString("name"));
76 version.setOrdinal(result.getInt("ordinal"));
77 version.setStatus(VersionStatus.valueOf(result.getString("status")));
78 return version;
79 }
81 @Override
82 public void save(Version instance) throws SQLException {
83 Objects.requireNonNull(instance.getName());
84 Objects.requireNonNull(instance.getProject());
85 insert.setInt(1, instance.getProject().getId());
86 insert.setString(2, instance.getName());
87 insert.setInt(3, instance.getOrdinal());
88 insert.setString(4, instance.getStatus().name());
89 insert.executeUpdate();
90 }
92 @Override
93 public boolean update(Version instance) throws SQLException {
94 if (instance.getId() < 0) return false;
95 Objects.requireNonNull(instance.getName());
96 update.setString(1, instance.getName());
97 update.setInt(2, instance.getOrdinal());
98 update.setString(3, instance.getStatus().name());
99 update.setInt(4, instance.getId());
100 return update.executeUpdate() > 0;
101 }
103 @Override
104 public List<Version> list(Project project) throws SQLException {
105 list.setInt(1, project.getId());
106 List<Version> versions = new ArrayList<>();
107 try (var result = list.executeQuery()) {
108 while (result.next()) {
109 final var v = mapColumns(result);
110 v.setProject(project);
111 versions.add(v);
112 }
113 }
114 return versions;
115 }
117 @Override
118 public Version find(int id) throws SQLException {
119 find.setInt(1, id);
120 try (var result = find.executeQuery()) {
121 if (result.next()) {
122 return mapColumns(result);
123 } else {
124 return null;
125 }
126 }
127 }
128 }