fix: Separate PostgreSQL ALTER statements in all migrations for compatibility v1.7.1

- Fixed PostgreSQL migration compatibility by separating comma-separated ALTER TABLE statements
- Resolved "cannot insert multiple commands into a prepared statement" error
- Updated migrations 003-011 to use individual ALTER TABLE statements for PostgreSQL
- Added IF NOT EXISTS to MySQL migration 011 to prevent duplicate column errors
- Fixed clippy warnings in encryption module with appropriate allow directives
- Bumped version to 1.7.1 with changelog entry

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <[email protected]>

Author: CodingAnarchy

CHANGELOG.md

@@ -5,6 +5,14 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [1.7.1] - 2025-07-04
+
+### Fixed
+- **🐛 PostgreSQL Migration Compatibility**
+  - Fixed PostgreSQL migration 011_add_encryption to separate multiple ALTER TABLE statements
+  - Resolved "cannot insert multiple commands into a prepared statement" error
+  - Each ADD COLUMN statement now executed individually for PostgreSQL compatibility
+
 ## [1.7.0] - 2025-07-03
 
 ### Added

Cargo.toml

@@ -9,7 +9,7 @@ members = [
 resolver = "2"
 
 [workspace.package]
-version = "1.7.0"
+version = "1.7.1"
 edition = "2024"
 license = "MIT"
 repository = "https://github.com/CodingAnarchy/hammerwork"
@@ -19,7 +19,7 @@ documentation = "https://docs.rs/hammerwork"
 rust-version = "1.86"
 
 [workspace.dependencies]
-hammerwork = { version = "1.7.0", path = "." }
+hammerwork = { version = "1.7.1", path = "." }
 tokio = { version = "1.0", features = ["full"] }
 sqlx = { version = "0.8", features = ["runtime-tokio-rustls", "chrono", "uuid", "json"] }
 chrono = { version = "0.4", features = ["serde"] }

src/encryption/engine.rs

@@ -644,6 +644,7 @@ impl EncryptionEngine {
     }
 
     #[cfg(feature = "encryption")]
+    #[allow(clippy::type_complexity)]
     fn encrypt_data(&self, data: &[u8]) -> Result<(Vec<u8>, Vec<u8>, Vec<u8>), EncryptionError> {
         let default_key_id = "default".to_string();
         let key_id = self.config.key_id.as_ref().unwrap_or(&default_key_id);
@@ -778,6 +779,7 @@ impl EncryptionEngine {
         hex::encode(hasher.finalize())
     }
 
+    #[allow(clippy::only_used_in_recursion)]
     fn scan_object_for_pii(
         &self,
         value: &Value,

src/encryption/key_manager.rs

@@ -284,11 +284,15 @@ pub struct KeyManagerStats {
 }
 
 /// Main key management system
+type KeyCacheEntry = (Vec<u8>, DateTime<Utc>); // (decrypted_material, cached_at)
+type KeyCache = Arc<Mutex<HashMap<String, KeyCacheEntry>>>;
+
 pub struct KeyManager<DB: Database> {
     config: KeyManagerConfig,
+    #[allow(dead_code)]
     pool: Pool<DB>,
     master_key: Arc<Mutex<Option<Vec<u8>>>>,
-    key_cache: Arc<Mutex<HashMap<String, (Vec<u8>, DateTime<Utc>)>>>, // key_id -> (decrypted_material, cached_at)
+    key_cache: KeyCache,
     stats: Arc<Mutex<KeyManagerStats>>,
 }
 
@@ -902,7 +906,6 @@ impl Default for KeyManagerStats {
 #[cfg(test)]
 mod tests {
     use super::*;
-    use crate::encryption::EncryptionAlgorithm;
 
     #[tokio::test]
     async fn test_key_manager_config_creation() {

src/migrations/003_add_timeouts.postgres.sql

@@ -3,5 +3,7 @@
 
 -- Add timeout fields
 ALTER TABLE hammerwork_jobs 
-ADD COLUMN IF NOT EXISTS timeout_seconds INTEGER,
+ADD COLUMN IF NOT EXISTS timeout_seconds INTEGER;
+
+ALTER TABLE hammerwork_jobs 
 ADD COLUMN IF NOT EXISTS timed_out_at TIMESTAMPTZ;

src/migrations/004_add_cron.postgres.sql

@@ -3,9 +3,15 @@
 
 -- Add cron scheduling fields
 ALTER TABLE hammerwork_jobs 
-ADD COLUMN IF NOT EXISTS cron_schedule VARCHAR(100),
-ADD COLUMN IF NOT EXISTS next_run_at TIMESTAMPTZ,
-ADD COLUMN IF NOT EXISTS recurring BOOLEAN NOT NULL DEFAULT FALSE,
+ADD COLUMN IF NOT EXISTS cron_schedule VARCHAR(100);
+
+ALTER TABLE hammerwork_jobs 
+ADD COLUMN IF NOT EXISTS next_run_at TIMESTAMPTZ;
+
+ALTER TABLE hammerwork_jobs 
+ADD COLUMN IF NOT EXISTS recurring BOOLEAN NOT NULL DEFAULT FALSE;
+
+ALTER TABLE hammerwork_jobs 
 ADD COLUMN IF NOT EXISTS timezone VARCHAR(50);
 
 -- Create indexes for cron job queries

src/migrations/006_add_result_storage.postgres.sql

@@ -3,8 +3,12 @@
 
 -- Add result storage fields
 ALTER TABLE hammerwork_jobs 
-ADD COLUMN IF NOT EXISTS result_data JSONB,
-ADD COLUMN IF NOT EXISTS result_stored_at TIMESTAMPTZ,
+ADD COLUMN IF NOT EXISTS result_data JSONB;
+
+ALTER TABLE hammerwork_jobs 
+ADD COLUMN IF NOT EXISTS result_stored_at TIMESTAMPTZ;
+
+ALTER TABLE hammerwork_jobs 
 ADD COLUMN IF NOT EXISTS result_expires_at TIMESTAMPTZ;
 
 -- Create index for result cleanup operations

src/migrations/007_add_dependencies.postgres.sql

@@ -3,10 +3,18 @@
 
 -- Add dependency tracking columns to hammerwork_jobs table
 ALTER TABLE hammerwork_jobs
-ADD COLUMN IF NOT EXISTS depends_on JSONB DEFAULT '[]'::jsonb,
-ADD COLUMN IF NOT EXISTS dependents JSONB DEFAULT '[]'::jsonb,
-ADD COLUMN IF NOT EXISTS dependency_status VARCHAR DEFAULT 'none',
-ADD COLUMN IF NOT EXISTS workflow_id UUID,
+ADD COLUMN IF NOT EXISTS depends_on JSONB DEFAULT '[]'::jsonb;
+
+ALTER TABLE hammerwork_jobs
+ADD COLUMN IF NOT EXISTS dependents JSONB DEFAULT '[]'::jsonb;
+
+ALTER TABLE hammerwork_jobs
+ADD COLUMN IF NOT EXISTS dependency_status VARCHAR DEFAULT 'none';
+
+ALTER TABLE hammerwork_jobs
+ADD COLUMN IF NOT EXISTS workflow_id UUID;
+
+ALTER TABLE hammerwork_jobs
 ADD COLUMN IF NOT EXISTS workflow_name VARCHAR;
 
 -- Add comments for clarity

src/migrations/008_add_result_config.postgres.sql

@@ -3,6 +3,10 @@
 
 -- Add result configuration fields
 ALTER TABLE hammerwork_jobs 
-ADD COLUMN IF NOT EXISTS result_storage_type VARCHAR(20) DEFAULT 'none',
-ADD COLUMN IF NOT EXISTS result_ttl_seconds BIGINT,
+ADD COLUMN IF NOT EXISTS result_storage_type VARCHAR(20) DEFAULT 'none';
+
+ALTER TABLE hammerwork_jobs 
+ADD COLUMN IF NOT EXISTS result_ttl_seconds BIGINT;
+
+ALTER TABLE hammerwork_jobs 
 ADD COLUMN IF NOT EXISTS result_max_size_bytes BIGINT;

src/migrations/009_add_tracing.postgres.sql

@@ -3,9 +3,15 @@
 
 -- Add tracing fields to support distributed tracing and correlation
 ALTER TABLE hammerwork_jobs 
-ADD COLUMN IF NOT EXISTS trace_id VARCHAR(128),
-ADD COLUMN IF NOT EXISTS correlation_id VARCHAR(128),
-ADD COLUMN IF NOT EXISTS parent_span_id VARCHAR(128),
+ADD COLUMN IF NOT EXISTS trace_id VARCHAR(128);
+
+ALTER TABLE hammerwork_jobs 
+ADD COLUMN IF NOT EXISTS correlation_id VARCHAR(128);
+
+ALTER TABLE hammerwork_jobs 
+ADD COLUMN IF NOT EXISTS parent_span_id VARCHAR(128);
+
+ALTER TABLE hammerwork_jobs 
 ADD COLUMN IF NOT EXISTS span_context TEXT;
 
 -- Index for trace ID lookups (finding all jobs in a trace)