Bump SQLx dependency to 0.3 and fix build errors.

Author: lseelenbinder

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "tile_sorcerer"
-version = "0.1.0"
+version = "0.2.0"
 authors = ["Ian Wagner <ian@stadiamaps.com>", "Luke Seelenbinder <luke@stadiamaps.com>"]
 license = "BSD-3-Clause"
 repository = "https://github.com/stadiamaps/tile_sorcerer"
@@ -22,7 +22,7 @@ version = "~1.0"
 features = ["derive"]
 
 [dependencies.sqlx]
-version = "~0.2.5"  # Minimum version 0.2.5, as earlier ones had a critical connection leaking issue
+version = "~0.3"
 default-features = false
 features = ["runtime-tokio", "postgres", "chrono", "uuid"]
 

src/tm2.rs

@@ -10,9 +10,7 @@ use serde::Deserialize;
 // TODO: remove once async fn in traits become stable
 use async_trait::async_trait;
 
-use sqlx::{query, PgPool, Row};
-
-use futures::stream::StreamExt;
+use sqlx::{query, PgPool, Row, cursor::Cursor};
 
 /// A TileMill (.tm2source) data structure.
 ///
@@ -147,14 +145,9 @@ impl TileSource for TM2Source {
 
         let mut raw_tile: Vec<u8> = Vec::new();
         let mut stream = query.fetch(&mut conn);
-        while let Some(result) = stream.next().await {
-            match result {
-                Ok(row) => {
-                    let layer: Vec<u8> = row.get(0);
-                    raw_tile.extend_from_slice(&layer);
-                }
-                Err(e) => return Err(e),
-            }
+        while let Some(row) = stream.next().await? {
+            let layer: Vec<u8> = row.get(0);
+            raw_tile.extend_from_slice(&layer);
         }
 
         Ok(raw_tile)