8
使用mysql数据库
在本节中，我们将了解我们如何与Talend中的数据库一起使用.
在我们开始使用MySQL数据库之前，我们将知道如何使用Talend Studio连接MySQL数据库.
创建数据库连接
使用数据库
按照以下进程查看我们如何在Talend Studio中使用数据库:
读取文件
将文件加载到数据库
执行作业
读取文件
要在Talend Studio中读取文件，请按以下步骤操作:
首先，我们将在 Repository 面板中创建一个作业。
- 然后，右键单击 Job Designs 字段，然后选择 Create job，如下图所示:
新作业窗口将打开我们将填写姓名，目的和描述的所有必要细节.
并且，单击完成按钮，我们可以在下面的屏幕截图中观察到:
在下一步中，组件窗口将显示我们可以在可用组件的可用列表中选择特定组件.
为此，我们将从组件窗口中选择 tdbconnection(mysql)组件，然后单击确定按钮见下面的图片:
此选定的组件在我们创建MySQL数据库的元数据时具有所有详细信息.
之后，我们将转到调色板 for 添加组件到一个作业，在调色板面板中提供多个可用的组件.
或者，我们也可以使用搜索字段，我们可以在其中输入组件的名称，然后选择它，因为我们可以在下面的图片中看到:
我们将此Excel文件作为
输入，，我们将从
调色板面板中拖动 tfileinputexcel 组件，并将其删除设计工作区窗口，正如我们在下面的图片中看到:
之后，去 tfileInputexcel_1 的组件窗口，然后选择 read Excel2007文件格式(.xlsx)的复选框.
并且，在 File name /Stream 字段中给出我们想要加载到数据库中的 excel 文件的地址，如下图所示:
之后，我们将手动定义Excel文件结构.
为此，单击 Edit Schema 按钮并创建输入文件的结构。
- 然后，单击 OK 按钮，如下图所示:
要在Excel文件和MySQL之间创建连接，请按照以下进程:
我们将右键单击 mysql_test_job ，然后转到 trigger 选项，然后选择在组件 OK 从弹出菜单中可以在下面的屏幕截图中看到:
在 mysql_test_job 和 tfileInputexcel_1 之间创建的成功连接，以阅读文件，因为我们可以在下面的图片中看到:
此组件应具有输出链路，这意味着存在能够读取和放弃数据的输入组件.
我们将在给定用例中添加一个组件.
我们有员工细节，其中 emp_designation 具有不同的价值，如员工可以是 hr，manager和雇员，因为我们可以在下面的图片中看到:
并且，我们将根据他们的名称过滤员工，并分别将它们分成MySQL的其他表.
为此，我们将使用相同数据集的复制在不同用例中的工作.
对于相同的数据集，我们有一个名为跨框的组件.
注意:渗透:它根据需要多次复制行.
要在"设计工作区"窗口中添加渗透组件，请键入组件的名称，然后按输入键，如下图片所示:
并且，我们的设计工作区窗口将在添加复制组件后看起来像我们可以在下面的图片中观察到:
一旦我们成功添加了组件，我们将将它们连接到其他组件.
就像我们在下面的屏幕截图一样，我们将把 tfileinputexcel_1 连接到
行→main
我们将使用n个输入，帮助pf 静置
tFileInputExcel 输入文件应至少有一个工作表名称。
- 因此，我们将工作表名称命名为"Sheet1"，如下图所示:
之后，我们将在这里过滤掉数据.
要过滤数据，我们将使用名为 tfilterrow 的过滤器组件，该组件可在设计工作区窗口中提供.
注意:tfilterrow:它通过在所选列上设置一个条件来筛选输入行，并有助于对源数据上的参数过滤器.
添加Tfilterrow后，我们的设计工作空间在下面的图片中看起来像这样:
- 然后，我们将 tReplicate_1 连接到
为此，我们将右键单击 tReplicate 并选择 Row -> Main 到 tFilterRow，如下图所示:
- 现在，我们将配置 tFilterRow_1，这非常简单，因为我们知道架构将被自动复制。
之后，我们将在条件字段中创建过滤的条件，可在Tfilterrow_1组件窗口上获得.
，我们的第一个条件是选择 emp_designation 是" hr "的员工，因为我们可以在下面的屏幕截图中看到:
将文件加载到数据库中
在本节中，我们将尝试将数据文件加载到 mysql数据库.
要将数据加载到MySQL中，请按照以下过程:
首先，我们在"设计工作区"窗口中添加MySQL输出组件，正如我们在下面的屏幕截图中看到:
一旦将组件插入到设计工作区窗口中，我们将使用行→过滤器从 tfilterrow_1 并将其授予 mysql_test_job .
- 然后，我们双击 MySql_test_job 并将表名为"emp_HR"作为输出，该输出将进入 MySQL 数据库。
为了更好地理解，我们也可以更改组件名称，如在此示例中，我们将 mysql_test_job 更改为
之后，我们将在与上面相同的过程后添加两个更多的过滤器.
对于我们的下一个条件，我们选择 emp_desgnation 是" manager "和"员工"的员工，就像我们在我们的情况下一样第一个条件.
我们的最终设计工作区窗口将在添加两个更过的过滤条件后看起来像这样.
完成所有步骤后，我们已准备好运行作业，并检查我们是否获得预期的输出.
执行作业
要运行作业，我们将点击
运行按钮，因为我们可以在下面的图片中看到:
当作业成功运行时，它将显示运行(作业dbjob)窗口中的作业的详细信息，因为我们可以在下面的图片中看到:
和设计工作区窗口将显示我们过滤条件的结果，正如我们在下面的屏幕截图:
中所看到的
并且，我们可以检查在MySQL数据库中加载输入数据作为输出的结果，正如我们在下面的屏幕截图中看到它创建了员工数据库中的三个表.
emp_hr
emp_manager
emp_employee
本文地址：https://www.itbaoku.cn/tutorial/cn_talend-talend_working_with_mysql_database.html
联系站长