[Snowflake] Prac 3 - QueryHistory

[NiFi] DB To Snowflake 실습의 연장선상으로,
해당 작업을 진행하면 어떤 Query가 실행되는지 확인하기 위함이다.

시간 순으로 정리

SELECT system$GET_NPS_FEEDBACK_TIMESTAMP(), system$GET_NPS_DISMISS_TIMESTAMP();

WorkSheet에 진입 시, 실행되는 쿼리이다.

CREATE OR REPLACE DATABASE TEST2 COMMENT = 'DB TO SNOWFLAKE TEST';
SHOW DATABASES;

TEST2 라는 DB를 생성하는 쿼리이다. 그리고 확인,

CREATE OR REPLACE TABLE TEST2.PUBLIC.DBTOSN
    (ID int,
     NAME varchar(32)
     );

DB의 Public 스키마에서 DBTOSN이라는 Table 생성하는 쿼리이다.

alter session /* JDBC:SnowflakeConnectionV1.setAutoCommit*/ set autocommit=false

JDBC를 통해 Snowflake에 연결된 세션에서 자동 커밋을 비활성화하고, 개발자가 명시적으로 트랜잭션을 커밋해야 변경 사항이 영구적으로 적용되도록 설정하는 쿼리이다.

• 세부적으로 들어가면,
  • alter session:
    • 현재 세션의 속성을 변경하겠다는 것이다.
  • /*JDBC:SnowflakeConnectionV1.setAutoCommit*/:
    • 이 부분은 주석(comment)입니다.
  • set autocommit=false:
    • 여러 SQL문을 하나의 트랜잭션으로 묶어 일괄 처리하기 위해 자동 커밋 설정을 변경하는 부분입니다.

show /* JDBC:DatabaseMetaData.getColumns() */ columns in table "TEST2"."PUBLIC"."DBTOSN"
show /* JDBC:DatabaseMetaData.getPrimaryKeys() */ primary keys in table "TEST2"."PUBLIC"."DBTOSN"

Snowflake 데이터베이스에서 특정 테이블의 컬럼 및 기본 키(primary key) 정보를 확인하기 위해 사용되는 명령이다.

INSERT INTO TEST2.PUBLIC.DBTOSN (ID, NAME) VALUES (?,?)

DB에서 추출한 데이터를 Snowflake Table에 삽입하는 쿼리이다.

alter session /* JDBC:SnowflakeConnectionV1.setAutoCommit*/ set autocommit=true

이전의 세션 설정을 다시 되돌리는 쿼리이다.

SELECT * FROM TEST2.PUBLIC.DBTOSN;

확인