database

database module

class database.DatabaseConnection(dbq: str, db_type: DatabaseType)

Bases: object

close()

get_session() → Session

class database.DatabaseType(value)

Bases: StrEnum

CLIENT = 'Client'

HIDRO = 'Hidro'

database.add_token(client_id, token, expires)

database.count_client(model: Base)

database.count_hidro(model: Base)

database.count_job(job_config: JobConfig, status=None)

database.execute_sql_file(db: DatabaseConnection, sql_file_path: str, parameters=None) → None

database.get_credentials() → Credentials

database.get_discharge_period()

database.get_jobs_yield(job_config, status)

database.get_rain_period()

database.get_sediments_period()

database.get_series_jobs(job_config, status)

database.get_stage_period()

database.get_states() → State

database.get_station_jobs(status) → StationJobs

database.get_token_model() → Token

database.get_water_period()

database.init_db(db: DatabaseConnection) → None

database.insert_hidro(collection: List[Base], has_id=False) → None

database.insert_jobs(jobs: List[HidroJob]) → None

database.update_jobs(jobs: List[HidroJob], job_config: JobConfig) → None

database.update_token(RegistroID, new_token, new_expires)