JDBC 드라이버 API 지원¶

메서드¶

Snowflake 고유 동작¶

없습니다.

추가 메서드¶

getQueryID()¶

목적

이 메서드는 이 CallableStatement 에서 가장 최근에 실행된 쿼리의 Snowflake 쿼리 ID를 반환합니다. 호출 가능한 문을 사용하여 아직 쿼리가 실행되지 않은 경우 메서드는 null을 반환합니다.

인자

없습니다.

반환

이 메서드는 UUID를 포함한 문자열로 ID를 반환합니다. UUIDs에 대한 정보는 SQL 함수 UUID_STRING 의 설명에 포함됩니다.

Throw

이 메서드는 SQLException 을 throw할 수 있습니다.

메서드¶

Snowflake 고유 동작¶

• close()

  오브젝트를 닫습니다. 오브젝트가 닫힌 후, 닫힌 오브젝트에 대한 거의 모든 메서드를 호출하면 SQLException 이 발생합니다. 이미 닫힌 오브젝트에서 close 를 호출하면 오류가 발생하지 않지만 예외가 발생합니다.

• getMetaData()

  JDBC 드라이버 및 Snowflake에 대한 메타데이터를 가져오도록 하겠습니다. 예를 들어, 트랙잭션의 지원 여부를 확인할 수 있습니다.

  반환된 값에서 호출할 수 있는 메서드에 대한 자세한 내용은 오브젝트: DatabaseMetaData 를 참조하십시오.

• prepareStatement(String sql)

  이 메서드는 SQL 문을 실행하기 위해 사용할 수 있는 preparedStatement 오브젝트를 반환합니다. preparedStatement 오브젝트의 execute() 메서드를 호출하여 문을 실행할 수 있습니다. 문은 그대로 실행하거나 문에 값을 바인딩한 후 실행할 수 있습니다.

  참고

  일부 시스템에서는 문이 준비된 후에 해당 문을 재컴파일하지 않고 반복해서 실행할 수 있습니다. 한 번 준비한 후 반복적으로 실행하면 시간과 리소스를 약간 절약할 수 있습니다.

  Snowflake에서 prepareStatement()는 코드를 실제로 컴파일하지 않습니다. 대신, PreparedStatement.execute(), PreparedStatement.executeQuery() 및 PreparedStatement.executeUpdate() 가 문을 컴파일 및 실행합니다. 그러므로 실행하기 전 문을 준비하는 것은 단순히 Statement.execute() 를 사용하는 것에 비해 리소스가 절약되지 않습니다.

• prepareCall(String sql)

• prepareCall(String sql, boolean)

• prepareCall(String sql, int, int)

• prepareCall(String sql, int, int, int)

  대부분의 JDBC 구현에서와 같이, prepareCall 메서드를 사용하여 매개 변수를 저장 프로시저에 바인딩할 수 있습니다. 예를 들어, 다음이 지원됩니다.

  CallableStatement stmt = testConnection.prepareCall("call read_result_set(?,?) ");
  

  Copy

  그러나 Snowflake JDBC 드라이버의 prepareCall 메서드는 저장 프로시저의 반환 값 바인딩을 지원하는 ? = 구문을 지원하지 않습니다. 예를 들어, 다음은 지원되지 않습니다.

  CallableStatement stmt = testConnection.prepareCall("? = call read_result_set() ");  -- INVALID
  

  Copy

추가 메서드¶

이러한 메서드는 JDBC Connection 인터페이스에서 지원하는 메서드에 추가됩니다.

public ResultSet createResultSet(String queryID)

목적

비동기식으로 실행된 SQL 문 의 queryID가 제공되면 쿼리 결과를 검색하여 ResultSet 오브젝트에 반환합니다.

이 메서드는 일반적으로 SQL 문의 종료된 후 24시간 이내에 호출됩니다.

인자

queryID: 결과를 살펴볼 쿼리의 쿼리 ID입니다.

반환

ResultSet입니다. 쿼리 실행이 아직 완료되지 않은 경우 서버는 《빈》 ResultSet을 반환합니다. 사용자는 resultSet.unwrap(SnowflakeResultSet.class).getStatus() 를 호출하여 데이터를 사용할 수 있는 시간을 확인할 수 있습니다.

Throw

이 메서드는 SQLException 을 throw할 수 있습니다.

참고

이 메서드는 JDBC 표준에 대한 Snowflake 확장입니다. 이 메서드를 사용하려면 Connection 오브젝트의 래핑을 해제 해야 합니다.

예

ResultSet resultSet;
resultSet = connection.unwrap(SnowflakeConnection.class).createResultSet(queryID);

Copy

이 메서드의 호출을 포함하는 보다 광범위한 예시는 비동기 쿼리의 예 를 참조하십시오.

