一、kettle转换数据
1.kettle欢迎界面
2.选择文件-新建-转换
3.准备输入输出数据源,
新建输入数据源,点击新建-数据库连接打开如下界面,填写数据
新建输出数据源,点击新建-数据库连接打开如下界面,填写数据
5.双击左边菜单,输入-表输入
6.打开表输入对象编辑页面
7.选择输入的数据库连接,并点击获取SQL查询语句
可以使生成的查询语句包含所有的列。
可以点击预览,查看数据。也可直接点击确定保存。
8.双击左边菜单,输出-表输出,在转换界面自动产生表输出,并和表输入自动连线。
也可以选中输出-表输出菜单,拖拽表输出到右边界面,选中表输入后,按住shift键,鼠标拖动到表输出上,自动连线。
9.编辑表输出
选择数据库连接,如果是新表,可以填写目标表表名,如果是已存在的表,可以点击浏览选择表。
这里使用新表。在数据库字段窗口,点击获取字段后,再点击SQL按钮。
打开创建表的窗口
点击执行,即可在输出数据库创建表。创建完成后,点击运行这个转换:
启动界面:
提示保存这个转换,保存后,开始抽取数据:
抽取成功,在输出库中查询该表,成功。
二、共享数据库
如果要共享上述转换中新建的数据源,可以选中主对象树-DB连接的数据源,右键菜单,点击共享。这样在新的转换中就可以使用到这个数据源了。
相关文章
- 数据加载与保存-通用方式 使用df.write.save方法保存数据,同样可通过format指定数据类型。 save方法后需传入保存路径(针对csv、orc、parquet、textFile格式)。 option方法用于设置特定格式的参数。 保存操作可使用SaveMode来指明如何处理数据,如覆盖(overwrite)、追加(append)等,通过mode方法设置。 特定格式保存 与加载类似,Parquet、JSON、CSV等格式均可通过指定format进行保存。 MySQL等关系型数据库的写入也通过JDBC实现,需指定format为jdbc,并传入数据库连接信息及表名。 注意事项
- springboot报错:解决java连接SQLSERVER数据库之驱动程序无法通过使用安全套接字层(SSL)加密与 SQL Server 建立安全连接的问题
- admin配置与Mysql数据库连接
- oracle数据库的安装与连接关键点
- kettle_Spoon 修改共享DB连接带汉字引发的错误
- Linux平台上用C语言实现与MySQL数据库的连接
- PHP 创建重用数据库连接函数 mysqli与PDO
- 【MySQL】数据库开发技术:内外连接与表的索引穿透深度解析
- PHP数据库驱动扩展概述与不同方式连接数据库总结
- JDBC中数据库的连接与查询