JDBC 连接

在本节中，我们将学习如何在 Talend Studio 的数据集成平台中使用元数据集中 JDBC 连接。

请按照以下步骤将 Talend 与 JDBC 数据库连接起来

• 设置数据库连接
• 检索表模式

设置数据库连接

要设置 JDBC 与 Talend 之间的关系，请按照以下流程进行操作

• 打开 Talend Studio，转到 Repository（存储库）窗格，然后将光标移到 Metadata（元数据）处
• 然后，右键单击 Metadata（元数据），并在 Db Connection（数据库连接）中选择 Create connection（创建连接） 选项，如下图所示

Repository（存储库） → Metadata（元数据） → Db Connections（数据库连接） → Create connection（创建连接）

JDBC 的数据库连接将分两步完成。

步骤 1：在存储库中创建新的数据库连接

• 单击创建连接后，将打开 Database Connection（数据库连接） 窗口，我们将在其中填写所有必填字段。
• 单击 Next（下一步） 按钮，我们可以在下面的屏幕截图中看到

步骤 2：更新数据库连接

• 单击 Next（下一步）按钮后，我们将 更新数据库连接， 并选择 DB type（数据库类型） 为 JDBC，我们可以在下面的图片中看到

• 选择数据库后，我们将填写有关所选数据库的所有信息，例如 JDBC URL、Drivers（驱动程序）、Driver class（驱动程序类）、User Id（用户 ID）、Password（密码）和 Mapping file（映射文件），
• 要访问数据库服务器，请将 JDBC URL 填写为 jdbc:mysql://:3306/
• 在 Driver jar（驱动程序 jar）中选择 jar 驱动程序以验证我们与数据库的连接
• 单击 [+] 按钮以添加驱动程序 jar 文件，并从我们的本地系统给出 jar 文件的路径，我们可以在下面的图片中看到

• 然后单击 [...] 按钮，将打开 Module（模块） 窗口
• 单击 Platform（平台） 单选按钮，并选择 mysql-connector-java-8.0.12.jar 文件， 并单击 OK（确定）

• 当我们单击 OK（确定）按钮时，它会自动获取驱动程序 jar (mysql-connector-java-8.0.12.jar)。
• 之后，从 Select class name（选择类名） 按钮中选择 Driver class（驱动程序类），这使我们能够与数据库进行通信。
• 然后，提供您的 user ID（用户 ID） 和 Password（密码） 与 MYSQL 数据库连接相同。
• 最后，单击 mapping file（映射文件） 下拉列表，并根据数据库的类型选择映射文件。
• 数据库的映射文件必须与模式中数据的 Java 类型匹配，在我们的例子中，我们选择 Mapping MySql（MySQL 映射）。
• 建立连接详细信息后，我们将单击 Test connection（测试连接） 按钮以检查我们的连接。
• 如果连接成功，我们将收到消息“连接成功”。
• 然后，单击 Finish（完成） 按钮以关闭连接设置窗口，我们可以在下面的屏幕截图中看到

我们创建的 JDBC 连接将出现在 Repository（存储库） 面板中。

它包含各种文件夹，如Queries（查询）、View schemas（视图模式）、Synonyms Schemas（同义词模式） 和 Table Schemas（表模式）， 我们可以在下面的图片中看到

检索表模式

要从我们上面创建的数据库连接中恢复表模式

• 转到 Repository（存储库） 面板，然后右键单击 Metadata（元数据）的 Db connection（数据库连接）节点中的 New_JDBC 数据库连接。
• 并从弹出菜单中选择 Retrieve schema（检索模式），我们可以在下图中看到

Repository（存储库） → Metadata（元数据） → Db connections（数据库连接） → New_JDBC → Retrieve Schema（检索模式）

• 将打开一个新窗口，我们可以在其中过滤数据库对象并显示数据库连接中的各种对象，例如 Table（表）、Views（视图） 和 Synonyms（同义词）。
• 我们还可以根据需要选择表，并定义表模式。

要过滤数据库对象，请按照与我们在本教程的上一部分中相同的流程进行操作。

过滤数据库对象列表后，按照以下流程将所需对象的模式加载到我们的存储库中。

• 我们在列表中选择一个或多个数据库对象，并单击 Next（下一步） 按钮以查看已过滤的数据库对象列表。
• 该列表提供了数据库连接中所有数据库及其数据库连接中存在的所有表，这些表符合我们的过滤条件。
• 如果需要，我们也可以更改模式，并验证 Type（类型） 列中的数据类型是否正确。
• 但是在这里，默认情况下，模式面板上显示的模式基于在已加载的模式列表中选择的第一个表（左侧面板）。
• 我们可以根据需要更改模式的名称，也可以自定义模式面板中的模式结构。
• 并且工具栏允许我们在模式中 添加、删除或移动 列。

要基于已加载的表模式之一检索模式

• 在下拉列表中选择 DB table schema（数据库表模式） 名称，在我们的例子中，我们使用 emp_employee 作为 DB table schema（数据库表模式）， 并单击 Retrieve schema（检索模式） 按钮，我们可以在下面的图片中看到

单击 OK（确定） 按钮以验证更改。

之后，单击 Finish（完成） 按钮以完成数据库模式的创建。

要验证数据是否已恢复

• 转到 Repository（存储库）面板 中的 Metadata（元数据） 部分。
• 展开 Db connections（数据库连接）， 并在下图中查看检索到的模式是否显示在 Table schemas（表模式） 子文件夹中。

• 现在，我们可以将数据库连接的任何表模式从 Repository（存储库）面板拖放到设计工作区中，作为新的数据库组件或现有组件，以重用元数据。