MySQL 连接

在本节中，我们将学习如何在 Talend Studio for Data Integration 平台中通过 Metadata 集中 MySQL 数据库连接。

在 Talend Studio 中，MySQL 数据库连接的完成分为以下两个步骤：

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

第一步：设置数据库连接

要设置数据库和 Talend 之间的关系，请按照以下流程操作：

• 首先，打开 Talend Studio，转到存储库 (Repository)面板，然后展开 Metadata（元数据）。
• 右键单击 DB Connections（数据库连接），然后在弹出菜单中选择 Create connection（创建连接），如下图所示：

存储库 (Repository) → Metadata（元数据） → DB Connections（数据库连接）

数据库连接将分两个步骤完成：

步骤1/2

• 点击弹出菜单中的 Create Connection（创建连接）选项后，屏幕上将出现 [Database Connection（数据库连接）] 窗口，我们将在其中填写必填字段，如 Name（名称），以及其他区域，如 Purpose（目的）、Description（描述）等等。
• 填写完所有信息后，单击 Next（下一步）按钮，如下面的屏幕截图所示：

步骤2/2

在此步骤中，我们将定义数据库的连接属性。

为此，我们在 DB type（数据库类型）字段中选择 MYSQL，如下面的屏幕截图所示：

• 选择数据库类型后，我们填写有关 MySQL 数据库的所有必要信息，例如 登录名 (login)、密码 (password)、服务器 (server)、数据库 (Database)。

注意：连接到 Talend Studio 的数据库连接时，请创建您的数据库。

• 完成所有连接详细信息后，单击 Test Connection（测试连接）按钮，以检查填写的数据库详细信息是否正确。
• 如果给定的详细信息正确，则会在消息框中显示 connection successfully（连接成功）消息：否则，会显示一个错误，如下面的屏幕截图所示：

• 单击 Finish（完成）按钮以完成连接属性。

第二步：检索表模式

在此步骤中，我们将从上面创建的数据库连接中检索表模式。

• 为此，请转到存储库 (Repository)面板，右键单击 DB 连接节点中的 MySQL_test_job。
• 然后，在弹出菜单中选择 Retrieve schema（检索模式）选项，如下图所示：

• 屏幕上将出现一个新的 [Schema（模式）] 窗口，我们可以在其中过滤和显示各种对象，例如数据库连接中的 Table（表）、Views（视图）和 Synonyms（同义词）。
• 我们还可以选择表并定义表模式，如下面的屏幕截图所示：

注意：如果无法从选定的数据库中检索任何表，或者我们没有访问数据库的权限，则会出现一条错误消息。

过滤数据库对象

我们可以使用 Select filter conditions（选择过滤条件）中的两个选项来过滤数据库对象，如下所示：

• 使用名称过滤器
• 使用 SQL 过滤器

要根据其名称过滤器过滤数据库，请按照以下流程操作：

• 如果我们从 Select Filter Conditions（选择过滤条件）中选择 Use the name filter（使用名称过滤器）选项
• 在 Select type（选择类型）部分中选择数据库对象的多个复选框（表、视图和同义词），以进行过滤和显示对象。

注意：可用选项可能因所选数据库而异。

• 在 Set the Name Filter（设置名称过滤器）部分中，单击 Edit（编辑）按钮以打开 Edit Filter Name（编辑过滤器名称）对话框。 我们可以在特定对话框中输入要使用的过滤器名称。
  例如
  • 如果我们想恢复名称以 "S" 开头的数据库对象，则将 Filter Name（过滤器名称）输入为 "S%"。
  • 或者，如果我们想恢复名称以 "type" 结尾的所有数据库对象，则将 "%type" 输入为我们的 Filter Name（过滤器名称）。
• 单击 OK（确定）按钮以关闭对话框，如下面的屏幕截图所示：

• 然后，单击 Next（下一步）按钮以在窗口上打开一个新的视图，其中列出了过滤后的数据库对象。

要借助 SQL 查询过滤数据库对象，请按照以下流程操作：

• 在 Select Filter Conditions（选择过滤条件）部分中选择 Use SQL Filter（使用 SQL 过滤器）选项，在 Set SQL Filter（设置 SQL 过滤器）中输入 SQL 查询
• 然后，单击 Next（下一步）按钮以打开一个新的视图，该视图具有列出的过滤器数据库对象，如下面的图像所示

注意：如果列表上没有显示模式，请单击模式窗口上显示的 Check connection（检查连接）按钮，以验证数据库连接状态。

选择表并定义表模式

在上面的图片中，我们过滤了数据库对象列表。

请按照以下流程在我们的存储库中加载所需目标的模式。

• 我们在列表中选择一个或多个数据库对象，然后单击 Next（下一步）按钮，以在窗口上打开一个新的视图，我们可以在其中查看所选对象的模式，如下图所示：

• 如果需要，我们可以更改模式，并在 Type（类型）列中检查数据类型是否正确。

以下是一些常用的 Talend 数据类型：

• List（列表）: 它是 XML 模式定义中原始类型元素的空格分隔列表，它使用 XSD: list 定义
• Object（对象）: 它是一种通用的 Talend 数据类型，允许在不考虑其内容的情况下处理数据。
• Document（文档）: 文档是一种数据类型，它允许处理整个 XML 文档，即使不考虑其内容也是如此。
• 但是，这里显示的 Schema（模式）面板上的模式默认基于模式加载列表中选择的第一个表（左侧面板）。
• 我们可以根据需要更改模式的名称，并且我们还可以在模式面板中自定义模式结构。
• 工具栏允许我们在我们的模式中添加、删除或移动列，我们还可以从文件加载 XML 模式或将当前模式导出为 XML。

要检索基于已加载的表模式之一的模式，请按照以下流程操作：

• 在下拉列表中选择 DB table schema（数据库表模式）名称，在本例中，我们选择 emp_hr 作为数据库表模式，然后单击 Retrieve schema（检索模式）。
• 单击 OK（确定）按钮以确认更改。
• 然后，单击 Finish（完成）按钮以完成数据库模式创建。

验证数据是否已检索

• 转到 Repository panel（存储库面板）中的 Metadata（元数据）部分，然后展开 Db connections（数据库连接），在那里我们可以看到检索到的模式显示在 Table schemas（表模式）子文件夹中，如下面的屏幕截图所示

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