a
    cOj                     @   s`   d Z ddlZddlmZ ddlZddlmZmZ dddZeddd	Z	d
d Z
edd ZdS )uf   
数据库连接工具。

提供 PostgreSQL 和 SQLite 的连接函数，以及上下文管理器。
    N)contextmanager   )DB_PATH	PG_CONFIGc                 C   s   | pt }tjf i |S )u4   获取 PostgreSQL 连接。默认连接 41 号 PG。)r   psycopg2connect)configZcfg r	   %/Users/admin/quant_ocf/ocf/core/db.pyget_pg_conn   s    r   c                 c   sJ   t | }| }z"|V  |  W |  |  n|  |  0 dS )u&   PostgreSQL 游标上下文管理器。N)r   cursorcommitclose)r   conncurr	   r	   r
   	pg_cursor   s    

r   c                   C   s
   t tS )u   获取本地 SQLite 连接。)sqlite3r   r   r	   r	   r	   r
   get_sqlite_conn"   s    r   c                  c   sH   t  } |  }z"|V  |   W |  |   n|  |   0 dS )u"   SQLite 游标上下文管理器。N)r   r   r   r   )r   r   r	   r	   r
   sqlite_cursor'   s    

r   )N)N)__doc__r   Z
contextlibr   r   settingsr   r   r   r   r   r   r	   r	   r	   r
   <module>   s   
