Function buildStatement

apps/sim/lib/data-drains/destinations/snowflake.ts:193–198

(config: SnowflakeDestinationConfig, rowCount: number)

}

function buildStatement(config: SnowflakeDestinationConfig, rowCount: number): string {
  const column = quoteIdentifier(config.column ?? 'DATA')
  const target = `${quoteIdentifier(config.database)}.${quoteIdentifier(config.schema)}.${quoteIdentifier(config.table)}`
  const placeholders = Array.from({ length: rowCount }, () => '(PARSE_JSON(?))').join(', ')
  return `INSERT INTO ${target} (${column}) VALUES ${placeholders}`
}

function isRetryableStatus(status: number): boolean {
  return status === 408 || status === 429 || (status >= 500 && status <= 599)