public InputStream downloadStream(String stageName, String sourceFileName, boolean decompress)

목적

이 메서드는 지정된 내부 스테이지에서 파일을 다운로드하고 입력 스트림을 반환합니다.

인자

stageName: 스테이지 이름입니다.

sourceFileName: 스테이지의 파일 경로입니다.

decompress: 파일이 압축된 경우 true입니다.

반환

이 메서드는 InputStream을 반환합니다.

Throw

SQL 오류가 발생하면 이 메서드는 SQLException을 throw합니다.

예

부분적인 예시는 내부 스테이지에서 스트림으로 직접 데이터 파일 다운로드 를 참조하십시오.

public String getSessionID()

목적

이 메서드는 현재 세션의 세션 ID를 반환합니다.

인자

없음

반환

세션 ID를 문자열로 반환합니다.

Throw

예를 들어 연결이 닫힌 경우와 같이 SQL 오류가 발생하면 이 메서드는 SQLException를 throw합니다.

사용법 노트

세션 ID는 연결이 열려 있는 동안 변경되지 않으므로 세션 ID는 성능 향상을 위해 (매번 서버에서 검색하지 않고) 로컬로 캐시됩니다.

public prepareStatement(String sql, Boolean skipParsing)

이 메서드는 더 이상 사용되지 않습니다. skipParsing 매개 변수는 더 이상 메서드의 동작에 영향을 주지 않으며, 이 메서드는 skipParsing 매개 변수의 설정에 관계없이 prepareStatement(String sql) 메서드와 동일하게 동작합니다.

새로운 코드에서는 prepareStatement(String sql) 메서드를 사용할 수 있습니다.

편리한 경우 인자 2개를 사용하는 이 메서드의 버전을 사용하는 기존 코드를 인자를 1개 사용하는 prepareStatement(String sql) 메서드를 사용하도록 업데이트해야 합니다.

public void uploadStream(String stageName, String destPrefix, InputStream inputStream, String destFileName, boolean compressData)

목적

이 메서드는 스트림에서 데이터를 압축하고 내부 스테이지 위치에 업로드합니다. 데이터는 파일 1개로 업로드됩니다. 이 메서드에서는 분할이 수행되지 않습니다.

인자

stageName: 스테이지 이름(예: ~ 또는 테이블 이름 또는 스테이지 이름)입니다.

destPrefix: 스테이지에서 데이터를 업로드해야 하는 경로/접두사입니다.

inputStream: 데이터를 업로드할 입력 스트림입니다.

destFileName: 사용할 대상 파일 이름입니다.

compressData: 스트림을 업로드하기 전에 데이터를 압축하거나 압축하지 않습니다.

반환

없습니다.

Throw

이 메서드는 스테이지의 스트림에서 데이터를 압축하고 삽입하지 못하는 경우 java.sql.SQLException 을 throw합니다.

참고

호출자는 메서드가 호출된 후 inputStream 을 해제할 책임이 있습니다.

예

부분적인 예시는 스트림에서 내부 스테이지로 직접 데이터 파일 업로드 를 참조하십시오.

메서드¶

Snowflake 고유 동작¶

public ResultSet getColumnPrivileges(String, String, String, String)

Snowflake는 열 수준 권한을 지원하지 않으므로 이 메서드는 항상 빈 세트를 반환합니다.

public ResultSet getStreams(String, String, String)

목적

이 메서드는 지정된 데이터베이스와 스키마 내에 포함된 스트림 에 대한 정보를 반환합니다.

인자

• originalCatalog: 데이터베이스의 이름입니다.

• orignalSchemaPattern: 스키마를 식별하는 패턴입니다(와일드카드 를 지원함).

• streamName: 스트림의 이름입니다(와일드카드 를 지원함).

반환

이 메서드는 다음 열을 포함하는 각 행과 함께, 각 스트림의 행을 포함하는 ResultSet 를 반환합니다.

• name: 스트림의 이름입니다.

• database_name: 스트림을 포함하는 스키마의 데이터베이스 이름입니다.

  데이터베이스 오브젝트(예: 스트림)는 스키마에 포함되며, 스키마는 데이터베이스에 포함됩니다.

• schema_name: 스트림을 포함하는 스키마의 이름입니다.

• owner: 스트림을 소유한 역할입니다.

• comment: 스트림과 연결된 설명입니다.

• table_name: 스트림에서 자신의 DML 업데이트가 추적되는 테이블의 이름입니다.

• source_type: 스트림의 원본 오브젝트입니다. 가능한 값은 다음과 같습니다.

  • table

  • view

  • directory table

  • external table

• base_tables: 뷰의 기본 테이블입니다. 이 열은 뷰의 스트림에만 적용됩니다.

