o KDi@s`dZddlmZddlmZddlTddlmZddlm Z Gdd d eZ d d e fDZ d S) z| This file contains system readonly models that can be got from the database https://clickhouse.tech/docs/en/system_tables/ )unicode_literals)Database)*)Model) comma_joinc@seZdZdZehdZdZdZeZ eZ eZ eZ eZ eZeZeZeZeZeZeddZ dddZdd d Zdd d Zdd dZdddZdddZedddZ edddZ!dS) SystemPartz Contains information about parts of a table in the MergeTree family. This model operates only fields, described in the reference. Other fields are ignored. https://clickhouse.tech/docs/en/system_tables/system.parts/ >DROPFETCHATTACHDETACHFREEZETcCsdS)Nparts)clsrrZ/var/www/Datamplify/venv/lib/python3.10/site-packages/infi/clickhouse_orm/system_models.py table_name4szSystemPart.table_nameNcCsf|}||jvsJdt|jd|jj|j||jf}|dur(|d|7}|jj||dddS)aA Performs some operation over partition - `db`: Database object to execute operation on - `operation`: Operation to execute from SystemPart.OPERATIONS set - `settings`: Settings for executing request to ClickHouse over db.raw() method Returns: Operation execution result zoperation must be in [%s]z%ALTER TABLE `%s`.`%s` %s PARTITION %sNz FROM %sF)settingsstream)upper OPERATIONSr _databasedb_nametable partitionraw)self operationr from_partsqlrrr_partition_operation_sql<s   z#SystemPart._partition_operation_sqlcC|jd|dS)z Move a partition to the 'detached' directory and forget it. - `settings`: Settings for executing request to ClickHouse over db.raw() method Returns: SQL Query r rr rrrrrdetachNzSystemPart.detachcCr!)z Delete a partition - `settings`: Settings for executing request to ClickHouse over db.raw() method Returns: SQL Query r r"r#r$rrrdropXr&zSystemPart.dropcCr!)z Add a new part or partition from the 'detached' directory to the table. - `settings`: Settings for executing request to ClickHouse over db.raw() method Returns: SQL Query r r"r#r$rrrattachbr&zSystemPart.attachcCr!)z Create a backup of a partition. - `settings`: Settings for executing request to ClickHouse over db.raw() method Returns: SQL Query r r"r#r$rrrfreezelr&zSystemPart.freezecCs|jd||dS)z Download a partition from another server. - `zookeeper_path`: Path in zookeeper to fetch from - `settings`: Settings for executing request to ClickHouse over db.raw() method Returns: SQL Query r )rrr#)rzookeeper_pathrrrrfetchvs zSystemPart.fetchcCs^t|ts Jdt|tsJd|r|d7}d|}|jd||||jf|dS)z Get all data from system.parts table - `database`: A database object to fetch data from. - `conditions`: WHERE clause conditions. Database condition is added automatically Returns: A list of SystemPart objects z1database must be database.Database class instancezconditions must be a stringz AND,z1SELECT %s FROM `system`.%s WHERE %s database='%s') model_class) isinstancerstrjoinfieldsselectrr)rdatabase conditions field_namesrrrgets zSystemPart.getcCs"|r|d7}|d7}tj||dS)a Gets active data from system.parts table - `database`: A database object to fetch data from. - `conditions`: WHERE clause conditions. Database and active conditions are added automatically Returns: A list of SystemPart objects z AND active)r5)rr7)rr4r5rrr get_actives zSystemPart.get_active)NN)N)r,)"__name__ __module__ __qualname____doc__ frozensetr _readonly_system StringFieldr4renginername UInt8Fieldr8 UInt64Fieldmarksbytes DateTimeFieldmodification_time remove_time UInt32Fieldrefcount classmethodrr r%r'r(r)r+r7r9rrrrr s:      rcCsg|]}|jqSr)r:).0crrr srPN) r= __future__rr4rr2modelsrutilsrr__all__rrrrs