X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Faaf%2Fdatabase%2FDBSingleton.java;fp=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Faaf%2Fdatabase%2FDBSingleton.java;h=0000000000000000000000000000000000000000;hb=0bff051a842b164b680bc938f4a56db435dd5841;hp=8c158cabfaad14ef272b33a3617ebb57e1473526;hpb=89e6d8f0b87a84b2de6cdab641b28692b9cf3be1;p=dmaap%2Fdbcapi.git diff --git a/src/main/java/org/onap/dmaap/dbcapi/aaf/database/DBSingleton.java b/src/main/java/org/onap/dmaap/dbcapi/aaf/database/DBSingleton.java deleted file mode 100644 index 8c158ca..0000000 --- a/src/main/java/org/onap/dmaap/dbcapi/aaf/database/DBSingleton.java +++ /dev/null @@ -1,98 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * org.onap.dmaap - * ================================================================================ - * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * ============LICENSE_END========================================================= - */ - -package org.onap.dmaap.dbcapi.aaf.database; - -import java.sql.*; -import java.util.*; - -import org.onap.dmaap.dbcapi.util.Singleton; - -public class DBSingleton extends TableHandler implements Singleton { - private C singleton; - public DBSingleton(Class cls, String tabname) throws Exception { - this(ConnectionFactory.getDefaultInstance(), cls, tabname); - } - public DBSingleton(ConnectionFactory cf, Class cls, String tabname) throws Exception { - super(cf, cls, tabname, null); - singleton = cls.newInstance(); - } - public C get() throws DBException { - return((new ConnWrapper() { - protected C run(Object junk) throws Exception { - ps = c.prepareStatement(getstmt); - rs = ps.executeQuery(); - if (!rs.next()) { - return(null); - } - for (DBFieldHandler f: fields) { - f.fromSQL(rs, singleton); - } - return(singleton); - } - }).protect(cf, null)); - } - public void init(C val) throws DBException { - if (get() != null) { - return; - } - (new ConnWrapper() { - protected Void run(C val) throws Exception { - ps = c.prepareStatement(initstmt); - for (DBFieldHandler f: fields) { - f.toSQL(val, ps); - } - ps.executeUpdate(); - if (val != singleton) { - for (DBFieldHandler f: fields) { - f.copy(val, singleton); - } - } - return(null); - } - }).protect(cf, val); - } - public void update(C val) throws DBException { - (new ConnWrapper() { - protected Void run(C val) throws Exception { - ps = c.prepareStatement(insorreplstmt); - for (DBFieldHandler f: fields) { - f.toSQL(val, ps); - } - ps.executeUpdate(); - if (val != singleton) { - for (DBFieldHandler f: fields) { - f.copy(val, singleton); - } - } - return(null); - } - }).protect(cf, val); - } - public void remove() throws DBException { - (new ConnWrapper() { - protected Void run(Object junk) throws Exception { - ps = c.prepareStatement(delstmt); - ps.executeUpdate(); - return(null); - } - }).protect(cf, null); - } -}