Cloud DB Connector

This package provides a flexible and secure way to establish connections to various database types, including AWS RDS, Azure SQL, Google Cloud MySQL, and local databases. It includes factory functions and connection classes, as well as helper functions to execute queries and handle database interactions with retry logic.

Package Structure

- db_manager.py        # Factory function to create DB connection based on the service type
- db_connection.py     # Interface to get DB connection
- aws_db.py            # AWS RDS MySQL connection class
- azure_db.py          # Azure SQL Database connection class
- gcp_db.py            # Google Cloud MySQL connection class
- local_db.py          # Local MySQL database connection class
- rds_execute.py       # Utility to execute SQL queries on the databases

Installation

Ensure all necessary dependencies are installed:

pip install clouddatabridge

Additional Requirements for Azure SQL Database

To connect to an Azure SQL Database, an ODBC driver is required. Install the appropriate driver for your operating system:

macOS: Microsoft ODBC Driver for SQL Server on macOS
Linux: Microsoft ODBC Driver for SQL Server on Linux
Windows: Microsoft ODBC Driver for SQL Server on Windows

Follow the official installation instructions on the linked pages for your OS.

Usage

Setting Up a Database Connection

The db_manager.py file contains a factory function, create_db_connection, to create a connection based on the chosen service (local, aws, azure, gcp). You can also use the get_db_connection function in db_connection.py for easier configuration management.

from clouddatabridge.rds_execute import rds_execute

query = "SELECT * FROM person"

local_result = rds_execute(
    service="gcp",
    query=query,
    is_proxy=False,
    host="your-azure-sql-hostname",
    user="your-username",
    password="your-password",
    database="your-database",
    port=3306
    )

print(local_result)

Components Overview

db_manager.py

This module provides a factory function create_db_connection that creates the appropriate database connection object based on the specified service parameter.

Supported Services: local, aws, azure, gcp
Parameters: is_proxy, host, user, password, database, port, region (for AWS)

db_connection.py

Contains the get_db_connection function, which uses create_db_connection to return the correct connection object and handles errors gracefully.

Database-Specific Connection Classes

Each database type has its own connection class with retry logic and automatic connection handling.

AWSRDSConnection (aws_db.py)

Manages a connection to an AWS RDS MySQL database and generates an authentication token for secure access.
AzureSQLConnection (azure_db.py)

Handles connections to Azure SQL Database, supporting automatic retries. Ensure you install the ODBC driver to connect successfully.
GCPMySQLConnection (gcp_db.py)

Supports MySQL connections on Google Cloud with similar retry and connection management logic.
LocalDBConnection (local_db.py)

Provides connections to a local MySQL database.

rds_execute.py

Provides a high-level rds_execute function that executes queries across supported databases. It detects the SQL operation type and handles transactions for INSERT, UPDATE, and DELETE operations, committing changes automatically.

Operations Supported: SELECT, INSERT, UPDATE, DELETE
Parameters:
- service: Type of database service (local, aws, azure, gcp)
- query: SQL query to execute
- params: Parameters for parameterized query (tuple or list of tuples for batch execution)

Error Handling

Connection Errors: Retries connection attempts with configurable retry delays for increased robustness.
Operational Errors: Prints specific messages on failure and re-raises the error if maximum retries are exceeded.

License

This package is licensed under the MIT License.

Metadata

Release files for clouddatabridge 0.1.41

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for clouddatabridge 0.1.41
File	Size	Uploaded
clouddatabridge-0.1.41.tar.gz	11.7 kB	Aug 25, 2025	Details

Built distribution (wheel)

Table of built distributions (wheels) for clouddatabridge 0.1.41
File	Interpreter	ABI	Platform	Reset
clouddatabridge-0.1.41-py3-none-any.whl 13.9 kB Aug 25, 2025	Python 3	none	any	Details

Total release size: 25.6 kB

Release files / clouddatabridge-0.1.41.tar.gz

Download URL	clouddatabridge-0.1.41.tar.gz
Size	11.7 kB
Tags	Source
SHA-256 checksum How to use checksums	`29f16c3cf2613a4574bd905c71234a53d1672aca6a57178b8d78b94804791cc6`
BLAKE2b-256 checksum How to use checksums	`950b0fedfd402869e47f410bbfea7d4a619765510386009b9dbfd623901e616d`
Upload date	Aug 25, 2025
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/6.1.0 CPython/3.9.13`

Release files / clouddatabridge-0.1.41-py3-none-any.whl

Download URL	clouddatabridge-0.1.41-py3-none-any.whl
Size	13.9 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`38ecb74bf029cf7559907824e95f5ce96c1ba8f6b4feec4b8575649eb8e0cb8c`
BLAKE2b-256 checksum How to use checksums	`55e639da45b0c8de01def7d5645fe56dfdd614b9e092b953426718ba1e8d178e`
Upload date	Aug 25, 2025
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/6.1.0 CPython/3.9.13`