Skip to main content

A Python module for simplifying interactions with PostgreSQL databases, with rich console output for better readability and debugging.

Project description

sonnixgres

A Python module for simplifying interactions with PostgreSQL databases, with rich console output for better readability and debugging.

Installation

Install sonnixgres using pip:

pip install sonnixgres

Usage

First, ensure that your PostgreSQL credentials are set as environment variables.

Create a .env file in your CWD with the following database enviornment variables:

DB_HOST=your_database_host
DB_DATABASE=your_database_name
DB_USER=your_database_username
DB_PASSWORD=your_database_password
DB_PORT=5432
DB_SCHEMA=your_database_schema
DB_TABLE=your_database_table

sonnixgres uses these variables to establish database connections.

from sonnixgres import create_connection, query_database, save_results_to_csv, create_and_populate_table, update_records, create_view
import pandas as pd

# Establish a database connection
connection = create_connection()

# Example usage of each function

Functions

create_connection()

Establishes a connection to the PostgreSQL database using credentials from environment variables.

query_database(connection, query, params=None, close_connection=True)

Executes a SQL query on the database and returns the result as a Pandas DataFrame.

  • connection: The database connection object.
  • query: SQL query string.
  • params: Optional parameters for the SQL query.
  • close_connection: Whether to close the database connection after executing the query.

save_results_to_csv(dataframe, filename)

Saves a Pandas DataFrame to a CSV file.

  • dataframe: The DataFrame to be saved.
  • filename: The name of the file where data will be saved.

create_table(connection, table_name)

Creates a new table in the database.

  • connection: The database connection object.
  • table_name: Name of the table to be created.

populate_table(connection, table_name, dataframe)

Populates a table with data from a DataFrame.

  • connection: The database connection object.
  • table_name: Name of the table to be populated.
  • dataframe: A pandas DataFrame whose data will be used to populate the table.

update_records(connection, update_query, params=None, close_connection=True)

Updates records in the database based on a given SQL query.

  • connection: The database connection object.
  • update_query: SQL update statement.
  • params: Parameters for the update query.
  • close_connection: Whether to close the database connection after executing the query.

create_view(connection, view_name, view_query, close_connection=True)

Creates a new view in the database.

  • connection: The database connection object.
  • view_name: Name of the view to be created.
  • view_query: SQL query string for creating the view.
  • close_connection: Whether to close the database connection after creating the view.

display_results_as_table(dataframe, max_column_width=50)

Displays a pandas DataFrame as a table in the console, with an internal row limit for display.

  • dataframe: The pandas DataFrame to be displayed.
  • max_column_width: Optional maximum width for each column in the table, defaulting to 50 characters.rows displayed.

Behavior

  • The function initializes a rich.console.Console object to handle the console output.

  • It sets a display limit of 50 rows. If the DataFrame has more than 50 rows, it only displays the first 50 rows and prints a message indicating this limit. This message also suggests using the 'save_results_to_csv' function to view all data.

  • The function creates a rich.table.Table object with headers (bold and magenta style) based on the DataFrame's columns.

  • Each column is added to the table with a specified max_column_width to control the display width.

  • Rows from the DataFrame (or limited DataFrame, if applicable) are added to the table.

  • Finally, the table is printed to the console using the Console object.

    License

BSD License

Contributions

Contributions are welcome. Please open an issue or submit a pull request with your improvements.

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
SOFTWARE.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

sonnixgres-0.1.5.tar.gz (4.6 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

sonnixgres-0.1.5-py3-none-any.whl (5.0 kB view details)

Uploaded Python 3

File details

Details for the file sonnixgres-0.1.5.tar.gz.

File metadata

  • Download URL: sonnixgres-0.1.5.tar.gz
  • Upload date:
  • Size: 4.6 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.7.1 CPython/3.12.0 Linux/6.5.0-14-generic

File hashes

Hashes for sonnixgres-0.1.5.tar.gz
Algorithm Hash digest
SHA256 fb69caad88308cbbbccfb78082d54e6307b97d6420425ad4b61d045b1231bd77
MD5 f5a32621d2bc8cdbeaece5faba2f7eaf
BLAKE2b-256 66159b53c9aaa2acc2d59c4f4ab2b085a61f3b16cedb3124e7e1b681757996cc

See more details on using hashes here.

File details

Details for the file sonnixgres-0.1.5-py3-none-any.whl.

File metadata

  • Download URL: sonnixgres-0.1.5-py3-none-any.whl
  • Upload date:
  • Size: 5.0 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.7.1 CPython/3.12.0 Linux/6.5.0-14-generic

File hashes

Hashes for sonnixgres-0.1.5-py3-none-any.whl
Algorithm Hash digest
SHA256 2c20156eaa036bdd8a660db7af02f04c8c7cbaecedb170f4fb353e0cf09447aa
MD5 86053afd3ceeb70ee3bbab60792b75a2
BLAKE2b-256 7612b5781aeb40fe895b3d5f0dd680465b79fa249019e1cf23a0bdb8843dfffe

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page