o
    Eh#                     @  sJ  d dl mZ d dlZd dlZd dlmZ d dlmZ d dlm	Z	m
Z
 d dlmZ G dd dZG dd	 d	eZG d
d deZG dd deZG dd deZG dd deZejdd Zejdd ZeZeZeZeZegZeegZejeejjejj e ddgdgZ!g eee!Z"dgZ#ddgZ$dgZ%g e$e#e%Z&eje"e&ddd Z'ejee$dd d! Z(ejee#dd"d# Z)eje!e%dd$d% Z*d&d' Z+eje+ d( e+ d) dd*d+ Z,g d,Z-g d-Z.d.d/gZ/d0d1 e.D Z0eje-d2d3d4 Z1eje0d2d5d6 Z2ejg d7d2d8d9 Z3ejd:d; Z4ejd<d= Z5dS )>    )annotationsN)HAS_PYARROW)VERSIONS)read_csv
read_tablec                   @  sd   e Zd ZU dZded< dZg Zded< dd Zd	d
 ZddddddZ	dd Z
dddddZdS )
BaseParserNz
str | NoneengineTzlist[str | None]float_precision_choicesc                 C  s    |  }|| j| jd |S )N)r   
low_memory)copyupdater   r
   )selfkwargs r   ?lib/python3.10/site-packages/pandas/tests/io/parser/conftest.pyupdate_kwargs   s   zBaseParser.update_kwargsc                 O     |  |}t|i |S N)r   r   r   argsr   r   r   r   r         
zBaseParser.read_csv)raise_on_extra_warningscheck_stacklevel	warn_typetype[Warning]warn_msgstrr   boolc                O  sN   |  |}tj||||d t|i |W  d    S 1 s w   Y  d S )N)matchr   r   )r   tmassert_produces_warningr   )r   r   r   r   r   r   r   r   r   r   read_csv_check_warnings    s   
$z"BaseParser.read_csv_check_warningsc                 O  r   r   )r   r   r   r   r   r   r   5   r   zBaseParser.read_table)r   c                O  sL   |  |}tj|||d t|i |W  d    S 1 sw   Y  d S )N)r   r   )r   r   r    r   )r   r   r   r   r   r   r   r   r   read_table_check_warnings9   s   
$z$BaseParser.read_table_check_warnings)r   r   r   r   r   r   )r   r   r   r   )__name__
__module____qualname__r   __annotations__r
   r	   r   r   r!   r   r"   r   r   r   r   r      s   
 		r   c                   @  s   e Zd ZdZg dZdS )CParserc)NZhighZ
round_tripNr#   r$   r%   r   r	   r   r   r   r   r'   K   s    r'   c                   @     e Zd ZdZdS )CParserHighMemoryFNr#   r$   r%   r
   r   r   r   r   r+   P       r+   c                   @  r*   )CParserLowMemoryTNr,   r   r   r   r   r.   T   r-   r.   c                   @     e Zd ZdZdgZdS )PythonParserpythonNr)   r   r   r   r   r0   X       
r0   c                   @  r/   )PyArrowParserpyarrowNr)   r   r   r   r   r3   ]   r2   r3   c                 C  s   | dddS )zG
    The directory path to the data files needed for parser tests.
    ioparserdatar   datapathr   r   r   csv_dir_pathb   s   r:   c                 C  s   t j| ddddS )zH
    The path to the data file "test1.csv" needed for parser tests.
    r5   r7   Zcsvz	test1.csv)ospathjoinr8   r   r   r   csv1j   s   r>   pyarrow is not installedreasonZmarksr1   Zc_highZc_lowr4   paramsidsc                 C  s8   |   }|jdkrtdtd  ddl}|d |S )z)
    Fixture all of the CSV parsers.
    r4   r   N   )paramr   pytestZimportorskipr   r4   Zset_cpu_count)requestr6   r4   r   r   r   all_parsers   s   

rJ   c                 C     |   S )z<
    Fixture all of the CSV parsers using the C engine.
    rG   rI   r   r   r   c_parser_only      rN   c                 C  rK   )zA
    Fixture all of the CSV parsers using the Python engine.
    rL   rM   r   r   r   python_parser_only   rO   rP   c                 C  rK   )zB
    Fixture all of the CSV parsers using the Pyarrow engine.
    rL   rM   r   r   r   pyarrow_parser_only   rO   rQ   c                  C  s   g } g }t ttD ]A\}}t|dr|jd }|jD ]/}|jdkr.tjj	tjj