• type: 스트림의 유형입니다. 현재, 함수는 항상 DELTA 를 반환합니다.

• stale: stale_after 시간이 지나기 전에 스트림을 마지막으로 읽었는지 여부입니다. TRUE 인 경우 스트림이 부실할 수 있습니다.

  부실한 스트림은 읽을 수 없습니다. 스트림을 다시 만들어 스트림에서 읽기를 재개할 수 있습니다. 스트림이 부실해지는 것을 방지하려면 stale_after 시간이 지나기 전에 스트림을 사용해야 합니다.

• mode: 스트림의 유형입니다. 가능한 값은 다음과 같습니다.

  • APPEND_ONLY: 스트림이 Append-only 스트림임을 나타냅니다.

  • INSERT_ONLY: 스트림이 삽입된 행에 대한 정보만 반환함을 나타냅니다. 이 값은 외부 테이블의 스트림에만 적용됩니다.

  • DEFAULT: 스트림이 테이블에 있음을 나타냅니다.

Throw

SQL 오류가 발생하면 이 메서드는 SQLException 을 발생시킵니다.

null 매개 변수 지원¶

일부 DatabaseMetaData 메서드는 데이터베이스 오브젝트 이름(예: 테이블/카탈로그 이름)에 대한 null 값을 허용합니다. 기본적으로 null 값은 메서드에서 해당 인자를 필터링하지 않음을 의미합니다. 예를 들어, schemaPattern 인자에 대해 null 값을 getColumns() 에 전달하면 getColumns() 는 모든 스키마에 대한 값을 반환합니다.

이러한 방법 중 일부의 경우 null 인자에 대한 기본 동작은 다음 매개 변수 로 재정의할 수 있습니다.

• CLIENT_METADATA_REQUEST_USE_CONNECTION_CTX.

• CLIENT_METADATA_USE_SESSION_DATABASE.

데이터베이스 오브젝트 이름에서 와일드카드 지원¶

일부 DatabaseMetaData 메서드는 테이블/카탈로그 이름과 같은 데이터베이스 오브젝트 이름에서 패턴 일치 와일드카드를 지원합니다. 지원되는 와일드카드 문자는 다음과 같습니다.

• %: 0개 이상의 문자로 구성된 모든 문자열과 일치합니다.

• _: 1개 문자와 일치합니다.

다음 예시는 지정된 데이터베이스(TEMPORARYDB1) 및 스키마(TEMPORARYSCHEMA1)의 모든 테이블과 모든 열 이름을 가져오기 위해 getColumns() 메서드에 전달할 값을 보여줍니다.

getColumns( connection,
    "TEMPORARYDB1",      // Database name.
    "TEMPORARYSCHEMA1",  // Schema name.
    "%",                 // All table names.
    "%"                  // All column names.
    );

테이블 이름 등의 데이터베이스 오브젝트 이름에는 예를 들어 SHIPPING_ADDRESSES 와 같이 밑줄이 포함되는 것이 일반적입니다. 밑줄을 이스케이프하지 않고 SHIPPING_ADDRESSES 를 검색하면 이름이 SHIPPING_ADDRESSES 인 테이블뿐만 아니라 SHIPPING2ADDRESSES 와 같은 테이블도 찾을 수 있습니다. SHIPPING2ADDRESSES 를 제외하고 SHIPPING_ADDRESSES 를 검색하려면 와일드카드 문자를 이스케이프하여 리터럴로 처리하도록 지정해야 합니다. 문자를 이스케이프하려면 백슬래시를 앞에 추가합니다.

백슬래시 문자 자체를 리터럴 문자로 사용하려면 이스케이프 처리해야 합니다. 예를 들어 밑줄, 앰퍼샌드 및 백슬래시가 와일드카드 문자나 이스케이프 문자가 아닌 이름의 리터럴 부분에 해당하는 이름이 T_&\ 인 테이블을 검색하려면 다음과 유사하게 메서드를 호출해야 합니다.

getColumns(
    connection, "TEMPORARYDB1", "TEMPORARYSCHEMA1", "T\\_\\\\", "%" // All column names.
    );

Java 컴파일러는 백슬래시가 이스케이프될 것으로 예상하므로 위의 각 백슬래시는 추가 시간을 이스케이프해야 합니다.

Java sees...............: T\\_\\%\\\\
SQL sees................: T\_\%\\
The actual table name is: T_%\

메서드¶

Snowflake 고유 동작¶

없습니다.

예¶

다음 코드 조각은 속성 정보를 가져오는 프로그램의 일부를 보여줍니다.

  // Demonstrate the Driver.getPropertyInfo() method.
  public static void do_the_real_work(String connectionString) throws Exception {
    Properties properties = new Properties();
    Driver driver = DriverManager.getDriver(connectionString);
    DriverPropertyInfo[] dpinfo = driver.getPropertyInfo("", properties);
    System.out.println(dpinfo[0].description);
  }

