catch error in multi-query batches

.gitignore

@@ -96,4 +96,7 @@ env/
 venv/
 ENV/
 env.bak/
-venv.bak/
+venv.bak/
+
+# example credential information
+cxn.json

cursor_batch_example.ipynb

@@ -0,0 +1,35 @@
+{
+ "cells": [
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "id": "02af0c28-3445-49f6-a97c-b82f28920a39",
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "i"
+   ]
+  }
+ ],
+ "metadata": {
+  "kernelspec": {
+   "display_name": "Python 3",
+   "language": "python",
+   "name": "python3"
+  },
+  "language_info": {
+   "codemirror_mode": {
+    "name": "ipython",
+    "version": 3
+   },
+   "file_extension": ".py",
+   "mimetype": "text/x-python",
+   "name": "python",
+   "nbconvert_exporter": "python",
+   "pygments_lexer": "ipython3",
+   "version": "3.9.5"
+  }
+ },
+ "nbformat": 4,
+ "nbformat_minor": 5
+}

dbt/adapters/sqlserver/connections.py

@@ -347,7 +347,7 @@ def add_query(self, sql, auto_begin=True, bindings=None, abridge_sql_log=False):
 
             # pyodbc does not handle a None type binding!
             if bindings is None:
-                cursor.execute(sql)
+                cursor2 = cursor.execute(sql)
             else:
                 cursor.execute(sql, bindings)
 
@@ -356,7 +356,7 @@ def add_query(self, sql, auto_begin=True, bindings=None, abridge_sql_log=False):
                     self.get_response(cursor), (time.time() - pre)
                 )
             )
-
+            
             return connection, cursor
 
     @classmethod
@@ -383,9 +383,16 @@ def get_response(cls, cursor) -> AdapterResponse:
 
     def execute(self, sql, auto_begin=True, fetch=False):
         _, cursor = self.add_query(sql, auto_begin)
-        status = self.get_response(cursor)
+        response = self.get_response(cursor)
         if fetch:
+            # Get the result of the first non-empty result set (if any)
+            while cursor.description is None:
+                if not cursor.nextset(): 
+                    break
             table = self.get_result_from_cursor(cursor)
         else:
             table = dbt.clients.agate_helper.empty_table()
-        return status, table
+        # Step through all result sets so we process all errors
+        while cursor.nextset(): 
+            pass
+        return response, table