appc-dispatcher/appc-dispatcher-common/appc-data-access-lib/src/main/java/org/onap/appc/dao/util/DBUtils.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP : APPC
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Copyright (C) 2017 Amdocs
   8  * =============================================================================
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  *
  21  * ECOMP is a trademark and service mark of AT&T Intellectual Property.
  22  * ============LICENSE_END=========================================================
  23  */
  24
  25 package org.onap.appc.dao.util;
  26
  27 import com.att.eelf.configuration.EELFLogger;
  28 import com.att.eelf.configuration.EELFManager;
  29 import org.onap.appc.configuration.Configuration;
  30 import org.onap.appc.configuration.ConfigurationFactory;
  31 import java.sql.*;
  32
  33 /**
  34  * @deprecated As of release 1802, replaced by {@link #(org.onap.appc.dao.util.dbcp.DBConnectionPool)}
  35  * <p>
  36  * This class provides the ability to access mysql database which has been @Deprecated because
  37  * {@link #getConnection(String)} for each database request is not a good practice especially
  38  * on appc performance.
  39  * <p>
  40  * If you would like to use appcctl (mysql database), bundle:appc-data-access-lib has created
  41  * a database connection pool bean and exported as a service by using blueprint.
  42  * If you would like to create a new database connection pool, refer to the way mentioned above.
  43  * {@link org.onap.appc.dao.util.api.DBConnectionPoolService} has an example of how to use
  44  * the connection pool.
  45  */
  46 @Deprecated
  47 public class DBUtils {
  48     private static final EELFLogger logger = EELFManager.getInstance().getLogger(DBUtils.class);
  49     private static final String JDBC_DRIVER = "org.mariadb.jdbc.Driver";
  50     private static final Configuration configuration = ConfigurationFactory.getConfiguration();
  51
  52     static {
  53         try {
  54             String driver = JDBC_DRIVER;
  55             Class.forName(driver);
  56         } catch (ClassNotFoundException e) {
  57             logger.error(e.getMessage());
  58         }
  59     }
  60
  61     public static Connection getConnection(String schema) throws SQLException {
  62         DriverManager.registerDriver(new org.mariadb.jdbc.Driver());
  63         String dbURL = configuration.getProperty(String.format("org.onap.appc.db.url.%s", schema), "");
  64         String userName = configuration.getProperty(String.format("org.onap.appc.db.user.%s", schema), "");
  65         String password = configuration.getProperty(String.format("org.onap.appc.db.pass.%s", schema), "");
  66         return DriverManager.getConnection(dbURL, userName, password);
  67     }
  68
  69     public static boolean clearResources(ResultSet resultSet, PreparedStatement ptmt, Connection connection) {
  70         boolean clearFlag = false;
  71         try {
  72             if (resultSet != null)
  73                 resultSet.close();
  74             if (ptmt != null)
  75                 ptmt.close();
  76             if (connection != null)
  77                 connection.close();
  78             clearFlag = true;
  79         } catch (SQLException e) {
  80             logger.error(e.getMessage());
  81         }
  82         return clearFlag;
  83
  84     }
  85 }