일반적으로 이 메서드는 루프 내부에서 호출되어야 합니다. 속성에 대한 정보를 검색한 후 해당 속성을 설정하면 새 설정과 추가 속성이 관련성이 있을 수 있으므로 해당 속성을 검색 및 설정해야 할 수 있습니다.

메서드¶

Snowflake 고유 동작¶

없습니다.

메서드¶

Snowflake 고유 동작¶

• addBatch()

  INSERT 문에서만 지원됩니다.

  addBatch 메서드(executeBatch 와 함께 사용)를 사용하여 단일 INSERT 문의 일부로 여러 데이터 행을 삽입할 수 있습니다.

  일괄 처리를 사용하는 것과 사용하지 않는 경우의 차이점은 다중 행 삽입을 사용하는 것과 단일 행 삽입을 사용하는 경우의 차이점과 유사합니다.

  INSERT INTO t1 (c1, c2) VALUES (1, 'One');   -- single row inserted.
  
  INSERT INTO t1 (c1, c2) VALUES (1, 'One'),   -- multiple rows inserted.
                                 (2, 'Two'),
                                 (3, 'Three');
  

  Copy

  일반적으로 행을 일괄 삽입하는 것이 개별 INSERT 문에 같은 수의 행을 삽입하는 것보다 더 효율적입니다. AUTOCOMMIT을 사용할 때(즉, 각 INSERT가 개별 트랜잭션인 경우) 이러한 이점이 훨씬 더 큽니다.

  addBatch 를 사용하는 예시는 일괄 삽입 을 참조하십시오.

  참고

  바인딩할 수 있거나 일괄 결합할 수 있는 데이터 크기의 상한에는 제한이 있습니다. 자세한 내용은 쿼리 텍스트 크기 제한 섹션을 참조하십시오.

• execute()

  이 메서드는 PreparedStatement 오브젝트가 생성될 때 제공된 SQL 문을 컴파일하여 실행됩니다. 문은 SQL 문의 유형일 수 있습니다. execute() 메서드는 ResultSet 을 반환하지 않습니다.

  이 메서드는 아무 것도 반환하지 않습니다. 쿼리를 실행하고 문이 실행될 때 ResultSet 을 반환해야 하는 경우에는 executeQuery() 메서드를 사용해야 합니다.

• executeQuery()

  이 메서드는 PreparedStatement 오브젝트가 생성될 때 제공된 SQL 문을 컴파일하여 실행한 후 ResultSet 을 반환합니다.

• executeUpdate()

  이 메서드는 PreparedStatement 오브젝트가 생성될 때 제공된 SQL 문을 컴파일하여 실행됩니다. 문은 DML 문(INSERT, UPDATE, DELETE 등) 또는 아무 것도 반환하지 않는 SQL 문(예: DDL 문)이어야 합니다.

  문이 DML 문인 경우 executeUpdate() 메서드는 업데이트된 행 수에 해당하는 정수를 반환합니다. 문이 행을 업데이트하지 않은 경우 함수에서는 0 이 반환됩니다.

  ResultSet을 반환하는 SQL 문을 실행해야 하는 경우에는 executeQuery()와 같은 다른 메서드를 사용해야 합니다.

• setObject()

  이 메서드를 사용하면 타임스탬프 변수를 타임스탬프 열에 바인딩할 때 타임스탬프 값을 해석하기 위해 사용할 타임스탬프 변형(TIMESTAMP_LTZ , TIMESTAMP_NTZ , TIMESTAMP_TZ)을 지정할 수 있습니다. 자세한 내용은 변수를 타임스탬프 열에 바인딩하기 섹션을 참조하십시오.

추가 메서드¶

아래 메서드는 PreparedStatement 인터페이스에서 지원하는 메서드에 추가됩니다.

executeAsyncQuery()¶

목적

이 메서드는 비동기 쿼리 를 수행하며, 실행을 위해 SQL 문을 제출한 후 쿼리가 완료될 때까지 대기하지 않고 호출자에게 제어를 반환합니다.

executeAsyncQuery() 에 유효한 모든 SQL 문은 executeQuery() 에도 유효합니다.

참고

PUT과 GET과 같은 파일 전송 문은 executeAsyncQuery() 에도 유효하지만 동기적인 방식으로 작동합니다.

인자

없습니다.

반환

《빈》 ResultSet입니다. 사용자는 쿼리 결과를 사용할 수 있을 때까지 resultSet.unwrap(SnowflakeResultSet.class).getStatus() 을 호출하여 결과 세트를 폴링해야 합니다.

Throw

이 메서드는 SQLException 을 throw할 수 있습니다.

참고

