oracle - 如何在 Docker 中连接到外部 Oracle 数据库
问题描述
我正在尝试连接到 docker 容器之外的 Oracle 数据库。我是 Docker 新手,不知道如何实现。在我的本地机器上,我可以通过提供主机、服务名称和端口或仅通过引用 tnsnames.ora 文件中提到的条目来连接到特定数据库。我已经在我的 Windows 10 机器上安装了 Docker。我的最终目标是使用 ksqlDB 流式传输有关 kafka 主题的表。但是,第一步是连接到我的 oracle 数据库。我不确定从 Docker 连接到任何外部数据库源需要进行哪些修改或设置。我尝试了以下连接器配置,但这不起作用。
连接器配置:
CREATE SOURCE CONNECTOR jdbc_source WITH(
'connector.class' = 'io.confluent.connect.jdbc.JdbcSourceConnector',
'connection.url' = 'jdbc:oracle:thin://dv11-db.com:1521/dv11.db.com',
'connection.user' = 'user',
'connection.password' = 'password',
'topic.prefix' = 'jdbc_',
'mode' = 'bulk',
'table.whitelist' = 'batch_driver'
);
错误:
{
"error_code" : 400,
"message" : "Connector configuration is invalid and contains the following 2 error(s):\nInvalid value java.sql.SQLException: No suitable driver
found for jdbc:oracle:thin://dv11-db.com:1521/dv11.db.com for configuration Couldn't open connection to jdbc:oracle:thin://dv11-db.com:1521/dv11.db.com\nInvalid value java.sql.SQLException: No suitable driver found for jdbc:oracle:thin://dv11-db.com:1521/dv11.db.com for configuration Couldn't open connection to jdbc:oracle:thin://dv11-db.com:1521/dv11.db.com\nYou can also find the above list of errors at the endpoint `/{connectorType}/config/validate`"
}
甲骨文配置:
(DESCRIPTION = (ADDRESS = (PROTOCOL = TCP)(HOST = dv11-db.com)(PORT = 1521)) (CONNECT_DATA = (SERVER = DEDICATED)(SERVICE_NAME = dv11.db.com)))
Docker-compose.yml
---
version: '2'
services:
zookeeper:
image: confluentinc/cp-zookeeper:latest
hostname: zookeeper
container_name: zookeeper
ports:
- "2181:2181"
environment:
ZOOKEEPER_CLIENT_PORT: 2181
ZOOKEEPER_TICK_TIME: 2000
broker:
image: confluentinc/cp-enterprise-kafka:latest
hostname: broker
container_name: broker
depends_on:
- zookeeper
ports:
- "29092:29092"
environment:
KAFKA_BROKER_ID: 1
KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://broker:9092,PLAINTEXT_HOST://localhost:29092
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
ksqldb-server:
image: confluentinc/ksqldb-server:0.7.0
hostname: ksqldb-server
container_name: ksqldb-server
depends_on:
- broker
ports:
- "8088:8088"
environment:
KSQL_LISTENERS: http://0.0.0.0:8088
KSQL_BOOTSTRAP_SERVERS: broker:9092
KSQL_KSQL_LOGGING_PROCESSING_STREAM_AUTO_CREATE: "true"
KSQL_KSQL_LOGGING_PROCESSING_TOPIC_AUTO_CREATE: "true"
KSQL_KSQL_CONNECT_WORKER_CONFIG: "/connect/connect.properties"
KSQL_CONNECT_GROUP_ID: "ksql-connect-cluster"
KSQL_CONNECT_BOOTSTRAP_SERVERS: "broker:9092"
KSQL_CONNECT_KEY_CONVERTER: "org.apache.kafka.connect.storage.StringConverter"
KSQL_CONNECT_VALUE_CONVERTER: "org.apache.kafka.connect.json.JsonConverter"
KSQL_CONNECT_VALUE_CONVERTER_SCHEMAS_ENABLE: "false"
KSQL_CONNECT_CONFIG_STORAGE_TOPIC: "ksql-connect-configs"
KSQL_CONNECT_OFFSET_STORAGE_TOPIC: "ksql-connect-offsets"
KSQL_CONNECT_STATUS_STORAGE_TOPIC: "ksql-connect-statuses"
KSQL_CONNECT_CONFIG_STORAGE_REPLICATION_FACTOR: 1
KSQL_CONNECT_OFFSET_STORAGE_REPLICATION_FACTOR: 1
KSQL_CONNECT_STATUS_STORAGE_REPLICATION_FACTOR: 1
KSQL_CONNECT_PLUGIN_PATH: "/usr/share/kafka/plugins"
volumes:
- ./confluentinc-kafka-connect-jdbc-5.4.0:/usr/share/kafka/plugins/jdbc
ksqldb-cli:
image: confluentinc/ksqldb-cli:0.7.0
container_name: ksqldb-cli
depends_on:
- broker
- ksqldb-server
entrypoint: /bin/sh
tty: true
解决方案
java.sql.SQLException:没有合适的驱动程序
不是码头问题。您没有将数据库驱动程序放在正确的位置
不应该进去的/usr/share/kafka/plugins/jdbc
。
应该进去/usr/share/kafka-connect-jdbc
参考https://www.confluent.io/blog/kafka-connect-deep-dive-jdbc-source-connector/
在我的本地机器上,我可以通过提供主机、服务名称和端口或仅通过引用 tnsnames.ora 文件中提到的条目来连接到特定数据库
不清楚你是如何连接的......来自代码?来自一些 Oracle 工具?
如果您的数据库在另一台服务器上,Docker 的网络连接应该以完全相同的方式工作。您仍然需要设置驱动程序
推荐阅读
- php - 如何在 bootstrap4 中添加轮播作为背景?
- java - 在Java中将BMP图像转换为PNG或JPG而不将整个图像加载到内存中
- matlab - 在函数中绘制不同阶矩阵
- amazon-web-services - 2 个 VPC 中 2 个私有子网上的 AWS 中的 2 个 Oracle RDS 实例之间的连接
- c# - SecurityProtocolType.Tls12 未解决底层连接已关闭发送时发生意外错误。(C#)
- python - 如何在 sqlalchemy 中查询“WHERE call.tags?'1'”?
- android - 为什么 Material Button 在顶部和底部都有填充?无法摆脱它
- android - UsbManager RequestPermission 返回 Null
- javascript - 在 int.toString() 中保留前导零
- docker - 如何创建现有 WAS 8.5.5.14 的 docker 镜像?