要创建一个Oracle连接池,可以使用Apache Commons DBCP(数据库连接池)库。以下是一个使用DBCP创建Oracle连接池的示例代码:

import java.sql.Connection;
import java.sql.SQLException;
import oracle.jdbc.pool.OracleDataSource;
import org.apache.commons.dbcp2.BasicDataSource;

public class OracleConnectionPool {
    private static BasicDataSource dataSource;

    private static final String ORACLE_URL = "jdbc:oracle:thin:@//hostname:port/service";
    private static final String ORACLE_USER = "username";
    private static final String ORACLE_PASSWORD = "password";
    private static final int MAX_CONNECTIONS = 10;

    public static void main(String[] args) {
        createDataSource();
        Connection connection = getConnectionFromPool();
        // 使用连接执行操作
        // ...
        releaseConnection(connection);
        closeDataSource();
    }

    private static void createDataSource() {
        try {
            OracleDataSource oracleDataSource = new OracleDataSource();
            oracleDataSource.setURL(ORACLE_URL);
            oracleDataSource.setUser(ORACLE_USER);
            oracleDataSource.setPassword(ORACLE_PASSWORD);

            dataSource = new BasicDataSource();
            dataSource.setDriverClassName(oracleDataSource.getDriver().getClass().getName());
            dataSource.setUrl(ORACLE_URL);
            dataSource.setUsername(ORACLE_USER);
            dataSource.setPassword(ORACLE_PASSWORD);
            dataSource.setMaxTotal(MAX_CONNECTIONS);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private static Connection getConnectionFromPool() {
        Connection connection = null;
        try {
            connection = dataSource.getConnection();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return connection;
    }

    private static void releaseConnection(Connection connection) {
        try {
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    private static void closeDataSource() {
        try {
            dataSource.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

请注意,您需要根据您的实际Oracle数据库配置进行相应的更改

java flink 创建oracle连接池

原文地址: http://www.cveoy.top/t/topic/ibEM 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录