Skip to main content
Version: 0.17.x

Class: SnowflakeConnector

Defined in: src/connectors/snowflake.ts:48

Secure Snowflake connector

The host field should be <account>.snowflakecomputing.com; the account identifier is extracted automatically.

Features:

  • SQL injection prevention
  • Credential validation
  • Read-only query patterns
  • Connection timeouts
  • Secure error handling

Example​

import { SnowflakeConnector } from '@freshguard/freshguard-core';

const connector = new SnowflakeConnector({
  host: 'xy12345.us-east-1.snowflakecomputing.com', port: 443,
  database: 'ANALYTICS',
  username: 'READER',
  password: process.env.SF_PASSWORD!,
});

Extends​

  • BaseConnector

Constructors​

Constructor​

new SnowflakeConnector(config, securityConfig?): SnowflakeConnector

Defined in: src/connectors/snowflake.ts:62

Parameters​

config​

ConnectorConfig

Connection config; host is <account>.snowflakecomputing.com. Pass options.schema to target a specific schema (default: 'PUBLIC'). Pass options.warehouse to specify the compute warehouse.

securityConfig?​

Partial<SecurityConfig>

Optional overrides for query timeouts, max rows, and blocked keywords

Returns​

SnowflakeConnector

Overrides​

BaseConnector.constructor

Properties​

config​

protected config: ConnectorConfig

Defined in: src/connectors/base-connector.ts:63

Inherited from​

BaseConnector.config

connectionTimeout​

protected readonly connectionTimeout: number

Defined in: src/connectors/base-connector.ts:49

Inherited from​

BaseConnector.connectionTimeout

enableDetailedLogging​

protected readonly enableDetailedLogging: boolean

Defined in: src/connectors/base-connector.ts:57

Inherited from​

BaseConnector.enableDetailedLogging

enableQueryAnalysis​

protected readonly enableQueryAnalysis: boolean

Defined in: src/connectors/base-connector.ts:58

Inherited from​

BaseConnector.enableQueryAnalysis

logger​

protected readonly logger: StructuredLogger

Defined in: src/connectors/base-connector.ts:53

Inherited from​

BaseConnector.logger

maxRows​

protected readonly maxRows: number

Defined in: src/connectors/base-connector.ts:51

Inherited from​

BaseConnector.maxRows

metrics​

protected readonly metrics: MetricsCollector

Defined in: src/connectors/base-connector.ts:54

Inherited from​

BaseConnector.metrics

queryAnalyzer​

protected readonly queryAnalyzer: QueryComplexityAnalyzer

Defined in: src/connectors/base-connector.ts:55

Inherited from​

BaseConnector.queryAnalyzer

queryTimeout​

protected readonly queryTimeout: number

Defined in: src/connectors/base-connector.ts:50

Inherited from​

BaseConnector.queryTimeout

requireSSL​

protected readonly requireSSL: boolean

Defined in: src/connectors/base-connector.ts:52

Inherited from​

BaseConnector.requireSSL

schemaCache​

protected readonly schemaCache: SchemaCache

Defined in: src/connectors/base-connector.ts:56

Inherited from​

BaseConnector.schemaCache

Methods​

cleanup()​

protected cleanup(): void

Defined in: src/connectors/base-connector.ts:806

Cleanup resources (should be called by subclasses in their close method)

Returns​

void

Inherited from​

BaseConnector.cleanup

clearSchemaCache()​

protected clearSchemaCache(): void

Defined in: src/connectors/base-connector.ts:792

Clear schema cache for testing or maintenance

Returns​

void

Inherited from​

BaseConnector.clearSchemaCache

close()​

close(): Promise<void>

Defined in: src/connectors/snowflake.ts:471

Close the Snowflake connection

Returns​

Promise<void>

Overrides​

BaseConnector.close

connectLegacy()​

connectLegacy(credentials): Promise<void>

Defined in: src/connectors/snowflake.ts:574

Legacy connect method for backward compatibility

Parameters​

credentials​

SourceCredentials

Returns​

Promise<void>

Deprecated​

Use constructor with ConnectorConfig instead

createDebugErrorFactory()​

protected createDebugErrorFactory(debugConfig?): DebugErrorFactory

Defined in: src/connectors/base-connector.ts:843

