为 Snowpark Java 设置 IntelliJ IDEA CE¶

选择 File » New » Project。

从 Project SDK 菜单中选择 11（适用于 Java 版本 11）。

请注意，您无需选择原型。不选中 Create from archetype 复选框即可。

点击 Next。

输入项目的名称和位置（例如 hello-snowpark）。

点击 Finish 以创建新项目。

打开项目的 pom.xml 文件。

在 <project> 标签中，添加标签以指定对 Snowpark 库的依赖关系：

<dependencies>
  ...
  <dependency>
    <groupId>com.snowflake</groupId>
    <artifactId>snowpark</artifactId>
    <version>1.12.1</version>
  </dependency>
  ...
</dependencies>

保存对 pom.xml 文件所做的更改。

更新 Maven 存储库。

请参阅`更新 Maven 存储库`_。

在 左侧 (https://www.jetbrains.com/help/idea/2020.3/guided-tour-around-the-user-interface.html) 的 Project 工具窗口中，展开您的项目，展开 src/main 文件夹，然后选择 java 文件夹。

右键点击文件夹，然后选择 New » Java class。

在 New Java Class 对话框中，输入名称“HelloSnowpark”，选择 Class，然后按 Enter 键。

在 HelloSnowpark.java 文件中，将内容替换为以下代码：

import com.snowflake.snowpark_java.*;
import java.util.HashMap;
import java.util.Map;

public class HelloSnowpark {
  public static void main(String[] args) {
    // Replace the <placeholders> below.
    Map<String, String> properties = new HashMap<>();
    properties.put("URL", "https://<account_identifier>.snowflakecomputing.cn:443");
    properties.put("USER", "<user name>");
    properties.put("PASSWORD", "<password>");
    properties.put("ROLE", "<role name>");
    properties.put("WAREHOUSE", "<warehouse name>");
    properties.put("DB", "<database name>");
    properties.put("SCHEMA", "<schema name>");
    Session session = Session.builder().configs(properties).create();
    session.sql("show tables").show();
  }
}

请注意以下事项：

• 将 <placeholders> 替换为您用于连接到 Snowflake 的值。

• 对于 <account_identifier>，请指定您的 账户标识符。

• 如果您更喜欢使用 密钥对身份验证，则执行以下操作：

  • 将 PASSWORD 替换为 PRIVATE_KEY_FILE，并将其设置为私钥文件的路径。

  • 如果私钥已加密，则必须将 PRIVATE_KEY_FILE_PWD 设置为用于解密私钥的密码。

  作为设置 PRIVATE_KEY_FILE 和 PRIVATE_KEY_FILE_PWD 的替代方法，您可以将 PRIVATEKEY 属性设置为私钥文件中:emph:`未加密私钥`的字符串值。

  • 例如，如果私钥文件未加密，请将其设置为文件中密钥的值（不带 -----BEGIN PRIVATE KEY----- 和 -----END PRIVATE KEY----- 页眉和页脚，也没有行尾）。

  • 请注意，如果私钥已加密，则必须先解密私钥，然后才能将其设置为 PRIVATEKEY 属性的值。

点击 Class 行旁边的绿色箭头，然后选择 Run HelloSnowpark.main() 以运行示例。