feat(postgres/sqlite): update API to be fully async

Signed-off-by: Vaughn Dice <vdice@akamai.com>
Co-authored-by: Joel Dice <joel.dice@akamai.com>

Author: vdice

docs/v4/postgres.html

@@ -1,14 +1,12 @@
-from spin_sdk import http, postgres
+from spin_sdk import http, postgres, util
 from spin_sdk.http import Request, Response
-from spin_sdk.postgres import RowSet, DbValue
-
+from spin_sdk.postgres import Connection, RowSet, DbValue
 
 def format_value(db_value: DbValue) -> str:
     if hasattr(db_value, "value"):
         return str(db_value.value)
     return "NULL"
 
-
 def format_rowset(rowset: RowSet) -> str:
     lines = []
     col_names = [col.name for col in rowset.columns]
@@ -19,11 +17,12 @@ def format_rowset(rowset: RowSet) -> str:
         lines.append(" | ".join(values))
     return "\n".join(lines)
 
-
 class HttpHandler(http.Handler):
     async def handle_request(self, request: Request) -> Response:
-        with await postgres.open("user=postgres dbname=spin_dev host=localhost sslmode=disable password=password") as db:
-            rowset = db.query("SELECT * FROM test", [])
+        with await Connection.open("user=postgres dbname=spin_dev host=localhost sslmode=disable password=password") as db:
+            columns, stream, future = await db.query("SELECT * FROM test", [])
+            rows = await util.collect((stream, future))
+            rowset = RowSet(columns, list(rows))
             result = format_rowset(rowset)
 
         return Response(200, {"content-type": "text/plain"}, bytes(result, "utf-8"))

docs/v4/sqlite.html

@@ -1,13 +1,14 @@
-from spin_sdk import http, sqlite
+from spin_sdk import http, util
 from spin_sdk.http import Request, Response
-from spin_sdk.sqlite import Value_Integer
+from spin_sdk.sqlite import Connection, Value_Text, Value_Integer
 
 class HttpHandler(http.Handler):
     async def handle_request(self, request: Request) -> Response:
-        with await sqlite.open_default() as db:
-            result = db.execute("SELECT * FROM todos WHERE id > (?);", [Value_Integer(1)])
-            rows = result.rows
-        
+        with await Connection.open_default() as db:
+            await db.execute("INSERT INTO todos (description, due) VALUES (?, ?)", [Value_Text("Try out Spin SQLite"), Value_Text("Friday")])
+            columns, stream, future = await db.execute("SELECT * FROM todos WHERE id > (?);", [Value_Integer(1)])
+            rows = await util.collect((stream, future))
+
         return Response(
             200,
             {"content-type": "text/plain"},