t ddgnd}tj| |f|d}| | || d|  qq	| |d	S )
za
    Return all allowable parser and float precision
    combinations and corresponding ids.
    valuesr   r4   r?   r@   r   rB   -rC   )zip_all_parsers_all_parser_idshasattrrR   r	   r   rH   mark
single_cpuskipifr   rG   append)rD   rE   r6   Z	parser_idZ	precisionrX   rG   r   r   r   ,_get_all_parser_float_precision_combinations   s&   



	


r\   rD   rE   c                 C     | j S )zR
    Fixture for all allowable combinations of parser
    and float precision
    rL   rM   r   r   r   all_parsers_all_precisions   s   	r^   )          ) rS   _utfZUTFc                 C  s$   g | ]}t D ]	}| | d qqS )z{0})_encoding_prefixes).0sepprefixr   r   r   
<listcomp>   s
    ri   )rD   c                 C  r]   )zE
    Fixture for all possible integer values for a UTF encoding.
    rL   rM   r   r   r   	utf_value      rj   c                 C  r]   )zD
    Fixture for all possible string formats of a UTF encoding.
    rL   rM   r   r   r   encoding_fmt   rk   rl   )*)z-1,0      )z-1,2e0g333333)z-1e0rm   )z+1e0      ?)z+1e+0rn   )z+1e-1皙?)z+,1e1rn   )z+1,e0rn   )z-,1e1rm   )z-1,e0rm   )z0,1ro   )z1,rn   )z,1ro   )z-,1g)z1_,rn   )z1_234,56
ףp=J@)z
1_234,56e0rp   )rc   rc   )-_rq   )-_1rr   )-_1e0rs   )_1rt   )_1,ru   )_1,_rv   )_1e0rw   )1,2e_1rx   )1,2e1_0ry   )1,_2rz   ),1__2r{   ),1er|   )-,1er}   )1_000,000_000r~   )1,e1_2r   )e11,2r   )1e11,2r   )1,2,2r   )1,2_1r   )	1,2e-10e1r   )--1,2r   )1a_2,1r   )z1,2E-1gQ?)z1,2E1g      (@c                 C  r]   )z
    Fixture for all numeric formats which should get recognized. The first entry
    represents the value to read while the second represents the expected result.
    rL   rM   r   r   r   numeric_decimal   s   4r   c                 C  s^   d| j v r| d}nd| j v r| dd }ndS |jdkr-tjjdd}| | dS dS )z
    Fixture that xfails a test if the engine is pyarrow.

    Use if failure is do to unsupported keywords or inconsistent results.
    rJ   r^   r   Nr4   zpyarrow doesn't support this.r@   )fixturenamesgetfixturevaluer   rH   rX   ZxfailZapplymarker)rI   r6   rX   r   r   r   pyarrow_xfail/  s   


r   c                 C  sR   d| j v r| d}nd| j v r| dd }ndS |jdkr'tjdd dS dS )z
    Fixture that skips a test if the engine is pyarrow.

    Use if failure is do a parsing failure from pyarrow.csv.read_csv
    rJ   r^   r   Nr4   z,https://github.com/apache/arrow/issues/38676r@   )r   r   r   rH   skip)rI   r6   r   r   r   pyarrow_skipB  s   


r   )6Z
__future__r   r;   rH   Zpandas.compatr   Zpandas.compat._optionalr   Zpandasr   r   Zpandas._testingZ_testingr   r   r'   r+   r.   r0   r3   Zfixturer:   r>   Z_cParserHighMemoryZ_cParserLowMemoryZ_pythonParserZ_pyarrowParserZ_py_parsers_onlyZ_c_parsers_onlyrG   rX   rY   rZ   Z_pyarrow_parsers_onlyrU   Z_py_parser_idsZ_c_parser_idsZ_pyarrow_parsers_idsrV   rJ   rN   rP   rQ   r\   r^   Z_utf_valuesZ_encoding_sepsre   Z_encoding_fmtsrj   rl   r   r   r   r   r   r   r   <module>   s    :












/