이 메서드는 JDBC 표준에 대한 Snowflake 확장입니다. 이 메서드를 사용하려면 PreparedStatement 오브젝트의 래핑을 해제 해야 합니다.

예

...
PreparedStatement prepStatement = connection.prepareStatement("insert into testTable values (?)");
prepStatement.setInt(1, 33);
ResultSet rs = prepStatement.executeAsyncQuery();
...

Copy

매우 유사한 비동기 쿼리의 예 메서드를 사용하는 보다 광범위한 예시는 SnowflakeStatement.executeAsyncQuery() 를 참조하십시오.

getQueryID()

목적

이 메서드는 이 SnowflakePreparedStatement 에서 가장 최근에 실행된 쿼리의 Snowflake 쿼리 ID를 반환합니다. 준비된 이 문을 사용하여 아직 쿼리가 실행되지 않은 경우 메서드는 null을 반환합니다.

인자

없습니다.

반환

이 메서드는 UUID를 포함한 문자열로 ID를 반환합니다.

Throw

이 메서드는 SQLException 을 throw할 수 있습니다.

참고

이 메서드는 JDBC 표준에 대한 Snowflake 확장입니다. 이 메서드를 사용하려면 SnowflakePreparedStatement 의 래핑을 해제 해야 합니다.

비동기 쿼리 의 경우에는 명령문의 실행이 완료될 때까지 ID 쿼리를 사용할 수 없습니다. executeAsyncQuery() 를 호출했지만 문의 실행이 완료되기 전에 SnowflakePreparedStatement.getQueryID() 를 호출하면 NULL 값이 반환됩니다. 대신, executeAsyncQuery() 로부터 반환된 ResultSet 오브젝트에 대한 resultSet.unwrap(SnowflakeResultSet.class).getQueryID() 을 호출합니다.

예

아래의 부분 예시는 이 메서드의 호출 방법을 보여줍니다.

    // Retrieve the query ID from the PreparedStatement.
    String queryID;
    queryID = preparedStatement.unwrap(SnowflakePreparedStatement.class).getQueryID();

Copy

열거형 상수¶

각 열거형 상수는 비동기 쿼리에 대해 가능한 다양한 상태를 나타냅니다.

메서드¶

열거형 타입은 다음 메서드를 정의하며, 이 메서드를 사용하면 쿼리 상태가 FAILED_WITH_ERROR 일 때 오류에 대한 세부 정보를 가져올 수 있습니다.

getErrorCode()¶

목적

쿼리 실행 중 오류가 발생한 경우 이 메서드는 서버에서 오류 코드를 반환합니다.

인자

없습니다.

반환

이 메서드는 오류 코드를 int 으로 반환합니다. 오류가 발생하지 않으면 메서드에서 0 값이 반환됩니다.

예

QueryStatus queryStatus = resultSet.unwrap(SnowflakeResultSet.class).getStatus();
if (queryStatus == queryStatus.FAILED_WITH_ERROR) {
  // Print the error code to stdout
  System.out.format("Error code: %d%n", queryStatus.getErrorCode());
}

Copy

이 메서드의 호출을 포함하는 보다 광범위한 예시는 비동기 쿼리의 예 를 참조하십시오.

getErrorMessage()¶

목적

쿼리 실행 중 오류가 발생한 경우 이 메서드는 서버에서 오류 메시지를 반환합니다.

인자

없습니다.

반환

이 메서드는 오류 메시지를 String 으로 반환합니다. 오류가 발생하지 않으면 메서드에서 No error reported 값이 반환됩니다.

예

QueryStatus queryStatus = resultSet.unwrap(SnowflakeResultSet.class).getStatus();
if (queryStatus == queryStatus.FAILED_WITH_ERROR) {
  // Print the error message to stdout
  System.out.format("Error message: %s%n", queryStatus.getErrorMessage());
}

Copy

이 메서드의 호출을 포함하는 보다 광범위한 예시는 비동기 쿼리의 예 를 참조하십시오.

메서드¶

Snowflake 고유 동작¶

• close()

  오브젝트를 닫습니다. 오브젝트가 닫힌 후, 닫힌 오브젝트에 대한 거의 모든 메서드를 호출하면 SQLException 이 발생합니다. 이미 닫힌 오브젝트에서 close 를 호출하면 오류가 발생하지 않지만 예외가 발생합니다.

• getDate(), getTime(), getTimestamp()

  버전 3.12.17 이상 버전의 JDBC 드라이버에서 이러한 메서드는 세션의 타임존(TIMEZONE 매개 변수를 사용하여 지정)을 사용합니다. 이전 버전에서는 JVM의 타임존을 사용합니다.

  이러한 메서드를 변경하여 JVM의 타임존을 사용하려면 JDBC_USE_SESSION_TIMEZONE 매개 변수를 FALSE 로 설정합니다.

