Merge pull request #14 from theseus-rs/add-examples

chore: add examples

Author: brianheineman

Cargo.lock

@@ -1,6 +1,6 @@
 [workspace]
 default-members = ["postgresql_archive", "postgresql_embedded"]
-members = ["postgresql_archive", "postgresql_embedded"]
+members = ["examples/*", "postgresql_archive", "postgresql_embedded"]
 resolver = "2"
 
 [workspace.package]

Cargo.toml

@@ -0,0 +1,11 @@
+[package]
+edition.workspace = true
+name = "archive_async"
+publish = false
+license.workspace = true
+version.workspace = true
+
+[dependencies]
+postgresql_archive = { path = "../../postgresql_archive" }
+tempfile = { workspace = true }
+tokio = { workspace = true }

examples/archive_async/Cargo.toml

@@ -0,0 +1,24 @@
+use postgresql_archive::{extract, get_archive, Result, LATEST};
+
+#[tokio::main]
+async fn main() -> Result<()> {
+    let (archive_version, archive, _hash) = get_archive(&LATEST).await?;
+    let out_dir = tempfile::tempdir()?.into_path();
+    extract(&archive, &out_dir).await?;
+    println!(
+        "PostgreSQL {} extracted to {}",
+        archive_version,
+        out_dir.to_string_lossy()
+    );
+    Ok(())
+}
+
+#[cfg(test)]
+mod test {
+    use super::*;
+
+    #[test]
+    fn test_main() -> Result<()> {
+        main()
+    }
+}

examples/archive_async/src/main.rs

@@ -0,0 +1,10 @@
+[package]
+edition.workspace = true
+name = "archive_sync"
+publish = false
+license.workspace = true
+version.workspace = true
+
+[dependencies]
+postgresql_archive = { path = "../../postgresql_archive", features = ["blocking"] }
+tempfile = { workspace = true }

examples/archive_sync/Cargo.toml

@@ -0,0 +1,24 @@
+use postgresql_archive::blocking::{extract, get_archive};
+use postgresql_archive::{Result, LATEST};
+
+fn main() -> Result<()> {
+    let (archive_version, archive, _hash) = get_archive(&LATEST)?;
+    let out_dir = tempfile::tempdir()?.into_path();
+    extract(&archive, &out_dir)?;
+    println!(
+        "PostgreSQL {} extracted to {}",
+        archive_version,
+        out_dir.to_string_lossy()
+    );
+    Ok(())
+}
+
+#[cfg(test)]
+mod test {
+    use super::*;
+
+    #[test]
+    fn test_main() -> Result<()> {
+        main()
+    }
+}

examples/archive_sync/src/main.rs

@@ -0,0 +1,11 @@
+[package]
+edition.workspace = true
+name = "embedded_async"
+publish = false
+license.workspace = true
+version.workspace = true
+
+[dependencies]
+postgresql_embedded = { path = "../../postgresql_embedded" }
+tokio = { workspace = true }
+

examples/embedded_async/Cargo.toml

@@ -0,0 +1,25 @@
+use postgresql_embedded::{PostgreSQL, Result};
+
+#[tokio::main]
+async fn main() -> Result<()> {
+    let mut postgresql = PostgreSQL::default();
+    postgresql.setup().await?;
+    postgresql.start().await?;
+
+    let database_name = "test";
+    postgresql.create_database(database_name).await?;
+    postgresql.database_exists(database_name).await?;
+    postgresql.drop_database(database_name).await?;
+
+    postgresql.stop().await
+}
+
+#[cfg(test)]
+mod test {
+    use super::*;
+
+    #[test]
+    fn test_main() -> Result<()> {
+        main()
+    }
+}

examples/embedded_async/src/main.rs

@@ -0,0 +1,9 @@
+[package]
+edition.workspace = true
+name = "embedded_sync"
+publish = false
+license.workspace = true
+version.workspace = true
+
+[dependencies]
+postgresql_embedded = { path = "../../postgresql_embedded", features = ["blocking"] }

examples/embedded_sync/Cargo.toml

@@ -0,0 +1,25 @@
+use postgresql_embedded::blocking::PostgreSQL;
+use postgresql_embedded::Result;
+
+fn main() -> Result<()> {
+    let mut postgresql = PostgreSQL::default();
+    postgresql.setup()?;
+    postgresql.start()?;
+
+    let database_name = "test";
+    postgresql.create_database(database_name)?;
+    postgresql.database_exists(database_name)?;
+    postgresql.drop_database(database_name)?;
+
+    postgresql.stop()
+}
+
+#[cfg(test)]
+mod test {
+    use super::*;
+
+    #[test]
+    fn test_main() -> Result<()> {
+        main()
+    }
+}