用java和spark激活snowflake中的仓库

ui7jx7zq  于 2021-05-27  发布在  Spark
关注(0)|答案(2)|浏览(433)

我正在尝试连接到snowflake db并激活一个特定的仓库
jdbc:snowflake用法:/xy12345.eu-central-1.snowflakecomputing.com/?warehouse=mywh
以及在酒店里
期权卖出(“仓库”,“mywh”)
还有什么需要补充的吗。
即使我给了一个错误的仓库,连接通过这是不正确的。我是否遗漏了什么,或者是否存在通过spark执行“use warehouse mywh”的情况。
谢谢

at0kjp5o

at0kjp5o1#

您是否可以使用游标执行命令-use warehouse来更改仓库的使用情况。

o7jaxewo

o7jaxewo2#

在jdbc上使用warehouse参数,或者在属性中提供它,就足以使用该仓库。困惑在于jdbc驱动程序如何连接到snowflake。
当您使用jdbc连接到snowflake时,jdbc驱动程序不会立即运行“use warehouse”。这就是为什么连接时不会出现任何错误,即使输入了错误的仓库。
当您尝试执行sql查询时,如果它需要活动仓库,则将使用您选择的仓库。如果您输入了错误的仓库,则会出现如下错误:

Exception in thread "main" net.snowflake.client.jdbc.SnowflakeSQLException: No active warehouse selected in the current session.  Select an active warehouse with the 'use warehouse' command.

相关问题