1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/src/main/java/de/uapcore/lightpit/dao/postgres/PGVersionDao.java Sun May 17 16:23:39 2020 +0200
1.3 @@ -0,0 +1,120 @@
1.4 +/*
1.5 + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
1.6 + *
1.7 + * Copyright 2018 Mike Becker. All rights reserved.
1.8 + *
1.9 + * Redistribution and use in source and binary forms, with or without
1.10 + * modification, are permitted provided that the following conditions are met:
1.11 + *
1.12 + * 1. Redistributions of source code must retain the above copyright
1.13 + * notice, this list of conditions and the following disclaimer.
1.14 + *
1.15 + * 2. Redistributions in binary form must reproduce the above copyright
1.16 + * notice, this list of conditions and the following disclaimer in the
1.17 + * documentation and/or other materials provided with the distribution.
1.18 + *
1.19 + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
1.20 + * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
1.21 + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
1.22 + * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
1.23 + * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
1.24 + * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
1.25 + * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
1.26 + * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
1.27 + * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
1.28 + * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
1.29 + * POSSIBILITY OF SUCH DAMAGE.
1.30 + *
1.31 + */
1.32 +package de.uapcore.lightpit.dao.postgres;
1.33 +
1.34 +import de.uapcore.lightpit.dao.VersionDao;
1.35 +import de.uapcore.lightpit.entities.Project;
1.36 +import de.uapcore.lightpit.entities.Version;
1.37 +import de.uapcore.lightpit.entities.VersionStatus;
1.38 +
1.39 +import java.sql.Connection;
1.40 +import java.sql.PreparedStatement;
1.41 +import java.sql.ResultSet;
1.42 +import java.sql.SQLException;
1.43 +import java.util.ArrayList;
1.44 +import java.util.List;
1.45 +import java.util.Objects;
1.46 +
1.47 +public final class PGVersionDao implements VersionDao {
1.48 +
1.49 + private final PreparedStatement insert, update, list, find;
1.50 +
1.51 + public PGVersionDao(Connection connection) throws SQLException {
1.52 + list = connection.prepareStatement(
1.53 + "select id, project, name, ordinal, status " +
1.54 + "from lpit_version " +
1.55 + "where project = ? " +
1.56 + "order by ordinal, name");
1.57 +
1.58 + find = connection.prepareStatement(
1.59 + "select id, project, name, ordinal, status " +
1.60 + "from lpit_version " +
1.61 + "where id = ?");
1.62 +
1.63 + insert = connection.prepareStatement(
1.64 + "insert into lpit_version (project, name, ordinal, status) values (?, ?, ?, ?::version_status)"
1.65 + );
1.66 + update = connection.prepareStatement(
1.67 + "update lpit_version set name = ?, ordinal = ?, status = ?::version_status where id = ?"
1.68 + );
1.69 + }
1.70 +
1.71 + public Version mapColumns(ResultSet result) throws SQLException {
1.72 + final var version = new Version(result.getInt("id"), new Project(result.getInt("project")));
1.73 + version.setName(result.getString("name"));
1.74 + version.setOrdinal(result.getInt("ordinal"));
1.75 + version.setStatus(VersionStatus.valueOf(result.getString("status")));
1.76 + return version;
1.77 + }
1.78 +
1.79 + @Override
1.80 + public void save(Version instance) throws SQLException {
1.81 + Objects.requireNonNull(instance.getName());
1.82 + Objects.requireNonNull(instance.getProject());
1.83 + insert.setInt(1, instance.getProject().getId());
1.84 + insert.setString(2, instance.getName());
1.85 + insert.setInt(3, instance.getOrdinal());
1.86 + insert.setString(4, instance.getStatus().name());
1.87 + insert.executeUpdate();
1.88 + }
1.89 +
1.90 + @Override
1.91 + public boolean update(Version instance) throws SQLException {
1.92 + Objects.requireNonNull(instance.getName());
1.93 + update.setString(1, instance.getName());
1.94 + update.setInt(2, instance.getOrdinal());
1.95 + update.setString(3, instance.getStatus().name());
1.96 + update.setInt(4, instance.getId());
1.97 + return update.executeUpdate() > 0;
1.98 + }
1.99 +
1.100 + @Override
1.101 + public List<Version> list(Project project) throws SQLException {
1.102 + list.setInt(1, project.getId());
1.103 + List<Version> versions = new ArrayList<>();
1.104 + try (var result = list.executeQuery()) {
1.105 + while (result.next()) {
1.106 + versions.add(mapColumns(result));
1.107 + }
1.108 + }
1.109 + return versions;
1.110 + }
1.111 +
1.112 + @Override
1.113 + public Version find(int id) throws SQLException {
1.114 + find.setInt(1, id);
1.115 + try (var result = find.executeQuery()) {
1.116 + if (result.next()) {
1.117 + return mapColumns(result);
1.118 + } else {
1.119 + return null;
1.120 + }
1.121 + }
1.122 + }
1.123 +}
