Update database/db_connector.py

database/db_connector.py

@@ -36,6 +36,26 @@ def get_connection():
     except Exception as e:
         print(f"خطأ في الاتصال بقاعدة البيانات: {e}")
         
-        # إذا فشل الاتصال، استخدم اتصال قاعدة بيانات وهمي
-        from utils.helpers import get_connection as get_mock_connection
-        return get_mock_connection()
+        # إذا فشل الاتصال، استخدم اتصال قاعدة بيانات SQLite محلية
+        import os
+        import sqlite3
+        
+        # إنشاء مجلد البيانات إذا لم يكن موجوداً
+        data_dir = os.path.join(os.path.dirname(os.path.dirname(__file__)), 'data')
+        os.makedirs(data_dir, exist_ok=True)
+        
+        # إنشاء اتصال قاعدة بيانات SQLite محلية
+        db_path = os.path.join(data_dir, 'local_db.sqlite')
+        conn = sqlite3.connect(db_path)
+        
+        # إعادة محاكاة سلوك اتصال PostgreSQL
+        conn.execute = conn.cursor().execute
+        
+        # إضافة وظيفة وهمية للاقتطاع (commit) والإغلاق
+        original_close = conn.close
+        def enhanced_close():
+            conn.commit()
+            original_close()
+        conn.close = enhanced_close
+        
+        return conn