diff --git a/docs/integrations/snowflake_ingestion.md b/docs/integrations/snowflake_ingestion.md
index cb5871c0..a0ef1129 100644
--- a/docs/integrations/snowflake_ingestion.md
+++ b/docs/integrations/snowflake_ingestion.md
@@ -25,7 +25,7 @@ pip install semantica[db-all]
 
 This will install:
 - `snowflake-connector-python>=3.0.0`
-- `cryptography>=3.4.0` (for key-pair authentication)
+- `cryptography>=3.4.0` (required for key-pair authentication)
 
 ## Authentication Methods
 
@@ -57,8 +57,10 @@ export SNOWFLAKE_DATABASE="MYDB"
 export SNOWFLAKE_SCHEMA="PUBLIC"
 ```
 
+**Note:** For key-pair authentication, you must provide the `private_key_path` parameter directly in code. Environment variables are supported for account, user, warehouse, database, schema, role, authenticator, and token parameters.
+
 ```python
-# Now you can omit parameters - they'll be read from environment
+# Now you can omit supported parameters - they'll be read from environment
 ingestor = SnowflakeIngestor()
 ```
 
@@ -566,7 +568,3 @@ while True:
     process_chunk(chunk)
     offset += CHUNK_SIZE
 ```
-
-## API Reference
-
-See the [full API documentation](../reference/ingest/snowflake_ingestor.md) for detailed information on all classes and methods.
diff --git a/semantica/ingest/snowflake_ingestor.py b/semantica/ingest/snowflake_ingestor.py
index ad17de82..ce322d89 100644
--- a/semantica/ingest/snowflake_ingestor.py
+++ b/semantica/ingest/snowflake_ingestor.py
@@ -48,22 +48,12 @@ from ..utils.progress_tracker import get_progress_tracker
 try:
     import snowflake.connector
     from snowflake.connector import DictCursor, SnowflakeConnection
-    from snowflake.connector.errors import (
-        DatabaseError,
-        Error,
-        InterfaceError,
-        ProgrammingError,
-    )
 
     SNOWFLAKE_AVAILABLE = True
 except (ImportError, OSError):
     snowflake = None
     SnowflakeConnection = None
     DictCursor = None
-    DatabaseError = None
-    Error = None
-    InterfaceError = None
-    ProgrammingError = None
     SNOWFLAKE_AVAILABLE = False
 
 
@@ -265,7 +255,12 @@ class SnowflakeConnector:
             if self.authenticator:
                 conn_params["authenticator"] = self.authenticator
 
-                if self.authenticator == "oauth" and self.token:
+                if self.authenticator == "oauth":
+                    if not self.token:
+                        raise ValidationError(
+                            "OAuth token is required when using OAuth authentication. "
+                            "Provide via 'token' parameter or SNOWFLAKE_TOKEN environment variable."
+                        )
                     conn_params["token"] = self.token
             elif self.private_key:
                 # Key-pair authentication
@@ -426,6 +421,26 @@ class SnowflakeIngestor:
 
         self.logger.debug("Snowflake ingestor initialized")
 
+    def _validate_identifier(self, identifier: str, identifier_type: str = "identifier"):
+        """Validate SQL identifier to prevent malformed names.
+        
+        Args:
+            identifier: The identifier to validate
+            identifier_type: Type of identifier (for error messages)
+            
+        Raises:
+            ValidationError: If identifier contains potentially problematic characters
+        """
+        if not identifier:
+            return
+            
+        # Check for quotes or other potentially problematic characters
+        if '"' in identifier or "'" in identifier or ";" in identifier:
+            raise ValidationError(
+                f"Invalid {identifier_type}: '{identifier}'. "
+                f"Identifiers must not contain quotes or semicolons."
+            )
+
     def ingest_table(
         self,
         table_name: str,
@@ -449,9 +464,13 @@ class SnowflakeIngestor:
             schema: Schema name (uses default if not provided)
             limit: Maximum number of rows to retrieve (optional)
             offset: Row offset for pagination (optional)
-            where: WHERE clause for filtering (optional)
-            order_by: ORDER BY clause for sorting (optional)
+            where: WHERE clause for filtering (optional, must be trusted SQL)
+            order_by: ORDER BY clause for sorting (optional, must be trusted SQL)
             **options: Additional query options
+            
+        Warning:
+            The 'where' and 'order_by' parameters accept raw SQL and must be
+            trusted input from the caller. Do not pass untrusted user input.
 
         Returns:
             SnowflakeData: Ingested data object containing:
@@ -476,6 +495,11 @@ class SnowflakeIngestor:
         )
 
         try:
+            # Validate identifiers
+            self._validate_identifier(table_name, "table_name")
+            self._validate_identifier(database, "database")
+            self._validate_identifier(schema, "schema")
+            
             # Connect to Snowflake
             conn = self.connector.connect()
 
@@ -669,6 +693,18 @@ class SnowflakeIngestor:
         try:
             database = database or self.connector.database
             schema = schema or self.connector.schema
+            
+            # Validate required parameters
+            if not database:
+                raise ValidationError(
+                    "Database name is required for schema introspection. "
+                    "Provide via 'database' parameter or set default database in connector."
+                )
+            
+            # Validate identifiers
+            self._validate_identifier(table_name, "table_name")
+            self._validate_identifier(database, "database")
+            self._validate_identifier(schema, "schema")
 
             conn = self.connector.connect()
 
@@ -747,6 +783,17 @@ class SnowflakeIngestor:
         try:
             database = database or self.connector.database
             schema = schema or self.connector.schema
+            
+            # Validate required parameters
+            if not database:
+                raise ValidationError(
+                    "Database name is required for listing tables. "
+                    "Provide via 'database' parameter or set default database in connector."
+                )
+            
+            # Validate identifiers
+            self._validate_identifier(database, "database")
+            self._validate_identifier(schema, "schema")
 
             conn = self.connector.connect()
 
diff --git a/tests/test_snowflake_ingestor.py b/tests/test_snowflake_ingestor.py
index 2338f3fe..c4e59de5 100644
--- a/tests/test_snowflake_ingestor.py
+++ b/tests/test_snowflake_ingestor.py
@@ -14,7 +14,6 @@ import pytest
 # Test if snowflake-connector-python is available
 try:
     import snowflake.connector
-    from snowflake.connector.errors import DatabaseError, ProgrammingError
 
     SNOWFLAKE_AVAILABLE = True
 except ImportError: