add exception for the iceberg table inserts

Author: buremba

tests/integration/utils.py

@@ -112,7 +112,7 @@ def universql_connection(**properties) -> SnowflakeConnection:
         print(f"Reusing existing server running on port {server_cache[account]} for account {account}")
     else:
         from universql.main import snowflake
-        with socketserver.TCPServer(("localhost", 0), None) as s:
+        with socketserver.TCPServer(("127.0.0.1", 0), None) as s:
             free_port = s.server_address[1]
 
         def start_universql():

universql/warehouse/duckdb.py

@@ -351,6 +351,11 @@ def execute(self, ast: sqlglot.exp.Expression, catalog_executor: Executor, locat
                         return {destination_table: ast.expression}
             elif isinstance(ast, Insert):
                 table_type = self.catalog._get_table_location(destination_table)
+                # if table_type is None:
+                #     tt = catalog_executor.catalog.get_table_paths([destination_table])
+                #     table_type = tt[destination_table]
+                if table_type is None:
+                    raise QueryError(f"Duckdb can only INSERT INTO tables that is created within the session. {destination_table} is not created in this session")
                 if table_type == TableType.ICEBERG:
                     query = self._sync_and_transform_query(ast.expression, locations)
                     namespace = self.catalog.iceberg_catalog.properties.get('namespace')