feat: postgres append, schema get & edit

aljazerzen · Feb 19, 2024 · d73a610 · d73a610
1 parent f7865a4
commit d73a610
Show file tree

Hide file tree

Showing 17 changed files with 708 additions and 184 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/README.md b/README.md
@@ -36,9 +36,9 @@ Similar to [ADBC](https://arrow.apache.org/docs/format/ADBC.html), but written i
 | Streaming       |                      |                  | x                    |
 | Temporal types  |                      | x                |                      |
 | Container types |                      | x                |                      |
-| Schema get      | x                    | x                |                      |
-| Schema edit     | x                    | x                |                      |
-| Append          | x                    | x                |                      |
+| Schema get      | x                    | x                | x                    |
+| Schema edit     | x                    | x                | x                    |
+| Append          | x                    | x                | x                    |
 
 None of the sources are enabled by default, use features to enable them.
 

diff --git a/connector_arrow/Cargo.toml b/connector_arrow/Cargo.toml
@@ -31,13 +31,20 @@ urlencoding = { version = "2.1", optional = true }
 uuid = { version = "0.8", optional = true }
 fallible-streaming-iterator = { version = "0.1", optional = true }
 csv = { version = "1", optional = true }
+bytes = { version = "1", optional = true }
+byteorder = { version = "1", optional = true }
 
 [dependencies.postgres]
 version = "0.19"
 default-features = false
 optional = true
 features = ["with-chrono-0_4", "with-uuid-0_8", "with-serde_json-1"]
 
+[dependencies.postgres-protocol]
+version = "0.6.6"
+default-features = false
+optional = true
+
 [dependencies.rusqlite]
 version = "0.30.0"
 default-features = false
@@ -50,20 +57,23 @@ optional = true
 
 [dev-dependencies]
 env_logger = "0.11"
-arrow = { version = "49", features = ["prettyprint"] }
-parquet = { version = "49" }
+arrow = { version = "49", features = ["prettyprint"], default-features = false }
+parquet = { version = "49", features = ["arrow"], default-features = false }
 insta = { version = "1.34.0" }
 similar-asserts = { version = "1.5.0" }
 
 [features]
 all = ["src_sqlite", "src_duckdb", "src_postgres"]
 src_postgres = [
     "postgres",
+    "postgres-protocol",
     "csv",
     "hex",
     "uuid",
     "rust_decimal",
     "rust_decimal_macros",
+    "bytes",
+    "byteorder"
 ]
 src_sqlite = ["rusqlite", "fallible-streaming-iterator", "urlencoding"]
 src_duckdb = [