Helper method for subclasses to create debug-enabled error factory

Parameters​

debugConfig?​

DebugConfig

Returns​

DebugErrorFactory

Inherited from​

BaseConnector.createDebugErrorFactory

escapeIdentifier()​

protected escapeIdentifier(identifier): string

Defined in: src/connectors/base-connector.ts:475

Escape SQL identifiers to prevent injection

Parameters​

identifier​

string

Returns​

string

Inherited from​

BaseConnector.escapeIdentifier

executeParameterizedQuery()​

protected executeParameterizedQuery(sql, parameters?): Promise<QueryResultRow[]>

Defined in: src/connectors/snowflake.ts:169

Execute a parameterized SQL query using Snowflake bind variables

Parameters​

sql​

string

parameters?​

unknown[] = []

Returns​

Promise<QueryResultRow[]>

Overrides​

BaseConnector.executeParameterizedQuery

executeQuery()​

protected executeQuery(sql): Promise<QueryResultRow[]>

Defined in: src/connectors/snowflake.ts:233

Execute a validated SQL query with security measures

Parameters​

sql​

string

Returns​

Promise<QueryResultRow[]>

Overrides​

BaseConnector.executeQuery

executeWithTimeout()​

protected executeWithTimeout<T>(operation, timeoutMs): Promise<T>

Defined in: src/connectors/base-connector.ts:492

Execute function with timeout protection

Type Parameters​

T​

T

Parameters​

operation​

() => Promise<T>

timeoutMs​

number

Returns​

Promise<T>

Inherited from​

BaseConnector.executeWithTimeout

getAccount()​

getAccount(): string

Defined in: src/connectors/snowflake.ts:677

Get Snowflake account name

Returns​

string

getLastModified()​

getLastModified(table): Promise<Date | null>

Defined in: src/connectors/snowflake.ts:445

Get last modified timestamp for Snowflake tables

Parameters​

table​

string

Returns​

Promise<Date | null>

Overrides​

BaseConnector.getLastModified

getMaxTimestamp()​

getMaxTimestamp(table, column): Promise<Date | null>

Defined in: src/connectors/base-connector.ts:606

Get maximum timestamp value from a column

Parameters​

table​

string

column​

string

Returns​

Promise<Date | null>

Inherited from​

BaseConnector.getMaxTimestamp

getMinTimestamp()​

getMinTimestamp(table, column): Promise<Date | null>

Defined in: src/connectors/base-connector.ts:674

Get minimum timestamp value from a column

Parameters​

table​

string

column​

string

Returns​

Promise<Date | null>

Inherited from​

BaseConnector.getMinTimestamp

getQueryAnalyzerConfig()​

protected getQueryAnalyzerConfig(): QueryAnalyzerConfig

Defined in: src/connectors/base-connector.ts:799

Get query analyzer configuration

Returns​

QueryAnalyzerConfig

Inherited from​

BaseConnector.getQueryAnalyzerConfig

getRowCount()​

getRowCount(table): Promise<number>

Defined in: src/connectors/base-connector.ts:548

Get row count for a table using parameterized query

Parameters​

table​

string

Returns​

Promise<number>

Inherited from​

BaseConnector.getRowCount

getSchema()​

getSchema(): string

Defined in: src/connectors/snowflake.ts:705

Get current schema

Returns​

string

getSchemaCacheStats()​

protected getSchemaCacheStats(): CacheStats

Defined in: src/connectors/base-connector.ts:785

Get schema cache statistics

Returns​

CacheStats

Inherited from​

BaseConnector.getSchemaCacheStats

getTableMetadata()​

getTableMetadata(tableName, timestampColumn?): Promise<{ lastUpdate?: Date; rowCount: number; }>

Defined in: src/connectors/snowflake.ts:639

Legacy get table metadata method for backward compatibility

Parameters​

tableName​

string

timestampColumn?​

string = 'UPDATED_AT'

Returns​

Promise<{ lastUpdate?: Date; rowCount: number; }>

Deprecated​

Use getRowCount() and getMaxTimestamp() instead

getTableMetadataFresh()​

protected getTableMetadataFresh(tableName): Promise<TableMetadata | null>

Defined in: src/connectors/base-connector.ts:330

Get fresh table metadata (to be overridden by specific connectors)

Parameters​

