sea-schema-sync

Author: tyt2y3

.github/workflows/rust.yml

@@ -111,9 +111,13 @@ jobs:
             ~/.cargo/git
             Cargo.lock
             target
+            sea-schema-sync/Cargo.lock
+            sea-schema-sync/target
           key: ${{ github.sha }}-${{ github.run_id }}-${{ runner.os }}-sqlite-${{ matrix.project }}
       - run: cargo build --manifest-path tests/${{ matrix.project }}/Cargo.toml
+      - run: cargo build --manifest-path sea-schema-sync/tests/${{ matrix.project }}/Cargo.toml
       - run: cargo test --manifest-path tests/${{ matrix.project }}/Cargo.toml --no-run
+      - run: cargo test --manifest-path sea-schema-sync/tests/${{ matrix.project }}/Cargo.toml --no-run
 
   mysql:
     name: MySQL
@@ -279,6 +283,10 @@ jobs:
             ~/.cargo/git
             Cargo.lock
             target
+            sea-schema-sync/Cargo.lock
+            sea-schema-sync/target
           key: ${{ github.sha }}-${{ github.run_id }}-${{ runner.os }}-sqlite-${{ matrix.project }}
       - run: cargo run --manifest-path tests/${{ matrix.project }}/Cargo.toml
+      - run: cargo run --manifest-path sea-schema-sync/tests/${{ matrix.project }}/Cargo.toml
       - run: cargo test --manifest-path tests/${{ matrix.project }}/Cargo.toml
+      - run: cargo test --manifest-path sea-schema-sync/tests/${{ matrix.project }}/Cargo.toml

build-tools/make-sync.sh

@@ -0,0 +1,34 @@
+rm -rf sea-schema-sync/src
+rm -rf sea-schema-sync/tests
+cp -r src sea-schema-sync
+mkdir -p sea-schema-sync/tests/writer
+mkdir -p sea-schema-sync/tests/live
+mkdir -p sea-schema-sync/tests/discovery
+cp -r tests/writer/sqlite sea-schema-sync/tests/writer
+cp -r tests/live/sqlite sea-schema-sync/tests/live
+cp -r tests/discovery/sqlite sea-schema-sync/tests/discovery
+cp -r tests/sakila sea-schema-sync/tests
+rm -rf sea-schema-sync/src/bin
+cd sea-schema-sync
+find src   -type f -name '*.rs' -exec sed -i '' 's/async //' {} +
+find tests -type f -name '*.rs' -exec sed -i '' 's/async //' {} +
+find src   -type f -name '*.rs' -exec sed -i '' 's/\.await//' {} +
+find tests -type f -name '*.rs' -exec sed -i '' 's/\.await//' {} +
+find src -type f -name '*.rs' -exec sed -i '' 's/not(feature = "sqlx-sqlite")/all(not(feature = "rusqlite"), not(feature = "sqlx-sqlite"))/' {} +
+find src   -type f -name '*.rs' -exec sed -i '' 's/#\[cfg(feature = "sqlx-sqlite")\]/#\[cfg(feature = "rusqlite")\]/' {} +
+find tests -type f -name 'Cargo.toml' -exec sed -i '' 's/sea-schema/sea-schema-sync/' {} +
+find tests -type f -name 'Cargo.toml' -exec sed -i '' 's/sqlx-sqlite/rusqlite/' {} +
+find tests -type f -name 'Cargo.toml' -exec sed -i '' 's/, "runtime-async-std-native-tls"//' {} +
+find tests -type f -name 'Cargo.toml' -exec sed -i '' '/sqlx/d' {} +
+find tests -type f -name 'Cargo.toml' -exec sed -i '' '/async-std/d' {} +
+find tests -type f -name '*.rs' -exec sed -i '' '/async_std/d' {} +
+find tests -type f -name 'Cargo.toml' -exec sed -i '' 's/, default-features = false//' {} +
+find src   -type f -name '*.rs' -exec sed -i '' 's/sqlx_types::/rusqlite_types::/' {} +
+find tests -type f -name '*.rs' -exec sed -i '' 's/sqlx_types::/rusqlite_types::/' {} +
+find src -type f -name '*.rs' -exec sed -i '' "s/SqlxRow/RusqliteRow/g" {} +
+find src -type f -name '*.rs' -exec sed -i '' 's/SqlxError/RusqliteError/g' {} +
+find src -type f -name '*.rs' -exec sed -i '' 's/SQLx/Rusqlite/' {} +
+find src -type f -name '*.rs' -exec sed -i '' 's/SqlitePool/RusqliteConnection/' {} +
+find src -type f -name '*.rs' -exec sed -i '' '/#\[async_trait::async_trait\]/d' {} +
+find src -type f -name '*.rs' -exec sed -i '' 's/ \+ Sync//' {} +
+cargo fmt

