开始
加载和管理数据
处理数据
政府
引用和资源
2023年8月1日更新
给我们反馈
这个示例查询PostgreSQL使用JDBC驱动程序。为更多的细节在阅读,写作,配置并行性,和查询下推,看到的使用JDBC查询数据库。
请注意
你可能更喜欢Lakehouse联盟管理查询PostgreSQL。看到使用Lakehouse联合运行查询。
司机=“org.postgresql.Driver”database_host=“< database-host-url >”database_port=“5432”如果你使用非默认端口#更新database_name=“<数据库名称>”表=“<表名称>”用户=“<用户名>”密码=“<密码>”url=f" jdbc: postgresql: / /{database_host}:{database_port}/{database_name}”remote_table=(火花。读。格式(“jdbc”)。选项(“司机”,司机)。选项(“url”,url)。选项(“数据表”,表)。选项(“用户”,用户)。选项(“密码”,密码)。负载())
瓦尔司机=“org.postgresql.Driver”瓦尔database_host=“< database-host-url >”瓦尔database_port=“5432”#更新如果你使用一个非- - - - - -默认的港口瓦尔database_name=“<数据库名称>”瓦尔表=“<表名称>”瓦尔用户=“<用户名>”瓦尔密码=“<密码>”瓦尔url=s " jdbc: postgresql: / /$ {database_host}:$ {database_port}/$ {database_name}”瓦尔remote_table=火花。读。格式(“jdbc”)。选项(“司机”,司机)。选项(“url”,url)。选项(“数据表”,表)。选项(“用户”,用户)。选项(“密码”,密码)。负载()
在砖运行时11.2及以上,您可以使用已命名的查询PosgresQL连接器。看下面的例子:
remote_table=(火花。读。格式(“postgresql”)。选项(“数据表”,table_name)。选项(“主机”,database_host_url)。选项(“端口”,5432年)。选项(“数据库”,database_name)。选项(“用户”,用户名)。选项(“密码”,密码)。负载())
下降表如果存在postgresql_table;创建表postgresql_table使用postgresql选项(数据表“<表名称>”,主机“< database-host-url >”,港口“5432”,数据库“<数据库名称>”,用户“<用户名>”,密码“<密码>”);
瓦尔remote_table=火花。读。格式(“postgresql”)。选项(“数据表”,table_name)。选项(“主机”,database_host_url)。选项(“端口”,5432年)。选项(“数据库”,database_name)。选项(“用户”,用户名)。选项(“密码”,密码)。负载()