테이블 가져오기 쿼리 구성
TableImportConfig는 config.type으로 원천 커넥터에 맞는 구성을 선택합니다. 이 값은 Connection을 생성할 때의 configuration.type과 구분합니다.
config.type | 대상 연결 |
|---|---|
databricksImportConfig | Databricks |
jdbcImportConfig | 사용자 지정 JDBC |
microsoftSqlServerImportConfig | Microsoft SQL Server |
postgreSqlImportConfig | PostgreSQL |
microsoftAccessImportConfig | Microsoft Access |
snowflakeImportConfig | Snowflake |
oracleImportConfig | Oracle Database 21 |
일곱 분기는 다음 필드를 사용합니다.
| 이름 | 자료형 | 필수 여부 | 의미 |
|---|---|---|---|
type | string | 필수 | 위 표의 구분자 |
query | string | 필수 | 동기화 한 번에 실행할 단일 SQL 조회 |
initialIncrementalState | TableImportInitialIncrementalState | 선택 | 단조 증가 열과 초기 기준값을 정하는 증분 상태 |
SQL 조회 조건
쿼리는 데이터 테이블을 반환해야 하며 결과를 Foundry 출력 데이터셋에 저장합니다. 저장 프로시저 호출 같은 작업은 피합니다. 원천 데이터베이스의 SQL 문법과 연결에 부여한 조회 권한을 사용합니다.
다음은 가상 주문 테이블을 읽는 구성입니다. example_orders, order_id, order_date는 실제로 조회할 테이블과 열로 바꿉니다.
{
"type": "jdbcImportConfig",
"query": "SELECT order_id, order_date FROM example_orders"
}
증분 조회에는 initialIncrementalState와 ?를 사용하는 조건을 함께 구성합니다. 초기 상태 예제는 정수 기준값보다 큰 주문만 선택합니다.
연결 유형과 오류
대상 Connection이 해당 구성의 테이블 가져오기를 지원해야 합니다. 구성 문자열만 다른 커넥터의 값으로 바꾼다고 연결이 변환되지는 않습니다.
TableImportNotSupportedForConnection은 해당 연결과 구성의 조합을 지원하지 않을 때 HTTP 400으로 반환됩니다. Platform API가 아직 지원하지 않는 가져오기 유형의 TableImportTypeNotSupported는 INTERNAL/HTTP 500입니다. 두 오류의 이름과 상태를 구분하여 연결과 구성을 확인합니다.