使用数据库源组件读取数据存储在一个数据库表、视图或使用一个查询。
连接
选择一个现有的数据库连接或创建一个新的(有关更多信息,请参见允许集成。io ETLaccess to my database server)。
源属性
- 访问模式——选择表中提取整个表/视图或查询执行一个查询。
- 源模式——源表的模式。如果空,所使用的默认模式。
- 源表/视图——表或视图的名称将导入的数据。
- where子句-可选的。您可以添加WHERE子句谓词条款作为SQL查询的一部分,是建立以从数据库中获取数据。确保跳过的关键字。
好 prod_category = 1, prod_color = '红色'
坏 prod_category = 1和prod_color = '红色'
- 查询——输入SQL查询。确保所有列独特的名字。
表访问模式并行化(仅用于表访问模式)
并行化查询,选择一个分裂的关键的查询和并行连接的最大数量。并行查询时,初步查询将得到的最大和最小值的列,然后将从多个连接查询的where子句将数据范围。例如:pk > = 1和pk < 1000 pk > = 1001和pk < 2000。
- 查询键列——指定一个源表列的名称将查询或离开空使用一个查询。推荐一个列,是均匀分布在它的价值范围内(主键列是一个不错的选择)。
- 最大并行连接——一个正数指定有多少任务分配到导入的过程。
注意:不增加任务的数量高于你的数据库可以合理的支持。
源行为
- 没有一个——默认情况下,从数据库中读取数据,并立即转换应用。
- 复制——将数据从数据库源复制到中间存储在处理数据。这可能保持数据库连接的打开时间短,但选择没有一个通常会导致更快的作业执行时间。
源模式
定义源表/视图/查询后选择在源代码中使用的字段。
与表访问模式下,您选择字段是用于构建查询,将读取数据执行。
与查询访问模式,选择所有字段中定义的查询,并确保使用相同的列名称
定义字段的数据类型。匹配时使用下表集成数据库数据类型。io ETL数据类型。
PostgreSQL | MySQL | 微软 SQL Server |
甲骨文 | 雪花 | Integrate.ioETL |
varchar、字符、文字、时间间隔 | varchar、nvarchar、文本、时间 | varchar、nvarchar文本、ntext datetimeoffset | 用longvarchar longnvarchar、nchar nvarchar, char、varchar、clob, nclob | varchar、字符、字符、字符串文本 | 字符串 |
短整型,整型 | bool,一些非常小的整数,smallint mediumint, int,整数 | 非常小的整数,短整型,int | 非常小的整数,整数,短整型 | 整数 | |
长整型数字 | 长整型数字 | 长整型数字 | 长整型数字 | 整数,整数,长整型数字,短整型,非常小的整数,byteint、数量(38岁,0) | 长 |
小数,真正的 | 小数、浮点数 | 十进制数字,浮动 | 浮点数、二进制浮点数、真实的 | 浮动 | |
双精度 | 双 | 真正的 | 数字、十进制、二进制双 | 浮动,float4 float8、双、双精度,真实,十进制数字 | 双 |
时间戳、日期 | 日期、日期时间、时间戳 | datetime、日期、datetime2 smalldatetime | 日期、时间、时间戳、timestamptz timestampltz | 日期、日期时间、时间戳、timestamptz timestampltz timestampntz | DateTime |
注意:执行查询时在读取提交事务隔离级别。