brokenspoke_analyzer.core.database.dbcore package¶

Define functions used to manipulate database data.

brokenspoke_analyzer.core.database.dbcore.configure_db(engine, cores, memory_mb, pguser)¶

Configure the database.

Configures the database with the appropriate settings, extensions and schemas.

This function is idempotent.

brokenspoke_analyzer.core.database.dbcore.configure_docker_db(engine)¶

Configure a database running in Docker.

brokenspoke_analyzer.core.database.dbcore.configure_extensions(engine)¶

Configure the required extensions.

brokenspoke_analyzer.core.database.dbcore.configure_schemas(engine, pguser)¶

Configure the schemas.

brokenspoke_analyzer.core.database.dbcore.configure_system(engine, cores, memory_mb)¶

Configure the system parameters.

This requires elevated permissions.

brokenspoke_analyzer.core.database.dbcore.create_psycopg_engine(database_url)¶

Create a SQLAlchemy engine with the psycopg3 driver.

brokenspoke_analyzer.core.database.dbcore.execute_query(engine, query)¶

Execute a query and commit it.

brokenspoke_analyzer.core.database.dbcore.execute_sql_file(engine, sqlfile)¶

Execute a SQL file.

brokenspoke_analyzer.core.database.dbcore.execute_with_autocommit(engine, statements)¶

Execute a series of statements with autocommit.

brokenspoke_analyzer.core.database.dbcore.export_to_csv(engine, csvfile, table)¶

Dump the table content into a CSV file.

brokenspoke_analyzer.core.database.dbcore.import_csv_file_with_header(engine, csvfile, table)¶

Import a CSV file into a table.

For some unknown and annoying reason, importing CSV data with a cursor does not work. Therefore we used psql as fallback.

brokenspoke_analyzer.core.database.dbcore.load_csv_file(engine, sqlfile, csvfile, table)¶

Create a table and load the data from the CSV file.