java flink 创建oracle连接池
要创建一个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数据库配置进行相应的更改
原文地址: http://www.cveoy.top/t/topic/ibEM 著作权归作者所有。请勿转载和采集!