tableName​

string

Returns​

Promise<TableMetadata | null>

Inherited from​

BaseConnector.getTableMetadataFresh

getTableSchema()​

getTableSchema(table): Promise<TableSchema>

Defined in: src/connectors/snowflake.ts:391

Get table schema information securely

Parameters​

table​

string

Returns​

Promise<TableSchema>

Overrides​

BaseConnector.getTableSchema

getWarehouse()​

getWarehouse(): string

Defined in: src/connectors/snowflake.ts:691

Get current warehouse

Returns​

string

listTables()​

listTables(): Promise<string[]>

Defined in: src/connectors/snowflake.ts:363

List all tables in the database/schema

Returns​

Promise<string[]>

Overrides​

BaseConnector.listTables

logDebugError()​

protected logDebugError(debugConfig, debugId, operation, context): void

Defined in: src/connectors/base-connector.ts:860

Helper method for subclasses to log debug errors

Parameters​

debugConfig​

DebugConfig | undefined

debugId​

string

operation​

string

context​

Record<string, unknown>

Returns​

void

Inherited from​

BaseConnector.logDebugError

logDebugInfo()​

protected logDebugInfo(debugConfig, debugId, operation, context): void

Defined in: src/connectors/base-connector.ts:851

Helper method for subclasses to log debug information

Parameters​

debugConfig​

DebugConfig | undefined

debugId​

string

operation​

string

context​

Record<string, unknown>

Returns​

void

Inherited from​

BaseConnector.logDebugInfo

logError()​

protected logError(operation, error, context?): void

Defined in: src/connectors/base-connector.ts:774

Helper method for specific connectors to log errors with consistent format

Parameters​

operation​

string

error​

Error

context?​

LogContext

Returns​

void

Inherited from​

BaseConnector.logError

logOperation()​

protected logOperation(operation, context): void

Defined in: src/connectors/base-connector.ts:763

Helper method for specific connectors to log operations with consistent format

Parameters​

operation​

string

context​

LogContext

Returns​

void

Inherited from​

BaseConnector.logOperation

query()​

query<T>(_sql): Promise<T[]>

Defined in: src/connectors/snowflake.ts:668

Legacy query method for backward compatibility

Type Parameters​

T​

T = unknown

Parameters​

_sql​

string

Returns​

Promise<T[]>

Deprecated​

Direct SQL queries are not allowed for security reasons

sanitizeError()​

protected sanitizeError(error): string

Defined in: src/connectors/base-connector.ts:509

Sanitize error messages to prevent information leakage

Parameters​

error​

unknown

Returns​

string

Inherited from​

BaseConnector.sanitizeError

setSchema()​

setSchema(schema): void

Defined in: src/connectors/snowflake.ts:698

Set schema

Parameters​

schema​

string

Returns​

void

setWarehouse()​

setWarehouse(warehouse): void

Defined in: src/connectors/snowflake.ts:684

Set Snowflake warehouse

Parameters​

warehouse​

string

Returns​

void

testConnection()​

testConnection(debugConfig?): Promise<boolean>

Defined in: src/connectors/snowflake.ts:240

Test database connection with security validation

Parameters​

debugConfig?​

DebugConfig

Returns​

Promise<boolean>

Overrides​

BaseConnector.testConnection

testConnectionLegacy()​

testConnectionLegacy(): Promise<{ error?: string; success: boolean; tableCount?: number; }>

Defined in: src/connectors/snowflake.ts:608

Legacy test connection method for backward compatibility

Returns​

Promise<{ error?: string; success: boolean; tableCount?: number; }>

Deprecated​

Use testConnection() instead

validateQuery()​

protected validateQuery(sql, tableNames?): Promise<void>

Defined in: src/connectors/base-connector.ts:153

Validate SQL query against security rules with enhanced analysis

Combines traditional pattern matching with advanced query complexity analysis

Parameters​

sql​

string

tableNames?​

string[] = []

Returns​

Promise<void>

Inherited from​

BaseConnector.validateQuery

validateResultSize()​

protected validateResultSize(results): void

Defined in: src/connectors/base-connector.ts:742

Validate that query results don't exceed max rows limit

Parameters​

results​

QueryResultRow[]

Returns​

void

Inherited from​

BaseConnector.validateResultSize