• getMetaData()

  ResultSet 오브젝트가 비동기 쿼리 용인 경우에는 쿼리 실행이 완료될 때까지 이 메서드가 차단됩니다. 이 메서드를 호출하기 전에 resultSet.unwrap(SnowflakeResultSet.class).getStatus() 를 사용하여 쿼리 상태를 가져올 수 있습니다.

• next()

  이를 통해 결과 세트의 다음 행이 《현재》 행으로 설정됩니다. getInt() 등의 get*() 메서드를 호출하면 현재 행의 값을 가져옵니다.

  ResultSet 이 close 메서드에 대한 호출에 의해 닫힌 경우, next 에 대한 후속 호출에서는 예외가 발생하지 않고 false를 반환합니다.

  ResultSet 오브젝트가 비동기 쿼리 용인 경우 결과를 사용할 수 있을 때까지 이 메서드가 차단됩니다. 이 메서드를 호출하기 전에 resultSet.unwrap(SnowflakeResultSet.class).getStatus() 를 사용하여 쿼리 상태를 가져올 수 있습니다.

추가 메서드¶

getQueryID()

목적

이 메서드는 이 결과 세트를 생성한 문의 Snowflake 쿼리 ID를 반환합니다.

인자

없습니다.

반환

이 메서드는 UUID를 포함한 문자열로 ID를 반환합니다.

참고

이 메서드는 JDBC 표준에 대한 Snowflake 확장입니다. 이 메서드를 사용하려면 ResultSet 의 래핑을 해제 해야 합니다.

예

    String queryID2;
    queryID2 = resultSet.unwrap(SnowflakeResultSet.class).getQueryID();

Copy

getStatus()¶

목적

SnowflakeStatement.executeAsyncQuery() 와 같은 비동기 쿼리에서 반환된 ResultSet의 경우 이 메서드는 쿼리의 상태를 반환합니다. 상태는 쿼리의 성공, 실패 또는 미완료 여부를 나타냅니다.

인자

없습니다.

반환

QueryStatus 열거형 상수 입니다.

Throw

이 메서드는 SQLException 을 throw할 수 있습니다.

참고

이 메서드는 JDBC 표준에 대한 Snowflake 확장입니다. 이 메서드를 사용하려면 ResultSet 오브젝트의 래핑을 해제 해야 합니다.

예

QueryStatus queryStatus = resultSet.unwrap(SnowflakeResultSet.class).getStatus();

Copy

이 메서드의 호출을 포함하는 보다 광범위한 예시는 비동기 쿼리의 예 를 참조하십시오.

메서드¶

Snowflake 고유 동작¶

• ResultSetMetaData 클래스에는 close() 메서드가 없습니다. 열린 ResultSetMetaData 오브젝트는 ResultSet 오브젝트가 생성된 ResultSetMetaData 를 사용자가 닫을 때 암시적으로 닫힙니다.

• getCatalogName(), getSchemaName(), getTableName()

  ResultSet 오브젝트가 비동기 쿼리 용인 경우 이 메서드는 빈 문자열을 반환합니다.

• GEOGRAPHY 열의 경우 getColumnTypeName 은 GEOGRAPHY 를 반환합니다.

  getColumnType 및 getColumnClassName 메서드는 열 타입이 GEOGRAPHY 임을 나타내지 않음에 유의하십시오.

추가 메서드¶

getColumnIndex(String columnName):

목적

columnName에 해당하는 열의 인덱스를 반환합니다. 예를 들어, 이름이 《BirthDate》인 열이 테이블의 세 번째 열이면 getColumnIndex(《BirthDate》)에서 2가 반환됩니다. (인덱스는 1부터 시작하지 않고 0부터 시작됩니다.)

인자

인덱스를 찾을 열의 이름입니다.

반환

columnName에 해당하는 열의 인덱스를 포함하는 정수를 반환합니다. columnName이 결과 세트의 열과 일치하지 않으면 -1을 반환합니다.

Throw

이 메서드는 SQLException 을 throw할 수 있습니다.

getColumnNames():

목적

이 함수는 결과 세트에서 모든 열 이름의 목록을 반환합니다.

이 함수는 인덱스를 기반으로 단일 열 이름을 반환하는 ResultSetMetaData의 getColumnName(int 열) 함수와 다릅니다.

인자

없습니다.

반환

반환되는 값의 데이터 타입은 《목록<문자열>》입니다. 목록에는 열 이름이 포함됩니다. 이름의 순서는 열 인덱스와 순서와 같습니다.

Throw

이 메서드는 SQLException 을 throw할 수 있습니다.

getInternalColumnType(int column):

목적

지정된 열의 데이터 타입을 반환합니다.

인자

