�
�gth? � �X � d dl Z d dlmZmZmZ d dlmZ d� Zd� Zd� Z e
dk( r e � yy)� N)�Flask�request�jsonify)�hivec �@ � t j j d� } t t j j dd� � }t j j d� }t j j d� }t j
| |||�� S )zGet a connection to Hive.�HIVESERVER2_HOST�HIVESERVER2_PORTi' �HIVESERVER2_USER�HIVESERVER2_PASSWORD)�host�port�username�password)�os�environ�get�intr �connect)r r
�userr s � /app/src/hiveserver2_mcp/main.py�get_hive_connectionr sj � �
�:�:�>�>�,� -�D� �r�z�z�~�~� 0�%�8� 9�D�
�:�:�>�>�,� -�D��z�z�~�~� 4�5�H� �<�<�T��t�h� O�O� c �\ � t t � } | j ddg�� d� � }| j ddg�� d� � }| j ddg�� d � � }| j d
dg�� d � � }| j d dg�� d
� � }| j ddg�� d� � }| S )Nz/query�POST)�methodsc �� � t j � } | j d� }|st ddi� dfS t � }|j � }|j
|� |j � }|j D �cg c] }|d �� }}|j � t ||d�� S c c}w # t $ r"}t dt |� i� dfcY d}~S d}~ww xY w) zExecute a query on Hive.�query�errorz
Missing query� r )�columns�rows�� N) r �get_jsonr r r �cursor�execute�fetchall� description�close� Exception�str)�data� query_str�connr$ �results�desc� column_names�es r r zcreate_app.<locals>.query s� � � � � �!���H�H�W�%� ���G�_�5�6��;� ;� 3�&�(�D��[�[�]�F� �N�N�9� %� �o�o�'�G�06�0B�0B�C�0B��D��G�0B�L�C� �J�J�L��|�W�E�F� F�� D�� � 3��G�S��V�,�-�s�2� 2�� 3�s0 �A B2 � B-�
B2 �-B2 �2 C �;C�C �C z /list_tables�GETc �: � t � } | j � }|j d� |j � D �cg c] }|d �� }}| j � t d|i� S c c}w # t $ r"}t dt |� i� dfcY d}~S d}~ww xY w)z(List all tables in the current database.z SHOW TABLESr �tablesr r" N�r r$ r% r& r( r r) r* )r- r$ �rowr4 r1 s r � list_tablesz create_app.<locals>.list_tables% s� � � 3�&�(�D��[�[�]�F� �N�N�=� )�(.���(9�:�(9��c�!�f�(9�F�:� �J�J�L��H�f�-�.� .�� ;�� � 3��G�S��V�,�-�s�2� 2�� 3��. �=A/ � A*� A/ �*A/ �/ B�8B�B�Bz/describe_tablec � � t j � } | j d� }|st ddi� dfS t � }|j � }|j
d|� �� |j � D �cg c]
}|d |d d��� }}|j � t d |i� S c c}w # t $ r"}t dt |� i� d
fcY d }~S d }~ww xY w) z(Describe the schema of a specific table.�tabler zMissing table namer z DESCRIBE r � )�name�type�schemar" N) r r# r r r r$ r% r& r( r) r* )r+ �
table_namer- r$ r6 r> r1 s r �describe_tablez"create_app.<locals>.describe_table2 s� � � � � �!���X�X�g�&�
���G�%9�:�;�S�@� @� 3�&�(�D��[�[�]�F� �N�N�Y�z�l�3� 4�BH�/�/�BS�T�BS�3�s�1�v�s�1�v�6�BS�F�T� �J�J�L��H�f�-�.� .�� U�� � 3��G�S��V�,�-�s�2� 2�� 3�s0 �A B. �8B)�
B. �)B. �. C�7C�C�Cz/list_databasesc �: � t � } | j � }|j d� |j � D �cg c] }|d �� }}| j � t d|i� S c c}w # t $ r"}t dt |� i� dfcY d}~S d}~ww xY w)z List all available databases.zSHOW DATABASESr � databasesr r" Nr5 )r- r$ r6 rB r1 s r �list_databasesz"create_app.<locals>.list_databasesE s� � � 3�&�(�D��[�[�]�F� �N�N�+� ,�+1�?�?�+<�=�+<�C��Q��+<�I�=� �J�J�L��K��3�4� 4�� >�� � 3��G�S��V�,�-�s�2� 2�� 3�r8 z
/use_databasec �h � t j � } | j d� }|st ddi� dfS t � }|j � }|j
d|� �� |j � t dd|� �i� S # t $ r"}t dt |� i� dfcY d }~S d }~ww xY w)
z Switch to a different database.�databaser zMissing database namer zUSE �messagezSwitched to database: r" N)
r r# r r r r$ r% r( r) r* )r+ �
database_namer- r$ r1 s r � use_databasez create_app.<locals>.use_databaseR s� � � � � �!�� ����,�
� ��G�%<�=�>��C� C� 3�&�(�D��[�[�]�F� �N�N�T�-� �1� 2� �J�J�L��I�)?�
��'O�P�Q� Q��� 3��G�S��V�,�-�s�2� 2�� 3�s �A
B � B1�B,�&B1�,B1z/statusc � � t � } | j � t ddi� S # t $ r#}t dt |� d�� dfcY d}~S d}~ww xY w)z"Get the current connection status.�status�okr )rJ rF r" N)r r( r r) r* )r- r1 s r rJ zcreate_app.<locals>.statusd sT � � H�&�(�D� �J�J�L��H�d�+�,� ,��� H��g�#�a�&�A�B�C�G� G�� H�s �&) � A�A�
A�A)r �__name__�route)�appr r7 r@ rC rH rJ s r �
create_apprO s� � �
��/�C��Y�Y�x�&��Y�*�3� +�3�& �Y�Y�~��w�Y�/�
3� 0�
3� �Y�Y� �6�(�Y�3�3� 4�3�$ �Y�Y� �5�'�Y�2�
3� 3�
3� �Y�Y����Y�1�3� 2�3�" �Y�Y�y�5�'�Y�*�H� +�H� �Jr c �> � t � } | j dd�� y)zStart the MCP server.z0.0.0.0i� )r r
N)rO �run)rN s r �mainrR p s � �
�,�C��G�G���G�&r �__main__) r �flaskr r r �pyhiver r rO rR rL � r r �<module>rW s7 �� � )� )� �P�`�D'�
�z���F� r