sea-schema-sync/Cargo.toml

@@ -0,0 +1,63 @@
+[workspace]
+members = [
+    ".",
+    "tests/discovery/sqlite",
+    "tests/live/sqlite",
+    "tests/writer/sqlite",
+]
+
+[package]
+name = "sea-schema-sync"
+version = "0.17.0-rc.15"
+authors = [ "Chris Tsang <tyt2y7@gmail.com>" ]
+edition = "2024"
+description = "🌿 SQL schema definition and discovery"
+license = "MIT OR Apache-2.0"
+documentation = "https://docs.rs/sea-schema"
+repository = "https://github.com/SeaQL/sea-schema"
+categories = ["database"]
+keywords = ["database", "sql", "mysql", "postgres"]
+rust-version = "1.85.0"
+
+[package.metadata.docs.rs]
+features = ["default"]
+rustdoc-args = ["--cfg", "docsrs"]
+
+[lib]
+name = "sea_schema"
+path = "src/lib.rs"
+
+[dependencies]
+async-trait = { version = "0.1", default-features = false }
+sea-schema-derive = { version = "0.3.0", path = "../sea-schema-derive", default-features = false }
+sea-query = { version = "1.0.0-rc.18", default-features = false, features = ["derive"] }
+sea-query-rusqlite = { version = "0.8.0-rc.11", optional = true }
+serde = { version = "1", default-features = false, optional = true, features = ["derive"] }
+log = { version = "0.4", default-features = false, optional = true }
+
+[features]
+default = ["sync", "sqlite", "discovery", "writer", "probe"]
+debug-print = ["log"]
+mysql = ["sea-query/backend-mysql"]
+postgres = ["sea-query/backend-postgres"]
+postgres-vector = ["sea-query/postgres-vector"]
+sqlite = ["sea-query/backend-sqlite"]
+def = []
+discovery = ["parser"]
+parser = ["query"]
+query = ["def"]
+writer = ["def"]
+planetscale = []
+sync = []
+probe = ["query"]
+sqlx-dep = []
+sqlx-mysql = []
+sqlx-postgres = []
+sqlx-sqlite = []
+rusqlite = ["sea-query-rusqlite"]
+with-serde = ["serde"]
+
+# This allows us to develop using a local version of sea-query
+[patch.crates-io]
+# sea-query = { path = "../sea-query" }
+# sea-query = { git = "https://github.com/SeaQL/sea-query", branch = "master" }

sea-schema-sync/src/connection.rs

@@ -0,0 +1,8 @@
+use crate::rusqlite_types::{RusqliteError, RusqliteRow};
+use sea_query::SelectStatement;
+
+pub trait Connection: Sized {
+    fn query_all(&self, select: SelectStatement) -> Result<Vec<RusqliteRow>, RusqliteError>;
+
+    fn query_all_raw(&self, sql: String) -> Result<Vec<RusqliteRow>, RusqliteError>;
+}

sea-schema-sync/src/lib.rs

@@ -0,0 +1,34 @@
+#![cfg_attr(docsrs, feature(doc_cfg))]
+
+#[cfg(feature = "mysql")]
+#[cfg_attr(docsrs, doc(cfg(feature = "mysql")))]
+pub mod mysql;
+
+#[cfg(feature = "postgres")]
+#[cfg_attr(docsrs, doc(cfg(feature = "postgres")))]
+pub mod postgres;
+
+#[cfg(feature = "sqlite")]
+#[cfg_attr(docsrs, doc(cfg(feature = "sqlite")))]
+pub mod sqlite;
+
+pub use sea_query;
+
+pub(crate) mod parser;
+
+#[cfg(not(feature = "sync"))]
+pub mod sqlx_types;
+
+#[cfg(feature = "sync")]
+pub mod rusqlite_types;
+
+pub(crate) mod util;
+
+pub mod name;
+pub use name::*;
+
+mod connection;
+pub use connection::*;
+
+#[cfg(feature = "probe")]
+pub mod probe;