열: 데이터 타입이 필요한 열의 인덱스(1부터 시작)를 나타냅니다.

반환

지정된 열의 데이터 타입을 반환합니다. 데이터 타입은 정수입니다.

Throw

이 메서드는 SQLException 을 throw할 수 있습니다.

getQueryID()

목적

이 메타데이터가 적용되는 쿼리의 Snowflake 쿼리 ID를 반환합니다.

인자

없습니다.

반환

이 메서드는 이 메타데이터가 생성된 쿼리의 쿼리 ID를 반환합니다. ID 쿼리는 UUID를 포함하는 문자열입니다. UUIDs에 대한 정보는 SQL 함수 UUID_STRING 의 설명에 포함됩니다.

Throw

이 메서드는 SQLException 을 throw할 수 있습니다.

메서드¶

SnowflakeTimestampWithTimezone(
    long seconds,
    int nanoseconds,
    TimeZone tz)

SnowflakeTimestampWithTimezone(
    Timestamp ts,
    TimeZone tz)

SnowflakeTimestampWithTimezone(
    Timestamp ts)

Snowflake 고유 동작¶

• getTimezone()

  타임스탬프에서 타임존을 반환합니다.

  import java.sql.Timestamp;
  import java.time.ZonedDateTime;
  import java.util.TimeZone;
  
  public void testGetTimezone() {
      String timezone = "Australia/Sydney";
  
      // Create a timestamp from a point in time
      Long datetime = System.currentTimeMillis();
      Timestamp currentTimestamp = new Timestamp(datetime);
      SnowflakeTimestampWithTimezone ts =
          new SnowflakeTimestampWithTimezone(currentTimestamp, TimeZone.getTimeZone(timezone));
  
      // Verify timezone was set
      assertEquals(ts.getTimezone().getID(), timezone);
  }
  

  Copy

• toZonedDateTime()

  SnowflakeTimestampWithTimezone 타임스탬프를 존이 지정된 날짜 시간(Java ZonedDateTime 오브젝트)으로 변환합니다.

  import java.sql.Timestamp;
  import java.time.ZonedDateTime;
  import java.util.TimeZone;
  
  public void testToZonedDateTime() {
      String timezone = "Australia/Sydney";
      String zonedDateTime = "2022-03-17T10:10:08+11:00[Australia/Sydney]";
  
      // Create a timestamp from a point in time
      Long datetime = 1647472208000L;
      Timestamp timestamp = new Timestamp(datetime);
      SnowflakeTimestampWithTimezone ts =
          new SnowflakeTimestampWithTimezone(timestamp, TimeZone.getTimeZone(timezone));
      ZonedDateTime zd = ts.toZonedDateTime();
  
      // Verify timestamp was converted to zoned datetime
      assertEquals(zd.toString(), zonedDateTime);
  }
  

  Copy

메서드¶

Snowflake 고유 동작¶

• close()

  이 메서드는 오브젝트를 닫습니다. 오브젝트가 닫힌 후, 닫힌 오브젝트에 대한 거의 모든 메서드를 호출하면 SQLException 이 발생합니다. 이미 닫힌 오브젝트에서 close 를 호출하면 오류가 발생하지 않지만 예외가 발생합니다.

• getBatchQueryID()

  이 메서드는 이 Statement 에서 가장 최근에 실행된 쿼리 일괄 처리의 Snowflake 쿼리 IDs 목록을 반환합니다. 문을 사용하여 아직 쿼리가 실행되지 않은 경우 메서드는 null을 반환합니다.

  이 메서드는 JDBC 표준에 대한 Snowflake 확장입니다. 이 메서드를 사용하려면 문의 래핑을 해제 해야 합니다. 예:

      connection.setAutoCommit(false);
      statement.addBatch("SELECT 1;");
      statement.addBatch("SELECT 2;");
      statement.executeBatch();
      connection.commit();
      connection.setAutoCommit(true);
      List<String> batchQueryIDs1;
      // Since getQueryID is not standard JDBC API, we must call unwrap() to
      // use these Snowflake methods.
      batchQueryIDs1 = statement.unwrap(SnowflakeStatement.class).getBatchQueryIDs();
      int num_query_ids = batchQueryIDs1.size();
      if (num_query_ids != 2) {
        System.out.println("ERROR: wrong number of query IDs in batch 1.");
      }
      // Check that each query ID is plausible.
      for (int i = 0; i < num_query_ids; i++) {
        String qid = batchQueryIDs1.get(i);
        if (!is_plausible_query_id(qid)) {
          msg = "SEVERE WARNING: suspicious query ID in batch";
          System.out.println("msg");
          System.out.println(qid);
        }
      }
  

  Copy

