Snowpark Java 사용의 간단한 예

다음 예에서는 현재 데이터베이스에 있는 테이블의 개수와 이름을 출력합니다. <placeholders> 를 Snowflake에 연결하는 데 사용하는 값으로 바꾸십시오.

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

public class SnowparkExample {
  public static void main(String[] args) {
    // Create a Session, specifying the properties used to
    // connect to the Snowflake database.
    Map<String, String> properties = new HashMap<>();
    properties.put("URL", "https://<account_identifier>");
    properties.put("USER", "<username>");
    properties.put("PASSWORD", "<password>");
    properties.put("ROLE", "<role_name_with_access_to_public_schema>");
    properties.put("WAREHOUSE", "<warehouse_name>");
    properties.put("DB", "<database_name>");
    properties.put("SCHEMA", "<schema_name>");
    Session session = Session.builder().configs(properties).create();

    // Get the number of tables in the PUBLIC schema.
    DataFrame dfTables = session.table("INFORMATION_SCHEMA.TABLES")
    long tableCount = dfTables.count();
    String currentDb = session.getCurrentDatabase().orElse("<no current database>");
    System.out.println("Number of tables in the PUBLIC schema in " + currentDb + " database: " + tableCount);

    // Get the list of table names in the PUBLIC schema.
    DataFrame dfPublicSchemaTables ="TABLE_NAME"));;

그러면 스키마의 테이블 수와 테이블 목록이 출력됩니다.

Number of tables in the PUBLIC schema in the "MY_DB" database: 8
|"TABLE_NAME"       |
|A_TABLE            |