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.