• getUpdateCount()

  이 메서드는 가장 최근에 실행된 SQL 문에 의해 업데이트된 행 수를 반환합니다.

  • 문이 DML 문(INSERT, UPDATE, DELETE 등)이면 getUpdateCount() 는 추가, 삭제 또는 변경된 행 수를 반환합니다. 행이 변경되지 않은 경우 이 값은 0 일 수 있습니다.

  • 문이 SELECT문이면 getUpdateCount() 는 -1 을 반환합니다.

  • 문이 DDL문이면 getUpdateCount() 는 -1 을 반환합니다.

추가 메서드¶

executeAsyncQuery(String)

목적

이 메서드는 비동기 쿼리 를 수행하며, 실행을 위해 SQL 문을 제출한 후 쿼리가 완료될 때까지 대기하지 않고 호출자에게 제어를 반환합니다.

인자

실행할 SQL 명령이 포함된 문자열입니다. executeAsyncQuery() 에 유효한 모든 SQL 문은 executeQuery() 에도 유효합니다.

참고

PUT과 GET과 같은 파일 전송 문은 executeAsyncQuery() 에도 유효하지만 동기적인 방식으로 작동합니다.

반환

《빈》 ResultSet입니다. 사용자는 쿼리 결과를 사용할 수 있을 때까지 resultSet.unwrap(SnowflakeResultSet.class).getStatus() 을 호출하여 결과 세트를 폴링해야 합니다.

Throw

이 메서드는 SQLException 을 throw할 수 있습니다.

참고

이 메서드는 JDBC 표준에 대한 Snowflake 확장입니다. 이 메서드를 사용하려면 Statement 오브젝트의 래핑을 해제 해야 합니다.

예

이 메서드에 대한 호출을 포함하는 예는 비동기 쿼리의 예 를 참조하십시오.

getQueryID()

목적

이 메서드는 이 Statement 에서 가장 최근에 실행된 쿼리의 Snowflake 쿼리 ID를 반환합니다.

인자

없습니다.

반환

가장 최근에 실행된 쿼리의 Snowflake 쿼리 ID입니다. ID 쿼리는 UUID를 포함하는 문자열입니다. 문을 사용하여 아직 쿼리가 실행되지 않은 경우 메서드는 null을 반환합니다.

Throw

이 메서드는 SQLException 을 throw할 수 있습니다.

참고

이 메서드는 JDBC 표준에 대한 Snowflake 확장입니다. 이 메서드를 사용하려면 문의 래핑을 해제 해야 합니다.

비동기 쿼리 의 경우에는 명령문의 실행이 완료될 때까지 ID 쿼리를 사용할 수 없습니다. executeAsyncQuery() 를 호출했지만 문의 실행이 완료되기 전에 SnowflakeStatement.getQueryID() 를 호출하면 NULL 값이 반환됩니다. 대신, executeAsyncQuery() 로부터 반환된 ResultSet 오브젝트에 대한 resultSet.unwrap(SnowflakeResultSet.class).getQueryID() 을 호출합니다.

예

    String queryID1;
    queryID1 = statement.unwrap(SnowflakeStatement.class).getQueryID();

Copy

setParameter(String parameter_name, <type> <value>)¶

목적

SnowflakeStatement 클래스는 setParameter 메서드를 Snowflake 확장으로 제공합니다. 이를 클래스를 사용하면 호출자는 Snowflake 관련 JDBC 매개 변수를 설정할 수 있습니다.

메서드는 오버로드됩니다. JDBC 매개 변수가 다르면 데이터 타입이 달라야 합니다. 함수에 대한 두 번째 인자로 전달할 수 있는 각 유효한 데이터 타입에 대한 메소드가 제공됩니다.

인자

매개 변수_이름:

이 문자열에는 미리 정의된 Snowflake JDBC 매개 변수의 이름이 포함되어야 합니다. 미리 정의된 JDBC 매개 변수(및 유효한 값 또는 범위)는 다음과 같습니다.

JDBC 매개 변수	참고
MULTI_STATEMENT_COUNT	문의 수를 지정하는 정수(0 = 문의 수가 제한이 없음, 1 이상은 실행되어야 하는 명령문의 정확한 수를 나타냄)입니다.

값:

지정된 JDBC 매개 변수에 할당되는 값입니다. 지정한 JDBC 매개 변수와 데이터 타입이 호환되는지 확인해야 합니다.

반환

없습니다.

Throw

이 함수에서는 SQLException가 throw될 수 있습니다.

참고

이 메서드는 JDBC 표준에 대한 Snowflake 확장입니다. 이 메서드를 사용하려면 문의 래핑을 해제 해야 합니다.

예

Statement statement1;
...
// Tell Statement to expect to execute 2 statements:
statement1.unwrap(SnowflakeStatement.class).setParameter(
        "MULTI_STATEMENT_COUNT", 2);

Copy