1 files changed, 0 insertions, 166 deletions
diff --git a/upstream/odl-aaa-moon/aaa/aaa-h2-store/src/main/java/org/opendaylight/aaa/h2/persistence/DomainStore.java b/upstream/odl-aaa-moon/aaa/aaa-h2-store/src/main/java/org/opendaylight/aaa/h2/persistence/DomainStore.java
deleted file mode 100644
index aa8f4b30..00000000
--- a/upstream/odl-aaa-moon/aaa/aaa-h2-store/src/main/java/org/opendaylight/aaa/h2/persistence/DomainStore.java
+++ /dev/null
@@ -1,166 +0,0 @@
-/*
- * Copyright (c) 2014, 2016 Hewlett-Packard Development Company, L.P. and others.  All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,
- * and is available at http://www.eclipse.org/legal/epl-v10.html
- */
-
-package org.opendaylight.aaa.h2.persistence;
-
-import com.google.common.base.Preconditions;
-
-import java.sql.Connection;
-import java.sql.PreparedStatement;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.sql.Statement;
-
-import org.apache.commons.lang3.StringEscapeUtils;
-import org.opendaylight.aaa.api.model.Domain;
-import org.opendaylight.aaa.api.model.Domains;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- *
- * @author peter.mellquist@hp.com
- *
- */
-public class DomainStore extends AbstractStore<Domain> {
-    private static final Logger LOG = LoggerFactory.getLogger(DomainStore.class);
-
-    protected final static String SQL_ID = "domainid";
-    protected final static String SQL_NAME = "name";
-    protected final static String SQL_DESCR = "description";
-    protected final static String SQL_ENABLED = "enabled";
-    private static final String TABLE_NAME = "DOMAINS";
-
-    protected DomainStore() {
-        super(TABLE_NAME);
-    }
-
-    @Override
-    protected String getTableCreationStatement() {
-        return "CREATE TABLE DOMAINS "
-                + "(domainid   VARCHAR(128)      PRIMARY KEY,"
-                + "name        VARCHAR(128)      UNIQUE NOT NULL, "
-                + "description VARCHAR(128)      , "
-                + "enabled     INTEGER           NOT NULL)";
-    }
-
-    @Override
-    protected Domain fromResultSet(ResultSet rs) throws SQLException {
-        Domain domain = new Domain();
-        domain.setDomainid(rs.getString(SQL_ID));
-        domain.setName(rs.getString(SQL_NAME));
-        domain.setDescription(rs.getString(SQL_DESCR));
-        domain.setEnabled(rs.getInt(SQL_ENABLED) == 1);
-        return domain;
-    }
-
-    protected Domains getDomains() throws StoreException {
-        Domains domains = new Domains();
-        domains.setDomains(listAll());
-        return domains;
-    }
-
-    protected Domains getDomains(String domainName) throws StoreException {
-        LOG.debug("getDomains for: {}", domainName);
-        Domains domains = new Domains();
-        try (Connection conn = dbConnect();
-             PreparedStatement pstmt = conn.prepareStatement("SELECT * FROM DOMAINS WHERE name = ?")) {
-            pstmt.setString(1, domainName);
-            LOG.debug("query string: {}", pstmt.toString());
-            domains.setDomains(listFromStatement(pstmt));
-        } catch (SQLException e) {
-            LOG.error("Error listing domains matching {}", domainName, e);
-            throw new StoreException("Error listing domains", e);
-        }
-        return domains;
-    }
-
-    protected Domain getDomain(String id) throws StoreException {
-        try (Connection conn = dbConnect();
-             PreparedStatement pstmt = conn.prepareStatement("SELECT * FROM DOMAINS WHERE domainid = ? ")) {
-            pstmt.setString(1, id);
-            LOG.debug("query string: {}", pstmt.toString());
-            return firstFromStatement(pstmt);
-        } catch (SQLException e) {
-            LOG.error("Error retrieving domain {}", id, e);
-            throw new StoreException("Error loading domain", e);
-        }
-    }
-
-    protected Domain createDomain(Domain domain) throws StoreException {
-        Preconditions.checkNotNull(domain);
-        Preconditions.checkNotNull(domain.getName());
-        Preconditions.checkNotNull(domain.isEnabled());
-        String query = "insert into DOMAINS (domainid,name,description,enabled) values(?, ?, ?, ?)";
-        try (Connection conn = dbConnect();
-             PreparedStatement statement = conn.prepareStatement(query)) {
-            statement.setString(1, domain.getName());
-            statement.setString(2, domain.getName());
-            statement.setString(3, domain.getDescription());
-            statement.setInt(4, domain.isEnabled() ? 1 : 0);
-            int affectedRows = statement.executeUpdate();
-            if (affectedRows == 0) {
-                throw new StoreException("Creating domain failed, no rows affected.");
-            }
-            domain.setDomainid(domain.getName());
-            return domain;
-        } catch (SQLException e) {
-            LOG.error("Error creating domain {}", domain.getName(), e);
-            throw new StoreException("Error creating domain", e);
-        }
-    }
-
-    protected Domain putDomain(Domain domain) throws StoreException {
-        Domain savedDomain = this.getDomain(domain.getDomainid());
-        if (savedDomain == null) {
-            return null;
-        }
-
-        if (domain.getDescription() != null) {
-            savedDomain.setDescription(domain.getDescription());
-        }
-        if (domain.getName() != null) {
-            savedDomain.setName(domain.getName());
-        }
-        if (domain.isEnabled() != null) {
-            savedDomain.setEnabled(domain.isEnabled());
-        }
-
-        String query = "UPDATE DOMAINS SET description = ?, enabled = ? WHERE domainid = ?";
-        try (Connection conn = dbConnect();
-             PreparedStatement statement = conn.prepareStatement(query)) {
-            statement.setString(1, savedDomain.getDescription());
-            statement.setInt(2, savedDomain.isEnabled() ? 1 : 0);
-            statement.setString(3, savedDomain.getDomainid());
-            statement.executeUpdate();
-        } catch (SQLException e) {
-            LOG.error("Error updating domain {}", domain.getDomainid(), e);
-            throw new StoreException("Error updating domain", e);
-        }
-
-        return savedDomain;
-    }
-
-    protected Domain deleteDomain(String domainid) throws StoreException {
-        domainid = StringEscapeUtils.escapeHtml4(domainid);
-        Domain deletedDomain = this.getDomain(domainid);
-        if (deletedDomain == null) {
-            return null;
-        }
-        String query = String.format("DELETE FROM DOMAINS WHERE domainid = '%s'", domainid);
-        try (Connection conn = dbConnect();
-             Statement statement = conn.createStatement()) {
-            int deleteCount = statement.executeUpdate(query);
-            LOG.debug("deleted {} records", deleteCount);
-            return deletedDomain;
-        } catch (SQLException e) {
-            LOG.error("Error deleting domain {}", domainid, e);
-            throw new StoreException("Error deleting domain", e);
-        }
-    }
-}