{"library":"nsj-multi-database-lib","title":"NSJ Multi-Database Library","description":"The NSJ Multi-Database Library is a Python module designed to enable applications, particularly those built with FastAPI, to efficiently manage and interact with multiple database connections within the same application. It provides an abstraction layer for various database engines (e.g., PostgreSQL, Oracle, SQL Server), simplifying connection pooling, session management, and transactional data access objects (DAOs). The current version is 2.1.0, and the library maintains a steady release cadence for improvements and bug fixes, supporting Python versions 3.6 up to 3.9.","language":"python","status":"active","last_verified":"Fri Apr 17","install":{"commands":["pip install nsj-multi-database-lib"],"cli":null},"imports":["from nsj_multi_database_lib.connection.connection_pool import ConnectionPool","from nsj_multi_database_lib.connection.database_manager import DatabaseManager","from nsj_multi_database_lib.dao.dao_base import DaoBase","from nsj_multi_database_lib.dao.transactional_dao import TransactionalDao"],"auth":{"required":false,"env_vars":[]},"quickstart":{"code":"import os\nfrom nsj_multi_database_lib.connection.connection_pool import ConnectionPool\nfrom nsj_multi_database_lib.connection.database_manager import DatabaseManager\nfrom sqlalchemy import text\n\n# Mock Database setup for example (using SQLite in-memory)\nDB_NAME_DEFAULT = \"default_db\"\nDB_NAME_AUDIT = \"audit_db\"\n\n# NOTE: In a real application, connection_string would use actual DB credentials.\n# Example for PostgreSQL: \"postgresql://user:password@host:port/database\"\nDATABASE_CONFIGS = {\n    DB_NAME_DEFAULT: {\n        \"engine\": \"sqlite\",\n        \"db\": \":memory:\",\n        \"connection_string\": \"sqlite:///:memory:\",\n        \"schema\": None,\n        \"label\": DB_NAME_DEFAULT\n    },\n    DB_NAME_AUDIT: {\n        \"engine\": \"sqlite\",\n        \"db\": \":memory:\",\n        \"connection_string\": \"sqlite:///:memory:\",\n        \"schema\": None,\n        \"label\": DB_NAME_AUDIT\n    }\n}\n\n# 1. Initialize the connection pool with your database configurations\nConnectionPool.configure(DATABASE_CONFIGS)\n\ntry:\n    print(\"\\n--- Using Default Database ---\")\n    # 2. Get a database session using the context manager\n    with DatabaseManager.get_session(DB_NAME_DEFAULT) as session:\n        # Example operations with SQLAlchemy 1.x compatible syntax\n        session.execute(text(\"CREATE TABLE users (id INTEGER PRIMARY KEY, name TEXT)\"))\n        session.execute(text(\"INSERT INTO users (id, name) VALUES (1, 'Alice')\"))\n        session.execute(text(\"INSERT INTO users (id, name) VALUES (2, 'Bob')\"))\n        session.commit()\n        result = session.execute(text(\"SELECT * FROM users\")).fetchall()\n        print(f\"Retrieved from {DB_NAME_DEFAULT}: {result}\")\n\n    print(\"\\n--- Using Audit Database ---\")\n    with DatabaseManager.get_session(DB_NAME_AUDIT) as session:\n        session.execute(text(\"CREATE TABLE logs (id INTEGER PRIMARY KEY, event TEXT)\"))\n        session.execute(text(\"INSERT INTO logs (id, event) VALUES (1, 'User Alice created')\"))\n        session.commit()\n        result = session.execute(text(\"SELECT * FROM logs\")).fetchall()\n        print(f\"Retrieved from {DB_NAME_AUDIT}: {result}\")\n\nexcept Exception as e:\n    print(f\"An error occurred: {e}\")\nfinally:\n    # 3. Always close connections when done to release resources\n    ConnectionPool.close_all_connections()\n    print(\"\\nAll database connections closed.\")","lang":"python","description":"This quickstart demonstrates how to configure multiple in-memory SQLite databases using `nsj-multi-database-lib`. It shows how to initialize the `ConnectionPool` with a dictionary of database configurations, obtain sessions for different databases using `DatabaseManager.get_session()`, and perform basic SQL operations within a transactional context. Remember to replace the SQLite in-memory setup with your actual database connection strings and credentials.","tag":null,"tag_description":null,"last_tested":null,"results":[]},"compatibility":null}